Switch from shutdown(SHUT_RD) to EPOLLIN to detect send <-> send misconfigurations.
This commit is contained in:
@@ -116,9 +116,6 @@ struct serializer *send_get_serializer(char *name) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
void send_new(int fd, struct serializer *serializer, struct peer *on_close) {
|
void send_new(int fd, struct serializer *serializer, struct peer *on_close) {
|
||||||
int res = shutdown(fd, SHUT_RD);
|
|
||||||
assert(res == 0 || (res == -1 && errno == ENOTSOCK));
|
|
||||||
|
|
||||||
struct send *send = malloc(sizeof(*send));
|
struct send *send = malloc(sizeof(*send));
|
||||||
assert(send);
|
assert(send);
|
||||||
|
|
||||||
@@ -131,7 +128,7 @@ void send_new(int fd, struct serializer *serializer, struct peer *on_close) {
|
|||||||
send->next = serializer->send_head;
|
send->next = serializer->send_head;
|
||||||
serializer->send_head = send;
|
serializer->send_head = send;
|
||||||
|
|
||||||
peer_epoll_add((struct peer *) send, 0);
|
peer_epoll_add((struct peer *) send, EPOLLIN);
|
||||||
|
|
||||||
fprintf(stderr, "S %s (%s): New send connection\n", send->id, serializer->name);
|
fprintf(stderr, "S %s (%s): New send connection\n", send->id, serializer->name);
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user