diff options
| author | Timo Dritschler <timo.dritschler@kit.edu> | 2015-01-30 18:26:50 +0100 |
|---|---|---|
| committer | Timo Dritschler <timo.dritschler@kit.edu> | 2015-01-30 18:26:50 +0100 |
| commit | 8f60d5536ef04f53969bb0a6e6ba5bea46f734de (patch) | |
| tree | ae15468bd5346b4402d84cbaf0cb6657c0d17bd5 /src/kiro-rdma.h | |
| parent | fb72ad6a4685274d37a73b048d50a7761c19f3c6 (diff) | |
| parent | 5ad42a8bd4ec754b9c33f9c0b22dceb0e812c4a5 (diff) | |
| download | kiro-8f60d5536ef04f53969bb0a6e6ba5bea46f734de.tar.gz kiro-8f60d5536ef04f53969bb0a6e6ba5bea46f734de.tar.bz2 kiro-8f60d5536ef04f53969bb0a6e6ba5bea46f734de.tar.xz kiro-8f60d5536ef04f53969bb0a6e6ba5bea46f734de.zip | |
Merge pull request #17 from ufo-kit/serverRealloc
Added server-side reallocation request
Diffstat (limited to 'src/kiro-rdma.h')
| -rw-r--r-- | src/kiro-rdma.h | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/src/kiro-rdma.h b/src/kiro-rdma.h index 5b4895f..c17e044 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; @@ -80,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; |