Evgeny Barskiy napsal(a):
> Corosync now works with infiniband transport in any redundant ring mode
>
> Signed-off-by: Evgeny Barskiy <barskiy@xxxxxx>
> ---
> exec/totemiba.c | 10 +++++++++-
> 1 files changed, 9 insertions(+), 1 deletions(-)
>
> diff --git a/exec/totemiba.c b/exec/totemiba.c
> index 189eb00..5d47d6b 100644
> --- a/exec/totemiba.c
> +++ b/exec/totemiba.c
> @@ -536,6 +536,7 @@ static int mcast_rdma_event_fn (int events, int suck, void *context)
> */
> case RDMA_CM_EVENT_ADDR_RESOLVED:
> rdma_join_multicast (instance->mcast_cma_id, &instance->mcast_addr, instance);
> + usleep(1000);
what is this usleep good for?
> break;
> /*
> * occurs when the CM joins the multicast group
> @@ -1029,6 +1030,12 @@ static int send_token_unbind (struct totemiba_instance *instance)
> instance->totemiba_poll_handle,
> instance->send_token_channel->fd);
>
> + if(instance->send_token_ah)
> + {
> + ibv_destroy_ah(instance->send_token_ah);
> + instance->send_token_ah = 0;
> + }
> +
> rdma_destroy_qp (instance->send_token_cma_id);
> ibv_destroy_cq (instance->send_token_send_cq);
> ibv_destroy_cq (instance->send_token_recv_cq);
> @@ -1417,7 +1424,8 @@ int totemiba_token_send (
> sge.lkey = send_buf->mr->lkey;
> sge.addr = (uintptr_t)msg;
>
> - res = ibv_post_send (instance->send_token_cma_id->qp, &send_wr, &failed_send_wr);
> + if(instance->send_token_ah != 0 && instance->send_token_bound)
> + res = ibv_post_send (instance->send_token_cma_id->qp, &send_wr, &failed_send_wr);
>
> return (res);
> }
>
_______________________________________________
discuss mailing list
discuss@xxxxxxxxxxxx
http://lists.corosync.org/mailman/listinfo/discuss
