Prevent cork usage as charybdis doesn't have its support

[irc/rqf/shadowircd.git] / libcharybdis / commio.c

diff --git a/libcharybdis/commio.c b/libcharybdis/commio.c
index 14c9efaf1ef689eef705a3cf114c36741923efcb..c7dfe1a4b9de3b69c0b02c12d3cf33e6457afe74 100644 (file)
--- a/libcharybdis/commio.c
+++ b/libcharybdis/commio.c
@@ -58,6 +58,26 @@ static void comm_connect_dns_callback(void *vptr, struct DNSReply *reply);
 static PF comm_connect_tryconnect;
 static int comm_max_connections = 0;
 
+static int
+comm_read_raw(fde_t *F, void *buf, size_t count)
+{
+       s_assert(F != NULL);
+       s_assert(buf != NULL);
+       s_assert(count > 0);
+
+       return read(F->fd, buf, count);
+}
+
+static int
+comm_write_raw(fde_t *F, const void *buf, size_t count)
+{
+       s_assert(F != NULL);
+       s_assert(buf != NULL);
+       s_assert(count > 0);
+
+       return write(F->fd, buf, count);
+}
+
 inline fde_t *
 comm_locate_fd(int fd)
 {
@@ -85,8 +105,12 @@ comm_add_fd(int fd)
        if (F != NULL)
                return F;
 
-       F = calloc(sizeof(fde_t), 1);
+       F = MyMalloc(sizeof(fde_t));
        F->fd = fd;
+
+       F->read_impl = comm_read_raw;
+       F->write_impl = comm_write_raw;
+
        list = &fd_table[fd % FD_HASH_SIZE];
        dlinkAdd(F, &F->node, list);