Revision 03de31e0 loop-mt.c

View differences:

loop-mt.c
197 197
  pthread_join(distributing_thread, NULL);
198 198
}
199 199

  
200
void source_loop(const char *fname, struct nodeID *s1, int csize, int chunks, bool loop, int buff_size)
200
void source_loop(const char *fname, struct nodeID *s1, int csize, int chunks, int buff_size)
201 201
{
202 202
  pthread_t generate_thread, receive_thread, gossiping_thread, distributing_thread;
203 203
  
......
210 210

  
211 211
//  sigInit(s);
212 212
  peers_init();
213
  if (source_init(fname, s, loop, fds, FDSSIZE, buff_size) < 0) {
213
  if (source_init(fname, s, fds, FDSSIZE, buff_size) < 0) {
214 214
    fprintf(stderr,"Cannot initialize source, exiting");
215 215
    return;
216 216
  }

Also available in: Unified diff