| 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_
|
|
|