return ret;
}
-void session_kill_ioreq(struct session *s, struct qr_task *task)
+void session_kill_ioreq(struct session *session, struct qr_task *task)
{
- if (!s) {
+ if (!session) {
return;
}
- assert(s->sflags.outgoing && s->handle);
- if (s->sflags.closing) {
+ assert(session->sflags.outgoing && session->handle);
+ if (session->sflags.closing) {
return;
}
- session_tasklist_del(s, task);
- if (s->handle->type == UV_UDP) {
- assert(session_tasklist_is_empty(s));
- session_close(s);
+ session_tasklist_del(session, task);
+ if (session->handle->type == UV_UDP) {
+ assert(session_tasklist_is_empty(session));
+ session_close(session);
return;
}
}
/** Update timestamp */
-void session_touch(struct session *s)
+void session_touch(struct session *session)
{
- s->last_activity = kr_now();
+ session->last_activity = kr_now();
}
-uint64_t session_last_activity(struct session *s)
+uint64_t session_last_activity(struct session *session)
{
- return s->last_activity;
+ return session->last_activity;
}
bool session_write_queue_is_empty(struct session *session)
knot_pkt_t *session_produce_packet(struct session *session, knot_mm_t *mm);
int session_discard_packet(struct session *session, const knot_pkt_t *pkt);
-void session_kill_ioreq(struct session *s, struct qr_task *task);
+void session_kill_ioreq(struct session *session, struct qr_task *task);
/** Update timestamp */
-void session_touch(struct session *s);
+void session_touch(struct session *session);
/** Returns either creation time or time of last IO activity if any occurs. */
/* Used for TCP timeout calculation. */
-uint64_t session_last_activity(struct session *s);
+uint64_t session_last_activity(struct session *session);
/** Check whether the write queue is empty. */
bool session_write_queue_is_empty(struct session *session);