diff --git a/3rdpart/ZLToolKit b/3rdpart/ZLToolKit index 0dbf6c8d..45d35704 160000 --- a/3rdpart/ZLToolKit +++ b/3rdpart/ZLToolKit @@ -1 +1 @@ -Subproject commit 0dbf6c8d727c9f905458c81043f8fbad07ca5c58 +Subproject commit 45d3570498f420bd7ef5fa97ef0a35a67f31a3be diff --git a/tests/test_bench_forward.cpp b/tests/test_bench_forward.cpp index eb6df202..a71994d1 100644 --- a/tests/test_bench_forward.cpp +++ b/tests/test_bench_forward.cpp @@ -180,7 +180,7 @@ int main(int argc, char *argv[]) { auto pusher = std::make_shared(src); pusher->setOnCreateSocket([](const EventPoller::Ptr &poller) { //socket关闭互斥锁,提高性能 - return std::make_shared(poller, false); + return Socket::createSocket(poller, false); }); //设置推流失败监听 pusher->setOnPublished([&mtx, &pusher_map, index](const SockException &ex) { diff --git a/tests/test_bench_pull.cpp b/tests/test_bench_pull.cpp index c16de46a..dd455f8e 100644 --- a/tests/test_bench_pull.cpp +++ b/tests/test_bench_pull.cpp @@ -123,7 +123,7 @@ int main(int argc, char *argv[]) { auto tag = player.get(); player->setOnCreateSocket([](const EventPoller::Ptr &poller) { //socket关闭互斥锁,提高性能 - return std::make_shared(poller, false); + return Socket::createSocket(poller, false); }); //设置播放失败监听 player->setOnPlayResult([&mtx, &player_map, tag](const SockException &ex) { diff --git a/tests/test_bench_push.cpp b/tests/test_bench_push.cpp index 604ad76f..ee07f0c2 100644 --- a/tests/test_bench_push.cpp +++ b/tests/test_bench_push.cpp @@ -166,7 +166,7 @@ int main(int argc, char *argv[]) { auto tag = pusher.get(); pusher->setOnCreateSocket([](const EventPoller::Ptr &poller) { //socket关闭互斥锁,提高性能 - return std::make_shared(poller, false); + return Socket::createSocket(poller, false); }); //设置推流失败监听 pusher->setOnPublished([&mtx, &pusher_map, tag](const SockException &ex) {