| /prebuilts/python/linux-x86/2.7.5/bin/ |
| smtpd.py | 130 print >> DEBUGSTREAM, 'Peer:', repr(self.__peer)
305 def process_message(self, peer, mailfrom, rcpttos, data):
308 peer is a tuple containing (ipaddr, port) of the client that made the
332 def process_message(self, peer, mailfrom, rcpttos, data):
339 print 'X-Peer:', peer[0]
346 def process_message(self, peer, mailfrom, rcpttos, data):
354 lines.insert(i, 'X-Peer: %s' % peer[0])
386 def process_message(self, peer, mailfrom, rcpttos, data)
[all...] |
| /prebuilts/python/linux-x86/2.7.5/lib/python2.7/ |
| smtpd.py | 130 print >> DEBUGSTREAM, 'Peer:', repr(self.__peer)
305 def process_message(self, peer, mailfrom, rcpttos, data):
308 peer is a tuple containing (ipaddr, port) of the client that made the
332 def process_message(self, peer, mailfrom, rcpttos, data):
339 print 'X-Peer:', peer[0]
346 def process_message(self, peer, mailfrom, rcpttos, data):
354 lines.insert(i, 'X-Peer: %s' % peer[0])
386 def process_message(self, peer, mailfrom, rcpttos, data)
[all...] |
| /external/libnfnetlink/src/ |
| libnfnetlink.c | 88 struct sockaddr_nl peer; member in struct:nfnl_handle
226 nfnlh->peer.nl_family = AF_NETLINK;
474 (struct sockaddr *)&nfnlh->peer, sizeof(nfnlh->peer));
493 msg.msg_name = (struct sockaddr *) &nfnlh->peer;
494 msg.msg_namelen = sizeof(nfnlh->peer);
591 struct sockaddr_nl peer; local
603 addrlen = sizeof(h->peer);
604 status = recvfrom(h->fd, buf, len, 0, (struct sockaddr *)&peer,
609 if (addrlen != sizeof(peer)) {
[all...] |
| /external/python/cpython3/Lib/ |
| smtpd.py | 161 self.peer = conn.getpeername()
169 print('Peer:', repr(self.peer), file=DEBUGSTREAM)
280 "use 'peer' instead", DeprecationWarning, 2)
281 return self.peer
285 "set 'peer' instead", DeprecationWarning, 2)
286 self.peer = value
379 args = (self.peer, self.mailfrom, self.rcpttos, self.received_data)
671 def process_message(self, peer, mailfrom, rcpttos, data, **kwargs):
674 peer is a tuple containing (ipaddr, port) of the client that made th
[all...] |
| /external/webrtc/webrtc/p2p/base/ |
| turnserver.cc | 58 Permission(rtc::Thread* thread, const rtc::IPAddress& peer);
61 const rtc::IPAddress& peer() const { return peer_; } function in class:cricket::TurnServerAllocation::Permission
79 const rtc::SocketAddress& peer);
83 const rtc::SocketAddress& peer() const { return peer_; } function in class:cricket::TurnServerAllocation::Channel
681 // If a permission exists, send the data on to the peer.
687 << "peer=" << peer_attr->GetAddress();
710 LOG_J(LS_INFO, this) << "Created permission, peer="
760 << ", peer=" << peer_attr->GetAddress();
773 // Send the data to the peer address.
775 size - TURN_CHANNEL_HEADER_SIZE, channel->peer());
[all...] |
| /system/core/adb/ |
| adb.cpp | 406 s->peer = create_remote_socket(p->msg.arg0, t);
407 s->peer->peer = s;
408 send_ready(s->id, s->peer->id, t);
418 if(s->peer == 0) {
420 s->peer = create_remote_socket(p->msg.arg0, t);
421 s->peer->peer = s;
423 } else if (s->peer->id == p->msg.arg0) {
428 p->msg.arg0, p->msg.arg1, s->peer->id, p->msg.arg1, t->serial)
[all...] |
| transport.cpp | 421 asocket* peer = socket->peer; local
424 if (peer) {
425 peer->peer = NULL;
426 peer->close(peer);
439 asocket* peer = tracker->socket.peer; local
447 return peer->enqueue(peer, std::move(data))
[all...] |
| /cts/tests/tests/os/src/android/os/cts/ |
| ParcelFileDescriptorPeer.java | 53 public void setPeer(IParcelFileDescriptorPeer peer) throws RemoteException {
54 mPeer = peer;
|
| /external/autotest/client/site_tests/p2p_ShareFiles/ |
| p2p_ShareFiles.py | 63 # Create a single fake peer that will be sending the multicast requests.
64 peer = host.SimpleHost(self._sim, '94:EB:2C:00:00:61', '169.254.10.97')
68 zero = zeroconf.ZeroconfDaemon(peer, 'a-peer')
79 raise error.TestFail('Expected one peer (the DUT) but %d found.' %
85 logging.info('Peer ips: %r', ips)
86 raise error.TestFail('Found wrong peer IP address on the DUT.')
88 logging.info('Peer p2p port is: %r', port)
93 logging.info('Peer files: %r', files)
98 logging.info('Peer connections: %r', num_connections
[all...] |
| /external/boringssl/src/ssl/test/runner/ |
| recordingconn.go | 51 local, peer string
90 fmt.Fprintf(w, ">>> runner is %s, shim is %s\n", r.local, r.peer)
94 fmt.Fprintf(w, ">>> Flow %d (%s to %s)\n", i+1, r.peer, r.local)
96 fmt.Fprintf(w, ">>> Flow %d (%s to %s)\n", i+1, r.local, r.peer)
|
| /external/okhttp/okio/okio/src/test/java/okio/ |
| SocketTimeoutTest.java | 97 Thread peer = new Thread("peer") { local
105 Thread.sleep(5000); // Sleep 5 seconds so the peer can close the connection.
115 peer.start();
|
| /frameworks/opt/net/wifi/tests/wifitests/src/com/android/server/wifi/rtt/ |
| RttNativeTest.java | 135 collector.checkThat("entry 0: peer type", rttConfig.peer, equalTo(RttPeerType.AP));
143 collector.checkThat("entry 1: peer type", rttConfig.peer, equalTo(RttPeerType.AP));
151 collector.checkThat("entry 2: peer type", rttConfig.peer, equalTo(RttPeerType.NAN));
185 collector.checkThat("entry 0: peer type", rttConfig.peer, equalTo(RttPeerType.AP));
193 collector.checkThat("entry 1: peer type", rttConfig.peer, equalTo(RttPeerType.NAN))
[all...] |
| /bionic/libc/kernel/uapi/linux/ |
| tipc.h | 140 __u32 peer; member in struct:tipc_sioc_ln_req
|
| /external/curl/tests/python_dependencies/impacket/ |
| nmb.py | 775 def _setup_connection(self, peer):
776 af, socktype, proto, canonname, sa = socket.getaddrinfo(peer[0], peer[1], 0, socket.SOCK_DGRAM)[0]
783 self.peer = peer
800 self._sock.connect(self.peer)
809 self._sock.sendto(str(p), self.peer)
812 self._sock = self._setup_connection(self.peer)
823 data, peer = self._sock.recvfrom(8192)
824 # print "peer: %r self.peer: %r" % (peer, self.peer
[all...] |
| /external/mtpd/ |
| pptp.c | 119 uint16_t peer; member in struct:packet::__anon30713::__anon30714::__anon30716::__anon30719
309 if (state == OCRQ && incoming.ocrp.peer == local) {
367 outgoing.icrp.peer = incoming.icrq.call;
376 outgoing.ocrp.peer = incoming.ocrq.call;
|
| /external/webrtc/webrtc/examples/peerconnection/server/ |
| peer_channel.h | 23 // Represents a single peer connected to the server.
44 void ForwardRequestToPeer(DataSocket* ds, ChannelMember* peer);
85 // Finds a connected peer that's associated with the |ds| socket.
89 // peer for which the request is targeted at.
100 // Called when a socket was determined to be closing by the peer (or if the
|
| /external/wpa_supplicant_8/src/eap_common/ |
| eap_sake_common.h | 2 * EAP server/peer: EAP-SAKE shared routines
91 int peer, const u8 *eap, size_t eap_len,
|
| /frameworks/opt/net/wifi/tests/wifitests/src/com/android/server/wifi/aware/ |
| TestUtils.java | 105 int channel, byte[] peer, String interfaceName, byte[] pmk, String passphrase,
|
| /art/runtime/native/ |
| dalvik_system_VMStack.cc | 41 jobject peer,
45 ObjPtr<mirror::Object> decoded_peer = soa.Decode<mirror::Object>(peer);
61 Thread* thread = thread_list->SuspendThreadByPeer(peer,
|
| java_lang_Thread.cc | 135 static void Thread_nativeSetName(JNIEnv* env, jobject peer, jstring java_name) {
139 if (soa.Decode<mirror::Object>(peer) == soa.Self()->GetPeer()) {
150 Thread* thread = thread_list->SuspendThreadByPeer(peer,
|
| /external/adhd/cras/src/server/ |
| cras_dsp_pipeline.c | 48 struct audio_port *peer; /* the audio port this port connects to */ member in struct:audio_port
56 struct control_port *peer; /* the control port this port connects to */ member in struct:control_port
344 from->peer = audio_port;
345 audio_port->peer = from;
364 from->peer = control_port;
365 control_port->peer = from;
554 audio_port->buf_index = audio_port->peer->buf_index;
630 &pipeline->instances, audio_port->peer->plugin);
686 * peer, we use &control_port->peer->value, s
[all...] |
| /external/autotest/client/cros/tendo/n_faced_peerd/ |
| manager.py | 16 from autotest_lib.client.cros.tendo.n_faced_peerd import peer
57 self.self_peer = peer.Peer(self._bus,
93 """Add a remote peer to this object.
98 @param remote_peer: Peer object. Should be the |self_peer| of another
102 logging.info('Adding remote peer %s', remote_peer.uuid)
106 self._peers[remote_peer.uuid] = peer.Peer(
111 """Cause this face to update its view of a remote peer.
113 @param remote_peer: Peer object. Should be the |self_peer| of anothe
[all...] |
| /external/syslinux/gpxe/src/net/ |
| tcp.c | 39 struct sockaddr_tcpip peer; member in struct:tcp_connection
210 * @v peer Peer socket address
214 static int tcp_open ( struct xfer_interface *xfer, struct sockaddr *peer,
216 struct sockaddr_tcpip *st_peer = ( struct sockaddr_tcpip * ) peer;
234 memcpy ( &tcp->peer, st_peer, sizeof ( tcp->peer ) );
484 tcphdr->dest = tcp->peer.st_port;
501 if ( ( rc = tcpip_tx ( iobuf, &tcp_protocol, NULL, &tcp->peer, NULL,
875 DBGC ( tcp, "TCP %p connection reset by peer\n", tcp )
1138 struct sockaddr_tcpip peer; local
[all...] |
| /system/bt/btif/co/ |
| bta_av_co.cc | 75 uint8_t seid; // Peer SEP index (in peer tables)
76 uint8_t codec_caps[AVDT_CODEC_SIZE]; // Peer SEP codec capabilities
77 uint8_t num_protect; // Peer SEP number of CP elements
78 uint8_t protect_info[AVDT_CP_INFO_LEN]; // Peer SEP content protection info
139 RawAddress addr; // Peer address
142 uint8_t num_sinks; // Total number of sinks at peer
143 uint8_t num_sources; // Total number of sources at peer
144 uint8_t num_seps; // Total number of SEPs at peer
156 uint16_t uuid_to_connect; // UUID of peer devic
784 BtaAvCoPeer* peer = FindPeer(peer_address); local
1638 const BtaAvCoPeer& peer = peers_[i]; local
[all...] |
| /external/wpa_supplicant_8/wpa_supplicant/hidl/1.0/ |
| sta_iface.cpp | 634 const u8 *peer = mac_address.data(); local
636 ret = wpa_tdls_send_discovery_request(wpa_s->wpa, peer);
638 ret = wpa_drv_tdls_oper(wpa_s, TDLS_DISCOVERY_REQ, peer);
651 const u8 *peer = mac_address.data(); local
654 wpa_tdls_remove(wpa_s->wpa, peer);
655 ret = wpa_tdls_start(wpa_s->wpa, peer);
657 ret = wpa_drv_tdls_oper(wpa_s, TDLS_SETUP, peer);
670 const u8 *peer = mac_address.data(); local
674 wpa_s->wpa, peer, WLAN_REASON_TDLS_TEARDOWN_UNSPECIFIED);
676 ret = wpa_drv_tdls_oper(wpa_s, TDLS_TEARDOWN, peer);
[all...] |
