Revision bc6a6205

View differences:

loop.c
47 47
  }
48 48
}
49 49

  
50
void loop(struct nodeID *s, int polling_time, int buff_size, int offer_threads)
50
void loop(struct nodeID *s, int polling_time, int buff_size, bool hrc, int offer_threads)
51 51
{
52 52
  int done = 0;
53 53
  static uint8_t buff[BUFFSIZE];
......
60 60
  stream_init(buff_size, s);
61 61
  update_peers(NULL, NULL, 0);
62 62
  
63
  if (!hrc)
63 64
  	fixed_offer_threads = offer_threads;
64
   
65
   // Start all offer threads once forever
66
   send_offer();
65
  else
66
	fixed_offer_threads = -1;  
67
  
68
  // Start all offer threads once forever
69
  send_offer();
67 70
  
68 71
  while (!done) {
69 72
    int len, res;
loop.h
7 7
#ifndef LOOP_H
8 8
#define LOOP_H
9 9

  
10
void loop(struct nodeID *s, int period, int buff_size,  int offer_threads);
10
void loop(struct nodeID *s, int period, int buff_size, bool hrc, int offer_threads);
11 11
void source_loop(const char *fname, struct nodeID *s, int csize, int chunks, int buff_size);
12 12
int get_fixed_offer_threads(void);
13 13

  

Also available in: Unified diff