| /dports/misc/gedkeeper/GEDKeeper-2.19.1/projects/GKCommunicator/GKNetCore.Tests/DHT/ |
| H A D | DHTMessageTests.cs | 17 var msg = new DHTMessage(MessageType.Query, QueryType.Ping, null); in Test_ctor()
26 var msg = DHTMessage.ParseBuffer(buffer); in Test_ParseBuffer_Empty()
30 msg = DHTMessage.ParseBuffer(buffer); in Test_ParseBuffer_Empty()
170 DHTMessage msg = DHTMessage.CreatePingQuery(tid, nodeId); in Test_CreatePingQuery()
182 DHTMessage msg = DHTMessage.CreatePingResponse(tid, nodeId); in Test_CreatePingResponse()
194 DHTMessage msg = DHTMessage.CreateFindNodeQuery(tid, nodeId); in Test_CreateFindNodeQuery()
206 DHTMessage msg = DHTMessage.CreateFindNodeResponse(tid, nodeId, new List<DHTNode>()); in Test_CreateFindNodeResponse()
219 …DHTMessage msg = DHTMessage.CreateAnnouncePeerQuery(tid, nodeId, infoHash, 1, 1, new BString("XX")… in Test_CreateAnnouncePeerQuery()
231 … DHTMessage msg = DHTMessage.CreateAnnouncePeerResponse(tid, nodeId, new List<DHTNode>()); in Test_CreateAnnouncePeerResponse()
244 DHTMessage msg = DHTMessage.CreateGetPeersQuery(tid, nodeId, infoHash); in Test_CreateGetPeersQuery()
[all …]
|
| /dports/misc/gedkeeper/GEDKeeper-2.19.1/projects/GKCommunicator/GKNetCore/DHT/Messages/ |
| H A D | DHTMessage.cs | 38 public class DHTMessage class
70 protected DHTMessage(BDictionary data) in DHTMessage() method in GKNet.DHT.DHTMessage
75 public DHTMessage(MessageType type, QueryType queryType, BDictionary data) in DHTMessage() method in GKNet.DHT.DHTMessage
93 public static DHTMessage ParseBuffer(string bencodedString) in ParseBuffer()
99 public static DHTMessage ParseBuffer(byte[] buffer) in ParseBuffer()
108 MessageType msgType = DHTMessage.GetMessageType(strMsgType); in ParseBuffer()
110 DHTMessage result; in ParseBuffer()
125 result = new DHTMessage(msgType, QueryType.None, data); in ParseBuffer()
186 return new DHTMessage(MessageType.Query, QueryType.Ping, sendData); in CreatePingQuery()
225 public static DHTMessage CreateFindNodeResponse(BString transactionID, in CreateFindNodeResponse()
[all …]
|
| /dports/www/aria2/aria2-1.36.0/src/ |
| H A D | DHTMessage.cc | 41 const std::string DHTMessage::Y("y");
43 const std::string DHTMessage::T("t");
45 const std::string DHTMessage::V("v");
47 const std::string DHTMessage::ID("id");
49 DHTMessage::DHTMessage(const std::shared_ptr<DHTNode>& localNode, in DHTMessage() function in aria2::DHTMessage
61 DHTMessage::~DHTMessage() = default;
63 void DHTMessage::generateTransactionID() in generateTransactionID()
|
| H A D | DHTMessageEntry.h | 46 class DHTMessage; variable
50 std::unique_ptr<DHTMessage> message;
54 DHTMessageEntry(std::unique_ptr<DHTMessage> message,
|
| H A D | DHTMessageDispatcher.h | 47 class DHTMessage; variable
53 virtual void addMessageToQueue(std::unique_ptr<DHTMessage> message,
58 virtual void addMessageToQueue(std::unique_ptr<DHTMessage> message,
|
| H A D | DHTMessageReceiver.h | 46 class DHTMessage; variable
63 void onMessageReceived(DHTMessage* message);
68 std::unique_ptr<DHTMessage> receiveMessage(const std::string& remoteAddr,
|
| H A D | DHTMessageTracker.h | 49 class DHTMessage; variable
67 void addMessage(DHTMessage* message, std::chrono::seconds timeout,
81 const DHTMessageTrackerEntry* getEntryFor(const DHTMessage* message) const;
|
| H A D | DHTMessage.h | 49 class DHTMessage {
62 DHTMessage(const std::shared_ptr<DHTNode>& localNode,
66 virtual ~DHTMessage();
|
| H A D | DHTMessageReceiver.cc | 64 std::unique_ptr<DHTMessage>
74 const String* y = downcast<String>(dict->get(DHTMessage::Y)); in receiveMessage()
121 void DHTMessageReceiver::onMessageReceived(DHTMessage* message) in onMessageReceived()
|
| H A D | DHTMessageFactoryImpl.cc | 189 void setVersion(DHTMessage* msg, const Dict* dict) in setVersion()
191 const String* v = downcast<String>(dict->get(DHTMessage::V)); in setVersion()
205 const String* transactionID = getString(dict, DHTMessage::T); in createQueryMessage()
206 const String* y = getString(dict, DHTMessage::Y); in createQueryMessage()
211 const String* id = getString(aDict, DHTMessage::ID); in createQueryMessage()
255 const String* transactionID = getString(dict, DHTMessage::T); in createResponseMessage()
256 const String* y = getString(dict, DHTMessage::Y); in createResponseMessage()
275 const String* id = getString(rDict, DHTMessage::ID); in createResponseMessage()
|
| H A D | DHTMessageDispatcherImpl.h | 60 addMessageToQueue(std::unique_ptr<DHTMessage> message,
66 addMessageToQueue(std::unique_ptr<DHTMessage> message,
|
| H A D | DHTMessageTracker.cc | 59 void DHTMessageTracker::addMessage(DHTMessage* message, in addMessage()
73 const String* tid = downcast<String>(dict->get(DHTMessage::T)); in messageArrived()
160 DHTMessageTracker::getEntryFor(const DHTMessage* message) const in getEntryFor()
|
| H A D | DHTMessageDispatcherImpl.cc | 57 std::unique_ptr<DHTMessage> message, std::chrono::seconds timeout, in addMessageToQueue()
65 std::unique_ptr<DHTMessage> message, in addMessageToQueue()
|
| /dports/net/cjdns/cjdns-cjdns-v21.1/dht/ |
| H A D | ReplyModule.c | 35 static int handleIncoming(struct DHTMessage* message, void* vcontext);
36 static int handleOutgoing(struct DHTMessage* message, void* vcontext);
58 static int handleIncoming(struct DHTMessage* message, void* vcontext) in handleIncoming()
73 struct DHTMessage* reply = Allocator_clone(message->allocator, (&(struct DHTMessage) { in handleIncoming()
85 static int handleOutgoing(struct DHTMessage* message, void* vcontext) in handleOutgoing()
|
| H A D | DHTModuleRegistry.c | 49 void DHTModuleRegistry_handleIncoming(struct DHTMessage* message, in DHTModuleRegistry_handleIncoming()
75 static int dhtModuleHandleOutgoing(struct DHTModule* module, struct DHTMessage* message) in dhtModuleHandleOutgoing()
92 static void forEachModule(int (*doThis)(struct DHTModule* module, struct DHTMessage* message), in forEachModule()
93 struct DHTMessage* message, in forEachModule()
107 void DHTModuleRegistry_handleOutgoing(struct DHTMessage* message, in DHTModuleRegistry_handleOutgoing()
|
| H A D | DHTMessage.h | 37 struct DHTMessage;
38 struct DHTMessage struct
56 struct DHTMessage* replyTo; argument
|
| H A D | SerializationModule.c | 37 static int handleOutgoing(struct DHTMessage* message,
39 static int handleIncoming(struct DHTMessage* message,
70 static int handleOutgoing(struct DHTMessage* message, in handleOutgoing()
99 static int handleIncoming(struct DHTMessage* message, in handleIncoming()
|
| H A D | DHTModule.h | 49 int (* handleIncoming)(struct DHTMessage* message, void* context);
57 int (* handleOutgoing)(struct DHTMessage* message, void* context);
|
| H A D | DHTModuleRegistry.h | 81 void DHTModuleRegistry_handleIncoming(struct DHTMessage* message,
87 void DHTModuleRegistry_handleOutgoing(struct DHTMessage* message,
|
| H A D | EncodingSchemeModule.c | 54 static int handleIncoming(struct DHTMessage* message, void* vcontext) in handleIncoming()
105 static int handleOutgoing(struct DHTMessage* dmesg, void* vcontext) in handleOutgoing()
|
| /dports/misc/gedkeeper/GEDKeeper-2.19.1/projects/GKCommunicator/GKNetCore/DHT/ |
| H A D | DHTClient.cs | 66 private readonly Dictionary<int, DHTMessage> fTransactions;
106 fTransactions = new Dictionary<int, DHTMessage>(); in DHTClient()
245 DHTMessage msg = DHTMessage.ParseBuffer(data); in OnRecvMessage()
433 Send(ipinfo, DHTMessage.CreateAnnouncePeerResponse(t, fLocalID, nodesList)); in OnRecvAnnouncePeerQuery()
447 Send(ipinfo, DHTMessage.CreatePingResponse(t, fLocalID)); in OnRecvPingQuery()
463 Send(ipinfo, DHTMessage.CreateFindNodeResponse(t, fLocalID, nodesList)); in OnRecvFindNodeQuery()
520 public void SetTransaction(BString transactionId, DHTMessage message) in SetTransaction()
531 DHTMessage message; in CheckTransaction()
552 var msg = DHTMessage.CreatePingQuery(transactionID, fLocalID); in SendPingQuery()
562 var msg = DHTMessage.CreateFindNodeQuery(transactionID, nid); in SendFindNodeQuery()
[all …]
|
| /dports/www/aria2/aria2-1.36.0/test/ |
| H A D | MockDHTMessageDispatcher.h | 14 std::unique_ptr<DHTMessage> message_;
18 Entry(std::unique_ptr<DHTMessage> message, std::chrono::seconds timeout, in Entry()
33 addMessageToQueue(std::unique_ptr<DHTMessage> message,
43 addMessageToQueue(std::unique_ptr<DHTMessage> message,
|
| /dports/net/cjdns/cjdns-cjdns-v21.1/dht/test/ |
| H A D | DHTModules_handleOutgoing_test.c | 25 struct DHTMessage* theMessage;
29 static int handleOutgoing(struct DHTMessage* message, void* vcontext) in handleOutgoing()
42 struct DHTMessage theMessage; in testOutputHandler()
|
| H A D | DHTModules_handleIncoming_test.c | 24 struct DHTMessage* theMessage;
28 static int handleIncoming(struct DHTMessage* message, void* vcontext) in handleIncoming()
41 struct DHTMessage theMessage; in testInputHandler()
|
| /dports/net/cjdns/cjdns-cjdns-v21.1/dht/dhtcore/ |
| H A D | RouterModule.c | 189 static int handleIncoming(struct DHTMessage* message, void* vcontext);
190 static int handleOutgoing(struct DHTMessage* message, void* vcontext);
253 struct DHTMessage* message, in sendNodes()
257 struct DHTMessage* query = message->replyTo; in sendNodes()
311 static inline int handleQuery(struct DHTMessage* message, in handleQuery()
314 struct DHTMessage* query = message->replyTo; in handleQuery()
380 static int handleOutgoing(struct DHTMessage* message, void* vcontext) in handleOutgoing()
425 struct DHTMessage* dmesg = Allocator_calloc(temp, sizeof(struct DHTMessage), 1); in sendMsg()
459 static int handleIncoming(struct DHTMessage* message, void* vcontext) in handleIncoming()
490 struct DHTMessage* message = module->currentMessage; in onResponseOrTimeout()
|