fix(volo-thrift): server rpcinfo.caller may be None

cloudwego · Aug 22, 2023 · cdc99ae · cdc99ae
1 parent 556c463
commit cdc99ae
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/volo-thrift/Cargo.toml b/volo-thrift/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "volo-thrift"
-version = "0.7.0"
+version = "0.7.1"
 edition.workspace = true
 homepage.workspace = true
 repository.workspace = true

diff --git a/volo-thrift/src/transport/pingpong/server.rs b/volo-thrift/src/transport/pingpong/server.rs
@@ -54,6 +54,8 @@ pub async fn serve<Svc, Req, Resp, E, D, SP>(
                         caller.set_address(peer_addr.clone());
                         cx.rpc_info.caller = Some(caller);
                     }
+                } else if cx.rpc_info.caller().is_none() {
+                    cx.rpc_info.caller = Some(Endpoint::new("-".into()));
                 }
 
                 let msg = tokio::select! {