Revision 14893aa5 streaming.c

View differences:

streaming.c
106 106
  init_measures();
107 107
}
108 108

  
109
int source_init(const char *fname, struct nodeID *myID, bool loop, int *fds, int fds_size)
109
int source_init(const char *fname, struct nodeID *myID, bool loop, int *fds, int fds_size, int buff_size)
110 110
{
111 111
  int flags = 0;
112 112

  
......
122 122
    return -1;
123 123
  }
124 124

  
125
  stream_init(1, myID);
125
  stream_init(buff_size, myID);
126 126
  return 0;
127 127
}
128 128

  

Also available in: Unified diff