PeerStreamer

#include "topology.h"

#include "measures.h"

#include "scheduling.h"

#include "scheduler_la.h"

struct chunk_buffer *cb;

static struct input_desc *input;

static int cb_size;

static int offer_per_tick = 1;	//N_p parameter of POLITO

  int i, d, cset_acc_size, res;

  struct peer *to = nodeid_to_peer(toid, 0);

  cset_acc_size = chunkID_set_size(cset_acc);

  reg_offer_accept(cset_acc_size > 0 ? 1 : 0);	//this only works if accepts are sent back even if 0 is accepted

  for (i = 0, d=0; i < cset_acc_size && d < max_deliver; i++) {

    selectPeersForChunks(SCHED_WEIGHTING, nodeids, n, chunkids, size, selectedpeers, &selectedpeers_len, SCHED_NEEDS, SCHED_PEER);

    for (i=0; i<selectedpeers_len ; i++){

      int max_deliver = offer_max_deliver(selectedpeers[i]->id);

      struct chunkID_set *my_bmap = cb_to_bmap(cb);

      dprintf("\t sending offer(%d) to %s, cb_size: %d\n", transid, node_addr(selectedpeers[i]->id), selectedpeers[i]->cb_size);