1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
/*
* Copyright (c) 2011 Tobias Markmann
* Licensed under the simplified BSD license.
* See Documentation/Licenses/BSD-simplified.txt for more information.
*/
/*
* Copyright (c) 2013-2017 Isode Limited.
* All rights reserved.
* See the COPYING file for more information.
*/
#pragma once
#include <memory>
#include <boost/optional/optional.hpp>
#include <Swiften/Base/API.h>
#include <Swiften/Elements/JingleFileTransferFileInfo.h>
#include <Swiften/FileTransfer/FileTransferOptions.h>
#include <Swiften/FileTransfer/JingleFileTransfer.h>
#include <Swiften/FileTransfer/OutgoingFileTransfer.h>
#include <Swiften/Jingle/JingleContentID.h>
#include <Swiften/Network/Timer.h>
namespace Swift {
class CryptoProvider;
class FileTransferTransporterFactory;
class IDGenerator;
class IncrementalBytestreamHashCalculator;
class ReadBytestream;
class TimerFactory;
class TransportSession;
class SWIFTEN_API OutgoingJingleFileTransfer : public OutgoingFileTransfer, public JingleFileTransfer {
public:
OutgoingJingleFileTransfer(
const JID& to,
std::shared_ptr<JingleSession>,
std::shared_ptr<ReadBytestream>,
FileTransferTransporterFactory*,
TimerFactory*,
IDGenerator*,
const JingleFileTransferFileInfo&,
const FileTransferOptions&,
CryptoProvider*);
virtual ~OutgoingJingleFileTransfer() override;
virtual void start() override;
virtual void cancel() override;
private:
enum State {
Initial,
GeneratingInitialLocalCandidates,
WaitingForAccept,
TryingCandidates,
WaitingForPeerProxyActivate,
WaitingForLocalProxyActivate,
WaitingForCandidateAcknowledge,
FallbackRequested,
Transferring,
WaitForTermination,
Finished
};
virtual void handleSessionAcceptReceived(const JingleContentID&, std::shared_ptr<JingleDescription>, std::shared_ptr<JingleTransportPayload>) override;
virtual void handleSessionTerminateReceived(boost::optional<JinglePayload::Reason> reason) override;
virtual void handleTransportAcceptReceived(const JingleContentID&, std::shared_ptr<JingleTransportPayload>) override;
virtual void handleTransportRejectReceived(const JingleContentID &, std::shared_ptr<JingleTransportPayload>) override;
virtual void startTransferViaRemoteCandidate() override;
virtual void startTransferViaLocalCandidate() override;
void startTransferringIfCandidateAcknowledged();
virtual void handleLocalTransportCandidatesGenerated(const std::string& s5bSessionID, const std::vector<JingleS5BTransportPayload::Candidate>&, const std::string& dstAddr) override;
virtual void handleTransportInfoAcknowledged(const std::string& id) override;
virtual JingleContentID getContentID() const override;
virtual void terminate(JinglePayload::Reason::Type reason) override;
virtual void fallback() override;
void handleTransferFinished(boost::optional<FileTransferError>);
void sendSessionInfoHash();
virtual void startTransferring(std::shared_ptr<TransportSession>) override;
virtual bool hasPriorityOnCandidateTie() const override;
virtual bool isWaitingForPeerProxyActivate() const override;
virtual bool isWaitingForLocalProxyActivate() const override;
virtual bool isTryingCandidates() const override;
virtual std::shared_ptr<TransportSession> createLocalCandidateSession() override;
virtual std::shared_ptr<TransportSession> createRemoteCandidateSession() override;
void handleWaitForRemoteTerminationTimeout();
void stopAll();
void setInternalState(State state);
void setFinishedState(FileTransfer::State::Type, const boost::optional<FileTransferError>& error);
static FileTransfer::State::Type getExternalState(State state);
private:
IDGenerator* idGenerator;
std::shared_ptr<ReadBytestream> stream;
JingleFileTransferFileInfo fileInfo;
FileTransferOptions options;
JingleContentID contentID;
IncrementalBytestreamHashCalculator* hashCalculator;
State state;
bool candidateAcknowledged;
Timer::ref waitForRemoteTermination;
boost::signals2::connection processedBytesConnection;
boost::signals2::connection transferFinishedConnection;
};
}
|
Swift