/dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/SourceFiles/storage/ |
H A D | storage_shared_media.h | 43 : peerId(peerId), messageId(messageId), types(types) { in SharedMediaAddNew() 54 PeerId peerId, in SharedMediaAddExisting() 58 : peerId(peerId) in SharedMediaAddExisting() 73 PeerId peerId, 78 : peerId(peerId) in peerId() function 98 : peerId(peerId) in SharedMediaRemoveOne() 113 : peerId(peerId) in peerId() function 123 SharedMediaInvalidateBottom(PeerId peerId) : peerId(peerId) { in SharedMediaInvalidateBottom() 135 : peerId(peerId) in SharedMediaKey() 141 return (peerId == other.peerId) [all …]
|
H A D | storage_shared_media.cpp | 37 auto peer = query.peerId; in add() 48 auto peerIt = enforceLists(query.peerId); in add() 60 auto peerIt = enforceLists(query.peerId); in add() 69 auto peerIt = _lists.find(query.peerId); in remove() 82 auto peerIt = _lists.find(query.peerId); in remove() 95 auto peerIt = _lists.find(query.peerId); in invalidate() 107 auto peerIt = _lists.find(query.key.peerId); in query() 124 auto peerIt = _lists.find(query.key.peerId); in snapshot() 138 auto peerIt = _lists.find(key.peerId); in empty()
|
/dports/databases/hbase/hbase-1.2.1/hbase-client/src/main/java/org/apache/hadoop/hbase/replication/ |
H A D | ReplicationPeers.java | 55 void addPeer(String peerId, ReplicationPeerConfig peerConfig, String tableCFs) in addPeer() argument 62 void removePeer(String peerId) throws ReplicationException; in removePeer() argument 64 boolean peerAdded(String peerId) throws ReplicationException; in peerAdded() argument 66 void peerRemoved(String peerId); in peerRemoved() argument 72 void enablePeer(String peerId) throws ReplicationException; in enablePeer() argument 78 void disablePeer(String peerId) throws ReplicationException; in disablePeer() argument 84 public String getPeerTableCFsConfig(String peerId) throws ReplicationException; in getPeerTableCFsConfig() argument 98 public Map<TableName, List<String>> getTableCFs(String peerId); in getTableCFs() argument 105 ReplicationPeer getPeer(String peerId); in getPeer() argument 121 boolean getStatusOfPeer(String peerId); in getStatusOfPeer() argument [all …]
|
H A D | ReplicationPeersZKImpl.java | 267 public ReplicationPeer getPeer(String peerId) { in getPeer() argument 268 return peerClusters.get(peerId); in getPeer() 288 "was interrupted. peerId=" + peerId); in getReplicationPeerConfig() 293 + peerId, e); in getReplicationPeerConfig() 370 return createAndAddPeer(peerId); in peerAdded() 374 public void peerRemoved(String peerId) { in peerRemoved() argument 375 ReplicationPeer rp = this.peerClusters.get(peerId); in peerRemoved() 390 if (this.peerClusters.containsKey(peerId)) { in createAndAddPeer() 396 peer = createPeer(peerId); in createAndAddPeer() 467 peerId, e); in createPeer() [all …]
|
/dports/games/cdogs-sdl/cdogs-sdl-1.0.1/src/cdogs/ |
H A D | net_server.c | 268 int peerId = -1; in OnReceive() local 293 CASSERT(peerId >= 0, "peer id unset"); in OnReceive() 313 NetServerSendGameStartMessages(n, peerId); in OnReceive() 360 const int peerId = n->peerId; in OnConnect() local 362 n->peerId++; in OnConnect() 367 cid.Id = peerId; in OnConnect() 383 int peerId = -1; in OnDisconnect() local 428 SendConfig(&gConfig, "Game.FPS", n, peerId); in NetServerSendGameStartMessages() 429 SendConfig(&gConfig, "Game.Fog", n, peerId); in NetServerSendGameStartMessages() 618 if (peerId >= 0) in NetServerSendMsg() [all …]
|
/dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/SourceFiles/main/ |
H A D | main_session_settings.h | 68 void setGroupStickersSectionHidden(PeerId peerId) { in setGroupStickersSectionHidden() argument 69 _groupStickersSectionHidden.insert(peerId); in setGroupStickersSectionHidden() 71 [[nodiscard]] bool isGroupStickersSectionHidden(PeerId peerId) const { in isGroupStickersSectionHidden() argument 72 return _groupStickersSectionHidden.contains(peerId); in isGroupStickersSectionHidden() 74 void removeGroupStickersSectionHidden(PeerId peerId) { in removeGroupStickersSectionHidden() argument 75 _groupStickersSectionHidden.remove(peerId); in removeGroupStickersSectionHidden() 104 [[nodiscard]] MsgId hiddenPinnedMessageId(PeerId peerId) const { in hiddenPinnedMessageId() argument 105 const auto i = _hiddenPinnedMessages.find(peerId); in hiddenPinnedMessageId() 108 void setHiddenPinnedMessageId(PeerId peerId, MsgId msgId) { in setHiddenPinnedMessageId() argument 110 _hiddenPinnedMessages[peerId] = msgId; in setHiddenPinnedMessageId() [all …]
|
/dports/net-im/qTox/qTox-1.17.4/src/core/ |
H A D | toxcall.cpp | 245 removePeer(peerId); in onAudioSinkInvalidated() 246 addPeer(peerId); in onAudioSinkInvalidated() 249 void ToxGroupCall::removePeer(ToxPk peerId) in removePeer() argument 251 const auto& source = peers.find(peerId); in removePeer() 258 QObject::disconnect(sinkInvalid[peerId]); in removePeer() 259 sinkInvalid.erase(peerId); in removePeer() 262 void ToxGroupCall::addPeer(ToxPk peerId) in addPeer() argument 269 …con = newSink->connectTo_invalidated(this, [this, peerId]() { this->onAudioSinkInvalidated(peerId)… in addPeer() 273 sinkInvalid.insert({peerId, con}); in addPeer() 276 bool ToxGroupCall::havePeer(ToxPk peerId) in havePeer() argument [all …]
|
/dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/SourceFiles/data/ |
H A D | data_sparse_ids.h | 32 PeerId peerId, 36 : peerId(peerId) in peerId() function 43 return (peerId == other.peerId) 51 PeerId peerId = 0; member 77 PeerId peerId, 103 return peerIsChannel(peerId) in IsFromSlice() 104 ? (peerId == peerFromChannel(fullId.channel)) in IsFromSlice() 107 static FullMsgId ComputeId(PeerId peerId, MsgId msgId) { in ComputeId() argument 108 return FullMsgId(peerToChannel(peerId), msgId); in ComputeId() 112 ? ComputeId(key.peerId, key.universalId) in ComputeId() [all …]
|
H A D | data_shared_media.h | 77 PeerId peerId, 82 : peerId(peerId) in peerId() function 91 return (peerId == other.peerId) 100 PeerId peerId = 0; member 129 key.peerId, in ViewerKey() 138 key.peerId, in EndingKey() 153 PeerId peerId); 166 static Value ComputeId(PeerId peerId, MsgId msgId) { in ComputeId() argument 167 return FullMsgId(peerToChannel(peerId), msgId); in ComputeId() 172 ? ComputeId(key.peerId, *messageId) in ComputeId()
|
H A D | data_search_controller.cpp | 195 : peerData(session->data().peer(query.peerId)) in CacheEntry() 231 PeerId peerId, in idsSlice() 236 peerId, in idsSlice() 244 query.peerId, in idsSlice() 253 PeerId peerId, in simpleIdsSlice() argument 258 Expects(peerId != 0); in simpleIdsSlice() 262 Expects((query.peerId == peerId) in simpleIdsSlice() 263 || (query.migratedPeerId == peerId)); in simpleIdsSlice() 270 auto listData = (peerId == query.peerId) in simpleIdsSlice() 303 return (history->peer->id == peerId); in simpleIdsSlice() [all …]
|
H A D | data_file_origin.h | 33 explicit FileOriginPeerPhoto(PeerId peerId) : peerId(peerId) { in FileOriginPeerPhoto() 36 PeerId peerId = 0; member 39 return peerId < other.peerId;
|
/dports/net/freerdp/freerdp-2.5.0/server/Mac/ |
H A D | mf_info.c | 130 int peerId; in mf_info_peer_register() local 147 peerId = 0; in mf_info_peer_register() 154 peerId = i; in mf_info_peer_register() 159 mfi->peers[peerId] = ((rdpContext*)context)->peer; in mf_info_peer_register() 160 mfi->peers[peerId]->pId = peerId; in mf_info_peer_register() 171 int peerId; in mf_info_peer_unregister() local 173 peerId = ((rdpContext*)context)->peer->pId; in mf_info_peer_unregister() 174 mfi->peers[peerId] = NULL; in mf_info_peer_unregister()
|
/dports/www/aria2/aria2-1.36.0/test/ |
H A D | BtHandshakeMessageTest.cc | 48 unsigned char peerId[] = {0xf0, 0xf0, 0xf0, 0xf0, 0xf0, 0xf0, 0xf0, in createHandshakeMessageData() local 51 memcpy(&msg[48], peerId, sizeof(peerId)); in createHandshakeMessageData() 79 constexpr unsigned char peerId[] = {0xf0, 0xf0, 0xf0, 0xf0, 0xf0, 0xf0, 0xf0, in testCreateMessage() local 85 msg->setPeerId(peerId); in testCreateMessage() 100 unsigned char peerId[] = {0xf0, 0xf0, 0xf0, 0xf0, 0xf0, 0xf0, 0xf0, in testToString() local 106 msg.setPeerId(peerId); in testToString()
|
/dports/net-p2p/go-ethereum/go-ethereum-1.10.14/vendor/github.com/status-im/keycard-go/vendor/github.com/ethereum/go-ethereum/swarm/network/stream/ |
H A D | stream.go | 229 peer := r.getPeer(peerId) 231 return fmt.Errorf("peer not found %v", peerId) 257 peer := r.getPeer(peerId) 259 return fmt.Errorf("peer not found %v", peerId) 292 peer := r.getPeer(peerId) 294 return fmt.Errorf("peer not found %v", peerId) 300 log.Debug("Unsubscribe ", "peer", peerId, "stream", s) 311 peer := r.getPeer(peerId) 321 log.Debug("Quit ", "peer", peerId, "stream", s) 342 return r.peers[peerId] [all …]
|
/dports/graphics/nomacs/nomacs-3.16.224/ImageLounge/src/DkGui/ |
H A D | DkNetwork.h | 57 quint16 peerId, 78 quint16 peerId; variable 103 bool removePeer(quint16 peerId); 104 bool setSynchronized(quint16 peerId, bool synchronized); 105 bool setTitle(quint16 peerId, const QString& title); 106 bool setShowInMenu(quint16 peerId, bool showInMenu); 154 virtual void synchronizeWith(quint16 peerId) = 0; 156 virtual void stopSynchronizeWith(quint16 peerId) = 0; 167 …virtual void connectionReadyForUse(quint16 peerId, const QString& title, DkConnection* connection); 207 void stopSynchronizeWith(quint16 peerId); [all …]
|
H A D | DkNetwork.cpp | 330 synchronizeWith(peer->peerId); in synchronizeWithServerPort() 534 quint16 peerId, in DkPeer() argument 544 this->peerId = peerId; in DkPeer() 590 if (peerList.contains(peer->peerId)) in addPeer() 593 peerList.insert(peer->peerId, peer); in addPeer() 599 if (!peerList.contains(peerId)) in removePeer() 602 peerList.remove(peerId); in removePeer() 609 if (!peerList.contains(peerId)) in setSynchronized() 611 DkPeer* peer = peerList.value(peerId); in setSynchronized() 619 if (!peerList.contains(peerId)) in setTitle() [all …]
|
/dports/net/freerdp/freerdp-2.5.0/server/Windows/ |
H A D | wf_info.c | 199 int peerId; in wf_info_peer_register() local 237 peerId = i; in wf_info_peer_register() 242 wfi->peers[peerId] = ((rdpContext*)context)->peer; in wf_info_peer_register() 243 wfi->peers[peerId]->pId = peerId; in wf_info_peer_register() 245 WLog_INFO(TAG, "Registering Peer: id=%d #=%d", peerId, wfi->peerCount); in wf_info_peer_register() 247 wfreerdp_server_peer_callback_event(peerId, FREERDP_SERVER_WIN_SRV_CALLBACK_EVENT_CONNECT); in wf_info_peer_register() 263 int peerId; in wf_info_peer_unregister() local 264 peerId = ((rdpContext*)context)->peer->pId; in wf_info_peer_unregister() 265 wfi->peers[peerId] = NULL; in wf_info_peer_unregister() 268 WLog_INFO(TAG, "Unregistering Peer: id=%d, #=%d", peerId, wfi->peerCount); in wf_info_peer_unregister() [all …]
|
/dports/audio/carla/Carla-2.4.1/source/modules/hylia/link/ableton/discovery/ |
H A D | PeerGateway.hpp | 108 onByeBye(msg.peerId); in operator ()() 115 const auto peerId = nodeState.ident(); in onPeerState() local 116 const auto existing = findPeer(peerId); in onPeerState() 124 auto newTo = make_pair(mPruneTimer.now() + std::chrono::seconds(ttl), peerId); in onPeerState() 133 void onByeBye(const NodeId& peerId) in onByeBye() 135 const auto it = findPeer(peerId); in onByeBye() 191 typename PeerTimeouts::iterator findPeer(const NodeId& peerId) in findPeer() 194 [&peerId](const PeerTimeout& pto) { return pto.second == peerId; }); in findPeer()
|
/dports/audio/supercollider/SuperCollider-3.11.0-Source/external_libraries/link/include/ableton/discovery/ |
H A D | PeerGateway.hpp | 109 onByeBye(msg.peerId); 116 const auto peerId = nodeState.ident(); 117 const auto existing = findPeer(peerId); 125 auto newTo = make_pair(mPruneTimer.now() + std::chrono::seconds(ttl), peerId); 134 void onByeBye(const NodeId& peerId) 136 const auto it = findPeer(peerId); 192 typename PeerTimeouts::iterator findPeer(const NodeId& peerId) 195 [&peerId](const PeerTimeout& pto) { return pto.second == peerId; });
|
/dports/devel/gwenhywfar-gtk2/gwenhywfar-5.6.0/src/crypttoken/ |
H A D | ct_context.c | 61 p_struct->peerId=NULL; in GWEN_LIST_FUNCTIONS() 98 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_free() 258 if (p_struct->peerId) { in GWEN_Crypt_Token_Context_dup() 260 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_dup() 261 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_dup() 263 if (p_src->peerId) { in GWEN_Crypt_Token_Context_dup() 264 p_struct->peerId=strdup(p_src->peerId); in GWEN_Crypt_Token_Context_dup() 440 if (p_struct->peerId) { in GWEN_Crypt_Token_Context_copy() 445 if (p_src->peerId) { in GWEN_Crypt_Token_Context_copy() 446 p_struct->peerId=strdup(p_src->peerId); in GWEN_Crypt_Token_Context_copy() [all …]
|
/dports/devel/gwenhywfar-gtk3/gwenhywfar-5.6.0/src/crypttoken/ |
H A D | ct_context.c | 61 p_struct->peerId=NULL; in GWEN_LIST_FUNCTIONS() 98 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_free() 258 if (p_struct->peerId) { in GWEN_Crypt_Token_Context_dup() 260 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_dup() 261 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_dup() 263 if (p_src->peerId) { in GWEN_Crypt_Token_Context_dup() 264 p_struct->peerId=strdup(p_src->peerId); in GWEN_Crypt_Token_Context_dup() 440 if (p_struct->peerId) { in GWEN_Crypt_Token_Context_copy() 445 if (p_src->peerId) { in GWEN_Crypt_Token_Context_copy() 446 p_struct->peerId=strdup(p_src->peerId); in GWEN_Crypt_Token_Context_copy() [all …]
|
/dports/devel/gwenhywfar-fox16/gwenhywfar-5.6.0/src/crypttoken/ |
H A D | ct_context.c | 61 p_struct->peerId=NULL; in GWEN_LIST_FUNCTIONS() 98 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_free() 258 if (p_struct->peerId) { in GWEN_Crypt_Token_Context_dup() 260 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_dup() 261 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_dup() 263 if (p_src->peerId) { in GWEN_Crypt_Token_Context_dup() 264 p_struct->peerId=strdup(p_src->peerId); in GWEN_Crypt_Token_Context_dup() 440 if (p_struct->peerId) { in GWEN_Crypt_Token_Context_copy() 445 if (p_src->peerId) { in GWEN_Crypt_Token_Context_copy() 446 p_struct->peerId=strdup(p_src->peerId); in GWEN_Crypt_Token_Context_copy() [all …]
|
/dports/devel/gwenhywfar-qt5/gwenhywfar-5.6.0/src/crypttoken/ |
H A D | ct_context.c | 61 p_struct->peerId=NULL; in GWEN_LIST_FUNCTIONS() 98 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_free() 258 if (p_struct->peerId) { in GWEN_Crypt_Token_Context_dup() 260 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_dup() 261 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_dup() 263 if (p_src->peerId) { in GWEN_Crypt_Token_Context_dup() 264 p_struct->peerId=strdup(p_src->peerId); in GWEN_Crypt_Token_Context_dup() 440 if (p_struct->peerId) { in GWEN_Crypt_Token_Context_copy() 445 if (p_src->peerId) { in GWEN_Crypt_Token_Context_copy() 446 p_struct->peerId=strdup(p_src->peerId); in GWEN_Crypt_Token_Context_copy() [all …]
|
/dports/devel/gwenhywfar/gwenhywfar-5.6.0/src/crypttoken/ |
H A D | ct_context.c | 61 p_struct->peerId=NULL; in GWEN_LIST_FUNCTIONS() 98 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_free() 258 if (p_struct->peerId) { in GWEN_Crypt_Token_Context_dup() 260 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_dup() 261 p_struct->peerId=NULL; in GWEN_Crypt_Token_Context_dup() 263 if (p_src->peerId) { in GWEN_Crypt_Token_Context_dup() 264 p_struct->peerId=strdup(p_src->peerId); in GWEN_Crypt_Token_Context_dup() 440 if (p_struct->peerId) { in GWEN_Crypt_Token_Context_copy() 445 if (p_src->peerId) { in GWEN_Crypt_Token_Context_copy() 446 p_struct->peerId=strdup(p_src->peerId); in GWEN_Crypt_Token_Context_copy() [all …]
|
/dports/irc/quassel/quassel-0.14-rc2/src/qtui/ |
H A D | coreinfodlg.cpp | 116 int peerId = peerMap["id"].toInt(); in coreInfoChanged() local 118 ids.removeAll(peerId); in coreInfoChanged() 121 CoreSessionWidget* coreSessionWidget = _widgets[peerId]; in coreInfoChanged() 128 _widgets[peerId] = coreSessionWidget; in coreInfoChanged() 184 void CoreInfoDlg::disconnectClicked(int peerId) in disconnectClicked() argument 186 Client::kickClient(peerId); in disconnectClicked()
|