OpenDDS: DataLinkCleanupTask.h Source File

00001 /*
00002  *
00003  *
00004  * Distributed under the OpenDDS License.
00005  * See: http://www.opendds.org/license.html
00006  */
00007 
00008 #ifndef OPENDDS_DCPS_DATALINKCLEANUP_H
00009 #define OPENDDS_DCPS_DATALINKCLEANUP_H
00010 
00011 #include /**/ "ace/pre.h"
00012 
00013 #include "dds/DCPS/transport/framework/QueueTaskBase_T.h"
00014 #include "dds/DCPS/transport/framework/DataLink.h"
00015 #include "dds/DCPS/transport/framework/DataLink_rch.h"
00016 
00017 #if !defined (ACE_LACKS_PRAGMA_ONCE)
00018 # pragma once
00019 #endif /* ACE_LACKS_PRAGMA_ONCE */
00020 
00021 namespace OpenDDS {
00022 namespace DCPS {
00023 
00024 class TransportImpl;
00025 
00026 /**
00027  * @class DataLinkCleanupTask
00028  *
00029  * @brief Active Object responsible for cleaning up DataLink resources.
00030  *
00031  */
00032 class OpenDDS_Dcps_Export DataLinkCleanupTask : public QueueTaskBase <DataLink_rch> {
00033 public:
00034   /// Constructor.
00035   DataLinkCleanupTask();
00036 
00037   /// Virtual Destructor.
00038   virtual ~DataLinkCleanupTask();
00039 
00040   /// Handle reconnect requests.
00041   virtual void execute(DataLink_rch& dl);
00042 };
00043 
00044 } // namespace DCPS
00045 } // namespace OpenDDS
00046 
00047 #include /**/ "ace/post.h"
00048 
00049 #endif /* OPENDDS_DCPS_DATALINKCLEANUP_H */