Index: webrtc/media/sctp/sctptransport.h |
diff --git a/webrtc/media/sctp/sctptransport.h b/webrtc/media/sctp/sctptransport.h |
deleted file mode 100644 |
index 6d3a41a8f16092be6b9e0b9179821b286b4fd944..0000000000000000000000000000000000000000 |
--- a/webrtc/media/sctp/sctptransport.h |
+++ /dev/null |
@@ -1,193 +0,0 @@ |
-/* |
- * Copyright (c) 2012 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_MEDIA_SCTP_SCTPTRANSPORT_H_ |
-#define WEBRTC_MEDIA_SCTP_SCTPTRANSPORT_H_ |
- |
-#include <errno.h> |
- |
-#include <memory> // for unique_ptr. |
-#include <set> |
-#include <string> |
-#include <vector> |
- |
-#include "webrtc/base/asyncinvoker.h" |
-#include "webrtc/base/constructormagic.h" |
-#include "webrtc/base/copyonwritebuffer.h" |
-#include "webrtc/base/sigslot.h" |
-#include "webrtc/base/thread.h" |
-// For SendDataParams/ReceiveDataParams. |
-#include "webrtc/media/base/mediachannel.h" |
-#include "webrtc/media/sctp/sctptransportinternal.h" |
-#include "webrtc/p2p/base/transportchannel.h" |
- |
-// Defined by "usrsctplib/usrsctp.h" |
-struct sockaddr_conn; |
-struct sctp_assoc_change; |
-struct sctp_stream_reset_event; |
-// Defined by <sys/socket.h> |
-struct socket; |
-namespace cricket { |
- |
-// Holds data to be passed on to a channel. |
-struct SctpInboundPacket; |
- |
-// From channel calls, data flows like this: |
-// [network thread (although it can in princple be another thread)] |
-// 1. SctpTransport::SendData(data) |
-// 2. usrsctp_sendv(data) |
-// [network thread returns; sctp thread then calls the following] |
-// 3. OnSctpOutboundPacket(wrapped_data) |
-// [sctp thread returns having async invoked on the network thread] |
-// 4. SctpTransport::OnPacketFromSctpToNetwork(wrapped_data) |
-// 5. TransportChannel::SendPacket(wrapped_data) |
-// 6. ... across network ... a packet is sent back ... |
-// 7. SctpTransport::OnPacketReceived(wrapped_data) |
-// 8. usrsctp_conninput(wrapped_data) |
-// [network thread returns; sctp thread then calls the following] |
-// 9. OnSctpInboundData(data) |
-// [sctp thread returns having async invoked on the network thread] |
-// 10. SctpTransport::OnInboundPacketFromSctpToChannel(inboundpacket) |
-// 11. SctpTransport::OnDataFromSctpToChannel(data) |
-// 12. SctpTransport::SignalDataReceived(data) |
-// [from the same thread, methods registered/connected to |
-// SctpTransport are called with the recieved data] |
-class SctpTransport : public SctpTransportInternal, |
- public sigslot::has_slots<> { |
- public: |
- // |network_thread| is where packets will be processed and callbacks from |
- // this transport will be posted, and is the only thread on which public |
- // methods can be called. |
- // |channel| is required (must not be null). |
- SctpTransport(rtc::Thread* network_thread, |
- cricket::TransportChannel* channel); |
- ~SctpTransport() override; |
- |
- // SctpTransportInternal overrides (see sctptransportinternal.h for comments). |
- void SetTransportChannel(cricket::TransportChannel* channel) override; |
- bool Start(int local_port, int remote_port) override; |
- bool OpenStream(int sid) override; |
- bool ResetStream(int sid) override; |
- bool SendData(const SendDataParams& params, |
- const rtc::CopyOnWriteBuffer& payload, |
- SendDataResult* result = nullptr) override; |
- bool ReadyToSendData() override; |
- void set_debug_name_for_testing(const char* debug_name) override { |
- debug_name_ = debug_name; |
- } |
- |
- // Exposed to allow Post call from c-callbacks. |
- // TODO(deadbeef): Remove this or at least make it return a const pointer. |
- rtc::Thread* network_thread() const { return network_thread_; } |
- |
- private: |
- void ConnectTransportChannelSignals(); |
- void DisconnectTransportChannelSignals(); |
- |
- // Creates the socket and connects. |
- bool Connect(); |
- |
- // Returns false when opening the socket failed. |
- bool OpenSctpSocket(); |
- // Helpet method to set socket options. |
- bool ConfigureSctpSocket(); |
- // Sets |sock_ |to nullptr. |
- void CloseSctpSocket(); |
- |
- // Sends a SCTP_RESET_STREAM for all streams in closing_ssids_. |
- bool SendQueuedStreamResets(); |
- |
- // Sets the "ready to send" flag and fires signal if needed. |
- void SetReadyToSendData(); |
- |
- // Callbacks from DTLS channel. |
- void OnWritableState(rtc::PacketTransportInterface* transport); |
- virtual void OnPacketRead(rtc::PacketTransportInterface* transport, |
- const char* data, |
- size_t len, |
- const rtc::PacketTime& packet_time, |
- int flags); |
- |
- // Methods related to usrsctp callbacks. |
- void OnSendThresholdCallback(); |
- sockaddr_conn GetSctpSockAddr(int port); |
- |
- // Called using |invoker_| to send packet on the network. |
- void OnPacketFromSctpToNetwork(const rtc::CopyOnWriteBuffer& buffer); |
- // Called using |invoker_| to decide what to do with the packet. |
- // The |flags| parameter is used by SCTP to distinguish notification packets |
- // from other types of packets. |
- void OnInboundPacketFromSctpToChannel(const rtc::CopyOnWriteBuffer& buffer, |
- ReceiveDataParams params, |
- int flags); |
- void OnDataFromSctpToChannel(const ReceiveDataParams& params, |
- const rtc::CopyOnWriteBuffer& buffer); |
- void OnNotificationFromSctp(const rtc::CopyOnWriteBuffer& buffer); |
- void OnNotificationAssocChange(const sctp_assoc_change& change); |
- |
- void OnStreamResetEvent(const struct sctp_stream_reset_event* evt); |
- |
- // Responsible for marshalling incoming data to the channels listeners, and |
- // outgoing data to the network interface. |
- rtc::Thread* network_thread_; |
- // Helps pass inbound/outbound packets asynchronously to the network thread. |
- rtc::AsyncInvoker invoker_; |
- // Underlying DTLS channel. |
- TransportChannel* transport_channel_; |
- bool was_ever_writable_ = false; |
- int local_port_ = kSctpDefaultPort; |
- int remote_port_ = kSctpDefaultPort; |
- struct socket* sock_ = nullptr; // The socket created by usrsctp_socket(...). |
- |
- // Has Start been called? Don't create SCTP socket until it has. |
- bool started_ = false; |
- // Are we ready to queue data (SCTP socket created, and not blocked due to |
- // congestion control)? Different than |transport_channel_|'s "ready to |
- // send". |
- bool ready_to_send_data_ = false; |
- |
- typedef std::set<uint32_t> StreamSet; |
- // When a data channel opens a stream, it goes into open_streams_. When we |
- // want to close it, the stream's ID goes into queued_reset_streams_. When |
- // we actually transmit a RE-CONFIG chunk with that stream ID, the ID goes |
- // into sent_reset_streams_. When we get a response RE-CONFIG chunk back |
- // acknowledging the reset, we remove the stream ID from |
- // sent_reset_streams_. We use sent_reset_streams_ to differentiate |
- // between acknowledgment RE-CONFIG and peer-initiated RE-CONFIGs. |
- StreamSet open_streams_; |
- StreamSet queued_reset_streams_; |
- StreamSet sent_reset_streams_; |
- |
- // A static human-readable name for debugging messages. |
- const char* debug_name_ = "SctpTransport"; |
- // Hides usrsctp interactions from this header file. |
- class UsrSctpWrapper; |
- |
- RTC_DISALLOW_COPY_AND_ASSIGN(SctpTransport); |
-}; |
- |
-class SctpTransportFactory : public SctpTransportInternalFactory { |
- public: |
- explicit SctpTransportFactory(rtc::Thread* network_thread) |
- : network_thread_(network_thread) {} |
- |
- std::unique_ptr<SctpTransportInternal> CreateSctpTransport( |
- TransportChannel* channel) override { |
- return std::unique_ptr<SctpTransportInternal>( |
- new SctpTransport(network_thread_, channel)); |
- } |
- |
- private: |
- rtc::Thread* network_thread_; |
-}; |
- |
-} // namespace cricket |
- |
-#endif // WEBRTC_MEDIA_SCTP_SCTPTRANSPORT_H_ |