Revision 0a40460a loop-mt.c

View differences:

loop-mt.c
121 121
  return NULL;
122 122
}
123 123

  
124
void loop(struct nodeID *s1, int csize)
124
void loop(struct nodeID *s1, int csize, int buff_size)
125 125
{
126 126
  pthread_t receive_thread, gossiping_thread, distributing_thread;
127 127
  
128 128
  period = csize;
129 129
  s = s1;
130 130
 
131
  stream_init(8, s);	// FIXME!
131
  stream_init(buff_size, s);
132 132
  pthread_mutex_init(&cb_mutex, NULL);
133 133
  pthread_mutex_init(&topology_mutex, NULL);
134 134
  pthread_create(&receive_thread, NULL, receive, NULL); 

Also available in: Unified diff