case FR_CONNECTION_STATE_FAILED:
case FR_CONNECTION_STATE_TIMEOUT:
if (conn->fd >= 0) {
+ DEBUG2("Closing connection (%i)", conn->fd);
fr_event_fd_delete(conn->el, conn->fd);
conn->close(conn->fd, conn->uctx);
conn->fd = -1;
*/
static void logtee_fd_idle(rlm_logtee_thread_t *t)
{
+ DEBUG4("Marking socket (%i) as idle", fr_connection_get_fd(t->conn));
fr_event_fd_insert(t->el, fr_connection_get_fd(t->conn),
_logtee_conn_read, NULL, _logtee_conn_error, t);
}
*/
static void logtee_fd_active(rlm_logtee_thread_t *t)
{
+ DEBUG4("Marking socket (%i) as active - Draining requests", fr_connection_get_fd(t->conn));
fr_event_fd_insert(t->el, fr_connection_get_fd(t->conn),
_logtee_conn_read, _logtee_conn_writable, _logtee_conn_error, t);
}
*/
static void _logtee_conn_close(int fd, UNUSED void *uctx)
{
+ DEBUG3("Closing socket (%i)", fd);
if (shutdown(fd, SHUT_RDWR) < 0) DEBUG3("Shutdown on socket (%i) failed: %s", fd, fr_syserror(errno));
if (close(fd) < 0) DEBUG3("Closing socket (%i) failed: %s", fd, fr_syserror(errno));
}
{
rlm_logtee_thread_t *t = talloc_get_type_abort(uctx, rlm_logtee_thread_t);
+ DEBUG2("Socket connected");
+
/*
* If we have data pending, add the writable event immediately
*/
logtee_fd_idle(t);
}
- return FR_CONNECTION_STATE_CONNECTING;
return FR_CONNECTION_STATE_CONNECTED;
}