add timeout to auth

src/os/src/detail/osSemaphore.c

@@ -118,13 +118,13 @@ int32_t tsem_timewait(tsem_t* sem, int64_t ms) {
 
 #endif
 
-#if defined(_TD_DARWIN_64)
+// #if defined(_TD_DARWIN_64)
 
-int tsem_timewait(tsem_t* psem, int64_t milis) {
-  if (psem == NULL || *psem == NULL) return -1;
-  dispatch_time_t time = dispatch_time(DISPATCH_TIME_NOW, (int64_t)(milis * USEC_PER_SEC));
-  dispatch_semaphore_wait(*psem, time);
-  return 0;
-}
+// int tsem_timewait(tsem_t* psem, int64_t milis) {
+//   if (psem == NULL || *psem == NULL) return -1;
+//   dispatch_time_t time = dispatch_time(DISPATCH_TIME_NOW, (int64_t)(milis * USEC_PER_SEC));
+//   dispatch_semaphore_wait(*psem, time);
+//   return 0;
+// }
 
-#endif
\ No newline at end of file
+// #endif
\ No newline at end of file

src/rpc/src/rpcMain.c

@@ -576,11 +576,19 @@ void rpcSendRecvWithTimeout(void *shandle, SRpcEpSet *pEpSet, SRpcMsg *pMsg, SRp
   int64_t rid = 0;
   rpcSendRequest(shandle, pEpSet, pMsg, &rid);
 
-  tsem_timewait(&sem, 3 * 1000);
-  rpcCancelRequest(rid);
+#if defined (LINUX)
+  if (tsem_timewait(&sem, 3 * 1000) == 0) {
+    // do nothing
+  } else {
+    rpcCancelRequest(rid);
+    pRsp->code = -1;
+  }
+
+#else 
+  tsem_wait(&sem);
+#endif
   tsem_destroy(&sem);
 
-  pRsp->code = -1;
   return;
 }