Searched defs:socket (Results 1 - 21 of 21) sorted by path

/system/bt/btif/src/
H A Dbtif_sock_sco.cc25 #include <sys/socket.h>
40 #include "osi/include/socket.h"
43 // This module provides a socket abstraction for SCO connections to a higher
58 // socket_read_ready_cb() - local host closed SCO socket
63 socket_t* socket; member in struct:__anon677
71 static void sco_socket_free_locked(sco_socket_t* socket);
77 static void socket_read_ready_cb(socket_t* socket, void* context);
137 socket_t* socket = NULL; local
141 LOG_ERROR(LOG_TAG, "%s unable to allocate socket pair: %s", __func__,
148 LOG_ERROR(LOG_TAG, "%s unable to allocate new SCO socket
313 socket_read_ready_cb(UNUSED_ATTR socket_t* socket, void* context) argument
[all...]
/system/bt/hci/src/
H A Dhci_inject.cc34 #include "osi/include/socket.h"
45 socket_t* socket; member in struct:__anon734
53 static void accept_ready(socket_t* socket, void* context);
54 static void read_ready(socket_t* socket, void* context);
127 static void accept_ready(socket_t* socket, UNUSED_ATTR void* context) { argument
128 CHECK(socket != NULL);
129 CHECK(socket == listen_socket);
131 socket = socket_accept(socket);
132 if (!socket) retur
147 read_ready(UNUSED_ATTR socket_t* socket, void* context) argument
[all...]
/system/bt/osi/src/
H A Dsocket.cc21 #include "osi/include/socket.h"
29 #include <sys/socket.h>
55 ret->fd = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
57 LOG_ERROR(LOG_TAG, "%s unable to create socket: %s", __func__,
86 void socket_free(socket_t* socket) { argument
87 if (!socket) return;
89 socket_unregister(socket);
90 close(socket->fd);
91 osi_free(socket);
94 bool socket_listen(const socket_t* socket, port_ argument
116 socket_accept(const socket_t* socket) argument
133 socket_read(const socket_t* socket, void* buf, size_t count) argument
143 socket_write(const socket_t* socket, const void* buf, size_t count) argument
153 socket_write_and_transfer_fd(const socket_t* socket, const void* buf, size_t count, int fd) argument
187 socket_bytes_available(const socket_t* socket) argument
195 socket_register(socket_t* socket, reactor_t* reactor, void* context, socket_cb read_cb, socket_cb write_cb) argument
213 socket_unregister(socket_t* socket) argument
223 socket_t* socket = static_cast<socket_t*>(context); local
230 socket_t* socket = static_cast<socket_t*>(context); local
[all...]
/system/bt/vendor_libs/test_vendor_lib/scripts/
H A Dtest_channel.py42 import socket namespace
60 """Simple wrapper class for a socket object.
63 socket: The underlying socket created for the specified address and port.
67 self._socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
237 except socket.error, e:
238 print 'Error connecting to socket
[all...]
/system/core/adb/
H A Djdwp_service.cpp27 #include <sys/socket.h>
42 when adbd starts, it creates a unix server socket
75 - it attaches the first socket in the pair to a local socket
76 which is itself attached to the transport's remote socket:
79 - it sends the file descriptor of the second socket directly
90 then, the JDWP thread uses this new socket descriptor as its
114 due to the way adb works, this doesn't need a special socket
115 type or fancy handling of socket termination if either the debugger
124 ** for each JDWP process, we record its pid and its connected socket
137 JdwpProcess(int socket) argument
178 int socket = -1; member in struct:JdwpProcess
219 jdwp_process_event(int socket, unsigned events, void* _proc) argument
[all...]
H A Dsysdeps_win32.cpp126 SOCKET socket; member in union:FHRec_::__anon1443
133 #define fh_socket u.socket
480 /***** socket-based file descriptors *****/
489 // lot of POSIX and socket error codes, some of the resulting error codes
528 // WSAPoll doesn't handle invalid/non-socket handles, so we need to handle them ourselves.
540 .fd = fh->u.socket,
581 /* gently tell any peer that we're closing the socket */
583 // If the socket is not connected, this returns an error. We want to
586 D("socket shutdown failed: %s",
609 // WSAEWOULDBLOCK is normal with a non-blocking socket, s
[all...]
H A Dtest_adb.py27 import socket namespace
146 # Use SO_LINGER to cause TCP RST segment to be sent on socket close.
153 sock.setsockopt(socket.SOL_SOCKET, socket.SO_LINGER,
156 linger = sock.getsockopt(socket.SOL_SOCKET, socket.SO_LINGER, 16)
168 socket.socket(socket.AF_INET, socket
[all...]
H A Dtest_device.py29 import socket namespace
265 listener = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
269 listener.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
277 client = socket.socket(socket
[all...]
H A Dtransport.cpp157 D("%s: failed to read packet from transport socket on fd %d", t->serial, fd);
175 fatal_errno("cannot enqueue packet on transport socket");
331 asocket socket; member in struct:device_tracker
354 static void device_tracker_close(asocket* socket) { argument
355 device_tracker* tracker = (device_tracker*)socket;
356 asocket* peer = socket->peer;
367 static int device_tracker_enqueue(asocket* socket, apacket* p) { argument
370 device_tracker_close(socket);
376 asocket* peer = tracker->socket.peer;
384 static void device_tracker_ready(asocket* socket) { argument
[all...]
/system/core/fastboot/
H A Dtcp.cpp59 static std::unique_ptr<TcpTransport> NewTransport(std::unique_ptr<Socket> socket,
81 std::unique_ptr<TcpTransport> TcpTransport::NewTransport(std::unique_ptr<Socket> socket, argument
83 std::unique_ptr<TcpTransport> transport(new TcpTransport(std::move(socket)));
H A Dudp.cpp43 #include "socket.h"
105 static std::unique_ptr<UdpTransport> NewTransport(std::unique_ptr<Socket> socket,
114 explicit UdpTransport(std::unique_ptr<Socket> socket) : socket_(std::move(socket)) {} argument
141 std::unique_ptr<UdpTransport> UdpTransport::NewTransport(std::unique_ptr<Socket> socket, argument
143 std::unique_ptr<UdpTransport> transport(new UdpTransport(std::move(socket)));
209 *error = "socket is closed";
/system/core/init/
H A Dproperty_service.cpp292 SocketConnection(int socket, const struct ucred& cred) argument
293 : socket_(socket), cred_(cred) {}
339 int socket() { function in class:android::init::SocketConnection
410 static void handle_property_set(SocketConnection& socket, argument
417 socket.SendUint32(PROP_ERROR_INVALID_NAME);
421 struct ucred cr = socket.cred();
423 getpeercon(socket.socket(), &source_ctx);
429 socket.SendUint32(PROP_SUCCESS);
438 socket
[all...]
/system/core/libcutils/
H A Duevent.c23 #include <sys/socket.h>
32 ssize_t uevent_kernel_multicast_recv(int socket, void *buffer, size_t length) argument
35 return uevent_kernel_multicast_uid_recv(socket, buffer, length, &uid);
41 * socket's peer.
47 ssize_t uevent_kernel_multicast_uid_recv(int socket, void *buffer, size_t length, uid_t *uid) argument
49 return uevent_kernel_recv(socket, buffer, length, true, uid);
52 ssize_t uevent_kernel_recv(int socket, void *buffer, size_t length, bool require_group, uid_t *uid) argument
68 ssize_t n = recvmsg(socket, &hdr, 0);
115 s = socket(PF_NETLINK, SOCK_DGRAM | SOCK_CLOEXEC, NETLINK_KOBJECT_UEVENT);
/system/core/libsysutils/src/
H A DFrameworkClient.cpp27 FrameworkClient::FrameworkClient(int socket) { argument
28 mSocket = socket;
H A DNetlinkListener.cpp21 #include <sys/socket.h>
25 #include <linux/netlink.h> /* out of order because must follow sys/socket.h */
36 NetlinkListener::NetlinkListener(int socket) : argument
37 SocketListener(socket, false) {
42 NetlinkListener::NetlinkListener(int socket, int format) : argument
43 SocketListener(socket, false), mFormat(format) {
48 int socket = cli->getSocket(); local
57 count = TEMP_FAILURE_RETRY(uevent_kernel_recv(socket,
H A DSocketClient.cpp26 #include <sys/socket.h>
33 SocketClient::SocketClient(int socket, bool owned) { argument
34 init(socket, owned, false);
37 SocketClient::SocketClient(int socket, bool owned, bool useCmdNum) { argument
38 init(socket, owned, useCmdNum);
41 void SocketClient::init(int socket, bool owned, bool useCmdNum) { argument
42 mSocket = socket;
57 int err = getsockopt(socket, SOL_SOCKET, SO_PEERCRED, &creds, &szCreds);
/system/core/logd/
H A DLogListener.cpp22 #include <sys/socket.h>
55 int socket = cli->getSocket(); local
60 ssize_t n = recvmsg(socket, &hdr, 0);
/system/netd/server/
H A DNetdNativeService.cpp197 String8("Could not open SOCK_DIAG socket"));
435 const android::base::unique_fd& socket,
445 socket,
454 const android::base::unique_fd& socket) {
459 socket));
434 ipSecApplyTransportModeTransform( const android::base::unique_fd& socket, int32_t transformId, int32_t direction, const std::string& localAddress, const std::string& remoteAddress, int32_t spi) argument
453 ipSecRemoveTransportModeTransform( const android::base::unique_fd& socket) argument
H A DXfrmController.cpp35 #include <sys/socket.h>
171 ALOGW("Could not get a new socket, line=%d", __LINE__);
230 ALOGE("netlink socket writev failed (%s)", strerror(errno));
524 int XfrmController::ipSecApplyTransportModeTransform(const android::base::unique_fd& socket, argument
540 int userSocket = socket.get();
543 ALOGE("Failed to get socket info in %s", __FUNCTION__);
558 ALOGE("Transform address family(%d) differs from socket address "
591 ALOGE("Error setting socket option for XFRM! (%s)", strerror(err));
597 int XfrmController::ipSecRemoveTransportModeTransform(const android::base::unique_fd& socket) { argument
598 (void)socket;
[all...]
/system/nvram/hal/
H A Dfake_nvram.cpp22 #include <sys/socket.h>
47 // Name of the control socket served by this daemon.
53 // Connection backlog on control socket.
60 // command messages from and to the control socket.
111 // Reads a single command from |socket|, decodes the command, executes it on
112 // |nvram_manager|, encodes the response, and writes the reply back to |socket|.
114 // expected the close the |socket|).
115 bool ProcessCommand(int socket, nvram::NvramManager* nvram_manager) { argument
118 TEMP_FAILURE_RETRY(read(socket, command_buffer, sizeof(command_buffer)));
124 PLOG(ERROR) << "Failed to read command from client socket";
[all...]
/system/update_engine/scripts/
H A Dupdate_device.py24 import socket namespace
178 except (KeyboardInterrupt, socket.error):
183 self._httpd.socket.close()

Completed in 380 milliseconds