blob: e5810ec638a090472108ba351d41bc0d627b4a51 (
plain) (
blame)
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
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
/**
* Superclass for all storage commands.
*
* A storage command is a storage message you will get a storage reply for.
*/
#pragma once
#include "storagemessage.h"
namespace storage::api {
class StorageReply;
class StorageCommand : public StorageMessage {
duration _timeout; /** Timeout of command in milliseconds */
/** Sets what node this message origins from. 0xFFFF is unset. */
uint16_t _sourceIndex;
protected:
StorageCommand(const StorageCommand& other);
explicit StorageCommand(const MessageType& type) noexcept : StorageCommand(type, NORMAL) { }
explicit StorageCommand(const MessageType& type, Priority p) noexcept;
public:
DECLARE_POINTER_TYPEDEFS(StorageCommand);
~StorageCommand() override;
bool sourceIndexSet() const { return (_sourceIndex != 0xffff); }
void setSourceIndex(uint16_t sourceIndex) { _sourceIndex = sourceIndex; }
uint16_t getSourceIndex() const { return _sourceIndex; }
void setTimeout(duration timeout) { _timeout = timeout; }
duration getTimeout() const { return _timeout; }
/** Overload this to get more descriptive message output. */
void print(std::ostream& out, bool verbose, const std::string& indent) const override;
/**
* A way for someone to make a reply to a storage message without
* knowing the type of the message. Should just call reply constructor
* taking command as input.
*/
virtual std::unique_ptr<StorageReply> makeReply() = 0;
};
}
|
