Fix RDMA-CM broken in 2.2.0
This commit is contained in:
@@ -74,7 +74,7 @@ Consider `use_rdmacm` for such networks.
|
|||||||
## use_rdmacm
|
## use_rdmacm
|
||||||
|
|
||||||
- Type: boolean
|
- Type: boolean
|
||||||
- Default: true
|
- Default: false
|
||||||
|
|
||||||
Use an alternative implementation of RDMA through RDMA-CM (Connection
|
Use an alternative implementation of RDMA through RDMA-CM (Connection
|
||||||
Manager). Works with all RDMA networks: Infiniband, iWARP and
|
Manager). Works with all RDMA networks: Infiniband, iWARP and
|
||||||
|
|||||||
@@ -74,7 +74,7 @@ RDMA-устройства, но они не имеют соединения с
|
|||||||
## use_rdmacm
|
## use_rdmacm
|
||||||
|
|
||||||
- Тип: булево (да/нет)
|
- Тип: булево (да/нет)
|
||||||
- Значение по умолчанию: true
|
- Значение по умолчанию: false
|
||||||
|
|
||||||
Использовать альтернативную реализацию RDMA на основе RDMA-CM (Connection
|
Использовать альтернативную реализацию RDMA на основе RDMA-CM (Connection
|
||||||
Manager). Работает со всеми типами RDMA-сетей: Infiniband, iWARP и
|
Manager). Работает со всеми типами RDMA-сетей: Infiniband, iWARP и
|
||||||
|
|||||||
@@ -51,7 +51,7 @@
|
|||||||
Рассмотрите включение `use_rdmacm` для таких сетей.
|
Рассмотрите включение `use_rdmacm` для таких сетей.
|
||||||
- name: use_rdmacm
|
- name: use_rdmacm
|
||||||
type: bool
|
type: bool
|
||||||
default: true
|
default: false
|
||||||
info: |
|
info: |
|
||||||
Use an alternative implementation of RDMA through RDMA-CM (Connection
|
Use an alternative implementation of RDMA through RDMA-CM (Connection
|
||||||
Manager). Works with all RDMA networks: Infiniband, iWARP and
|
Manager). Works with all RDMA networks: Infiniband, iWARP and
|
||||||
|
|||||||
@@ -1186,9 +1186,7 @@ void etcd_state_client_t::parse_state(const etcd_kv_t & kv)
|
|||||||
osd_num_t peer_osd = std::stoull(key.substr(etcd_prefix.length()+11));
|
osd_num_t peer_osd = std::stoull(key.substr(etcd_prefix.length()+11));
|
||||||
if (peer_osd > 0)
|
if (peer_osd > 0)
|
||||||
{
|
{
|
||||||
if (value.is_object() && value["state"] == "up" &&
|
if (value.is_object() && value["state"] == "up")
|
||||||
value["addresses"].is_array() &&
|
|
||||||
value["port"].int64_value() > 0 && value["port"].int64_value() < 65536)
|
|
||||||
{
|
{
|
||||||
this->peer_states[peer_osd] = value;
|
this->peer_states[peer_osd] = value;
|
||||||
this->seen_peers.insert(peer_osd);
|
this->seen_peers.insert(peer_osd);
|
||||||
|
|||||||
@@ -515,7 +515,7 @@ void osd_messenger_t::rdmacm_established(rdma_cm_event *ev)
|
|||||||
cl->peer_fd = conn->peer_fd;
|
cl->peer_fd = conn->peer_fd;
|
||||||
cl->peer_state = PEER_RDMA;
|
cl->peer_state = PEER_RDMA;
|
||||||
cl->connect_timeout_id = -1;
|
cl->connect_timeout_id = -1;
|
||||||
cl->in_osd_num = peer_osd;
|
cl->osd_num = peer_osd;
|
||||||
cl->in_buf = malloc_or_die(receive_buffer_size);
|
cl->in_buf = malloc_or_die(receive_buffer_size);
|
||||||
cl->rdma_conn = rc;
|
cl->rdma_conn = rc;
|
||||||
clients[conn->peer_fd] = cl;
|
clients[conn->peer_fd] = cl;
|
||||||
|
|||||||
Reference in New Issue
Block a user