ret = timer_start(session, on_tcp_watchdog_timeout,
KR_CONN_RTT_MAX, 0);
if (ret < 0) {
- assert(false);
session_del_waiting(session, task);
session_del_tasks(session, task);
subreq_finalize(task, packet_source, packet);
if (len < 0 || session->bytes_to_skip < 0) {
/* Something gone wrong.
* Better kill the connection */
- assert(false);
return kr_error(EILSEQ);
}
if (len == 0) {
(uv_handle_t *)handle,
addr);
if (!ctx) {
- assert(false);
return kr_error(ENOMEM);
}
task = qr_task_create(ctx);
if (!task) {
- assert(false);
request_free(ctx);
return kr_error(ENOMEM);
}
if (len < 0 || session->bytes_to_skip < 0) {
/* Something gone wrong.
* Better kill the connection */
- assert(false);
return kr_error(EILSEQ);
}
if (len == 0) {
/* TODO: this is simple via iteration; recursion doesn't really help */
ret = worker_process_tcp(worker, handle, msg, len);
if (ret < 0) {
- assert(false);
return ret;
}
submitted += ret;