Home
last modified time | relevance | path

Searched refs:peerState (Results 1 – 25 of 31) sorted by relevance

12

/dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/src/ableton/discovery/
H A Dtst_UdpMessenger.cpp62 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 DPeerState.hpp76 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 DPeers.hpp213 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 DPeerState.hpp76 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 DPeers.hpp213 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 Dtopic_test.go478 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 DJnxBgpM2Established.php45 $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 DJnxBgpM2BackwardTransition.php49 $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 DNetworkManager.cpp177 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 DNetworkManager.h199 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 DReplicationPeerZKImpl.java50 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 DMessageTypes.hpp39 NodeState peerState; member
H A DPeerGateway.hpp102 onPeerState(msg.peerState, msg.ttl); in operator ()()
/dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/include/ableton/discovery/
H A DMessageTypes.hpp39 NodeState peerState; member
H A DPeerGateway.hpp103 onPeerState(msg.peerState, msg.ttl);
/dports/games/stuntrally/stuntrally-2.6.1/source/network/
H A Dnetworkcallbacks.hpp52 virtual void peerState(PeerInfo peer, uint8_t state) {} in peerState() function
H A Dgameclient.cpp469 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 Dserver.go155 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 Dserver.go155 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 Dserver.go155 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 Dserver.go155 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 Dserver.go155 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 Dserver.go155 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 Dquery.go224 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 Dq931.cpp1330 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()

12