PeerStreamer-ng

void send_bmap(const struct streaming_context *stc, const struct nodeID *toid)

{

  struct chunkID_set *my_bmap = cb_to_bmap(stc->cb);

#ifdef LOG_SIGNAL

	log_signal(psinstance_nodeid(stc->ps),toid,chunkID_set_size(my_bmap),0,sig_send_buffermap,"SENT");

#endif

  my_bmap = cb_to_bmap(stc->cb);	//cache our bmap for faster processing

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

#ifdef LOG_SIGNAL

	 	log_signal(psinstance_nodeid(stc->ps),neighbours[i]->id,chunkID_set_size(my_bmap),0,sig_send_buffermap,"SENT");

#endif

void send_ack(const struct streaming_context * stc, struct nodeID *toid, uint16_t trans_id)

{

  struct chunkID_set *my_bmap = cb_to_bmap(stc->cb);

#ifdef LOG_SIGNAL

	log_signal(psinstance_nodeid(stc->ps),toid,chunkID_set_size(my_bmap),trans_id,sig_ack,"SENT");

#endif

    }

    if (!to || needs(to, chunkid)) {	//he should not have it. Although the "accept" should have been an answer to our "offer", we do some verification

      chunk_attributes_update_sending(c);

      if (res >= 0) {

        if(to) chunkID_set_add_chunk(to->bmap, c->id); //don't send twice ... assuming that it will actually arrive

        d++;

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

      struct chunkID_set *offer_cset = compose_offer_cset(stc, selectedpeers[i]);

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

#ifdef LOG_SIGNAL

			log_signal(psinstance_nodeid(stc->ps),selectedpeers[i]->id,chunkID_set_size(offer_cset),transid,sig_offer,"SENT");

#endif

		}

		chunk_attributes_update_sending(target_chunk);

		transid = transaction_create(&(stc->transactions), target_peer->id);

		if (res>=0) {

#ifdef LOG_CHUNK

			log_chunk(psinstance_nodeid(stc->ps), target_peer->id, target_chunk,"SENT");

      chunk_attributes_update_sending(c);

      transid = transaction_create(&(stc->transactions), p->id);

//      res = sendChunk(p->id, c, 0);	//we do not use transactions in pure push

      dprintf("\tResult: %d\n", res);

      if (res>=0) {