00001 /* 00002 * 00003 * 00004 * Distributed under the OpenDDS License. 00005 * See: http://www.opendds.org/license.html 00006 */ 00007 00008 #ifndef OPENDDS_TCPSYNCHRESOURCE_H 00009 #define OPENDDS_TCPSYNCHRESOURCE_H 00010 00011 #include "TcpConnection_rch.h" 00012 #include "TcpConnection.h" 00013 #include "dds/DCPS/transport/framework/ThreadSynchResource.h" 00014 00015 OPENDDS_BEGIN_VERSIONED_NAMESPACE_DECL 00016 00017 namespace OpenDDS { 00018 namespace DCPS { 00019 00020 class TcpDataLink; 00021 00022 class TcpSynchResource : public ThreadSynchResource { 00023 public: 00024 00025 TcpSynchResource(TcpDataLink& link, 00026 const int& max_output_pause_period_ms); 00027 virtual ~TcpSynchResource(); 00028 00029 virtual void notify_lost_on_backpressure_timeout(); 00030 00031 private: 00032 00033 TcpDataLink& link_; 00034 }; 00035 00036 } // namespace DCPS 00037 } // namespace OpenDDS 00038 00039 OPENDDS_END_VERSIONED_NAMESPACE_DECL 00040 00041 #endif /* OPENDDS_TCPSYNCHRESOURCE_H */