sf_nio.c: check_task adapt to RDMA
parent
435ae6bb84
commit
0eb842dc09
20
src/sf_nio.c
20
src/sf_nio.c
|
|
@ -495,15 +495,19 @@ static inline int check_task(struct fast_task_info *task,
|
||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (tcp_socket_connected(task->event.fd)) {
|
if (task->handler->comm_type == fc_comm_type_sock) {
|
||||||
return EAGAIN;
|
if (tcp_socket_connected(task->event.fd)) {
|
||||||
} else {
|
return EAGAIN;
|
||||||
logDebug("file: "__FILE__", line: %d, "
|
} else {
|
||||||
"client ip: %s, connection is closed",
|
logDebug("file: "__FILE__", line: %d, "
|
||||||
__LINE__, task->client_ip);
|
"client ip: %s, connection is closed",
|
||||||
|
__LINE__, task->client_ip);
|
||||||
|
|
||||||
ioevent_add_to_deleted_list(task);
|
ioevent_add_to_deleted_list(task);
|
||||||
return -1;
|
return -1;
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
return EAGAIN;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue