blob: c6bdcd087a6a2f789d5a0889b2f2a3f328391771 (
plain)
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
|
#ifndef D_MOCK_BT_MESSAGE_DISPATCHER_H
#define D_MOCK_BT_MESSAGE_DISPATCHER_H
#include "BtMessageDispatcher.h"
#include <algorithm>
#include "BtMessage.h"
#include "Piece.h"
namespace aria2 {
class MockBtMessageDispatcher : public BtMessageDispatcher {
public:
std::deque<std::unique_ptr<BtMessage>> messageQueue;
virtual ~MockBtMessageDispatcher() {}
virtual void
addMessageToQueue(std::unique_ptr<BtMessage> btMessage) CXX11_OVERRIDE
{
messageQueue.push_back(std::move(btMessage));
}
virtual void sendMessages() CXX11_OVERRIDE {}
virtual void doCancelSendingPieceAction(size_t index, int32_t begin,
int32_t length) CXX11_OVERRIDE
{
}
virtual void
doCancelSendingPieceAction(const std::shared_ptr<Piece>& piece) CXX11_OVERRIDE
{
}
virtual void doAbortOutstandingRequestAction(
const std::shared_ptr<Piece>& piece) CXX11_OVERRIDE
{
}
virtual void doChokedAction() CXX11_OVERRIDE {}
virtual void doChokingAction() CXX11_OVERRIDE {}
virtual void checkRequestSlotAndDoNecessaryThing() CXX11_OVERRIDE {}
virtual bool isSendingInProgress() CXX11_OVERRIDE { return false; }
virtual size_t countMessageInQueue() CXX11_OVERRIDE
{
return messageQueue.size();
}
virtual size_t countOutstandingRequest() CXX11_OVERRIDE { return 0; }
virtual bool isOutstandingRequest(size_t index,
size_t blockIndex) CXX11_OVERRIDE
{
return false;
}
virtual const RequestSlot*
getOutstandingRequest(size_t index, int32_t begin,
int32_t length) CXX11_OVERRIDE
{
return nullptr;
}
virtual void removeOutstandingRequest(const RequestSlot* slot) CXX11_OVERRIDE
{
}
virtual void
addOutstandingRequest(std::unique_ptr<RequestSlot> slot) CXX11_OVERRIDE
{
}
virtual size_t countOutstandingUpload() CXX11_OVERRIDE { return 0; }
};
} // namespace aria2
#endif // D_MOCK_BT_MESSAGE_DISPATCHER_H
|
