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

Unified Diff: webrtc/test/channel_transport/udp_socket_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_posix.h
diff --git a/webrtc/test/channel_transport/udp_socket_posix.h b/webrtc/test/channel_transport/udp_socket_posix.h
new file mode 100644
index 0000000000000000000000000000000000000000..537b52e393049238cfa5756eb2fc8317be7ef44f
--- /dev/null
+++ b/webrtc/test/channel_transport/udp_socket_posix.h
@@ -0,0 +1,94 @@
+/*
+ * 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_POSIX_H_
+#define WEBRTC_TEST_CHANNEL_TRANSPORT_UDP_SOCKET_POSIX_H_
+
+#include <arpa/inet.h>
+#include <netinet/in.h>
+#include <sys/socket.h>
+#include <sys/types.h>
+
+#include "webrtc/base/event.h"
+#include "webrtc/base/criticalsection.h"
+#include "webrtc/test/channel_transport/udp_socket_wrapper.h"
+
+namespace webrtc {
+namespace test {
+
+#define SOCKET_ERROR -1
+
+class UdpSocketPosix : public UdpSocketWrapper
+{
+public:
+ UdpSocketPosix(const int32_t id, UdpSocketManager* mgr,
+ bool ipV6Enable = false);
+
+ virtual ~UdpSocketPosix();
+
+ bool SetCallback(CallbackObj obj, IncomingSocketCallback cb) override;
+
+ bool Bind(const SocketAddress& name) override;
+
+ bool SetSockopt(int32_t level,
+ int32_t optname,
+ const int8_t* optval,
+ int32_t optlen) override;
+
+ int32_t SetTOS(const int32_t serviceType) override;
+
+ int32_t SendTo(const int8_t* buf,
+ size_t len,
+ const SocketAddress& to) override;
+
+ // Deletes socket in addition to closing it.
+ // TODO (hellner): make destructor protected.
+ void CloseBlocking() override;
+
+ SOCKET GetFd();
+
+ bool ValidHandle() override;
+
+ bool SetQos(int32_t /*serviceType*/,
+ int32_t /*tokenRate*/,
+ int32_t /*bucketSize*/,
+ int32_t /*peekBandwith*/,
+ int32_t /*minPolicedSize*/,
+ int32_t /*maxSduSize*/,
+ const SocketAddress& /*stRemName*/,
+ int32_t /*overrideDSCP*/) override;
+
+ bool CleanUp();
+ void HasIncoming();
+ bool WantsIncoming();
+ void ReadyForDeletion();
+private:
+ friend class UdpSocketManagerPosix;
+
+ const int32_t _id;
+ IncomingSocketCallback _incomingCb;
+ CallbackObj _obj;
+
+ SOCKET _socket;
+ UdpSocketManager* _mgr;
+ rtc::Event _closeBlockingCompletedCond;
+ rtc::Event _readyForDeletionCond;
+
+ bool _closeBlockingActive;
+ bool _closeBlockingCompleted;
+ bool _readyForDeletion;
+
+ rtc::CriticalSection _cs;
+};
+
+} // namespace test
+} // namespace webrtc
+
+#endif // WEBRTC_TEST_CHANNEL_TRANSPORT_UDP_SOCKET_POSIX_H_
« no previous file with comments | « webrtc/test/channel_transport/udp_socket_manager_wrapper.cc ('k') | webrtc/test/channel_transport/udp_socket_posix.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698