diff --git a/server/wsproxy/downstreammgr.cc b/server/wsproxy/downstreammgr.cc
index 8500356..a3ab904 100644
--- a/server/wsproxy/downstreammgr.cc
+++ b/server/wsproxy/downstreammgr.cc
@@ -77,9 +77,9 @@ std::weak_ptr<DownStream> DownStreamMgr::GetDownStream(int sockhandle)
     return itr != socket_hash_.end() ? itr->second : nullptr;
 }
 
-void DownStreamMgr::BindUpStream(int socket_handle, int conn_instance_id)
+void DownStreamMgr::BindUpStream(int socket_handle, int instance_id)
 {
-    std::weak_ptr<UpStream> up_wp = UpStreamMgr::Instance()->GetUpStreamById(conn_instance_id);
+    std::weak_ptr<UpStream> up_wp = UpStreamMgr::Instance()->GetUpStreamById(instance_id);
     if (!up_wp.expired()) {
         auto down_wp = GetDownStream(socket_handle);
         if (auto down = down_wp.lock(); !down_wp.expired()) {
diff --git a/server/wsproxy/downstreammgr.h b/server/wsproxy/downstreammgr.h
index a4465ef..55dd8dc 100644
--- a/server/wsproxy/downstreammgr.h
+++ b/server/wsproxy/downstreammgr.h
@@ -18,7 +18,7 @@ class DownStreamMgr : public a8::Singleton<DownStreamMgr>
     void OnUpStreamDisconnect(int instance_id);
     void OnUpStreamConnect(int instance_id);
     std::weak_ptr<DownStream> GetDownStream(int sockhande);
-    void BindUpStream(int socket_handle, int conn_instance_id);
+    void BindUpStream(int socket_handle, int instance_id);
     void AddPendingAccount(const std::string& account_id, int socket_handle, long long req_tick);
 
 private: