/system/core/libsysutils/src/ |
H A D | FrameworkClient.cpp | 27 FrameworkClient::FrameworkClient(int socket) { argument 28 mSocket = socket;
|
H A D | NetlinkListener.cpp | 21 #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 D | SocketClient.cpp | 26 #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/adb/ |
H A D | test_adb.py | 27 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 D | jdwp_service.cpp | 27 #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 D | test_device.py | 29 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 D | transport.cpp | 157 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...] |
H A D | sysdeps_win32.cpp | 126 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...] |
/system/core/libcutils/ |
H A D | uevent.c | 23 #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/logd/ |
H A D | LogListener.cpp | 22 #include <sys/socket.h> 55 int socket = cli->getSocket(); local 60 ssize_t n = recvmsg(socket, &hdr, 0);
|
/system/update_engine/scripts/ |
H A D | update_device.py | 24 import socket namespace 178 except (KeyboardInterrupt, socket.error): 183 self._httpd.socket.close()
|
/system/bt/btif/src/ |
H A D | btif_sock_sco.cc | 25 #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 D | hci_inject.cc | 34 #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 D | socket.cc | 21 #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 D | test_channel.py | 42 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/fastboot/ |
H A D | tcp.cpp | 59 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 D | udp.cpp | 43 #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/nvram/hal/ |
H A D | fake_nvram.cpp | 22 #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/core/init/ |
H A D | property_service.cpp | 292 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/netd/server/ |
H A D | NetdNativeService.cpp | 197 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 D | XfrmController.cpp | 35 #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...] |