rdma polling mode process message in new bthread

Author: yanglimingcn

src/brpc/input_messenger.cpp

@@ -331,7 +331,12 @@ int InputMessenger::ProcessNewMessage(
                     "destroyed when authentication failed";
             }
         }
-        if (!m->is_read_progressive()) {
+#if BRPC_WITH_RDMA
+        if (!m->is_read_progressive() && !rdma::FLAGS_rdma_use_polling)
+#else
+        if (!m->is_read_progressive())
+#endif
+        {
             // Transfer ownership to last_msg
             last_msg.reset(msg.release());
         } else {

src/brpc/rdma/rdma_endpoint.h

@@ -36,6 +36,7 @@ namespace brpc {
 class Socket;
 namespace rdma {
 
+DECLARE_bool(rdma_use_polling);
 DECLARE_int32(rdma_poller_num);
 DECLARE_bool(rdma_edisp_unsched);
 DECLARE_bool(rdma_disable_bthread);