Home
last modified time | relevance | path

Searched refs:sock (Results 1 – 23 of 23) sorted by relevance

/device/linaro/dragonboard/shared/utils/qrtr/lib/
Dqrtr.c16 static int qrtr_getname(int sock, struct sockaddr_qrtr *sq) in qrtr_getname() argument
21 rc = getsockname(sock, (void *)sq, &sl); in qrtr_getname()
36 int sock; in qrtr_open() local
39 sock = socket(AF_QIPCRTR, SOCK_DGRAM, 0); in qrtr_open()
40 if (sock < 0) { in qrtr_open()
48 rc = setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv)); in qrtr_open()
61 rc = bind(sock, (void *)&sq, sizeof(sq)); in qrtr_open()
68 return sock; in qrtr_open()
70 close(sock); in qrtr_open()
74 void qrtr_close(int sock) in qrtr_close() argument
[all …]
Dlibqrtr.h124 void qrtr_close(int sock);
126 int qrtr_sendto(int sock, uint32_t node, uint32_t port, const void *data, unsigned int sz);
127 int qrtr_recvfrom(int sock, void *buf, unsigned int bsz, uint32_t *node, uint32_t *port);
128 int qrtr_recv(int sock, void *buf, unsigned int bsz);
130 int qrtr_new_server(int sock, uint32_t service, uint16_t version, uint16_t instance);
131 int qrtr_remove_server(int sock, uint32_t service, uint16_t version, uint16_t instance);
133 int qrtr_publish(int sock, uint32_t service, uint16_t version, uint16_t instance);
134 int qrtr_bye(int sock, uint32_t service, uint16_t version, uint16_t instance);
136 int qrtr_new_lookup(int sock, uint32_t service, uint16_t version, uint16_t instance);
137 int qrtr_remove_lookup(int sock, uint32_t service, uint16_t version, uint16_t instance);
[all …]
/device/linaro/dragonboard/shared/utils/tqftpserv/
Dtqftpserv.c61 int sock; member
102 len = send(client->sock, buf, p - buf, 0); in tftp_send_data()
110 static int tftp_send_ack(int sock, int block) in tftp_send_ack() argument
117 return send(sock, &ack, sizeof(ack), 0); in tftp_send_ack()
120 static int tftp_send_oack(int sock, size_t *blocksize, size_t *tsize, in tftp_send_oack() argument
175 return send(sock, buf, p - buf, 0); in tftp_send_oack()
178 static int tftp_send_error(int sock, int code, const char *msg) in tftp_send_error() argument
194 rc = send(sock, buf, len, 0); in tftp_send_error()
214 int sock; in handle_rrq() local
262 sock = qrtr_open(0); in handle_rrq()
[all …]
/device/google/cuttlefish/host/frontend/adb_connector/
Dadb_connection_maintainer.cpp73 bool AdbSendMessage(const SharedFD& sock, const std::string& message) { in AdbSendMessage() argument
74 if (!sock->IsOpen()) { in AdbSendMessage()
77 if (!SendAll(sock, message)) { in AdbSendMessage()
81 return RecvAll(sock, kAdbStatusResponseLength) == kAdbOkayStatusResponse; in AdbSendMessage()
85 auto sock = SharedFD::SocketLocalClient(kAdbDaemonPort, SOCK_STREAM); in AdbSendMessage() local
86 return AdbSendMessage(sock, message); in AdbSendMessage()
108 std::string RecvAdbResponse(const SharedFD& sock) { in RecvAdbResponse() argument
109 auto length_as_hex_str = RecvAll(sock, kAdbMessageLengthLength); in RecvAdbResponse()
115 return RecvAll(sock, length); in RecvAdbResponse()
120 int RecvUptimeResult(const SharedFD& sock) { in RecvUptimeResult() argument
[all …]
/device/linaro/dragonboard/shared/utils/qrtr/
Dqrtr.py15 self.sock = _qrtr.qrtr_open(port)
16 if self.sock < 0:
22 self._qrtr.qrtr_close(self.sock)
30 err = _qrtr.qrtr_lookup(self.sock, srv, instance, ifilter,
37 err = _qrtr.qrtr_publish(self.sock, service, version, instance)
43 err = _qrtr.qrtr_new_server(self.sock, service, version, instance)
51 err = _qrtr.qrtr_remove_server(self.sock, *service)
57 err = _qrtr.qrtr_new_lookup(self.sock, service, version, instance)
63 err = _qrtr.qrtr_remove_lookup(self.sock, *lookup)
69 n = _qrtr.qrtr_sendto(self.sock, node, port, c_char_p(data), len(data))
[all …]
/device/linaro/dragonboard/shared/utils/qrtr/src/
Daddr.c29 int sock; in qrtr_set_address() local
33 sock = socket(AF_QIPCRTR, SOCK_DGRAM, 0); in qrtr_set_address()
34 if (sock < 0) in qrtr_set_address()
37 ret = getsockname(sock, (void*)&sq, &sl); in qrtr_set_address()
40 close(sock); in qrtr_set_address()
46 sock = socket(AF_NETLINK, SOCK_DGRAM, NETLINK_ROUTE); in qrtr_set_address()
47 if (sock < 0) in qrtr_set_address()
63 ret = send(sock, &req, req.nh.nlmsg_len, 0); in qrtr_set_address()
67 ret = recv(sock, &resp, sizeof(resp), 0); in qrtr_set_address()
76 close(sock); in qrtr_set_address()
Dns.c44 int sock; member
171 rc = sendto(ctx->sock, &cmsg, sizeof(cmsg), 0, in service_announce_new()
195 rc = sendto(ctx->sock, &cmsg, sizeof(cmsg), 0, in service_announce_del()
217 rc = sendto(ctx->sock, &pkt, sizeof(pkt), 0, in lookup_notify()
328 rc = sendto(ctx->sock, buf, len, 0, (void *)sq, sizeof(*sq)); in ctrl_cmd_hello()
371 rc = sendto(ctx->sock, &pkt, sizeof(pkt), 0, in ctrl_cmd_bye()
435 rc = sendto(ctx->sock, &pkt, sizeof(pkt), 0, in ctrl_cmd_del_client()
578 int sock = ctx->sock; in ctrl_port_fn() local
587 len = recvfrom(sock, buf, sizeof(buf), 0, (void *)&sq, &sl); in ctrl_port_fn()
590 close(sock); in ctrl_port_fn()
[all …]
Dlookup.c142 int sock; in main() local
165 sock = socket(AF_QIPCRTR, SOCK_DGRAM, 0); in main()
166 if (sock < 0) in main()
169 rc = getsockname(sock, (void *)&sq, &sl); in main()
180 rc = setsockopt(sock, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv)); in main()
184 rc = sendto(sock, &pkt, sizeof(pkt), 0, (void *)&sq, sizeof(sq)); in main()
190 while ((len = recv(sock, &pkt, sizeof(pkt), 0)) > 0) { in main()
236 close(sock); in main()
/device/linaro/dragonboard/shared/utils/rmtfs/
Drmtfs.c54 static void rmtfs_open(int sock, const struct qrtr_packet *pkt) in rmtfs_open() argument
95 ret = qrtr_sendto(sock, pkt->node, pkt->port, in rmtfs_open()
102 static void rmtfs_close(int sock, const struct qrtr_packet *pkt) in rmtfs_close() argument
141 ret = qrtr_sendto(sock, pkt->node, pkt->port, in rmtfs_close()
148 static void rmtfs_iovec(int sock, struct qrtr_packet *pkt) in rmtfs_iovec() argument
243 ret = qrtr_sendto(sock, pkt->node, pkt->port, in rmtfs_iovec()
250 static void rmtfs_alloc_buf(int sock, struct qrtr_packet *pkt) in rmtfs_alloc_buf() argument
292 ret = qrtr_sendto(sock, pkt->node, pkt->port, in rmtfs_alloc_buf()
299 static void rmtfs_get_dev_error(int sock, struct qrtr_packet *pkt) in rmtfs_get_dev_error() argument
338 ret = qrtr_sendto(sock, pkt->node, pkt->port, in rmtfs_get_dev_error()
[all …]
/device/google/cuttlefish/host/commands/tcp_connector/
Dmain.cpp92 cuttlefish::SharedFD sock; in main() local
93 OpenSocket(&sock, FLAGS_data_port); in main()
105 while (cuttlefish::WriteAll(sock, buf, read) == -1) { in main()
107 << sock->StrError(); in main()
110 OpenSocket(&sock, FLAGS_data_port); in main()
118 auto read = sock->Read(buf, sizeof(buf)); in main()
122 << sock->StrError(); in main()
125 OpenSocket(&sock, FLAGS_data_port); in main()
/device/google/cuttlefish/common/libs/fs/
Dshared_buf.cc99 bool SendAll(SharedFD sock, std::string_view msg) { in SendAll() argument
101 if (!sock->IsOpen()) { in SendAll()
105 auto just_written = sock->Send(msg.data() + total_written, in SendAll()
115 std::string RecvAll(SharedFD sock, const size_t count) { in RecvAll() argument
117 if (!sock->IsOpen()) { in RecvAll()
122 auto just_read = sock->Read(data.get() + total_read, count - total_read); in RecvAll()
Dshared_buf.h170 bool SendAll(SharedFD sock, std::string_view msg);
179 std::string RecvAll(SharedFD sock, const size_t count);
/device/google/cuttlefish/host/frontend/webrtc/doc/
Dinterface.dot3 audio_server [label = "internal/audio_server.sock", shape = "rectangle"]
5 confirmationui_sign [label = "internal/confui_sign.sock", shape = "rectangle"]
11 keyboard_server [label = "internal/keyboard.sock", shape = "rectangle"]
12 touch_server [label = "internal/touch_N.sock", shape = "rectangle"]
17 wayland_socket [label = "internal/frames.sock", shape = "rectangle"]
Dgraphics.dot10 wayland_socket [label = "internal/frames.sock", shape = "rectangle"]
/device/google/cuttlefish/host/commands/metrics/
Dutils.cc72 int sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_IP); in GetMacAddress() local
73 if (sock == -1) { in GetMacAddress()
82 if (ioctl(sock, SIOCGIFCONF, &ifc) == -1) { in GetMacAddress()
94 if (ioctl(sock, SIOCGIFFLAGS, &ifr) != 0) { in GetMacAddress()
101 if (ioctl(sock, SIOCGIFHWADDR, &ifr) == 0) { in GetMacAddress()
/device/linaro/poplar/wifi/wifi_hal/
Dwifi_hal.cpp118 void wifi_socket_set_local_port(struct nl_sock *sock, uint32_t port) in wifi_socket_set_local_port() argument
121 nl_socket_set_local_port(sock, pid + (port << 22)); in wifi_socket_set_local_port()
127 struct nl_sock *sock = nl_socket_alloc(); in wifi_create_nl_socket() local
128 if (sock == NULL) { in wifi_create_nl_socket()
133 wifi_socket_set_local_port(sock, port); in wifi_create_nl_socket()
139 if (nl_connect(sock, NETLINK_GENERIC)) { in wifi_create_nl_socket()
141 nl_socket_free(sock); in wifi_create_nl_socket()
154 return sock; in wifi_create_nl_socket()
/device/linaro/dragonboard/shared/utils/pd-mapper/
Dpd-mapper.c57 static void handle_get_domain_list(int sock, const struct qrtr_packet *pkt) in handle_get_domain_list() argument
113 ret = qrtr_sendto(sock, pkt->node, pkt->port, in handle_get_domain_list()
/device/google/cuttlefish/guest/hals/ril/reference-ril/
Dreference-ril.c553 int sock = socket(family, SOCK_DGRAM, 0); in set_Ip_Addr() local
554 if (sock == -1) { in set_Ip_Addr()
576 if (ioctl(sock, SIOCSIFADDR, &request) < 0) { in set_Ip_Addr()
580 if (ioctl(sock, SIOCSIFNETMASK, &request) < 0) { in set_Ip_Addr()
584 if (ioctl(sock, SIOGIFINDEX, &request) < 0) { in set_Ip_Addr()
597 if (ioctl(sock, SIOCSIFADDR, &req6) < 0) { in set_Ip_Addr()
602 close(sock); in set_Ip_Addr()
617 int sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_IP); in setInterfaceState() local
618 if (sock == -1) { in setInterfaceState()
627 status = ioctl(sock, SIOCGIFFLAGS, &request); in setInterfaceState()
[all …]
/device/google/cuttlefish/host/commands/modem_simulator/
Dchannel_monitor.h115 void OnClientSocketClosed(int sock);
/device/google/cuttlefish/host/commands/secure_env/doc/
Dlinkage.dot3 confirmationui_sign [color = "red", label = "internal/confui_sign.sock", shape = "rectangle"]
/device/google/cuttlefish/host/commands/run_cvd/doc/
Dlinkage.dot11 launcher_monitor_socket [label = "launcher_monitor.sock", shape = "rectangle"]
/device/google/cuttlefish_vmm/qemu/x86_64-linux-gnu/usr/share/qemu/
Dtrace-events-all490 ssh_co_yield(int sock, void *rd_handler, void *wr_handler) "s->sock=%d rd_handler=%p wr_handler=%p"
491 ssh_co_yield_back(int sock) "s->sock=%d - back"
506 curl_sock_cb(int action, int fd) "sock action %d on fd %d"
/device/google/cuttlefish_vmm/qemu/aarch64-linux-gnu/usr/share/qemu/
Dtrace-events-all490 ssh_co_yield(int sock, void *rd_handler, void *wr_handler) "s->sock=%d rd_handler=%p wr_handler=%p"
491 ssh_co_yield_back(int sock) "s->sock=%d - back"
506 curl_sock_cb(int action, int fd) "sock action %d on fd %d"