Swiftdiff options
| author | Tobias Markmann <tm@ayena.de> | 2015-03-01 20:56:38 (GMT) |
|---|---|---|
| committer | Tobias Markmann <tm@ayena.de> | 2015-03-02 15:35:01 (GMT) |
| commit | ed3cd92d0ed1109dfcfd8f81bb43c91a6f73201e (patch) | |
| tree | 4b094e56e07c739980cfe604cd217b1e8b9b772a /Swiften/FileTransfer/S5BTransportSession.h | |
| parent | db98c3283af01ccaf904b8e65879c026c4b181ec (diff) | |
| download | swift-ed3cd92d0ed1109dfcfd8f81bb43c91a6f73201e.zip swift-ed3cd92d0ed1109dfcfd8f81bb43c91a6f73201e.tar.bz2 | |
Move *TransportSession to their own files
Test-Information:
Builds.
Change-Id: I1d8a942a2063c6bc0f7322161a33c0413a6899a3
Diffstat (limited to 'Swiften/FileTransfer/S5BTransportSession.h')
| -rw-r--r-- | Swiften/FileTransfer/S5BTransportSession.h | 67 |
1 files changed, 67 insertions, 0 deletions
diff --git a/Swiften/FileTransfer/S5BTransportSession.h b/Swiften/FileTransfer/S5BTransportSession.h new file mode 100644 index 0000000..234c491 --- /dev/null +++ b/Swiften/FileTransfer/S5BTransportSession.h @@ -0,0 +1,67 @@ +/* + * Copyright (c) 2015 Isode Limited. + * All rights reserved. + * See the COPYING file for more information. + */ + +#pragma once + +#include <Swiften/Base/API.h> +#include <Swiften/Base/boost_bsignals.h> +#include <Swiften/FileTransfer/TransportSession.h> +#include <Swiften/FileTransfer/ReadBytestream.h> +#include <Swiften/FileTransfer/WriteBytestream.h> + +namespace Swift { + +template <typename T> +class SWIFTEN_API S5BTransportSession : public TransportSession { + public: + S5BTransportSession( + boost::shared_ptr<T> session, + boost::shared_ptr<ReadBytestream> readStream) : + session(session), + readStream(readStream) { + initialize(); + } + + S5BTransportSession( + boost::shared_ptr<T> session, + boost::shared_ptr<WriteBytestream> writeStream) : + session(session), + writeStream(writeStream) { + initialize(); + } + + virtual ~S5BTransportSession() { + } + + virtual void start() SWIFTEN_OVERRIDE { + if (readStream) { + session->startSending(readStream); + } + else { + session->startReceiving(writeStream); + } + } + + virtual void stop() SWIFTEN_OVERRIDE { + session->stop(); + } + + private: + void initialize() { + finishedConnection = session->onFinished.connect(boost::bind(boost::ref(onFinished), _1)); + bytesSentConnection = session->onBytesSent.connect(boost::bind(boost::ref(onBytesSent), _1)); + } + + private: + boost::shared_ptr<T> session; + boost::shared_ptr<ReadBytestream> readStream; + boost::shared_ptr<WriteBytestream> writeStream; + + boost::bsignals::scoped_connection finishedConnection; + boost::bsignals::scoped_connection bytesSentConnection; +}; + +} |