msg/xio: do not reference g_conf and g_ceph_context

* otherwise librados and libcephfs will have dependencies
  on these global variables. because they enclose libmsg
  in them.
* replace `derr` with ldout(cct,0)

Fixes: #10735
Signed-off-by: Kefu Chai <kchai@redhat.com>

diff --git a/src/msg/xio/XioConnection.cc b/src/msg/xio/XioConnection.cc
index a4d44d8c41454a05c0f2f7126e62b54e10f07bc9..1738a663292e24a0d35bd4de98bcb4a284c8116a 100644 (file)
--- a/src/msg/xio/XioConnection.cc
+++ b/src/msg/xio/XioConnection.cc
@@ -211,7 +211,7 @@ int XioConnection::on_msg_req(struct xio_session *session,
 
   if (! in_seq.p()) {
     if (!treq->in.header.iov_len) {
-       derr << __func__ << " empty header: packet out of sequence?" << dendl;
+       ldout(msgr->cct,0) << __func__ << " empty header: packet out of sequence?" << dendl;
        xio_release_msg(req);
        return 0;
     }
@@ -657,9 +657,8 @@ int XioConnection::CState::state_discon()
   return 0;
 }
 
-int XioConnection::CState::state_flow_controlled(uint32_t flags) {
-  dout(11) << __func__ << " ENTER " << dendl;
-
+int XioConnection::CState::state_flow_controlled(uint32_t flags)
+{
   if (! (flags & OP_FLAG_LOCKED))
     pthread_spin_lock(&xcon->sp);
 

diff --git a/src/msg/xio/XioMessenger.cc b/src/msg/xio/XioMessenger.cc
index f5c650673e310bd0c5ed64d5b5e6f32847384c68..3fdb36e74537f2cf0248663a33df331135e7809c 100644 (file)
--- a/src/msg/xio/XioMessenger.cc
+++ b/src/msg/xio/XioMessenger.cc
@@ -644,26 +644,26 @@ int XioMessenger::bind(const entity_addr_t& addr)
   if (a->is_blank_ip()) {
     a = &_addr;
     std::vector <std::string> my_sections;
-    g_conf->get_my_sections(my_sections);
+    cct->_conf->get_my_sections(my_sections);
     std::string rdma_local_str;
-    if (g_conf->get_val_from_conf_file(my_sections, "rdma local",
+    if (cct->_conf->get_val_from_conf_file(my_sections, "rdma local",
                                      rdma_local_str, true) == 0) {
       struct entity_addr_t local_rdma_addr;
       local_rdma_addr = *a;
       const char *ep;
       if (!local_rdma_addr.parse(rdma_local_str.c_str(), &ep)) {
-       derr << "ERROR:  Cannot parse rdma local: " << rdma_local_str << dendl;
+       ldout(cct,0) << "ERROR:  Cannot parse rdma local: " << rdma_local_str << dendl;
        return -EINVAL;
       }
       if (*ep) {
-       derr << "WARNING: 'rdma local trailing garbage ignored: '" << ep << dendl;
+       ldout(cct,0) << "WARNING: 'rdma local trailing garbage ignored: '" << ep << dendl;
       }
       int p = _addr.get_port();
       _addr.set_sockaddr(reinterpret_cast<struct sockaddr *>(
                          &local_rdma_addr.ss_addr()));
       _addr.set_port(p);
     } else {
-      derr << "WARNING: need 'rdma local' config for remote use!" <<dendl;
+      ldout(cct,0) << "WARNING: need 'rdma local' config for remote use!" <<dendl;
     }
   }