Home
last modified time | relevance | path

Searched refs:remoteNode (Results 1 – 25 of 83) sorted by relevance

1234

/dports/www/aria2/aria2-1.36.0/test/
H A DMockDHTMessageFactory.h37 auto remoteNode = std::make_shared<DHTNode>(); in createResponseMessage() local
39 remoteNode->setIPAddress(ipaddr); in createResponseMessage()
40 remoteNode->setPort(port); in createResponseMessage()
42 localNode_, remoteNode, downcast<String>(dict->get("t"))->s()); in createResponseMessage()
46 createPingMessage(const std::shared_ptr<DHTNode>& remoteNode,
53 createPingReplyMessage(const std::shared_ptr<DHTNode>& remoteNode, in createPingReplyMessage() argument
61 createFindNodeMessage(const std::shared_ptr<DHTNode>& remoteNode,
69 const std::shared_ptr<DHTNode>& remoteNode, in createFindNodeReplyMessage() argument
77 createGetPeersMessage(const std::shared_ptr<DHTNode>& remoteNode, in createGetPeersMessage() argument
85 const std::shared_ptr<DHTNode>& remoteNode, in createGetPeersReplyMessage() argument
[all …]
H A DMockDHTMessage.h31 const std::shared_ptr<DHTNode>& remoteNode,
34 : DHTMessage(localNode, remoteNode, transactionID), in DHTMessage() argument
73 const std::shared_ptr<DHTNode>& remoteNode,
76 : DHTQueryMessage(localNode, remoteNode, transactionID), in DHTQueryMessage() argument
117 const std::shared_ptr<DHTNode>& remoteNode,
120 : DHTResponseMessage(localNode, remoteNode, transactionID), in DHTResponseMessage() argument
H A DDHTFindNodeReplyMessageTest.cc36 std::shared_ptr<DHTNode> remoteNode(new DHTNode()); in testGetBencodedMessage() local
42 DHTFindNodeReplyMessage msg(AF_INET, localNode, remoteNode, transactionID); in testGetBencodedMessage()
79 std::shared_ptr<DHTNode> remoteNode(new DHTNode()); in testGetBencodedMessage6() local
85 DHTFindNodeReplyMessage msg(AF_INET6, localNode, remoteNode, transactionID); in testGetBencodedMessage6()
H A DMockDHTTask.h21 MockDHTTask(const std::shared_ptr<DHTNode>& remoteNode) in MockDHTTask() argument
22 : remoteNode_(remoteNode), finished_(false) in MockDHTTask()
H A DDHTGetPeersReplyMessageTest.cc37 std::shared_ptr<DHTNode> remoteNode(new DHTNode()); in testGetBencodedMessage() local
45 DHTGetPeersReplyMessage msg(AF_INET, localNode, remoteNode, token, in testGetBencodedMessage()
100 std::shared_ptr<DHTNode> remoteNode(new DHTNode()); in testGetBencodedMessage6() local
108 DHTGetPeersReplyMessage msg(AF_INET6, localNode, remoteNode, token, in testGetBencodedMessage6()
H A DDHTAnnouncePeerReplyMessageTest.cc31 std::shared_ptr<DHTNode> remoteNode(new DHTNode()); in testGetBencodedMessage() local
37 DHTAnnouncePeerReplyMessage msg(localNode, remoteNode, transactionID); in testGetBencodedMessage()
/dports/www/aria2/aria2-1.36.0/src/
H A DDHTMessageFactoryImpl.cc213 auto remoteNode = getRemoteNode(id->uc(), ipaddr, port); in createQueryMessage() local
216 msg = createPingMessage(remoteNode, transactionID->s()); in createQueryMessage()
222 msg = createFindNodeMessage(remoteNode, targetNodeID->uc(), in createQueryMessage()
237 msg = createAnnouncePeerMessage(remoteNode, infoHash->uc(), in createQueryMessage()
277 auto remoteNode = getRemoteNode(id->uc(), ipaddr, port); in createResponseMessage() local
323 const std::shared_ptr<DHTNode>& remoteNode, in createPingMessage() argument
344 const std::shared_ptr<DHTNode>& remoteNode, in createFindNodeMessage() argument
355 const std::shared_ptr<DHTNode>& remoteNode, in createFindNodeReplyMessage() argument
389 const std::shared_ptr<DHTNode>& remoteNode, const Dict* dict, in createFindNodeReplyMessage() argument
456 const std::shared_ptr<DHTNode>& remoteNode, in createGetPeersReplyMessage() argument
[all …]
H A DDHTMessageFactoryImpl.h97 const std::shared_ptr<DHTNode>& remoteNode,
101 createPingReplyMessage(const std::shared_ptr<DHTNode>& remoteNode,
106 const std::shared_ptr<DHTNode>& remoteNode,
111 createFindNodeReplyMessage(const std::shared_ptr<DHTNode>& remoteNode,
116 const std::shared_ptr<DHTNode>& remoteNode,
121 const std::shared_ptr<DHTNode>& remoteNode, const unsigned char* infoHash,
125 const std::shared_ptr<DHTNode>& remoteNode,
131 createGetPeersReplyMessage(const std::shared_ptr<DHTNode>& remoteNode,
136 const std::shared_ptr<DHTNode>& remoteNode, const unsigned char* infoHash,
141 createAnnouncePeerReplyMessage(const std::shared_ptr<DHTNode>& remoteNode,
H A DDHTMessageFactory.h77 createPingMessage(const std::shared_ptr<DHTNode>& remoteNode,
81 createPingReplyMessage(const std::shared_ptr<DHTNode>& remoteNode,
86 createFindNodeMessage(const std::shared_ptr<DHTNode>& remoteNode,
91 const std::shared_ptr<DHTNode>& remoteNode,
96 createGetPeersMessage(const std::shared_ptr<DHTNode>& remoteNode,
101 const std::shared_ptr<DHTNode>& remoteNode,
107 createAnnouncePeerMessage(const std::shared_ptr<DHTNode>& remoteNode,
113 createAnnouncePeerReplyMessage(const std::shared_ptr<DHTNode>& remoteNode,
H A DDHTPeerLookupTask.cc77 std::shared_ptr<DHTNode> remoteNode = message->getRemoteNode(); in onReceivedInternal() local
78 tokenStorage_[util::toHex(remoteNode->getID(), DHT_ID_LENGTH)] = in onReceivedInternal()
86 DHTPeerLookupTask::createMessage(const std::shared_ptr<DHTNode>& remoteNode) in createMessage() argument
88 return getMessageFactory()->createGetPeersMessage(remoteNode, getTargetID()); in createMessage()
H A DDHTNodeLookupTaskCallback.cc75 const std::shared_ptr<DHTNode>& remoteNode) in onTimeout() argument
77 task_->onTimeout(remoteNode); in onTimeout()
H A DDHTPeerLookupTaskCallback.cc72 const std::shared_ptr<DHTNode>& remoteNode) in onTimeout() argument
74 task_->onTimeout(remoteNode); in onTimeout()
H A DDHTNodeLookupTask.cc62 DHTNodeLookupTask::createMessage(const std::shared_ptr<DHTNode>& remoteNode) in createMessage() argument
64 return getMessageFactory()->createFindNodeMessage(remoteNode, getTargetID()); in createMessage()
H A DDHTMessage.cc50 const std::shared_ptr<DHTNode>& remoteNode, in DHTMessage() argument
53 remoteNode_{remoteNode},
H A DDHTPingTask.cc47 DHTPingTask::DHTPingTask(const std::shared_ptr<DHTNode>& remoteNode, in DHTPingTask() argument
49 : remoteNode_(remoteNode), in DHTPingTask()
H A DDHTPingMessage.cc48 const std::shared_ptr<DHTNode>& remoteNode, in DHTPingMessage() argument
50 : DHTQueryMessage(localNode, remoteNode, transactionID) in DHTPingMessage()
H A DDHTAnnouncePeerReplyMessage.cc45 const std::shared_ptr<DHTNode>& remoteNode, in DHTAnnouncePeerReplyMessage() argument
47 : DHTResponseMessage(localNode, remoteNode, transactionID) in DHTAnnouncePeerReplyMessage()
H A DDHTPingReplyMessage.cc48 const std::shared_ptr<DHTNode>& remoteNode, const unsigned char* id, in DHTPingReplyMessage() argument
50 : DHTResponseMessage(localNode, remoteNode, transactionID) in DHTPingReplyMessage()
H A DDHTPingReplyMessageCallback.h75 onTimeout(const std::shared_ptr<DHTNode>& remoteNode) CXX11_OVERRIDE in onTimeout() argument
77 task_->onTimeout(remoteNode); in onTimeout()
H A DDHTResponseMessage.cc46 const std::shared_ptr<DHTNode>& remoteNode, in DHTResponseMessage() argument
48 : DHTAbstractMessage(localNode, remoteNode, transactionID) in DHTResponseMessage()
H A DDHTQueryMessage.cc47 const std::shared_ptr<DHTNode>& remoteNode, in DHTQueryMessage() argument
49 : DHTAbstractMessage(localNode, remoteNode, transactionID) in DHTQueryMessage()
/dports/sysutils/kio-fuse/kio-fuse-5.0.1/
H A Dkiofusevfs.cpp1198 fflush(remoteNode->m_localCache); in read()
1312 remoteNode->m_cacheSize = std::max(remoteNode->m_cacheSize, off_t(offset + size)); in write()
1314 remoteNode->m_stat.st_size = std::max(remoteNode->m_stat.st_size, remoteNode->m_cacheSize); in write()
1318 remoteNode->m_stat.st_ctim = remoteNode->m_stat.st_mtim; in write()
1319 that->markCacheDirty(remoteNode); in write()
1377 … remoteNode->m_stat.st_size = std::max(off_t(offset + data.size()), remoteNode->m_stat.st_size); in write()
2061 if(!remoteNode) in awaitChildrenComplete()
2067 if(!remoteNode->m_childrenRequested) in awaitChildrenComplete()
2139 emit remoteNode->gotChildren(0); in awaitChildrenComplete()
2272 if(!remoteNode || !remoteNode->hasStatTimedOut()) in awaitAttrRefreshed()
[all …]
/dports/comms/echolinux/echolinux-0.17a/echolinux/
H A Dcontrol.c47 char *remoteNode = NULL; variable
109 remoteNode = host; in makeConnection()
110 hp = gethostbyname(remoteNode); in makeConnection()
113 remoteNode = inet_ntoa(*(struct in_addr *)hp->h_addr_list[0]); in makeConnection()
134 execlp("echoaudio", "echoaudio", remoteNode, callsign, NULL); in makeConnection()
/dports/devel/py-py_interface/py_interface-2.3/py_interface/
H A Derl_node.py159 def SendRPC(self, remoteNode, mod, fun, args, cb): argument
189 rexMBox.SendRPC(remoteNode, mod, fun, args, cb)
225 def SendRPC(self, remoteNode, mod, fun, args, cb): argument
260 if type(remoteNode) == bytes or type(remoteNode) == str:
261 remoteNodeName = remoteNode
262 elif erl_term.IsErlAtom(remoteNode):
263 remoteNodeName = remoteNode.atomText
276 self.Send(("rex", remoteNode),
/dports/net/ns3/ns-allinone-3.35/ns-3.35/src/mpi/model/
H A Dnull-message-simulator-impl.cc174 Ptr<Node> remoteNode; in CalculateLookAhead() local
177 remoteNode = (channel->GetDevice (1))->GetNode (); in CalculateLookAhead()
181 remoteNode = (channel->GetDevice (0))->GetNode (); in CalculateLookAhead()
185 if (remoteNode->GetSystemId () == MpiInterface::GetSystemId ()) in CalculateLookAhead()
193 …ChannelBundle> remoteChannelBundle = RemoteChannelBundleManager::Find (remoteNode->GetSystemId ()); in CalculateLookAhead()
196 … remoteChannelBundle = RemoteChannelBundleManager::Add (remoteNode->GetSystemId ()); in CalculateLookAhead()

1234