]> git.apps.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
msg/async: fix some return values and misspellings.
authorYan Jun <yan.jun8@zte.com.cn>
Mon, 25 Apr 2016 01:45:20 +0000 (09:45 +0800)
committerYan Jun <yan.jun8@zte.com.cn>
Mon, 25 Apr 2016 01:45:20 +0000 (09:45 +0800)
Signed-off-by: Yan Jun <yan.jun8@zte.com.cn>
src/msg/async/EventKqueue.cc
src/msg/async/net_handler.cc

index 54fef5f22de4460504896cc7e15b5fb3e70ea89b..d546462c2ed80f1c68253186eac45f3746d072bc 100644 (file)
@@ -28,7 +28,7 @@ int KqueueDriver::init(int nevent)
   if (!events) {
     lderr(cct) << __func__ << " unable to malloc memory: "
                            << cpp_strerror(errno) << dendl;
-    return -errno;
+    return -ENOMEM;
   }
   memset(events, 0, sizeof(struct kevent)*nevent);
 
@@ -58,7 +58,7 @@ int KqueueDriver::add_event(int fd, int cur_mask, int add_mask)
     if (kevent(kqfd, &ke, 1, NULL, 0, NULL) == -1) {
       lderr(cct) << __func__ << " unable to add event: "
                              << cpp_strerror(errno) << dendl;
-      return -1;
+      return -errno;
     }
   }
 
@@ -80,7 +80,7 @@ int KqueueDriver::del_event(int fd, int cur_mask, int delmask)
     if ((r = kevent(kqfd, &ke, 1, NULL, 0, NULL)) < 0) {
       lderr(cct) << __func__ << " kevent: delete fd=" << fd << " mask=" << filter
                  << " failed." << cpp_strerror(errno) << dendl;
-      return r;
+      return -errno;
     }
   }
   return 0;
index ba63eec4e5c067226ac4eba2bdcb7bd31063a5e7..2a892768792cf339b3748cc437474e40c5cf4328 100644 (file)
@@ -38,7 +38,7 @@ int NetHandler::create_socket(int domain, bool reuse_addr)
     return -errno;
   }
 
-  /* Make sure connection-intensive things like the benckmark
+  /* Make sure connection-intensive things like the benchmark
    * will be able to close/open sockets a zillion of times */
   if (reuse_addr) {
     if (::setsockopt(s, SOL_SOCKET, SO_REUSEADDR, &on, sizeof(on)) == -1) {