]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
msg/async/AsyncMessenger: use sockaddr accessors for bind
authorSage Weil <sage@redhat.com>
Fri, 6 May 2016 14:01:36 +0000 (10:01 -0400)
committerSage Weil <sage@redhat.com>
Wed, 11 May 2016 12:12:25 +0000 (08:12 -0400)
Signed-off-by: Sage Weil <sage@redhat.com>
src/msg/async/AsyncMessenger.cc

index 395936d84d2f940dc08887a25d72cda8bc6849b5..6e08b42231a46962da739f354da4d078feca548c 100644 (file)
@@ -116,9 +116,10 @@ int Processor::bind(const entity_addr_t &bind_addr, const set<int>& avoid_ports)
         continue;
       }
 
-      rc = ::bind(listen_sd, (struct sockaddr *) &listen_addr.ss_addr(), listen_addr.addr_size());
+      rc = ::bind(listen_sd, listen_addr.get_sockaddr(),
+                 listen_addr.get_sockaddr_len());
       if (rc < 0) {
-        lderr(msgr->cct) << __func__ << " unable to bind to " << listen_addr.ss_addr()
+        lderr(msgr->cct) << __func__ << " unable to bind to " << listen_addr
                          << ": " << cpp_strerror(errno) << dendl;
         r = -errno;
         continue;
@@ -130,12 +131,13 @@ int Processor::bind(const entity_addr_t &bind_addr, const set<int>& avoid_ports)
           continue;
 
         listen_addr.set_port(port);
-        rc = ::bind(listen_sd, (struct sockaddr *) &listen_addr.ss_addr(), listen_addr.addr_size());
+        rc = ::bind(listen_sd, listen_addr.get_sockaddr(),
+                   listen_addr.get_sockaddr_len());
         if (rc == 0)
           break;
       }
       if (rc < 0) {
-        lderr(msgr->cct) << __func__ << " unable to bind to " << listen_addr.ss_addr()
+        lderr(msgr->cct) << __func__ << " unable to bind to " << listen_addr
                          << " on any port in range " << msgr->cct->_conf->ms_bind_port_min
                          << "-" << msgr->cct->_conf->ms_bind_port_max << ": "
                          << cpp_strerror(errno) << dendl;