| /dports/net-p2p/p5-Net-BitTorrent/Net-BitTorrent-0.052/t/700_classes/Net/BitTorrent/ |
| H A D | Peer.t | 143 is($_peer->host . q[:] . $_peer->port,
145 is($_peer->am_choking, 1,
153 is($_peer->incoming, 1,
159 is($_peer->peerid, undef,
193 is($_peer->host . q[:] . $_peer->port,
203 is($_peer->incoming, 1,
330 is($_peer->_host . q[:] . $_peer->_port,
358 isa_ok($_peer->_socket,
462 is($_peer->host . q[:] . $_peer->port,
512 is($_peer->host . q[:] . $_peer->port,
[all …]
|
| /dports/irc/quassel-core/quassel-0.14-rc2/src/core/ |
| H A D | coreauthhandler.cpp | 31 , _peer(nullptr) in CoreAuthHandler()
50 if (_peer) in onReadyRead()
157 _peer = peer; in setPeer()
159 _peer->setProxyLine(_proxyLine); in setPeer()
173 _peer->close(); in onProtocolVersionMismatch()
181 _peer->dispatch( in checkClientRegistered()
183 _peer->close(); in checkClientRegistered()
200 _peer->close(); in handle()
205 _peer->setBuildDate(msg.buildDate); in handle()
286 _peer->dispatch(Protocol::LoginSuccess()); in handle()
[all …]
|
| /dports/irc/quassel/quassel-0.14-rc2/src/core/ |
| H A D | coreauthhandler.cpp | 31 , _peer(nullptr) in CoreAuthHandler()
50 if (_peer) in onReadyRead()
157 _peer = peer; in setPeer()
159 _peer->setProxyLine(_proxyLine); in setPeer()
173 _peer->close(); in onProtocolVersionMismatch()
181 _peer->dispatch( in checkClientRegistered()
183 _peer->close(); in checkClientRegistered()
200 _peer->close(); in handle()
205 _peer->setBuildDate(msg.buildDate); in handle()
286 _peer->dispatch(Protocol::LoginSuccess()); in handle()
[all …]
|
| /dports/security/py-asyncssh/asyncssh-2.8.1/asyncssh/ |
| H A D | forward.py | 32 self._peer = peer
43 self._peer = peer
96 if self._peer:
97 self._peer.write(data)
106 if self._peer:
107 self._peer.write_eof()
116 self._peer.pause_reading()
130 if self._peer:
131 peer = self._peer
132 self._peer = None
[all …]
|
| /dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/SourceFiles/boxes/peers/ |
| H A D | add_participants_box.cpp | 74 , _peer(peer) in AddParticipantsBoxController()
86 _peer, in subscribeToMigration()
94 auto limit = _peer && (_peer->isChat() || _peer->isMegagroup()) in rowClicked()
125 if (!_peer) { in alreadyInCount()
138 if (!_peer) { in isAlreadyIn()
183 if (!_peer) { in needsInviteLinkButton()
319 , _peer(peer) in AddSpecialBoxController()
633 _peer, in showAdmin()
741 _peer, in showRestricted()
860 _peer, in kickUser()
[all …]
|
| H A D | edit_peer_info_box.cpp | 373 , _isGroup(_peer->isChat() || _peer->isMegagroup()) { in Controller()
389 _peer, in subscribeToMigration()
457 _peer, in createPhotoEdit()
617 _peer, in showEditPeerTypeBox()
826 _peer, in fillHistoryVisibilityButton()
956 _peer in fillManageSection()
969 _peer in fillManageSection()
1018 _peer in fillManageSection()
1036 _peer in fillManageSection()
1101 _peer in fillPendingRequestsButton()
[all …]
|
| H A D | edit_peer_type_box.cpp | 130 not_null<PeerData*> _peer; member in __anon7b83fe860111::Controller
157 : _peer(peer) in Controller()
163 , _isGroup(_peer->isChat() || _peer->isMegagroup()) in Controller()
167 _peer->updateFull();
191 Box(ManageInviteLinksBox, _peer, _peer->session().user(), 0, 0), in createContent()
476 &_peer->session(), in askUsernameRevoke()
557 _peer, in createInviteLinkBlock()
565 ((_peer->isMegagroup() || _peer->asChat()) in createInviteLinkBlock()
582 : _peer(peer) in EditPeerTypeBox()
601 _peer->updateFull(); in prepare()
[all …]
|
| H A D | edit_participants_box.cpp | 314 : _peer(peer) in ParticipantsAdditionalData()
721 : _peer(peer) in ParticipantsOnlineSorter()
799 , _peer(peer) in ParticipantsBoxController()
958 _peer, in addNewItem()
1136 _peer, in prepare()
1372 ? ((_peer->isChat() || _peer->isMegagroup()) in refreshDescription()
1433 && (_peer->isChat() || _peer->isMegagroup()) in rowClicked()
1507 return _peer->isMegagroup() && !_peer->isGigagroup(); in rowContextMenu()
1532 _peer, in showAdmin()
1611 _peer, in showRestricted()
[all …]
|
| /dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/SourceFiles/calls/ |
| H A D | calls_userpic.cpp | 32 , _peer(peer) { in Userpic()
70 _peer->session().changes().peerFlagsValue( in setup()
71 _peer, in setup()
77 _peer->session().downloaderTaskFinished( in setup()
130 _userpic = _peer->createUserpicView(); in processPhoto()
131 _peer->loadUserpic(); in processPhoto()
132 const auto photo = _peer->userpicPhotoId() in processPhoto()
133 ? _peer->owner().photo(_peer->userpicPhotoId()).get() in processPhoto()
141 _peer->session().api().requestFullPeer(_peer); in processPhoto()
194 Data::PeerUserpicColor(_peer->id), in createCache()
[all …]
|
| /dports/net/gsocket/gsocket-1.4.28/tools/ |
| H A D | pkt_mgr.c | 16 struct _peer *p = (struct _peer *)ptr; in pkt_app_cb_wsize()
43 struct _peer *p = (struct _peer *)ptr; in pkt_app_cb_ping()
54 struct _peer *p = (struct _peer *)ptr; in pkt_app_cb_pong()
91 struct _peer *p = (struct _peer *)ptr; in pkt_app_cb_ids()
111 struct _peer *p = (struct _peer *)ptr; in pkt_app_cb_pwdrequest()
147 pkt_app_send_pong(GS_SELECT_CTX *ctx, struct _peer *p) in pkt_app_send_pong()
174 pkt_app_send_ping(GS_SELECT_CTX *ctx, struct _peer *p) in pkt_app_send_ping()
193 pkt_app_send_ids(GS_SELECT_CTX *ctx, struct _peer *p) in pkt_app_send_ids()
218 pkt_app_send_pwdreply(GS_SELECT_CTX *ctx, struct _peer *p) in pkt_app_send_pwdreply()
241 pkt_app_send_ft(GS_SELECT_CTX *ctx, struct _peer *p) in pkt_app_send_ft()
[all …]
|
| H A D | filetransfer_mgr.c | 23 struct _peer *peer = (struct _peer *)arg; in pkt_cb_put()
41 struct _peer *peer = (struct _peer *)arg; in pkt_cb_dl()
61 struct _peer *peer = (struct _peer *)arg; in pkt_cb_listrequest()
80 struct _peer *peer = (struct _peer *)arg; in pkt_cb_listreply()
96 struct _peer *peer = (struct _peer *)arg; in pkt_cb_switch()
112 struct _peer *peer = (struct _peer *)arg; in pkt_cb_data()
126 struct _peer *peer = (struct _peer *)arg; in pkt_cb_accept()
144 struct _peer *peer = (struct _peer *)arg; in pkt_cb_error()
175 struct _peer *p = (struct _peer *)arg; in cb_stats()
302 GS_FTM_init(struct _peer *p, int is_server) in GS_FTM_init()
[all …]
|
| H A D | console.h | 21 int CONSOLE_action(struct _peer *p, uint8_t key);
22 int CONSOLE_command(struct _peer *p, const char *cmd);
24 void CONSOLE_resize(struct _peer *p);
25 int CONSOLE_readline(struct _peer *p, void *data, size_t len);
28 void CONSOLE_update_pinginfo(struct _peer *p, float ms, int load, char *active_user, int sec_idle, …
29 void CONSOLE_update_bps(struct _peer *p);
|
| H A D | pkt_mgr.h | 66 int pkt_app_send_wsize(GS_SELECT_CTX *ctx, struct _peer *p, int row);
67 int pkt_app_send_pong(GS_SELECT_CTX *ctx, struct _peer *p);
68 int pkt_app_send_ping(GS_SELECT_CTX *ctx, struct _peer *p);
69 int pkt_app_send_ids(GS_SELECT_CTX *ctx, struct _peer *p);
70 int pkt_app_send_all_log(GS_SELECT_CTX *ctx, struct _peer *p);
71 int pkt_app_send_ft(GS_SELECT_CTX *ctx, struct _peer *p);
72 int pkt_app_send_pwdrequest(GS_SELECT_CTX *ctx, struct _peer *p);
73 int pkt_app_send_pwdreply(GS_SELECT_CTX *ctx, struct _peer *p);
|
| /dports/irc/smuxi/smuxi-1.1/lib/db4o-net/Db4objects.Db4o/Db4objects.Db4o/Internal/Freespace/ |
| H A D | FreeSlotNode.cs | 14 internal Db4objects.Db4o.Internal.Freespace.FreeSlotNode _peer; field in Db4objects.Db4o.Internal.Freespace.FreeSlotNode
24 frslot._peer = _peer; in ShallowClone()
30 _peer = new Db4objects.Db4o.Internal.Freespace.FreeSlotNode(a_key); in CreatePeer()
31 _peer._peer = this; in CreatePeer()
109 StatefulBuffer checker = trans.Container().CreateStatefulBuffer(trans, node._peer in DebugCheckBuffer()
116 Sharpen.Runtime.Out.WriteLine("!!! Free space corruption at:" + node._peer._key); in DebugCheckBuffer()
126 a_writer.WriteInt(_peer._key); in Write()
142 if (_peer != null) in ToString()
144 str += " peer: " + _peer._key; in ToString()
|
| H A D | InMemoryFreespaceManager.cs | 33 AddToFreeBySize(addressNode._peer); in AddFreeSlotNodes()
57 return new Slot(sizeNode._peer._key, sizeNode._key); in AllocateTransactionLogSlot()
104 sizeNode = addressnode._peer; in Free()
111 sizeNode._key += secondAddressNode._peer._key; in Free()
112 RemoveFromBothTrees(secondAddressNode._peer); in Free()
122 sizeNode = addressnode._peer; in Free()
162 int address = node._peer._key; in AllocateSlot()
163 _freeByAddress = _freeByAddress.RemoveNode(node._peer); in AllocateSlot()
206 FreeSlotNode node = ((FreeSlotNode)a_object)._peer; in Visit()
231 _freeByAddress = _freeByAddress.RemoveNode(sizeNode._peer); in RemoveFromBothTrees()
[all …]
|
| /dports/devel/godot-tools/godot-3.2.3-stable/modules/websocket/ |
| H A D | wsl_client.cpp | 93 _peer->set_no_delay(true); in _do_handshake()
223 if (_peer->is_connected_to_host()) { in poll()
224 _peer->poll(); in poll()
284 return _peer; in get_peer()
289 if (_peer->is_connected_to_host()) in get_connection_status()
300 _peer->close(p_code, p_reason); in disconnect_from_host()
319 return _peer->get_connected_host(); in get_connected_host()
325 return _peer->get_connected_port(); in get_connected_port()
344 _peer.instance(); in WSLClient()
351 _peer->close_now(); in ~WSLClient()
[all …]
|
| /dports/devel/godot/godot-3.2.3-stable/modules/websocket/ |
| H A D | wsl_client.cpp | 93 _peer->set_no_delay(true); in _do_handshake()
223 if (_peer->is_connected_to_host()) { in poll()
224 _peer->poll(); in poll()
284 return _peer; in get_peer()
289 if (_peer->is_connected_to_host()) in get_connection_status()
300 _peer->close(p_code, p_reason); in disconnect_from_host()
319 return _peer->get_connected_host(); in get_connected_host()
325 return _peer->get_connected_port(); in get_connected_port()
344 _peer.instance(); in WSLClient()
351 _peer->close_now(); in ~WSLClient()
[all …]
|
| /dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/SourceFiles/ui/ |
| H A D | special_buttons.cpp | 126 , _peer(peer) in UserpicButton()
163 , _peer(peer) in UserpicButton()
178 , _peer(peer) in UserpicButton()
240 Expects(_peer != nullptr); in openPeerPhoto()
260 _peer, in setupPeerViewers()
435 Expects(_peer != nullptr); in processPeerPhoto()
440 _peer->loadUserpic(); in processPeerPhoto()
461 Expects(_peer != nullptr); in createStreamingObjects()
660 return _showSavedMessagesOnSelf && _peer && _peer->isSelf(); in showSavedMessages()
664 return _showSavedMessagesOnSelf && _peer && _peer->isRepliesChat(); in showRepliesMessages()
[all …]
|
| /dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/SourceFiles/info/profile/ |
| H A D | info_profile_cover.cpp | 247 , _peer(peer) in Cover()
251 _peer, in Cover()
257 _peer->isMegagroup() in Cover()
261 _peer->updateFull();
266 if (!_peer->isMegagroup()) {
276 _peer, in __anon3f1f07c30702()
317 _peer, in initViewers()
322 if (!_peer->isUser()) { in initViewers()
324 _peer, in initViewers()
333 _peer in initViewers()
[all …]
|
| /dports/net/libzmq4/zeromq-4.3.4/src/ |
| H A D | pipe.cpp | 120 _peer (NULL), in pipe_t()
138 zmq_assert (!_peer); in set_peer()
139 _peer = peer_; in set_peer()
283 send_activate_read (_peer); in flush()
355 send_pipe_term_ack (_peer); in process_pipe_term()
364 send_pipe_term_ack (_peer); in process_pipe_term()
380 send_pipe_term_ack (_peer); in process_pipe_term_ack()
431 send_pipe_term (_peer); in terminate()
440 send_pipe_term_ack (_peer); in terminate()
450 send_pipe_term (_peer); in terminate()
[all …]
|
| /dports/net/py-pyzmq/pyzmq-22.3.0/bundled/zeromq/src/ |
| H A D | pipe.cpp | 120 _peer (NULL), in pipe_t()
138 zmq_assert (!_peer); in set_peer()
139 _peer = peer_; in set_peer()
283 send_activate_read (_peer); in flush()
355 send_pipe_term_ack (_peer); in process_pipe_term()
364 send_pipe_term_ack (_peer); in process_pipe_term()
380 send_pipe_term_ack (_peer); in process_pipe_term_ack()
431 send_pipe_term (_peer); in terminate()
440 send_pipe_term_ack (_peer); in terminate()
450 send_pipe_term (_peer); in terminate()
[all …]
|
| /dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/SourceFiles/boxes/ |
| H A D | pin_messages_box.cpp | 43 : _peer(peer) in PinMessageBox()
61 if (_peer->isUser() && !_peer->isSelf()) { in prepare()
67 _peer->shortName()), in prepare()
71 } else if (!_pinningOld && (_peer->isChat() || _peer->isMegagroup())) { in prepare()
121 _peer->input, in pinMessage()
124 _peer->session().api().applyUpdates(result); in pinMessage()
|
| /dports/net-im/telegram-desktop/tdesktop-3.2.5-full/Telegram/SourceFiles/history/ |
| H A D | history_widget.cpp | 549 return _peer && (_peer == peer); in __anon05ff6a844602()
1757 if (!_peer || _peer->id != peer) return; in setReplyReturns()
2311 if (!_peer || (!_peer->isChannel() && !_peer->isRepliesChat())) { in updateNotifyControls()
3756 if (!_peer || !_peer->canWrite()) { in chooseAttach()
3880 if (!_peer || _peer != peer) return; in hideSingleUseKeyboard()
4061 return _peer && _peer->isUser() && _peer->asUser()->isBlocked(); in isBlocked()
4065 return _peer && _peer->isChannel() && !_peer->asChannel()->amIn(); in isJoinChannel()
4121 …_peer && ((_peer->isChat() && _peer->asChat()->botStatus > 0) || (_peer->isMegagroup() && _peer->a… in updateCmdStartShown()
4231 if (active && _peer && (_peer->isChat() || _peer->isMegagroup())) { in setMembersShowAreaActive()
5739 if (!_peer || !_peer->canWrite()) { in sendInlineResult()
[all …]
|
| /dports/irc/quassel/quassel-0.14-rc2/src/client/ |
| H A D | coreconnection.cpp | 110 if (!_peer) { in reconnectTimeout()
170 if (_peer) { in peer()
171 return _peer; in peer()
178 return _peer && _peer->isSecure(); in isEncrypted()
189 if (_peer) in isLocalConnection()
243 else if (_peer) in disconnectFromCore()
244 _peer->close(); in disconnectFromCore()
267 if (_peer) { in resetConnection()
270 _peer->close(); in resetConnection()
355 _peer = peer; in connectToCurrentAccount()
[all …]
|
| /dports/irc/quassel-core/quassel-0.14-rc2/src/client/ |
| H A D | coreconnection.cpp | 110 if (!_peer) { in reconnectTimeout()
170 if (_peer) { in peer()
171 return _peer; in peer()
178 return _peer && _peer->isSecure(); in isEncrypted()
189 if (_peer) in isLocalConnection()
243 else if (_peer) in disconnectFromCore()
244 _peer->close(); in disconnectFromCore()
267 if (_peer) { in resetConnection()
270 _peer->close(); in resetConnection()
355 _peer = peer; in connectToCurrentAccount()
[all …]
|