diff options
| author | Timo Dritschler <timo.dritschler@kit.edu> | 2014-12-03 19:29:03 +0100 |
|---|---|---|
| committer | Timo Dritschler <timo.dritschler@kit.edu> | 2014-12-03 19:39:08 +0100 |
| commit | cc2059982024af79136b9420eaec6fcfedabf3fb (patch) | |
| tree | 344035ea910eda089c655f5382d19c6e7d46705a /src/kiro-client.c | |
| parent | 8579e596df0bebee274dcadf766ae425bad9b1e8 (diff) | |
| download | kiro-cc2059982024af79136b9420eaec6fcfedabf3fb.tar.gz kiro-cc2059982024af79136b9420eaec6fcfedabf3fb.tar.bz2 kiro-cc2059982024af79136b9420eaec6fcfedabf3fb.tar.xz kiro-cc2059982024af79136b9420eaec6fcfedabf3fb.zip | |
KIRO Server now has a message event handler for receives
Diffstat (limited to 'src/kiro-client.c')
| -rw-r--r-- | src/kiro-client.c | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/kiro-client.c b/src/kiro-client.c index 0bb95fa..bb2645c 100644 --- a/src/kiro-client.c +++ b/src/kiro-client.c @@ -154,7 +154,8 @@ process_rdma_event (GIOChannel *source, GIOCondition condition, gpointer data) // Right now, we don't need 'source' and 'condition' // Tell the compiler to ignore them by (void)-ing them (void) source; - (void) condition; + //(void) condition; + g_debug ("Message condidition: %i", condition); KiroClientPrivate *priv = (KiroClientPrivate *)data; struct ibv_wc wc; @@ -297,8 +298,8 @@ kiro_client_connect (KiroClient *self, const char *address, const char *port) priv->main_loop = g_main_loop_new (NULL, FALSE); priv->conn_ec = g_io_channel_unix_new (priv->ec->fd); priv->rdma_ec = g_io_channel_unix_new (priv->conn->recv_cq_channel->fd); - g_io_add_watch (priv->conn_ec, G_IO_IN | G_IO_PRI | G_IO_ERR | G_IO_HUP, process_cm_event, (gpointer)priv); - g_io_add_watch (priv->rdma_ec, G_IO_IN | G_IO_PRI | G_IO_ERR | G_IO_HUP, process_rdma_event, (gpointer)priv); + g_io_add_watch (priv->conn_ec, G_IO_IN | G_IO_PRI, process_cm_event, (gpointer)priv); + g_io_add_watch (priv->rdma_ec, G_IO_IN | G_IO_PRI, process_rdma_event, (gpointer)priv); priv->main_thread = g_thread_new ("KIRO Client main loop", start_client_main_loop, priv->main_loop); // We gave control to the main_loop (with add_watch) and don't need our ref |