Revision 03de31e0 streaming.c

View differences:

streaming.c
111 111
  init_measures();
112 112
}
113 113

  
114
int source_init(const char *fname, struct nodeID *myID, bool loop, int *fds, int fds_size, int buff_size)
114
int source_init(const char *fname, struct nodeID *myID, int *fds, int fds_size, int buff_size)
115 115
{
116
  int flags = 0;
117

  
118
  if (memcmp(fname, "udp:", 4) == 0) {
119
    fname += 4;
120
    flags = INPUT_UDP;
121
  }
122
  if (memcmp(fname, "ipb:", 4) == 0) {
123
    fname += 4;
124
    flags = INPUT_IPB;
125
  }
126
  if (loop) {
127
    flags |= INPUT_LOOP;
128
  }
129

  
130
  input = input_open(fname, flags, fds, fds_size);
116
  input = input_open(fname, fds, fds_size);
131 117
  if (input == NULL) {
132 118
    return -1;
133 119
  }

Also available in: Unified diff