msg/async:change EventCenter::process_events(int timeout_microseconds) to EventCenter...

Signed-off-by: shangfufei <shangfufei@inspur.com>

diff --git a/src/msg/async/Event.cc b/src/msg/async/Event.cc
index af5dad703eeb12c2da4bc48fd34cd9bc01c68718..cda4d1a3af5a0139d25e3acd51c9e0c4010ef27e 100644 (file)
--- a/src/msg/async/Event.cc
+++ b/src/msg/async/Event.cc
@@ -357,7 +357,7 @@ int EventCenter::process_time_events()
   return processed;
 }
 
-int EventCenter::process_events(int timeout_microseconds,  ceph::timespan *working_dur)
+int EventCenter::process_events(unsigned timeout_microseconds,  ceph::timespan *working_dur)
 {
   struct timeval tv;
   int numevents;

diff --git a/src/msg/async/Event.h b/src/msg/async/Event.h
index 50f2a2b8795be04807169dbf44692e85b23b7137..22229f31bbbf83a5a0220608d9a6c139ec38d00e 100644 (file)
--- a/src/msg/async/Event.h
+++ b/src/msg/async/Event.h
@@ -203,7 +203,7 @@ class EventCenter {
   uint64_t create_time_event(uint64_t milliseconds, EventCallbackRef ctxt);
   void delete_file_event(int fd, int mask);
   void delete_time_event(uint64_t id);
-  int process_events(int timeout_microseconds, ceph::timespan *working_dur = nullptr);
+  int process_events(unsigned timeout_microseconds, ceph::timespan *working_dur = nullptr);
   void wakeup();
 
   // Used by external thread

diff --git a/src/msg/async/Stack.cc b/src/msg/async/Stack.cc
index 895cc82ee5a99323e0ef513b3a4e6ccda728011d..86005434b87f3d12caf04a7a53de4ec8a7e0bbec 100644 (file)
--- a/src/msg/async/Stack.cc
+++ b/src/msg/async/Stack.cc
@@ -41,7 +41,7 @@ std::function<void ()> NetworkStack::add_thread(unsigned i)
       char tp_name[16];
       sprintf(tp_name, "msgr-worker-%u", w->id);
       ceph_pthread_setname(pthread_self(), tp_name);
-      const uint64_t EventMaxWaitUs = 30000000;
+      const unsigned EventMaxWaitUs = 30000000;
       w->center.set_owner();
       ldout(cct, 10) << __func__ << " starting" << dendl;
       w->initialize();