fix previous change
Adrian Smith
10 years ago
243 | 243 |
space = min(space, stream.meta_next);
|
244 | 244 |
}
|
245 | 245 |
|
246 | |
n = stream.state == recv(fd, streambuf->writep, space, 0);
|
|
246 |
n = recv(fd, streambuf->writep, space, 0);
|
247 | 247 |
if (n == 0) {
|
248 | 248 |
LOG_INFO("end of stream");
|
249 | 249 |
_disconnect(DISCONNECT, DISCONNECT_OK);
|