Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(85)

Unified Diff: webrtc/test/channel_transport/udp_socket_manager_posix.h

Issue 2336123002: Revert of Moved webrtc/test/channel_transport/ into webrtc/voice_engine/test/ (Closed)
Patch Set: Created 4 years, 3 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
Index: webrtc/test/channel_transport/udp_socket_manager_posix.h
diff --git a/webrtc/test/channel_transport/udp_socket_manager_posix.h b/webrtc/test/channel_transport/udp_socket_manager_posix.h
new file mode 100644
index 0000000000000000000000000000000000000000..92bff6b0eeaf1e31bfb942930fe2393bbc06a7fb
--- /dev/null
+++ b/webrtc/test/channel_transport/udp_socket_manager_posix.h
@@ -0,0 +1,88 @@
+/*
+ * Copyright (c) 2011 The WebRTC project authors. All Rights Reserved.
+ *
+ * Use of this source code is governed by a BSD-style license
+ * that can be found in the LICENSE file in the root of the source
+ * tree. An additional intellectual property rights grant can be found
+ * in the file PATENTS. All contributing project authors may
+ * be found in the AUTHORS file in the root of the source tree.
+ */
+
+#ifndef WEBRTC_TEST_CHANNEL_TRANSPORT_UDP_SOCKET_MANAGER_POSIX_H_
+#define WEBRTC_TEST_CHANNEL_TRANSPORT_UDP_SOCKET_MANAGER_POSIX_H_
+
+#include <sys/types.h>
+#include <unistd.h>
+
+#include <list>
+#include <map>
+
+#include "webrtc/base/platform_thread.h"
+#include "webrtc/system_wrappers/include/critical_section_wrapper.h"
+#include "webrtc/test/channel_transport/udp_socket_manager_wrapper.h"
+#include "webrtc/test/channel_transport/udp_socket_wrapper.h"
+
+namespace webrtc {
+namespace test {
+
+class UdpSocketPosix;
+class UdpSocketManagerPosixImpl;
+#define MAX_NUMBER_OF_SOCKET_MANAGERS_LINUX 8
+
+class UdpSocketManagerPosix : public UdpSocketManager
+{
+public:
+ UdpSocketManagerPosix();
+ virtual ~UdpSocketManagerPosix();
+
+ bool Init(int32_t id, uint8_t& numOfWorkThreads) override;
+
+ bool Start() override;
+ bool Stop() override;
+
+ bool AddSocket(UdpSocketWrapper* s) override;
+ bool RemoveSocket(UdpSocketWrapper* s) override;
+
+private:
+ int32_t _id;
+ CriticalSectionWrapper* _critSect;
+ uint8_t _numberOfSocketMgr;
+ uint8_t _incSocketMgrNextTime;
+ uint8_t _nextSocketMgrToAssign;
+ UdpSocketManagerPosixImpl* _socketMgr[MAX_NUMBER_OF_SOCKET_MANAGERS_LINUX];
+};
+
+class UdpSocketManagerPosixImpl
+{
+public:
+ UdpSocketManagerPosixImpl();
+ virtual ~UdpSocketManagerPosixImpl();
+
+ virtual bool Start();
+ virtual bool Stop();
+
+ virtual bool AddSocket(UdpSocketWrapper* s);
+ virtual bool RemoveSocket(UdpSocketWrapper* s);
+
+protected:
+ static bool Run(void* obj);
+ bool Process();
+ void UpdateSocketMap();
+
+private:
+ typedef std::list<UdpSocketWrapper*> SocketList;
+ typedef std::list<SOCKET> FdList;
+ rtc::PlatformThread _thread;
+ CriticalSectionWrapper* _critSectList;
+
+ fd_set _readFds;
+
+ std::map<SOCKET, UdpSocketPosix*> _socketMap;
+ SocketList _addList;
+ FdList _removeList;
+};
+
+} // namespace test
+} // namespace webrtc
+
+#endif // WEBRTC_TEST_CHANNEL_TRANSPORT_UDP_SOCKET_MANAGER_POSIX_H_
« no previous file with comments | « webrtc/test/channel_transport/udp_socket2_win.cc ('k') | webrtc/test/channel_transport/udp_socket_manager_posix.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698