Commit 65809450 authored by zhujiashun's avatar zhujiashun

- Implement H2GlobalStreamCreator::ReplaceSocketForStream

- Set stream creator in serialize_request
parent adb2032a
...@@ -100,6 +100,7 @@ public: ...@@ -100,6 +100,7 @@ public:
_cntl->_request_protocol = protocol; _cntl->_request_protocol = protocol;
return *this; return *this;
} }
ProtocolType request_protocol() { return _cntl->_request_protocol; }
Span* span() const { return _cntl->_span; } Span* span() const { return _cntl->_span; }
......
...@@ -783,6 +783,8 @@ private: ...@@ -783,6 +783,8 @@ private:
butil::Mutex _stream_mutex; butil::Mutex _stream_mutex;
std::set<StreamId> *_stream_set; std::set<StreamId> *_stream_set;
SocketUniquePtr _agent_socket;
}; };
} // namespace brpc } // namespace brpc
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment