// initialize listening connections
// port 2374
- rxpd_socket_activate (rxpd_socket_new_tcp4 (rxpd, NULL, 2374));
+ rxpd_socket_schedule (rxpd_socket_new_tcp4 (rxpd, NULL, 2374));
//rxpd_socket_new_unix (rxpd, "/tmp/rxpd");
}
struct rxpd_socket*
-rxpd_socket_activate (struct rxpd_socket* self)
+rxpd_socket_schedule (struct rxpd_socket* self)
{
if (self)
{
struct rxpd_connection* conn =
rxpd_connection_new (self->base, fd);
- rxpd_connection_activate (conn);
- rxpd_socket_activate (self);
+ rxpd_connection_schedule (conn);
+ rxpd_socket_schedule (self);
}
///
}
struct rxpd_connection*
-rxpd_connection_activate (struct rxpd_connection* self)
+rxpd_connection_schedule (struct rxpd_connection* self)
{
if (self)
{
RXPD_COMMANDS
#undef RXPD_CMD
}
- rxpd_connection_activate (self);
+ rxpd_connection_schedule (self);
}
void
rxpd_connection_cmd_CHECK (int fd, short event, void* ptr)
{
struct rxpd_connection* self = (struct rxpd_connection*) ptr;
- rxpd_buffer_printf (&self->out, "#ERROR: unimplemented command %s\n", &__func__[20]);
+ LLIST_FOREACH (&self->file.rules, node)
+
+
+ //rxpd_buffer_printf (&self->out, "#ERROR: unimplemented command %s\n", &__func__[20]);
+
+
+ rxpd_connection_schedule (self);
}
void
rxpd_socket_accept (int sock, short event, void* ptr);
struct rxpd_socket*
-rxpd_socket_activate (struct rxpd_socket* self);
+rxpd_socket_schedule (struct rxpd_socket* self);
struct rxpd_socket*
rxpd_socket_suspend (struct rxpd_socket* self);
struct rxpd_connection*
-rxpd_connection_activate (struct rxpd_connection* self);
+rxpd_connection_schedule (struct rxpd_connection* self);
struct rxpd_connection*