Revision 6abd9b83 loop-mt.c

View differences:

loop-mt.c
150 150
  pthread_join(distributing_thread, NULL);
151 151
}
152 152

  
153
void source_loop(const char *fname, struct nodeID *s1, int csize, int chunks)
153
void source_loop(const char *fname, struct nodeID *s1, int csize, int chunks, bool loop)
154 154
{
155 155
  pthread_t generate_thread, receive_thread, gossiping_thread, distributing_thread;
156 156
  
......
158 158
  chunks_per_period = chunks;
159 159
  s = s1;
160 160
 
161
  source_init(fname, s);
161
  source_init(fname, s, loop);
162 162
  pthread_mutex_init(&cb_mutex, NULL);
163 163
  pthread_mutex_init(&topology_mutex, NULL);
164 164
  pthread_create(&receive_thread, NULL, source_receive, NULL); 

Also available in: Unified diff