| /dports/devel/spark/spark-2.1.1/graphx/src/main/scala/org/apache/spark/graphx/impl/ |
| H A D | ShippableVertexPartition.scala | 47 apply(iter, routingTable, defaultVal, (a, b) => a)
63 routingTable.iterator.foreach { vid =>
101 val routingTable: RoutingTablePartition) constant
116 Iterator.tabulate(routingTable.numEdgePartitions) { pid =>
121 routingTable.foreachWithinEdgePartition(pid, shipSrc, shipDst) { vid =>
138 Iterator.tabulate(routingTable.numEdgePartitions) { pid =>
139 val vids = new PrimitiveVector[VertexId](routingTable.partitionSize(pid))
141 routingTable.foreachWithinEdgePartition(pid, true, true) { vid =>
156 new ShippableVertexPartition(index, self.values, self.mask, self.routingTable)
160 new ShippableVertexPartition(self.index, values, self.mask, self.routingTable)
[all …]
|
| H A D | RoutingTablePartition.scala | 103 private val routingTable: Array[(Array[VertexId], BitSet, BitSet)]) extends Serializable {
105 val numEdgePartitions: Int = routingTable.length
108 def partitionSize(pid: PartitionID): Int = routingTable(pid)._1.length
111 def iterator: Iterator[VertexId] = routingTable.iterator.flatMap(_._1.iterator)
115 new RoutingTablePartition(routingTable.map {
127 val (vidsCandidate, srcVids, dstVids) = routingTable(pid)
|
| /dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/libp2p/go-libp2p-kad-dht/ |
| H A D | dht_bootstrap_test.go | 46 ps := d1.routingTable.ListPeers()
108 require.Len(t, d.routingTable.ListPeers(), 2)
135 require.Len(t, d.routingTable.ListPeers(), 2)
136 require.Contains(t, d.routingTable.ListPeers(), d3.self)
157 require.Len(t, d.routingTable.ListPeers(), 2)
162 for _, p := range d.routingTable.ListPeers() {
163 d.routingTable.RemovePeer(p)
165 require.Len(t, d.routingTable.ListPeers(), 0)
172 require.Len(t, d.routingTable.ListPeers(), 2)
181 require.Len(t, d.routingTable.ListPeers(), 2)
[all …]
|
| H A D | dht_options.go | 57 routingTable struct { member
121 o.routingTable.latencyTolerance = time.Minute
123 o.routingTable.refreshInterval = 10 * time.Minute
124 o.routingTable.autoRefresh = true
125 o.routingTable.peerFilter = emptyRTFilter
176 c.routingTable.latencyTolerance = latency
185 c.routingTable.refreshQueryTimeout = timeout
198 c.routingTable.refreshInterval = period
340 c.routingTable.autoRefresh = false
396 c.routingTable.peerFilter = filter
[all …]
|
| H A D | rt_diversity_filter_test.go | 92 return d.routingTable.Find(d2.self) != ""
97 require.Len(t, d.routingTable.ListPeers(), 1)
98 require.True(t, d.routingTable.Find(d3.self) == "")
101 d.routingTable.RemovePeer(d2.self)
102 b, err := d.routingTable.TryAddPeer(d3.self, true, false)
105 require.Len(t, d.routingTable.ListPeers(), 1)
106 require.True(t, d.routingTable.Find(d3.self) != "")
141 require.Len(t, d.routingTable.ListPeers(), 3)
142 require.True(t, d.routingTable.Find(d5.self) == "")
|
| H A D | dht.go | 317 dht.routingTable = rt
360 dht.host, dht.routingTable, cfg.routingTable.autoRefresh,
363 cfg.routingTable.refreshQueryTimeout,
364 cfg.routingTable.refreshInterval,
414 return dht.routingTable.GetDiversityStats()
472 if dht.routingTable.Size() == 0 {
505 if dht.routingTable.Size() == 0 {
523 ps := dht.routingTable.ListPeers()
634 prevSize := dht.routingTable.Size()
702 dht.routingTable.RemovePeer(p)
[all …]
|
| /dports/net-im/openfire/Openfire-4.7.1/xmppserver/src/main/java/org/jivesoftware/openfire/net/ |
| H A D | SocketPacketWriteHandler.java | 43 private RoutingTable routingTable; field in SocketPacketWriteHandler
45 public SocketPacketWriteHandler(RoutingTable routingTable) { in SocketPacketWriteHandler() argument
46 this.routingTable = routingTable; in SocketPacketWriteHandler()
56 routingTable.routePacket(recipient, packet, false); in process()
61 routingTable.routePacket(packet.getFrom(), packet, false); in process()
65 routingTable.routePacket(recipient, packet, false); in process()
69 for (JID route : routingTable.getRoutes(recipient, null)) { in process()
70 routingTable.routePacket(route, packet, false); in process()
|
| H A D | SocketAcceptingMode.java | 83 final RoutingTable routingTable = server.getRoutingTable(); in createServerSocketReader() local
89 …return new ServerSocketReader(router, routingTable, serverName, sock, conn, useBlockingMode, direc… in createServerSocketReader()
|
| /dports/www/aria2/aria2-1.36.0/src/ |
| H A D | DHTSetup.cc | 156 tracker->setRoutingTable(routingTable.get()); in setup()
162 receiver->setRoutingTable(routingTable.get()); in setup()
165 taskFactory->setRoutingTable(routingTable.get()); in setup()
171 routingTable->setTaskQueue(taskQueue.get()); in setup()
172 routingTable->setTaskFactory(taskFactory.get()); in setup()
177 factory->setRoutingTable(routingTable.get()); in setup()
230 command->setRoutingTable(routingTable.get()); in setup()
244 command->setRoutingTable(routingTable.get()); in setup()
250 routingTable->addNode(node); in setup()
261 DHTRegistry::getMutableData().routingTable = std::move(routingTable); in setup()
[all …]
|
| H A D | DHTAbstractTask.cc | 59 void DHTAbstractTask::setRoutingTable(DHTRoutingTable* routingTable) in setRoutingTable() argument
61 routingTable_ = routingTable; in setRoutingTable()
|
| H A D | DHTBucketRefreshCommand.cc | 69 void DHTBucketRefreshCommand::setRoutingTable(DHTRoutingTable* routingTable) in setRoutingTable() argument
71 routingTable_ = routingTable; in setRoutingTable()
|
| H A D | DHTAbstractMessage.cc | 96 void DHTAbstractMessage::setRoutingTable(DHTRoutingTable* routingTable) in setRoutingTable() argument
98 routingTable_ = routingTable; in setRoutingTable()
|
| /dports/net-im/openfire/Openfire-4.7.1/xmppserver/src/main/java/org/jivesoftware/openfire/ |
| H A D | SessionManager.java | 227 private RoutingTable routingTable; field in SessionManager
833 return routingTable.isAnonymousRoute(address); in isAnonymousRoute()
874 return routingTable.getClientRoute(from); in getSession()
884 return routingTable.getClientsRoutes(false); in getSessions()
993 return routingTable.getServerRoute(pair); in getOutgoingServerSession()
1046 int total = routingTable.getClientsRoutes(true).size(); in getUserSessionsCount()
1162 return routingTable.getServerHostnames(); in getOutgoingServers()
1165 return routingTable.getServerRoutes(); in getOutgoingDomainPairs()
1175 routingTable.broadcastPacket(packet, false); in broadcast()
1191 routingTable.routePacket(address, packet, true); in userBroadcast()
[all …]
|
| H A D | PresenceRouter.java | 48 private RoutingTable routingTable; field in PresenceRouter
130 routingTable.routePacket(recipientJID, packet, false); in handle()
148 !routingTable.hasComponentRoute(senderJID)) { in handle()
161 for (JID jid : routingTable.getRoutes(recipientJID, senderJID)) { in handle()
165 routingTable.routePacket(jid, packet, false); in handle()
180 routingTable.routePacket(recipientJID, packet, false); in handle()
190 routingTable.routePacket(recipientJID, packet, false); in handle()
208 routingTable = server.getRoutingTable(); in initialize()
|
| H A D | MessageRouter.java | 54 private RoutingTable routingTable; field in MessageRouter
134 routingTable.routePacket(recipientJID, packet, false); in route()
143 … List<JID> routes = routingTable.getRoutes(packet.getFrom().asBareJID(), null); in route()
232 routingTable = server.getRoutingTable(); in initialize()
252 for (JID address : routingTable.getRoutes(recipient.asBareJID(), packet.getFrom())) { in routingFailed()
253 ClientSession session = routingTable.getClientRoute(address); in routingFailed()
257 routingTable.routePacket( recipient.asBareJID(), packet, false ); in routingFailed()
|
| /dports/net/traefik/traefik-2.6.1/pkg/tcp/ |
| H A D | router.go | 22 routingTable map[string]Handler member
46 if r.catchAllNoTLS != nil && len(r.routingTable) == 0 {
83 if r.routingTable != nil && serverName != "" {
84 if target, ok := r.routingTable[serverName]; ok {
91 if target, ok := r.routingTable["*"]; ok {
105 if r.routingTable == nil {
106 r.routingTable = map[string]Handler{}
108 r.routingTable[strings.ToLower(sniHost)] = target
|
| /dports/net/jgroups/jgroups-2.12.0/src/org/jgroups/stack/ |
| H A D | GossipRouter.java | 321 routingTable.clear(); in clear()
338 if(routingTable.isEmpty()) { in dumpRoutingTable()
367 if(routingTable.isEmpty()) { in dumpRoutingTableDetailed()
505 map=routingTable.get(group); in removeEntry()
511 routingTable.remove(group); in removeEntry()
521 routingTable.remove(entry.getKey()); in removeEntry()
538 ConcurrentMap<Address,ConnectionHandler> map=routingTable.get(group); in findAddressEntry()
545 final ConcurrentMap<Address,ConnectionHandler> map=routingTable.get(group); in sendToAllMembersInGroup()
600 Map<Address, ConnectionHandler> map = routingTable.get(group); in connectionTorn()
801 map = routingTable.get(group); in handleConnect()
[all …]
|
| /dports/www/aria2/aria2-1.36.0/test/ |
| H A D | BtPortMessageTest.cc | 121 DHTRoutingTable routingTable(localNode); in testDoReceivedAction() local
123 routingTable.addNode(nodes[i]); in testDoReceivedAction()
131 msg.setRoutingTable(&routingTable); in testDoReceivedAction()
153 DHTRoutingTable routingTable(localNode); // no nodes , 1 bucket. in testDoReceivedAction_bootstrap() local
160 msg.setRoutingTable(&routingTable); in testDoReceivedAction_bootstrap()
|
| H A D | DHTGetPeersMessageTest.cc | 109 DHTRoutingTable routingTable(localNode_); in testDoReceivedAction() local
131 msg.setRoutingTable(&routingTable); in testDoReceivedAction()
181 DHTRoutingTable routingTable(localNode_); in testDoReceivedAction() local
183 routingTable.addNode(returnNode1); in testDoReceivedAction()
186 msg.setRoutingTable(&routingTable); in testDoReceivedAction()
|
| H A D | DHTFindNodeMessageTest.cc | 92 DHTRoutingTable routingTable(localNode_); in testDoReceivedAction() local
93 routingTable.addNode(targetNode); in testDoReceivedAction()
99 msg.setRoutingTable(&routingTable); in testDoReceivedAction()
|
| /dports/net-im/openfire/Openfire-4.7.1/xmppserver/src/main/java/org/jivesoftware/util/cache/ |
| H A D | ConsistencyMonitor.java | 116 …final RoutingTableImpl routingTable = (RoutingTableImpl) XMPPServer.getInstance().getRoutingTable(… in run() local
122 …final Collection<String> serverRoutesFailures = routingTable.clusteringStateConsistencyReportForSe… in run()
127 …final Collection<String> componentRoutesFailures = routingTable.clusteringStateConsistencyReportFo… in run()
132 …final Collection<String> clientRoutesFailures = routingTable.clusteringStateConsistencyReportForCl… in run()
139 …final Collection<String> usersSessionsFailures = routingTable.clusteringStateConsistencyReportForU… in run()
|
| /dports/net-im/openfire/Openfire-4.7.1/xmppserver/src/main/java/org/jivesoftware/openfire/component/ |
| H A D | InternalComponentManager.java | 108 private RoutingTable routingTable; field in InternalComponentManager
122 routingTable = server.getRoutingTable(); in initialize()
181 if (!routingTable.hasComponentRoute(componentJID)) { in addComponent()
292 routingTable.removeComponentRoute(componentJID); in removeComponent()
297 if (!routingTable.hasComponentRoute(componentJID)) { in removeComponent()
384 for (String domain : routingTable.getComponentsDomains()) { in addListener()
488 return routingTable.hasComponentRoute(componentJID); in hasComponent()
506 if (routingTable.hasComponentRoute(probee)) { in checkPresences()
510 routingTable.routePacket(probee, presence, false); in checkPresences()
797 routingTable.getComponentsDomains().stream() in restoreCacheContent()
[all …]
|
| /dports/net/cjdns/cjdns-cjdns-v21.1/contrib/php/ |
| H A D | sendGraph | 100 if (!empty($res['routingTable']))
101 foreach ($res['routingTable'] as $a)
|
| /dports/devel/spark/spark-2.1.1/graphx/src/main/scala/org/apache/spark/graphx/ |
| H A D | VertexRDD.scala | 324 val routingTable = constant
326 Iterator(ShippableVertexPartition(vertexIter, routingTable, defaultVal, mergeFunc))
346 val routingTable = constant
348 Iterator(ShippableVertexPartition(Iterator.empty, routingTable, defaultVal))
|
| /dports/net-im/openfire/Openfire-4.7.1/xmppserver/src/main/java/org/jivesoftware/openfire/handler/ |
| H A D | PresenceUpdateHandler.java | 140 private RoutingTable routingTable; field in PresenceUpdateHandler
413 if (routingTable.hasClientRoute(handlerJID)) { in directedPresenceSent()
560 if (!routingTable.hasClientRoute(directedPresence.getHandler()) && in removedExpiredPresences()
561 !routingTable.hasComponentRoute(directedPresence.getHandler())) { in removedExpiredPresences()
592 routingTable = server.getRoutingTable(); in initialize()
740 final RoutingTable routingTable = XMPPServer.getInstance().getRoutingTable(); in entryAdded() local
743 .filter(dp -> routingTable.isLocalRoute(dp.getHandler())) in entryAdded()
764 final RoutingTable routingTable = XMPPServer.getInstance().getRoutingTable(); in entryUpdated() local
768 .filter(dp -> routingTable.isLocalRoute(dp.getHandler())) in entryUpdated()
|