Home
last modified time | relevance | path

Searched refs:peerId (Results 1 – 25 of 355) sorted by relevance

12345678910>>...15

/dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/SourceFiles/storage/
H A Dstorage_shared_media.h43 : 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 Dstorage_shared_media.cpp37 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 DReplicationPeers.java55 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 DReplicationPeersZKImpl.java267 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 Dnet_server.c268 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 Dmain_session_settings.h68 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 Dtoxcall.cpp245 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 Ddata_sparse_ids.h32 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 Ddata_shared_media.h77 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 Ddata_search_controller.cpp195 : 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 Ddata_file_origin.h33 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 Dmf_info.c130 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 DBtHandshakeMessageTest.cc48 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 Dstream.go229 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 DDkNetwork.h57 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 DDkNetwork.cpp330 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 Dwf_info.c199 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 DPeerGateway.hpp108 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 DPeerGateway.hpp109 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 Dct_context.c61 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 Dct_context.c61 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 Dct_context.c61 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 Dct_context.c61 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 Dct_context.c61 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 Dcoreinfodlg.cpp116 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()

12345678910>>...15