addStreamProxy、addStreamPusherProxy接口确保线程负载均衡

cmake/checks/atomic_check.cpp

@@ -1,4 +1,4 @@
-#include <atomic>
+#include <atomic>
 
 static int test()
 {

resource.rc

@@ -1,5 +1,5 @@
-#ifdef APSTUDIO_INVOKED
+#ifdef APSTUDIO_INVOKED
-#error This file is not editable by Visual C++.
+#error "This file is not editable by Visual C++."
 #endif //APSTUDIO_INVOKED
 
 #include "winres.h"

server/WebApi.cpp

@@ -1191,6 +1191,7 @@ void installWebApi() {
 
         auto dst_url = allArgs["dst_url"];
         auto retry_count = allArgs["retry_count"].empty() ? -1 : allArgs["retry_count"].as<int>();
+        EventPollerPool::Instance().getPoller(false)->async([=](){
             addStreamPusherProxy(allArgs["schema"],
                                  allArgs["vhost"],
                                  allArgs["app"],
@@ -1211,6 +1212,7 @@ void installWebApi() {
                                      invoker(200, headerOut, val.toStyledString());
                                  });
         });
+    });
 
     // 关闭推流代理  [AUTO-TRANSLATED:91602b75]
     // Close the push stream proxy
@@ -1258,6 +1260,7 @@ void installWebApi() {
             vhost = allArgs["vhost"];
         }
         auto tuple = MediaTuple { vhost, allArgs["app"], allArgs["stream"], "" };
+        EventPollerPool::Instance().getPoller(false)->async([=]() {
             addStreamProxy(tuple,
                            allArgs["url"],
                            retry_count,
@@ -1275,6 +1278,7 @@ void installWebApi() {
                                invoker(200, headerOut, val.toStyledString());
                            });
         });
+    });
 
     // 关闭拉流代理  [AUTO-TRANSLATED:5204f128]
     // Close the pull stream proxy

src/Extension/Track.cpp

@@ -1,4 +1,4 @@
-/*
+/*
  * Copyright (c) 2016-present The ZLMediaKit project authors. All Rights Reserved.
  *
  * This file is part of ZLMediaKit(https://github.com/ZLMediaKit/ZLMediaKit).