From 6a931a1185aa8170636b8f55c38ad91af6f897f6 Mon Sep 17 00:00:00 2001 From: Timo Dritschler Date: Thu, 18 Dec 2014 12:31:18 +0100 Subject: KIRO Server can now issue a client reallocation command --- src/kiro-rdma.h | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'src/kiro-rdma.h') diff --git a/src/kiro-rdma.h b/src/kiro-rdma.h index 5b4895f..6baa017 100644 --- a/src/kiro-rdma.h +++ b/src/kiro-rdma.h @@ -56,7 +56,8 @@ struct kiro_ctrl_msg { KIRO_ACK_RDMA, // acknowledge RDMA Request and provide Memory Region Information KIRO_REJ_RDMA, // RDMA Request rejected :( (peer_mri will be invalid) KIRO_PING, // PING Message - KIRO_PONG // PONG Message (PING reply) + KIRO_PONG, // PONG Message (PING reply) + KIRO_REALLOC // Used by the server to notify the client about a new peer_mri } msg_type; struct ibv_mr peer_mri; -- cgit v1.2.3 From 5ad42a8bd4ec754b9c33f9c0b22dceb0e812c4a5 Mon Sep 17 00:00:00 2001 From: Timo Dritschler Date: Thu, 15 Jan 2015 14:48:08 +0100 Subject: Fixed race conditions in kiro_server_realloc KIRO client now reacts to server realloc --- src/kiro-rdma.h | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'src/kiro-rdma.h') diff --git a/src/kiro-rdma.h b/src/kiro-rdma.h index 6baa017..c17e044 100644 --- a/src/kiro-rdma.h +++ b/src/kiro-rdma.h @@ -81,9 +81,9 @@ kiro_attach_qp (struct rdma_cm_id *id) id->pd = ibv_alloc_pd (id->verbs); id->send_cq_channel = ibv_create_comp_channel (id->verbs); - id->recv_cq_channel = id->send_cq_channel; //we use one shared completion channel + id->recv_cq_channel = ibv_create_comp_channel (id->verbs); id->send_cq = ibv_create_cq (id->verbs, 1, id, id->send_cq_channel, 0); - id->recv_cq = id->send_cq; //we use one shared completion queue + id->recv_cq = ibv_create_cq (id->verbs, 1, id, id->recv_cq_channel, 0); struct ibv_qp_init_attr qp_attr; memset (&qp_attr, 0, sizeof (struct ibv_qp_init_attr)); qp_attr.qp_context = (void *) (uintptr_t) id; -- cgit v1.2.3