| /external/chromium_org/net/server/ |
| http_server_request_info.h | 34 // Request peer address.
35 IPEndPoint peer; member in class:net::HttpServerRequestInfo
|
| /external/iptables/include/libipq/ |
| libipq.h | 53 struct sockaddr_nl peer; member in struct:ipq_handle
|
| /external/okhttp/okhttp-tests/src/test/java/com/squareup/okhttp/internal/spdy/ |
| SpdyConnectionTest.java | 59 private final MockSpdyPeer peer = new MockSpdyPeer(); field in class:SpdyConnectionTest
62 peer.close();
67 peer.acceptFrame(); // SYN_STREAM
68 peer.sendFrame()
70 peer.sendFrame().data(true, 1, new OkBuffer().writeUtf8("robot"));
71 peer.acceptFrame(); // DATA
72 peer.play();
75 SpdyConnection connection = connection(peer, SPDY3);
84 // verify the peer received what was expected
85 MockSpdyPeer.InFrame synStream = peer.takeFrame()
[all...] |
| /external/chromium_org/device/nfc/ |
| nfc_adapter.cc | 59 void NfcAdapter::SetPeer(const std::string& identifier, NfcPeer* peer) {
61 VLOG(1) << "Peer object for peer \"" << identifier << "\" already exists.";
64 peers_[identifier] = peer;
81 VLOG(1) << "Peer object for peer \"" << identifier << "\" not found.";
84 NfcPeer* peer = iter->second; local
86 return peer;
|
| nfc_adapter_chromeos.cc | 185 VLOG(1) << "Found peer device does not belong to the current adapter.";
189 // Create the peer object.
198 device::NfcPeer* peer = RemovePeer(object_path.value()); local
199 if (!peer) {
200 VLOG(1) << "Removed peer device does not belong to the current adapter.";
203 FOR_EACH_OBSERVER(NfcAdapter::Observer, observers_, PeerLost(this, peer));
204 delete peer;
265 // Create peer objects for peers that were added before the adapter was set.
319 device::NfcPeer* peer = *iter; local
321 PeerLost(this, peer));
[all...] |
| nfc_chromeos_unittest.cc | 83 virtual void PeerFound(NfcAdapter* adapter, NfcPeer* peer) OVERRIDE {
86 peer_identifier_ = peer->GetIdentifier();
90 virtual void PeerLost(NfcAdapter* adapter, NfcPeer* peer) OVERRIDE {
92 EXPECT_EQ(peer_identifier_, peer->GetIdentifier());
114 NfcPeer* peer, const NfcNdefRecord* record) OVERRIDE {
115 EXPECT_EQ(peer, adapter_->GetPeer(peer_identifier_));
116 EXPECT_EQ(peer_identifier_, peer->GetIdentifier());
321 // Tests that peer and record objects are created for all peers and records
365 NfcPeer* peer = peers[0]; local
366 const NfcNdefMessage& message = peer->GetNdefMessage()
540 NfcPeer* peer = adapter_->GetPeer(observer.peer_identifier_); local
[all...] |
| /external/chromium_org/ui/views/controls/button/ |
| radio_button.cc | 84 RadioButton* peer = static_cast<RadioButton*>(*i); local
85 peer->SetChecked(false);
|
| /external/chromium_org/v8/tools/testrunner/server/ |
| presence_handler.py | 38 from ..objects import peer namespace
41 STARTUP_REQUEST = "V8 test peer starting up"
43 EXIT_REQUEST = "V8 testing peer going down"
69 p = peer.Peer(self.client_address[0], jobs, relative_perf,
78 p = peer.Peer(self.client_address[0], jobs, perf, pubkey_fingerprint)
|
| /external/chromium_org/v8/tools/testrunner/network/ |
| network_execution.py | 38 from ..objects import peer namespace
49 return [ peer.Peer.Unpack(p) for p in data ]
143 # Spawn one thread for each peer.
170 def _TalkToPeer(self, peer):
173 code = sock.connect_ex((peer.address, constants.PEER_PORT))
176 peer.runtime = None
178 packet = workpacket.WorkPacket(peer=peer, context=self.context,
191 # The peer is reporting an error
[all...] |
| /external/iproute2/include/ |
| libnetlink.h | 16 struct sockaddr_nl peer; member in struct:rtnl_handle
42 extern int rtnl_talk(struct rtnl_handle *rtnl, struct nlmsghdr *n, pid_t peer,
|
| /external/openssl/apps/ |
| sess_id.c | 93 X509 *peer = NULL; local
167 peer = SSL_SESSION_get0_peer(x);
236 if (peer == NULL)
239 X509_print(out,peer);
258 else if (!noout && (peer != NULL)) /* just print the certificate */
261 i=(int)i2d_X509_bio(out,peer);
263 i=PEM_write_bio_X509(out,peer);
|
| s_cb.c | 777 } peer; local
790 /* Read peer information */
791 (void)BIO_dgram_get_peer(SSL_get_rbio(ssl), &peer); local
793 /* Create buffer with peer's address and port */
795 switch (peer.sa.sa_family)
799 length += sizeof(peer.s4.sin_port);
804 length += sizeof(peer.s6.sin6_port);
819 switch (peer.sa.sa_family)
823 &peer.s4.sin_port,
824 sizeof(peer.s4.sin_port))
865 } peer; local
872 (void)BIO_dgram_get_peer(SSL_get_rbio(ssl), &peer); local
[all...] |
| pkeyutl.c | 516 EVP_PKEY *peer = NULL; local
524 peer = load_pubkey(bio_err, file, peerform, 0, NULL, NULL, "Peer Key");
526 if (!peer)
528 BIO_printf(bio_err, "Error reading peer key %s\n", file);
533 ret = EVP_PKEY_derive_set_peer(ctx, peer);
535 EVP_PKEY_free(peer);
|
| /external/bluetooth/bluedroid/btif/include/ |
| btif_pan_internal.h | 69 BD_ADDR peer; member in struct:__anon5669
|
| /external/chromium_org/content/child/ |
| resource_dispatcher.h | 111 PendingRequestInfo(RequestPeer* peer,
120 RequestPeer* peer; member in struct:content::ResourceDispatcher::PendingRequestInfo
|
| resource_dispatcher.cc | 77 virtual bool Start(RequestPeer* peer) OVERRIDE;
173 bool IPCResourceLoaderBridge::Start(RequestPeer* peer) {
180 request_id_ = dispatcher_->AddPendingRequest(peer,
339 request_info->peer->OnUploadProgress(position, size);
356 request_info->peer, response_head.mime_type, request_info->url);
358 request_info->peer = new_peer;
376 request_info->peer->OnReceivedResponse(renderer_response_info);
386 request_info->peer->OnReceivedCachedMetadata(&data.front(), data.size());
456 // call peer's callback.
472 request_info->peer->OnReceivedData
551 RequestPeer* peer = request_info->peer; local
[all...] |
| web_url_loader_impl_unittest.cc | 66 virtual bool Start(RequestPeer* peer) OVERRIDE {
68 peer_ = peer;
90 RequestPeer* peer() { return peer_; } function in class:content::__anon12146::TestBridge
281 ASSERT_TRUE(peer());
291 peer()->OnReceivedRedirect(redirect_info,
298 peer()->OnReceivedResponse(content::ResourceResponseInfo());
305 peer()->OnReceivedData(kTestData, strlen(kTestData), strlen(kTestData));
311 peer()->OnCompletedRequest(net::OK, false, false, "", base::TimeTicks(),
321 peer()->OnCompletedRequest(net::ERR_FAILED, false, false, "",
332 peer()->OnReceivedResponse(response_info)
363 RequestPeer* peer() { return bridge()->peer(); } function in class:content::__anon12146::WebURLLoaderImplTest
[all...] |
| /external/chromium_org/ipc/mojo/ |
| ipc_channel_mojo_readers.cc | 213 mojo::ScopedMessagePipeHandle peer; local
215 mojo::CreateMessagePipe(NULL, &message_pipe_, &peer);
221 MojoHandle peer_to_send = peer.get().value();
235 // |peer| is sent and no longer owned by |this|.
236 (void)peer.release();
|
| /external/chromium_org/third_party/boringssl/src/crypto/bio/ |
| pair.c | 63 BIO *peer; /* NULL if buf == NULL. member in struct:bio_bio_st
64 * If peer != NULL, then peer->ptr is also a bio_bio_st,
65 * and its "peer" member points back to us.
66 * peer != NULL iff init != 0 in the BIO. */
68 /* This is for what we write (i.e. reading uses peer's struct): */
69 int closed; /* valid iff peer != NULL */
70 size_t len; /* valid iff buf != NULL; 0 if peer == NULL */
75 size_t request; /* valid iff peer != NULL; 0 if len != 0,
76 * otherwise set by peer to number of byte
[all...] |
| /bootable/recovery/minadbd/ |
| sockets.c | 54 ** these have no peer anymore, but still packets to
122 if(s->transport == t || (s->peer && s->peer->transport == t)) {
223 if(s->peer) {
224 D("LS(%d): closing peer. peer->id=%d peer->fd=%d\n",
225 s->id, s->peer->id, s->peer->fd);
226 s->peer->peer = 0
471 asocket* peer = s->peer; local
[all...] |
| /external/chromium_org/net/base/ |
| address_tracker_linux.cc | 161 struct sockaddr_nl peer = {}; local
162 peer.nl_family = AF_NETLINK;
176 0, reinterpret_cast<struct sockaddr*>(&peer),
177 sizeof(peer)));
195 reinterpret_cast<struct sockaddr*>(&peer),
196 sizeof(peer)));
|
| /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/openssl/crypto/bio/ |
| bss_bio.c | 57 * of this kind, handled by the same thread (i.e. the "peer" is actually
127 BIO *peer; /* NULL if buf == NULL. member in struct:bio_bio_st
128 * If peer != NULL, then peer->ptr is also a bio_bio_st,
129 * and its "peer" member points back to us.
130 * peer != NULL iff init != 0 in the BIO. */
132 /* This is for what we write (i.e. reading uses peer's struct): */
133 int closed; /* valid iff peer != NULL */
134 size_t len; /* valid iff buf != NULL; 0 if peer == NULL */
139 size_t request; /* valid iff peer != NULL; 0 if len != 0
[all...] |
| /art/runtime/ |
| thread_list.cc | 446 static void ThreadSuspendByPeerWarning(Thread* self, int level, const char* message, jobject peer) {
449 scoped_name_string(env, (jstring)env->GetObjectField(peer,
453 LOG(level) << message << ": " << peer; local
456 LOG(level) << message << ": " << peer << ":" << scoped_name_chars.c_str();
460 Thread* ThreadList::SuspendThreadByPeer(jobject peer, bool request_suspension,
479 thread = Thread::FromManagedThread(soa, peer);
481 ThreadSuspendByPeerWarning(self, WARNING, "No such thread for suspend", peer);
513 ThreadSuspendByPeerWarning(self, FATAL, "Thread suspension timed out", peer);
[all...] |
| /cts/tests/tests/os/src/android/os/cts/ |
| ParcelFileDescriptorProcessTest.java | 76 private static void crash(IParcelFileDescriptorPeer peer) {
78 peer.crash();
|
