/dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/src/ableton/discovery/ |
H A D | tst_UdpMessenger.cpp | 62 const TestNodeState peerState = {5, 15}; variable 123 v1::aliveMessage(peerState.ident(), 0, makePayload(), begin(buffer)); 173 auto end = v1::aliveMessage(peerState.nodeId, 3, toPayload(peerState), begin(buffer)); 176 end = v1::byeByeMessage(peerState.nodeId, begin(buffer)); 182 CHECK(peerState.nodeId == handler.peerStates[0].peerState.nodeId); 183 CHECK(peerState.fooVal == handler.peerStates[0].peerState.fooVal); 185 CHECK(peerState.nodeId == handler.byeByes[0].peerId);
|
/dports/audio/carla/Carla-2.4.1/source/modules/hylia/link/ableton/link/ |
H A D | PeerState.hpp | 76 auto peerState = PeerState{NodeState::fromPayload(move(id), begin, end), {}}; in fromPayload() 79 [&peerState](MeasurementEndpointV4 me4) { peerState.endpoint = move(me4.ep); }); in fromPayload() 80 return peerState; in fromPayload()
|
H A D | Peers.hpp | 213 void sawPeerOnGateway(PeerState peerState, asio::ip::address gatewayAddr) in sawPeerOnGateway() 217 const auto peerSession = peerState.sessionId(); in sawPeerOnGateway() 218 const auto peerTimeline = peerState.timeline(); in sawPeerOnGateway() 219 const auto peerStartStopState = peerState.startStopState(); in sawPeerOnGateway() 228 auto peer = make_pair(move(peerState), move(gatewayAddr)); in sawPeerOnGateway() 332 [&](const PeerState& peerState) { return peerState.timeline() == timeline; }); in sessionTimelineExists() argument 338 return hasPeerWith(sessionId, [&](const PeerState& peerState) { in sessionStartStopStateExists() argument 339 return peerState.startStopState() == startStopState; in sessionStartStopStateExists()
|
/dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/include/ableton/link/ |
H A D | PeerState.hpp | 76 auto peerState = PeerState{NodeState::fromPayload(move(id), begin, end), {}}; in fromPayload() 79 [&peerState](MeasurementEndpointV4 me4) { peerState.endpoint = move(me4.ep); }); in fromPayload() 80 return peerState; in fromPayload()
|
H A D | Peers.hpp | 213 void sawPeerOnGateway(PeerState peerState, asio::ip::address gatewayAddr) in sawPeerOnGateway() 217 const auto peerSession = peerState.sessionId(); in sawPeerOnGateway() 218 const auto peerTimeline = peerState.timeline(); in sawPeerOnGateway() 219 const auto peerStartStopState = peerState.startStopState(); in sawPeerOnGateway() 228 auto peer = make_pair(move(peerState), move(gatewayAddr)); in sawPeerOnGateway() 332 [&](const PeerState& peerState) { return peerState.timeline() == timeline; }); in sessionTimelineExists() argument 338 return hasPeerWith(sessionId, [&](const PeerState& peerState) { in sessionStartStopStateExists() argument 339 return peerState.startStopState() == startStopState; in sessionStartStopStateExists()
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/libp2p/go-libp2p-pubsub/ |
H A D | topic_test.go | 478 if len(peerState) != numHosts-1 { 482 for _, e := range peerState { 500 if len(peerState) != numHosts-1 { 504 for _, e := range peerState { 719 if len(peerState) != 0 { 720 for p, s := range peerState { 728 peerState := make(map[peer.ID]EventType) 740 e, ok := peerState[event.Peer] 742 peerState[event.Peer] = event.Type 744 delete(peerState, event.Peer) [all …]
|
/dports/net-mgmt/librenms/librenms-21.5.1/LibreNMS/Snmptrap/Handlers/ |
H A D | JnxBgpM2Established.php | 45 $peerState = $trap->getOidData($trap->findOid('BGP4-V2-MIB-JUNIPER::jnxBgpM2PeerState')); 56 $bgpPeer->bgpPeerState = $peerState; 59 … Log::event("BGP Peer $peerAddr is now in the $peerState state", $device->device_id, 'trap', 1);
|
H A D | JnxBgpM2BackwardTransition.php | 49 $peerState = $trap->getOidData($trap->findOid('BGP4-V2-MIB-JUNIPER::jnxBgpM2PeerState')); 60 $bgpPeer->bgpPeerState = $peerState; 63 … Log::event("BGP Peer $peerAddr is now in the $peerState state", $device->device_id, 'trap', 5);
|
/dports/games/dunelegacy/dunelegacy-0.96.4/src/Network/ |
H A D | NetworkManager.cpp | 177 if(peerData->peerState == PeerData::PeerState::ReadyForOtherPeersToConnect) { in update() 182 peerData->peerState = PeerData::PeerState::WaitingForOtherPeersToConnect; in update() 195 peerData->peerState = PeerData::PeerState::Connected; in update() 223 switch(peerData->peerState) { in update() 286 peerData->peerState = PeerData::PeerState::WaitingForOtherPeersToConnect; in update() 338 if(peerData->peerState == PeerData::PeerState::WaitingForOtherPeersToConnect) { in update() 476 peerData->peerState = PeerData::PeerState::Connected; in handlePacket() 499 peerData->peerState = PeerData::PeerState::Connected; in handlePacket() 513 peerData->peerState = PeerData::PeerState::Connected; in handlePacket() 564 if(peerData->peerState == PeerData::PeerState::WaitingForName) { in handlePacket() [all …]
|
/dports/games/dunelegacy/dunelegacy-0.96.4/include/Network/ |
H A D | NetworkManager.h | 199 PeerData(ENetPeer* pPeer, PeerState peerState) in PeerData() argument 200 : pPeer(pPeer), peerState(peerState), timeout(0) { in PeerData() 206 PeerState peerState; variable
|
/dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ |
H A D | ReplicationPeerZKImpl.java | 50 private volatile PeerState peerState; field in ReplicationPeerZKImpl 107 this.peerState = in readPeerStateZnode() 135 return peerState; in getPeerState()
|
/dports/audio/carla/Carla-2.4.1/source/modules/hylia/link/ableton/discovery/ |
H A D | MessageTypes.hpp | 39 NodeState peerState; member
|
H A D | PeerGateway.hpp | 102 onPeerState(msg.peerState, msg.ttl); in operator ()()
|
/dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/include/ableton/discovery/ |
H A D | MessageTypes.hpp | 39 NodeState peerState; member
|
H A D | PeerGateway.hpp | 103 onPeerState(msg.peerState, msg.ttl);
|
/dports/games/stuntrally/stuntrally-2.6.1/source/network/ |
H A D | networkcallbacks.hpp | 52 virtual void peerState(PeerInfo peer, uint8_t state) {} in peerState() function
|
H A D | gameclient.cpp | 469 m_callback->peerState(picopy, e.packet_data[0]); in receiveEvent()
|
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/ |
H A D | server.go | 155 type peerState struct { struct 164 func (ps *peerState) Count() int { argument 171 func (ps *peerState) forAllOutboundPeers(closure func(sp *serverPeer)) { argument 182 func (ps *peerState) forAllPeers(closure func(sp *serverPeer)) { argument 1570 func (s *server) handleAddPeerMsg(state *peerState, sp *serverPeer) bool { 1677 func (s *server) handleDonePeerMsg(state *peerState, sp *serverPeer) { 1711 func (s *server) handleBanPeerMsg(state *peerState, sp *serverPeer) { 1725 func (s *server) handleRelayInvMsg(state *peerState, msg relayMsg) { 1791 func (s *server) handleBroadcastMsg(state *peerState, bmsg *broadcastMsg) { 1842 func (s *server) handleQuery(state *peerState, querymsg interface{}) { [all …]
|
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/ |
H A D | server.go | 155 type peerState struct { struct 164 func (ps *peerState) Count() int { argument 171 func (ps *peerState) forAllOutboundPeers(closure func(sp *serverPeer)) { argument 182 func (ps *peerState) forAllPeers(closure func(sp *serverPeer)) { argument 1570 func (s *server) handleAddPeerMsg(state *peerState, sp *serverPeer) bool { 1677 func (s *server) handleDonePeerMsg(state *peerState, sp *serverPeer) { 1711 func (s *server) handleBanPeerMsg(state *peerState, sp *serverPeer) { 1725 func (s *server) handleRelayInvMsg(state *peerState, msg relayMsg) { 1791 func (s *server) handleBroadcastMsg(state *peerState, bmsg *broadcastMsg) { 1842 func (s *server) handleQuery(state *peerState, querymsg interface{}) { [all …]
|
/dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/ |
H A D | server.go | 155 type peerState struct { struct 164 func (ps *peerState) Count() int { argument 171 func (ps *peerState) forAllOutboundPeers(closure func(sp *serverPeer)) { argument 182 func (ps *peerState) forAllPeers(closure func(sp *serverPeer)) { argument 1570 func (s *server) handleAddPeerMsg(state *peerState, sp *serverPeer) bool { 1677 func (s *server) handleDonePeerMsg(state *peerState, sp *serverPeer) { 1711 func (s *server) handleBanPeerMsg(state *peerState, sp *serverPeer) { 1725 func (s *server) handleRelayInvMsg(state *peerState, msg relayMsg) { 1791 func (s *server) handleBroadcastMsg(state *peerState, bmsg *broadcastMsg) { 1842 func (s *server) handleQuery(state *peerState, querymsg interface{}) { [all …]
|
/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/btcsuite/btcd/ |
H A D | server.go | 155 type peerState struct { struct 164 func (ps *peerState) Count() int { argument 171 func (ps *peerState) forAllOutboundPeers(closure func(sp *serverPeer)) { argument 182 func (ps *peerState) forAllPeers(closure func(sp *serverPeer)) { argument 1570 func (s *server) handleAddPeerMsg(state *peerState, sp *serverPeer) bool { 1677 func (s *server) handleDonePeerMsg(state *peerState, sp *serverPeer) { 1711 func (s *server) handleBanPeerMsg(state *peerState, sp *serverPeer) { 1725 func (s *server) handleRelayInvMsg(state *peerState, msg relayMsg) { 1791 func (s *server) handleBroadcastMsg(state *peerState, bmsg *broadcastMsg) { 1842 func (s *server) handleQuery(state *peerState, querymsg interface{}) { [all …]
|
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/btcsuite/btcd/ |
H A D | server.go | 155 type peerState struct { struct 164 func (ps *peerState) Count() int { argument 171 func (ps *peerState) forAllOutboundPeers(closure func(sp *serverPeer)) { argument 182 func (ps *peerState) forAllPeers(closure func(sp *serverPeer)) { argument 1570 func (s *server) handleAddPeerMsg(state *peerState, sp *serverPeer) bool { 1677 func (s *server) handleDonePeerMsg(state *peerState, sp *serverPeer) { 1711 func (s *server) handleBanPeerMsg(state *peerState, sp *serverPeer) { 1725 func (s *server) handleRelayInvMsg(state *peerState, msg relayMsg) { 1791 func (s *server) handleBroadcastMsg(state *peerState, bmsg *broadcastMsg) { 1842 func (s *server) handleQuery(state *peerState, querymsg interface{}) { [all …]
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/btcsuite/btcd/ |
H A D | server.go | 155 type peerState struct { struct 164 func (ps *peerState) Count() int { argument 171 func (ps *peerState) forAllOutboundPeers(closure func(sp *serverPeer)) { argument 182 func (ps *peerState) forAllPeers(closure func(sp *serverPeer)) { argument 1570 func (s *server) handleAddPeerMsg(state *peerState, sp *serverPeer) bool { 1677 func (s *server) handleDonePeerMsg(state *peerState, sp *serverPeer) { 1711 func (s *server) handleBanPeerMsg(state *peerState, sp *serverPeer) { 1725 func (s *server) handleRelayInvMsg(state *peerState, msg relayMsg) { 1791 func (s *server) handleBroadcastMsg(state *peerState, bmsg *broadcastMsg) { 1842 func (s *server) handleQuery(state *peerState, querymsg interface{}) { [all …]
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/libp2p/go-libp2p-kad-dht/ |
H A D | query.go | 224 peerState := make(map[peer.ID]qpeerset.PeerState) 228 peerState[p] = state 246 res.state[i] = peerState[p]
|
/dports/net/yate/yate-6.4.0-1/libs/ysig/ |
H A D | q931.cpp | 1330 u_int8_t peerState = (u_int8_t)lookup(s,s_states,255); in processMsgStatus() local 1332 if (peerState == 255) in processMsgStatus() 1336 if (peerState != Null) { in processMsgStatus() 1343 if (peerState == Null) in processMsgStatus() 1346 if (peerState == Restart || peerState == RestartReq) in processMsgStatus() 1368 if (peerState == OutgoingProceeding) { in processMsgStatus() 1378 if (peerState == OutgoingProceeding || peerState == CallDelivered) { in processMsgStatus() 1388 if (peerState == CallInitiated) { in processMsgStatus() 1397 if (outgoing() && peerState == ConnectReq) { in processMsgStatus() 1402 else if (peerState == Active) { in processMsgStatus()
|