| /external/parameter-framework/asio-1.10.6/include/asio/detail/ |
| reactive_socket_accept_op.hpp | 34 socket_ops::state_type state, Socket& peer, const Protocol& protocol,
39 peer_(peer),
56 // On success, assign new connection to peer socket object.
85 socket_ops::state_type state, Socket& peer, const Protocol& protocol,
87 : reactive_socket_accept_op_base<Socket, Protocol>(socket, state, peer,
|
| /external/syslinux/gpxe/src/include/gpxe/ |
| ipoib.h | 39 /** Peer addresses
42 * peer addresses using a lookup key. There simply
51 } __attribute__ (( packed )) peer; member in union:ipoib_hdr::__anon33328
|
| /external/v8/tools/testrunner/network/ |
| distro.py | 77 # Pick the least-busy peer. Sorting the list for each test
81 # If the peer already has a shell assigned and would need this one
83 peer = peers[index]
84 if (shell.total_duration < peer.needed_work and
85 len(peer.shells) > 0 and
90 peer.AddTests(shell)
|
| network_execution.py | 38 from ..objects import peer
49 return [ peer.Peer.Unpack(p) for p in data ]
141 # Spawn one thread for each peer.
168 def _TalkToPeer(self, peer):
171 code = sock.connect_ex((peer.address, constants.PEER_PORT))
174 peer.runtime = None
176 packet = workpacket.WorkPacket(peer=peer, context=self.context,
189 # The peer is reporting an error
[all...] |
| /external/iputils/ |
| tftpd.c | 79 int peer; variable
189 peer = socket(from.sa.sa_family, SOCK_DGRAM, 0);
190 if (peer < 0) {
194 if (connect(peer, (struct sockaddr *)&from, sizeof(from)) < 0) {
372 if (send(peer, dp, size + 4, confirmed) != size + 4) {
380 n = recv(peer, ackbuf, sizeof (ackbuf), 0);
398 synchnet(peer);
437 if (send(peer, ackbuf, 4, confirmed) != 4) {
445 n = recv(peer, dp, PKTSIZE, 0);
461 (void) synchnet(peer);
[all...] |
| /external/autotest/client/cros/tendo/ |
| peerd_dbus_helper.py | 17 Peer = collections.namedtuple('Peer', ['uuid', 'last_seen', 'services'])
22 DBUS_INTERFACE_PEER = 'org.chromium.peerd.Peer'
112 peer = Peer(uuid=peer_properties[PEER_PROPERTY_ID],
115 peers.append(peer)
141 Return a Peer instance if peerd has found a matching peer.
145 @param uuid: string unique identifier of peer.
146 @return Peer tuple if a matching peer exists, None otherwise
[all...] |
| /external/v8/tools/testrunner/server/ |
| main.py | 151 def AddPeer(self, peer):
154 if p.address == peer.address:
156 self.peers.append(peer)
157 if peer.trusted:
158 status_handler.ITrustYouNow(peer)
187 for peer in self.peers:
188 if peer.address == self.ip: continue
189 if peer.pubkey == fingerprint:
190 status_handler.ITrustYouNow(peer)
193 status_handler.NotifyNewTrusted(peer, result
[all...] |
| /art/runtime/openjdkjvmti/ |
| ti_thread.cc | 205 art::ObjPtr<art::mirror::Object> peer = self->GetPeerFromOtherThread(); local
208 if (peer != nullptr) {
211 art::ObjPtr<art::mirror::Object> group = f->GetObject(peer);
221 art::ObjPtr<art::mirror::Object> ccl = peer != nullptr
222 ? context_class_loader_->GetObject(peer)
228 // Only the peer. This thread has either not been started, or is dead. Read things from
230 art::ObjPtr<art::mirror::Object> peer = soa.Decode<art::mirror::Object>(thread); local
236 art::ObjPtr<art::mirror::Object> name = f->GetObject(peer);
257 info_ptr->priority = static_cast<jint>(f->GetInt(peer));
264 info_ptr->is_daemon = f->GetBoolean(peer) == 0 ? JNI_FALSE : JNI_TRUE
418 art::ObjPtr<art::mirror::Object> peer = soa.Decode<art::mirror::Object>(thread); local
469 art::ObjPtr<art::mirror::Object> peer = thread->GetPeerFromOtherThread(); local
[all...] |
| /external/parameter-framework/asio-1.10.6/include/asio/ |
| basic_socket_acceptor.hpp | 903 * This function is used to accept a new connection from a peer into the
907 * @param peer The socket into which the new connection will be accepted.
920 void accept(basic_socket<Protocol1, SocketService>& peer,
925 peer, static_cast<endpoint_type*>(0), ec);
931 * This function is used to accept a new connection from a peer into the
935 * @param peer The socket into which the new connection will be accepted.
954 basic_socket<Protocol1, SocketService>& peer,
959 peer, static_cast<endpoint_type*>(0), ec);
967 * @param peer The socket into which the new connection will be accepted.
968 * Ownership of the peer object is retained by the caller, which mus
[all...] |
| /external/openssh/ |
| kex.c | 345 sshbuf_reset(kex->peer);
398 if ((r = sshbuf_put(kex->peer, ptr, dlen)) != 0)
444 if ((kex->peer = sshbuf_new()) == NULL ||
509 sshbuf_free(kex->peer);
623 proposals_match(char *my[PROPOSAL_MAX], char *peer[PROPOSAL_MAX])
634 if ((p = strchr(peer[*idx], ',')) != NULL)
636 if (strcmp(my[*idx], peer[*idx]) != 0) {
637 debug2("proposal mismatch: my %s peer %s",
638 my[*idx], peer[*idx]);
651 char **my = NULL, **peer = NULL local
[all...] |
| /external/wpa_supplicant_8/src/wps/ |
| wps_upnp_web.c | 413 static void wps_upnp_peer_del(struct upnp_wps_peer *peer)
415 dl_list_del(&peer->list);
416 if (peer->wps)
417 wps_deinit(peer->wps);
418 os_free(peer);
429 struct upnp_wps_peer *peer; local
439 peer = os_zalloc(sizeof(*peer));
440 if (!peer)
455 peer->wps = wps_init(&cfg)
499 struct upnp_wps_peer *tmp, *peer; local
[all...] |
| /development/samples/AppNavigation/src/com/example/android/appnavigation/app/ |
| PeerActivity.java | 36 setContentView(R.layout.peer);
|
| /external/curl/tests/server/ |
| tftpd.c | 200 static curl_socket_t peer = CURL_SOCKET_BAD; variable
846 peer = socket(AF_INET, SOCK_DGRAM, 0);
847 if(CURL_SOCKET_BAD == peer) {
852 if(connect(peer, &from.sa, sizeof(from.sa4)) < 0) {
861 peer = socket(AF_INET6, SOCK_DGRAM, 0);
862 if(CURL_SOCKET_BAD == peer) {
867 if(connect(peer, &from.sa, sizeof(from.sa6)) < 0) {
885 sclose(peer);
886 peer = CURL_SOCKET_BAD;
910 if((peer != sock) && (peer != CURL_SOCKET_BAD)
[all...] |
| /external/iproute2/tipc/ |
| Makefile | 9 peer.o tipc.o
|
| /system/core/adb/ |
| socket.h | 42 /* flag: set when the socket's peer has closed
59 asocket *peer; member in struct:asocket
73 /* enqueue is called by our peer when it has data
76 ** peer->ready() when we once again are ready to
81 /* ready is called by the peer when it is ready for
86 /* shutdown is called by the peer before it goes away.
87 ** the socket should not do any further calls on its peer.
92 /* close is called by the peer when it has gone away.
94 ** peer once our close method is called.
|
| /bionic/libc/kernel/uapi/linux/ |
| scif_ioctl.h | 30 struct scif_port_id peer; member in struct:scifioctl_connect
35 struct scif_port_id peer; member in struct:scifioctl_accept
|
| /cts/tests/tests/os/src/android/os/cts/ |
| SeccompTest.java | 209 final IsolatedServiceConnection peer = new IsolatedServiceConnection(); local
211 assertTrue(getContext().bindService(intent, peer, Context.BIND_AUTO_CREATE));
213 final ISeccompIsolatedService service = peer.get();
223 getContext().unbindService(peer);
240 final IsolatedServiceConnection peer = new IsolatedServiceConnection(); local
242 assertTrue(getContext().bindService(intent, peer, Context.BIND_AUTO_CREATE));
244 final ISeccompIsolatedService service = peer.get();
255 getContext().unbindService(peer);
|
| /external/kernel-headers/original/uapi/linux/ |
| scif_ioctl.h | 76 * @peer: destination node and port to connect to
80 struct scif_port_id peer; member in struct:scifioctl_connect
86 * @peer: global id of peer endpoint
91 struct scif_port_id peer; member in struct:scifioctl_accept
|
| /external/wpa_supplicant_8/src/p2p/ |
| p2p_go_neg.c | 52 wpa_hexdump_ascii(MSG_DEBUG, "P2P: Peer country", pos, 3);
54 p2p_info(p2p, "Mismatching country (ours=%c%c peer's=%c%c)",
66 p2p_info(p2p, "Invalid peer Channel List");
79 p2p_dbg(p2p, "Own reg_classes %d peer reg_classes %d intersection reg_classes %d",
138 struct p2p_device *peer)
158 p2p_buf_add_public_action_hdr(buf, P2P_GO_NEG_REQ, peer->dialog_token);
162 if (peer->flags & P2P_DEV_PREFER_PERSISTENT_GROUP) {
164 if (peer->flags & P2P_DEV_PREFER_PERSISTENT_RECONN)
174 p2p_buf_add_go_intent(buf, (p2p->go_intent << 1) | peer->tie_breaker);
183 p2p_buf_add_device_info(buf, p2p, peer);
[all...] |
| /external/ipsec-tools/src/racoon/ |
| sainfo.c | 76 * First pass is for sainfo from a specified peer, second for others.
79 getsainfo(loc, rmt, peer, remoteid)
80 const vchar_t *loc, *rmt, *peer;
87 if (peer == NULL)
104 if (peer == NULL)
107 dpeer = ipsecdoi_id2str(peer);
110 "getsainfo params: loc=\'%s\', rmt=\'%s\', peer=\'%s\', id=%i\n",
133 if (ipsecdoi_chkcmpids(peer, s->id_i, 0))
294 snprintf(buf, 255, "loc=\'%s\', rmt=\'%s\', peer=\'%s\', id=%i",
|
| /external/dnsmasq/src/ |
| tftp.c | 46 struct sockaddr_in addr, peer; local
72 msg.msg_name = &peer;
73 msg.msg_namelen = sizeof(peer);
153 transfer->peer = peer;
194 len = tftp_err(ERR_ILL, packet, _("unsupported request from %s"), inet_ntoa(peer.sin_addr));
244 strncat(daemon->namebuff, inet_ntoa(peer.sin_addr), (MAXDNAME-1) - strlen(daemon->namebuff));
276 (struct sockaddr *)&peer, sizeof(peer)) == -1 && errno == EINTR);
282 my_syslog(MS_TFTP | LOG_INFO, _("TFTP sent %s to %s"), daemon->namebuff, inet_ntoa(peer.sin_addr))
[all...] |
| /external/autotest/client/site_tests/p2p_ServeFiles/ |
| p2p_ServeFiles.py | 112 # Create a single fake peer that will be sending the multicast requests.
113 peer = host.SimpleHost(self._sim, '94:EB:2C:00:00:61', '169.254.10.55')
117 zero = zeroconf.ZeroconfDaemon(peer, 'peer')
155 # Check we can download if the connection comes from a peer on the
158 self._sim.run_on_simulator(lambda: peer.tcp_forward(1234, ips[0], port))
160 ret = self._p2p_fetch(peer.ip_addr, 1234, 'file')
165 peer.id_addr)
|
| /prebuilts/go/darwin-x86/src/net/ |
| unixsock_test.go | 68 t.Fatalf("unexpected peer address: %v", from)
104 var peer Addr
108 _, peer, err = c1.ReadFrom(b[:])
112 if peer != nil { // peer is connected-mode
113 t.Fatalf("unexpected peer address: %v", peer)
154 var peer Addr
158 _, peer, err = c1.ReadFrom(nil)
162 if peer != nil { // peer is connected-mod
[all...] |
| /prebuilts/go/linux-x86/src/net/ |
| unixsock_test.go | 68 t.Fatalf("unexpected peer address: %v", from)
104 var peer Addr
108 _, peer, err = c1.ReadFrom(b[:])
112 if peer != nil { // peer is connected-mode
113 t.Fatalf("unexpected peer address: %v", peer)
154 var peer Addr
158 _, peer, err = c1.ReadFrom(nil)
162 if peer != nil { // peer is connected-mod
[all...] |
| /art/runtime/native/ |
| dalvik_system_VMStack.cc | 32 static jobject GetThreadStack(const ScopedFastNativeObjectAccess& soa, jobject peer)
35 ObjPtr<mirror::Object> decoded_peer = soa.Decode<mirror::Object>(peer);
51 Thread* thread = thread_list->SuspendThreadByPeer(peer, true, false, &timed_out);
|
