Commit 638ef8c7 by Johnny

Refine: 调整 WebRtcSession::getPoller 静态函数为 QueryPollerByBuffer 全局函数,以改善其他 getPoller 同名函数可读性。

parent 22c68a29
...@@ -274,7 +274,7 @@ int start_main(int argc,char *argv[]) { ...@@ -274,7 +274,7 @@ int start_main(int argc,char *argv[]) {
if (!buf) { if (!buf) {
return Socket::createSocket(poller, false); return Socket::createSocket(poller, false);
} }
auto new_poller = WebRtcSession::getPoller(buf); auto new_poller = QueryPollerByBuffer(buf);
if (!new_poller) { if (!new_poller) {
//该数据对应的webrtc对象未找到,丢弃之 //该数据对应的webrtc对象未找到,丢弃之
return Socket::Ptr(); return Socket::Ptr();
......
...@@ -40,7 +40,7 @@ static string getUserName(const Buffer::Ptr &buffer) { ...@@ -40,7 +40,7 @@ static string getUserName(const Buffer::Ptr &buffer) {
return vec[0]; return vec[0];
} }
EventPoller::Ptr WebRtcSession::getPoller(const Buffer::Ptr &buffer) { EventPoller::Ptr QueryPollerByBuffer(const Buffer::Ptr &buffer) {
auto user_name = getUserName(buffer); auto user_name = getUserName(buffer);
if (user_name.empty()) { if (user_name.empty()) {
return nullptr; return nullptr;
...@@ -80,7 +80,7 @@ void WebRtcSession::onError(const SockException &err) { ...@@ -80,7 +80,7 @@ void WebRtcSession::onError(const SockException &err) {
return; return;
} }
auto transport = std::move(_transport); auto transport = std::move(_transport);
this->Session::getPoller()->async([transport] { getPoller()->async([transport] {
//延时减引用,防止使用transport对象时,销毁对象 //延时减引用,防止使用transport对象时,销毁对象
}, false); }, false);
} }
......
...@@ -18,10 +18,10 @@ ...@@ -18,10 +18,10 @@
using namespace toolkit; using namespace toolkit;
EventPoller::Ptr QueryPollerByBuffer(const Buffer::Ptr &buffer);
class WebRtcSession : public UdpSession { class WebRtcSession : public UdpSession {
public: public:
static EventPoller::Ptr getPoller(const Buffer::Ptr &);
WebRtcSession(const Socket::Ptr &sock); WebRtcSession(const Socket::Ptr &sock);
~WebRtcSession() override; ~WebRtcSession() override;
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论