Home
last modified time | relevance | path

Searched refs:socket (Results 1 – 25 of 102) sorted by relevance

12345

/device/google/trout/agl_services_build/yocto-layer/meta-google/recipes-trout/images/machine-image/sa81x5/google-overlay/usr/bin/
Dgnss_replay.py26 import socket
54 def __init__(self, socket): argument
55 self.socket = socket
63 inp = self.socket.recv(128)
67 self.socket.send(str.encode(response))
70 self.socket.send(b'\n\n\n\n')
79 sk = socket.socket(socket.AF_UNIX, socket.SOCK_SEQPACKET)
80 sk.connect(args.socket)
/device/google/trout/hal/gnss/host/
Dgnss_replay.py26 import socket
54 def __init__(self, socket): argument
55 self.socket = socket
63 inp = self.socket.recv(128)
67 self.socket.send(str.encode(response))
70 self.socket.send(b'\n\n\n\n')
79 sk = socket.socket(socket.AF_UNIX, socket.SOCK_SEQPACKET)
80 sk.connect(args.socket)
/device/google/cuttlefish/host/commands/secure_env/
Dsuspend_resume_handler.cpp25 Result<void> WriteSuspendRequest(const SharedFD& socket) { in WriteSuspendRequest() argument
28 socket->Write(&suspend_request, sizeof(suspend_request)), in WriteSuspendRequest()
29 "socket write failed: " << socket->StrError()); in WriteSuspendRequest()
33 Result<void> ReadSuspendAck(const SharedFD& socket) { in ReadSuspendAck() argument
36 socket->Read(&ack_response, sizeof(ack_response)), in ReadSuspendAck()
37 "socket read failed: " << socket->StrError()); in ReadSuspendAck()
42 Result<void> WriteResumeRequest(const SharedFD& socket) { in WriteResumeRequest() argument
45 socket->Write(&resume_request, sizeof(resume_request)), in WriteResumeRequest()
46 "socket write failed: " << socket->StrError()); in WriteResumeRequest()
/device/google/cuttlefish/guest/hals/ril/reference-libril/
DRilSapSocket.cpp89 RLOGD("SocketName:%s",current->socket->name); in printList()
90 RLOGD("Socket id:%d",current->socket->id); in printList()
103 if(socketId == current->socket->id) { in getSocketById()
104 sap_socket = current->socket; in getSocketById()
148 RilSapSocket* socket = NULL; in addSocketToList() local
152 socket = new RilSapSocket(socketName, socketid, uimFuncs); in addSocketToList()
156 delete socket; in addSocketToList()
159 listItem->socket = socket; in addSocketToList()
162 RLOGD("Adding socket with id: %d", socket->id); in addSocketToList()
182 if(strcmp(current->socket->name, socketName) == 0) { in SocketExists()
/device/google/cuttlefish/host/commands/run_cvd/launch/
Dtombstone_receiver.cpp41 auto socket = in TombstoneReceiver() local
46 CF_EXPECTF(socket->IsOpen(), "Can't tombstone server socket: '{}'", in TombstoneReceiver()
47 socket->StrError()); in TombstoneReceiver()
50 .AddParameter("-server_fd=", socket) in TombstoneReceiver()
Dmodem.cpp100 for (const auto& socket : sockets) { in ModemSimulator() local
104 cmd.AppendToLastParameter(socket); in ModemSimulator()
/device/google/cuttlefish/shared/sepolicy/vendor/
Dsocket_vsock_proxy.te7 allow socket_vsock_proxy self:{ socket vsock_socket } { create getopt read write getattr listen acc…
12 # TODO: socket returned by accept() has unlabeled context on it. Give it a
14 allow socket_vsock_proxy unlabeled:{ socket vsock_socket } { getopt read write shutdown };
Dadbd.te1 allow adbd self:{ socket vsock_socket } {create listen accept rw_socket_perms_no_ioctl};
Dshell.te4 dontaudit shell adbd:{ socket vsock_socket } rw_socket_perms_no_ioctl;
Dhal_light_cuttlefish.te10 allow hal_light_cuttlefish self:{ socket vsock_socket } { create_socket_perms_no_ioctl listen accep…
/device/generic/goldfish/wifi/mac80211_create_radios/
Dmain.cpp204 int createRadios(struct nl_sock* socket, const int netlinkFamily, in createRadios() argument
218 int ret = nl_send_auto(socket, msg.get()); in createRadios()
230 std::unique_ptr<struct nl_sock, nl_sock_deleter> socket(nl_socket_alloc()); in manageRadios() local
231 if (!socket) { RETURN_ERROR("nl_socket_alloc", 1); } in manageRadios()
234 ret = genl_connect(socket.get()); in manageRadios()
237 const int netlinkFamily = genl_ctrl_resolve(socket.get(), kHwSimFamilyName); in manageRadios()
240 ret = createRadios(socket.get(), netlinkFamily, nRadios, macPrefix, in manageRadios()
/device/google/cuttlefish_vmm/x86_64-linux-gnu/etc/seccomp/
Dvhost_vsock_device.policy92 # Policy file for the vhost-user transport over a socket.
94 # FIONBIO: for setting non-blocking mode over the socket.
99 # For accepting a client connection over the socket.
101 # For creating a socket if the specified socket path does not exits
/device/google/cuttlefish/host/libs/audio_connector/
Dserver.cpp75 uint32_t buffer_offset, SharedFD socket) { in SendStatusCallback() argument
79 auto weak_socket = WeakFD(socket); in SendStatusCallback()
83 auto socket = weak_socket.lock(); in SendStatusCallback() local
84 if (!socket->IsOpen()) { in SendStatusCallback()
94 auto sent = socket->Send(&reply, sizeof(reply), MSG_DONTWAIT); in SendStatusCallback()
96 LOG(ERROR) << "Failed to send entire reply: " << socket->StrError(); in SendStatusCallback()
386 ssize_t AudioClientConnection::ReceiveMsg(SharedFD socket, void* buffer, in ReceiveMsg() argument
388 auto read = socket->Recv(buffer, size, MSG_TRUNC); in ReceiveMsg()
397 << socket->StrError(); in ReceiveMsg()
/device/google/cuttlefish/host/libs/wayland/
Dwayland_server.cpp70 const char* socket = wl_display_add_socket_auto(server_state_->display_); in ServerLoop() local
71 CHECK(socket != nullptr) in ServerLoop()
74 LOG(INFO) << "WaylandServer running on socket " << socket; in ServerLoop()
/device/generic/trusty/sepolicy/system_ext/private/
Dfile_contexts14 /dev/socket/rpmb_mock_system u:object_r:rpmb_dev_system_socket:s0
15 /dev/socket/rpmb_mock_test_system u:object_r:rpmb_dev_system_socket:s0
16 /dev/socket/rpmb_mock_wv_system u:object_r:rpmb_dev_system_socket:s0
/device/google/cuttlefish/apex/com.google.cf.bt/
DAndroid.bp47 name: "android.hardware.bluetooth.socket-service.default.xml",
48 src: ":manifest_android.hardware.bluetooth.socket-service.default.xml",
67 "android.hardware.bluetooth.socket-service.default",
78 "android.hardware.bluetooth.socket-service.default.xml",
/device/google/cuttlefish/shared/sepolicy/vendor/telephony/
Dlibcuttlefish_rild.te16 allow libcuttlefish_rild self:{ socket vsock_socket } { create_socket_perms_no_ioctl getattr };
17 allow libcuttlefish_rild su:{ socket udp_socket } { create_socket_perms_no_ioctl getattr };
/device/google/cuttlefish/shared/sepolicy/system_ext/private/
Dfile_contexts15 /dev/socket/rpmb_mock_system u:object_r:rpmb_dev_system_socket:s0
16 /dev/socket/rpmb_mock_test_system u:object_r:rpmb_dev_system_socket:s0
17 /dev/socket/rpmb_mock_wv_system u:object_r:rpmb_dev_system_socket:s0
/device/google/cuttlefish/guest/hals/light/lights/
Dlights_vsock_server.rs20 use nix::sys::socket::{connect, socket, AddressFamily, SockFlag, SockType};
144 let fd = socket( in drop()
/device/linaro/dragonboard/shared/utils/qrtr/src/
Daddr.c33 sock = socket(AF_QIPCRTR, SOCK_DGRAM, 0); in qrtr_set_address()
46 sock = socket(AF_NETLINK, SOCK_DGRAM, NETLINK_ROUTE); in qrtr_set_address()
/device/google/cuttlefish/common/libs/utils/
Dunix_sockets.cpp205 UnixMessageSocket::UnixMessageSocket(SharedFD socket) : socket_(socket) { in UnixMessageSocket() argument
207 CHECK(socket->GetSockOpt(SOL_SOCKET, SO_SNDBUF, &max_message_size_, &ln) == 0) in UnixMessageSocket()
209 << socket->StrError(); in UnixMessageSocket()
/device/google/cuttlefish/shared/minidroid/sample/
Dvsock-test.c53 int listen_fd = check_socket("listen_fd", socket(AF_VSOCK, SOCK_STREAM, 0)); in main_server()
101 int fd = check_socket("main socket", socket(AF_VSOCK, SOCK_STREAM, 0)); in main_client()
/device/google/cuttlefish/host/commands/screen_recording_server/
Dmain.cpp79 for (const SharedFD& socket : *launcher_monitor_sockets) { in SendToAllInstances()
81 RunLauncherAction(socket, extended_action, std::nullopt); in SendToAllInstances()
/device/google/cuttlefish/host/commands/snapshot_util_cvd/
Dmain.cc60 auto socket = CF_EXPECT( in BroadcastLauncherAction() local
62 CF_EXPECT(RunLauncherAction(socket, extended_action, std::nullopt)); in BroadcastLauncherAction()
/device/google/cuttlefish/host/libs/vm_manager/
Dcrosvm_builder.cpp115 void CrosvmBuilder::AddHvcSocket(const std::string& socket) { in AddHvcSocket() argument
118 ",type=unix-stream,input-unix-stream=true,path=", socket); in AddHvcSocket()

12345