mollyim/webrtc
1
0
Fork 0
mirror of https://github.com/mollyim/webrtc.git synced 2025-05-13 05:40:42 +01:00
Code Issues Projects Releases Packages Wiki Activity Actions

Use DefaultTaskQueueFactory in tool network_tester_server

Browse source 
instead of using it via GlobalTaskQueueFactory helper

Bug: webrtc:10284
Change-Id: Ic8215143bc2ac555fb5b36bf1ea13780065c45a5
Reviewed-on: https://webrtc-review.googlesource.com/c/src/+/129934
Reviewed-by: Mirko Bonadei <mbonadei@webrtc.org>
Commit-Queue: Danil Chapovalov <danilchap@webrtc.org>
Cr-Commit-Position: refs/heads/master@{#27330}
This commit is contained in:
Danil Chapovalov 2019-03-27 19:42:15 +01:00 committed by Commit Bot
parent 71f76b54ad
commit 3993b18795
3 changed files with 8 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
rtc_tools/network_tester/BUILD.gn
View file

@ -44,6 +44,7 @@ if (rtc_enable_protobuf) {
":network_tester_config_proto",
":network_tester_packet_proto",
"../../api/task_queue",
"../../api/task_queue:default_task_queue_factory",
"../../p2p",
"../../rtc_base",
"../../rtc_base:checks",

6
rtc_tools/network_tester/packet_sender.cc
View file

@ -17,6 +17,7 @@
#include "absl/memory/memory.h"
#include "absl/types/optional.h"
#include "api/task_queue/default_task_queue_factory.h"
#include "api/task_queue/queued_task.h"
#include "api/task_queue/task_queue_base.h"
#include "rtc_base/time_utils.h"
@ -85,7 +86,10 @@ PacketSender::PacketSender(TestController* test_controller,
sending_(false),
config_file_path_(config_file_path),
test_controller_(test_controller),
worker_queue_("Packet Sender", rtc::TaskQueue::Priority::HIGH) {}
task_queue_factory_(CreateDefaultTaskQueueFactory()),
worker_queue_(task_queue_factory_->CreateTaskQueue(
"Packet Sender",
TaskQueueFactory::Priority::HIGH)) {}
PacketSender::~PacketSender() = default;

2
rtc_tools/network_tester/packet_sender.h
View file

@ -14,6 +14,7 @@
#include <memory>
#include <string>
#include "api/task_queue/task_queue_factory.h"
#include "rtc_base/constructor_magic.h"
#include "rtc_base/ignore_wundef.h"
#include "rtc_base/sequenced_task_checker.h"
@ -55,6 +56,7 @@ class PacketSender {
bool sending_ RTC_GUARDED_BY(worker_queue_checker_);
const std::string config_file_path_;
TestController* const test_controller_;
std::unique_ptr<TaskQueueFactory> task_queue_factory_;
rtc::TaskQueue worker_queue_;
RTC_DISALLOW_COPY_AND_ASSIGN(PacketSender);