Revision 9a1f5816 streaming.c

View differences:

streaming.c
280 280
  struct peerset *pset;
281 281
  struct chunkID_set *my_bmap;
282 282

  
283
  pset = get_neighbours();
283
  pset = topology_get_neighbours();
284 284
  n = peerset_size(pset);
285 285
  neighbours = peerset_get_peers(pset);
286 286

  
......
321 321
void ack_chunk(struct chunk *c, struct nodeID *from, uint16_t trans_id)
322 322
{
323 323
  //reduce load a little bit if there are losses on the path from this guy
324
  double average_lossrate = get_average_lossrate_pset(get_neighbours());
324
  double average_lossrate = get_average_lossrate_pset(topology_get_neighbours());
325 325
  average_lossrate = finite(average_lossrate) ? average_lossrate : 0;	//start agressively, assuming 0 loss
326 326
  if (rand()/((double)RAND_MAX + 1) < 1 * average_lossrate ) {
327 327
    return;
......
677 677
  struct peer **neighbours;
678 678
  struct peerset *pset;
679 679

  
680
  pset = get_neighbours();
680
  pset = topology_get_neighbours();
681 681
  n = peerset_size(pset);
682 682
  neighbours = peerset_get_peers(pset);
683 683
  dprintf("Send Offer: %d neighbours\n", n);
......
813 813
	size_t selectedpairs_len = multiplicity;
814 814
	struct PeerChunk  * selectedpairs;
815 815

  
816
	pset = get_neighbours();
816
	pset = topology_get_neighbours();
817 817
	peers_num = peerset_size(pset);
818 818
	peers = peerset_get_peers(pset);
819 819
	peer_evaluation = push_strategy ? peerWeightLoss : SCHED_PEER;
......
843 843
  struct peer **neighbours;
844 844
  struct peerset *pset;
845 845

  
846
  pset = get_neighbours();
846
  pset = topology_get_neighbours();
847 847
  n = peerset_size(pset);
848 848
  neighbours = peerset_get_peers(pset);
849 849
  dprintf("Send Chunk: %d neighbours\n", n);

Also available in: Unified diff