source: source/ariba/overlay/messages/DHTMessage.h@ 6851

Last change on this file since 6851 was 6835, checked in by mies, 15 years ago

added replace flag

File size: 1.9 KB
Line 
1#ifndef DHTMESSAGE_H_
2#define DHTMESSAGE_H_
3
4#include "ariba/utility/messages.h"
5#include "ariba/utility/serialization.h"
6
7namespace ariba {
8namespace overlay {
9
10using ariba::utility::Message;
11using_serialization;
12
13class DHTMessage : public Message { VSERIALIZEABLE
14public:
15 DHTMessage();
16 DHTMessage( const Data& key );
17 DHTMessage( const Data& key, const Data& value );
18 DHTMessage( const Data& key, const vector<Data>& values );
19 virtual ~DHTMessage();
20
21 const NodeID& getHashedKey() const {
22 return hash;
23 }
24
25 const Data& getKey() const {
26 return key;
27 }
28
29 /// returns the first element of the key vector
30 const Data& getValue() const {
31 return values.at(0);
32 }
33
34 bool hasValues() const {
35 values.size() != 0;
36 }
37
38 uint16_t getTTL() const {
39 return ttl;
40 }
41
42 void setTTL( uint16_t ttl ) {
43 this->ttl = ttl;
44 }
45
46 void setReplace( bool replace ) {
47 this->replace = replace;
48 }
49
50 bool doReplace() const {
51 return replace;
52 }
53
54 /// return alles values for the key
55 const vector<Data>& getValues() const {
56 return values;
57 }
58
59private:
60 NodeID hash;
61 uint16_t ttl;
62 bool replace;
63 Data key;
64 vector<Data> values;
65};
66
67}} // namespace ariba::overlay
68
69sznBeginDefault( ariba::overlay::DHTMessage, X ) {
70
71 // serialize flags
72 X && replace && cI(0,7);
73
74 // serialize tll
75 X && ttl;
76
77 // key serialization
78 uint16_t key_length = key.isUnspecified() ? 0 : key.getLength();
79 X && key_length;
80 if (X.isDeserializer()) key.setLength( key_length );
81 X && this->key;
82
83 // store number of values
84 uint16_t num_values = values.size();
85 X && num_values;
86
87 // value serialization
88 for (size_t i=0; i<num_values; i++) {
89 Data value;
90 if (X.isSerializer()) value = values[i];
91 uint16_t value_length = value.isUnspecified() ? 0 : value.getLength();
92 X && value_length;
93 if (X.isDeserializer()) value.setLength( value_length );
94 X && value;
95 if (X.isDeserializer()) values.push_back(value);
96 }
97} sznEnd();
98
99#endif /* DHTMESSAGE_H_ */
Note: See TracBrowser for help on using the repository browser.