amass/ZLMediaKit
1
0
Fork 0
mirror of https://github.com/ZLMediaKit/ZLMediaKit.git synced 2024-11-22 10:40:05 +08:00
Code Issues Actions 6 Packages Projects Releases Wiki Activity

Update ZLToolKit

Browse Source
This commit is contained in:
xiongziliang 2024-01-06 17:47:43 +08:00
parent aeda47ec8c
commit 77400832ac
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
3rdpart/ZLToolKit

@ -1 +1 @@
Subproject commit 0dbf6c8d727c9f905458c81043f8fbad07ca5c58 Subproject commit 45d3570498f420bd7ef5fa97ef0a35a67f31a3be

2
tests/test_bench_forward.cpp
View File

@ -180,7 +180,7 @@ int main(int argc, char *argv[]) {
auto pusher = std::make_shared<MediaPusher>(src); auto pusher = std::make_shared<MediaPusher>(src);
pusher->setOnCreateSocket([](const EventPoller::Ptr &poller) { pusher->setOnCreateSocket([](const EventPoller::Ptr &poller) {
//socket关闭互斥锁，提高性能 //socket关闭互斥锁，提高性能
return std::make_shared<Socket>(poller, false); return Socket::createSocket(poller, false);
}); });
//设置推流失败监听 //设置推流失败监听
pusher->setOnPublished([&mtx, &pusher_map, index](const SockException &ex) { pusher->setOnPublished([&mtx, &pusher_map, index](const SockException &ex) {

2
tests/test_bench_pull.cpp
View File

@ -123,7 +123,7 @@ int main(int argc, char *argv[]) {
auto tag = player.get(); auto tag = player.get();
player->setOnCreateSocket([](const EventPoller::Ptr &poller) { player->setOnCreateSocket([](const EventPoller::Ptr &poller) {
//socket关闭互斥锁，提高性能 //socket关闭互斥锁，提高性能
return std::make_shared<Socket>(poller, false); return Socket::createSocket(poller, false);
}); });
//设置播放失败监听 //设置播放失败监听
player->setOnPlayResult([&mtx, &player_map, tag](const SockException &ex) { player->setOnPlayResult([&mtx, &player_map, tag](const SockException &ex) {

2
tests/test_bench_push.cpp
View File

@ -166,7 +166,7 @@ int main(int argc, char *argv[]) {
auto tag = pusher.get(); auto tag = pusher.get();
pusher->setOnCreateSocket([](const EventPoller::Ptr &poller) { pusher->setOnCreateSocket([](const EventPoller::Ptr &poller) {
//socket关闭互斥锁，提高性能 //socket关闭互斥锁，提高性能
return std::make_shared<Socket>(poller, false); return Socket::createSocket(poller, false);
}); });
//设置推流失败监听 //设置推流失败监听
pusher->setOnPublished([&mtx, &pusher_map, tag](const SockException &ex) { pusher->setOnPublished([&mtx, &pusher_map, tag](const SockException &ex) {