Revision 14893aa5 loop-mt.c

View differences:

loop-mt.c
195 195
  pthread_join(distributing_thread, NULL);
196 196
}
197 197

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

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

Also available in: Unified diff