#include <srs2.h>
-#include "epoll.h"
#include "mem.h"
#include "buffer.h"
#include "server.h"
return -1;
}
if (srsd->obuf.len) {
- epoll_modify(srsd->fd, EPOLLIN | EPOLLOUT, srsd);
+ server_rw(srsd);
}
return 0;
}
buffer_consume(&srsd->ibuf, nl - srsd->ibuf.data);
}
if (srsd->obuf.len) {
- epoll_modify(srsd->fd, EPOLLIN | EPOLLOUT, srsd);
+ server_rw(srsd);
}
return 0;
}
|| start_listener(port_dec, true) < 0) {
return EXIT_FAILURE;
}
- return server_loop(srsd_starter, NULL, process_srs, NULL, NULL, &config);
+ return server_loop(srsd_starter, NULL, process_srs, NULL, &config);
}