Home
last modified time | relevance | path

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

123

/system/ulib/zxs/
A Dzxs.cpp205 zx_status_t status = zxsio_txn(socket->socket, &msg); in zxs_close()
206 zx_handle_close(socket->socket); in zxs_close()
212 zx_status_t status = zxsio_op(socket->socket, ZXSIO_CONNECT, 0, 0, in zxs_connect()
239 return zxsio_op(socket->socket, ZXSIO_BIND, 0, 0, in zxs_bind()
244 return zxsio_op(socket->socket, ZXSIO_LISTEN, 0, 0, &backlog, in zxs_listen()
254 status = zx_socket_accept(socket->socket, in zxs_accept()
299 zx_status_t status = zxsio_op(socket->socket, ZXSIO_GETSOCKNAME, 0, in zxs_getsockname()
333 zx_status_t status = zxsio_op(socket->socket, ZXSIO_GETSOCKOPT, 0, in zxs_getsockopt()
377 status = zx_object_wait_one(socket->socket, in zxs_write()
413 status = zx_object_wait_one(socket->socket, in zxs_read()
[all …]
/system/ulib/zx/include/lib/zx/
A Dsocket.h13 class socket : public object<socket> {
17 constexpr socket() = default;
19 explicit socket(zx_handle_t value) : object(value) {} in socket() function
21 explicit socket(handle&& h) : object(h.release()) {} in socket() function
23 socket(socket&& other) : object(other.release()) {} in socket() function
25 socket& operator=(socket&& other) {
31 socket* endpoint1);
43 zx_status_t share(socket socket_to_share) const { in share()
47 zx_status_t accept(socket* out_socket) const { in accept()
50 socket result; in accept()
[all …]
/system/ulib/zxs/include/lib/zxs/
A Dzxs.h30 zx_handle_t socket; member
82 zx_status_t zxs_close(const zxs_socket_t* socket);
106 zx_status_t zxs_listen(const zxs_socket_t* socket, uint32_t backlog);
114 zx_status_t zxs_accept(const zxs_socket_t* socket, struct sockaddr* addr,
129 zx_status_t zxs_getsockopt(const zxs_socket_t* socket, int32_t level,
137 zx_status_t zxs_setsockopts(const zxs_socket_t* socket,
142 zx_status_t zxs_send(const zxs_socket_t* socket, const void* buffer,
146 zx_status_t zxs_recv(const zxs_socket_t* socket, void* buffer,
158 zx_status_t zxs_recvfrom(const zxs_socket_t* socket, struct sockaddr* addr,
173 zx_status_t zxs_recvmsg(const zxs_socket_t* socket, struct msghdr* msg,
[all …]
/system/utest/zxs/
A Dzxs-test.cpp238 fake->socket = { in SetUp()
247 zx_handle_close(fake->socket.socket); in TearDown()
257 zxs_socket_t* socket = &fake.socket; in connect_test() local
274 zxs_socket_t* socket = &fake.socket; in bind_test() local
291 zxs_socket_t* socket = &fake.socket; in getsockname_test() local
311 zxs_socket_t* socket = &fake.socket; in getpeername_test() local
331 zxs_socket_t* socket = &fake.socket; in sockopts_test() local
361 zxs_socket_t* socket = &fake.socket; in listen_accept_test() local
389 zxs_socket_t* socket = &fake.socket; in close_test() local
392 fake.socket.socket = ZX_HANDLE_INVALID; in close_test()
[all …]
/system/ulib/zxio/
A Dpipe.cpp14 zx_handle_t socket = pipe->socket; in zxio_pipe_release() local
15 pipe->socket = ZX_HANDLE_INVALID; in zxio_pipe_release()
16 *out_handle = socket; in zxio_pipe_release()
22 zx_handle_t socket = pipe->socket; in zxio_pipe_close() local
23 pipe->socket = ZX_HANDLE_INVALID; in zxio_pipe_close()
24 zx_handle_close(socket); in zxio_pipe_close()
38 *out_handle = pipe->socket; in zxio_pipe_wait_begin()
60 zx_status_t status = zx_socket_read(pipe->socket, 0, buffer, capacity, in zxio_pipe_read()
85 return zx_socket_write(pipe->socket, 0, buffer, capacity, out_actual); in zxio_pipe_write()
100 zx_status_t zxio_pipe_init(zxio_storage_t* storage, zx_handle_t socket) { in zxio_pipe_init() argument
[all …]
/system/ulib/fidl/
A Dtransport.cpp11 zx_status_t fidl_socket_write_control(zx_handle_t socket, const void* buffer, in fidl_socket_write_control() argument
14 zx_status_t status = zx_socket_write(socket, ZX_SOCKET_CONTROL, buffer, in fidl_socket_write_control()
21 status = zx_object_wait_one(socket, ZX_SOCKET_CONTROL_WRITABLE | ZX_SOCKET_PEER_CLOSED, in fidl_socket_write_control()
35 zx_status_t fidl_socket_read_control(zx_handle_t socket, void* buffer, in fidl_socket_read_control() argument
38 zx_status_t status = zx_socket_read(socket, ZX_SOCKET_CONTROL, buffer, in fidl_socket_read_control()
45 status = zx_object_wait_one(socket, ZX_SOCKET_CONTROL_READABLE | ZX_SOCKET_PEER_CLOSED, in fidl_socket_read_control()
60 zx_status_t fidl_socket_call_control(zx_handle_t socket, const void* buffer, in fidl_socket_call_control() argument
63 zx_status_t status = fidl_socket_write_control(socket, buffer, capacity); in fidl_socket_call_control()
67 return fidl_socket_read_control(socket, out_buffer, out_capacity, out_actual); in fidl_socket_call_control()
/system/ulib/zx/
A Dsocket.cpp11 zx_status_t socket::create(uint32_t flags, socket* endpoint0, in create()
12 socket* endpoint1) { in create()
15 socket h0; in create()
16 socket h1; in create()
/system/utest/syslog/
A Dsyslog_socket_tests.cpp82 zx::socket local, remote; in TestLogSimpleWrite()
94 zx::socket local, remote; in TestLogWrite()
106 zx::socket local, remote; in TestLogPreprocessedMessage()
115 static zx_status_t GetAvailableBytes(const zx::socket& socket, in GetAvailableBytes() argument
130 zx::socket local, remote; in TestLogSeverity()
149 zx::socket local, remote; in TestLogWriteWithTag()
162 zx::socket local, remote; in TestLogWriteWithGlobalTag()
176 zx::socket local, remote; in TestLogWriteWithMultiGlobalTag()
190 zx::socket local, remote; in TestLogFallback()
214 zx::socket local, remote; in TestMsgLengthLimit()
[all …]
/system/ulib/fdio/
A Dbsdsocket.c85 zxs_socket_t socket = {}; in socket() local
88 0u, &socket); in socket()
94 io = fdio_socket_create_datagram(socket.socket, 0); in socket()
96 io = fdio_socket_create_stream(socket.socket, 0); in socket()
122 const zxs_socket_t* socket = NULL; in connect() local
142 const zxs_socket_t* socket; in bind() local
155 const zxs_socket_t* socket; in listen() local
179 const zxs_socket_t* socket = NULL; in accept4() local
392 const zxs_socket_t* socket = NULL; in getsockname() local
413 const zxs_socket_t* socket = NULL; in getpeername() local
[all …]
A Dremoteio.c72 if (info->pipe.socket != ZX_HANDLE_INVALID) { in zxrio_object_extract_handle()
73 *out = info->pipe.socket; in zxrio_object_extract_handle()
158 handle_target = &info->extra.pipe.socket; in zxrio_decode_describe_handle()
374 zx_status_t fdio_from_socket(zx_handle_t socket, fdio_t** out_io) { in fdio_from_socket() argument
379 zx_handle_close(socket); in fdio_from_socket()
387 io = fdio_socket_create_datagram(socket, IOFLAG_SOCKET_CONNECTED); in fdio_from_socket()
389 io = fdio_socket_create_stream(socket, IOFLAG_SOCKET_CONNECTED); in fdio_from_socket()
393 io = fdio_pipe_create(socket); in fdio_from_socket()
470 if (info->pipe.socket == ZX_HANDLE_INVALID) { in fdio_from_handles()
475 return fdio_from_socket(info->pipe.socket, out); in fdio_from_handles()
[all …]
/system/host/bootserver/
A Dtftp.c96 int socket; member
108 struct pollfd poll_fds = {.fd = state->socket, in transport_send()
134 int flags = fcntl(state->socket, F_GETFL, 0); in transport_recv()
154 recv_result = recv(state->socket, data, len, 0); in transport_recv()
186 state->socket = socket(AF_INET6, SOCK_DGRAM, IPPROTO_UDP); in transport_init()
187 if (state->socket < 0) { in transport_init()
200 close(state->socket); in transport_init()
201 state->socket = -1; in transport_init()
223 .socket = -1, in tftp_xfer()
281 if (ts.socket >= 0) { in tftp_xfer()
[all …]
/system/ulib/fidl/include/lib/fidl/
A Dtransport.h16 zx_status_t fidl_socket_write_control(zx_handle_t socket, const void* buffer,
25 zx_status_t fidl_socket_read_control(zx_handle_t socket, void* buffer,
40 zx_status_t fidl_socket_call_control(zx_handle_t socket, const void* buffer,
/system/dev/misc/test/
A Dtest.cpp34 void TestSetOutputSocket(zx::socket socket);
35 void TestGetOutputSocket(zx::socket* out_socket);
43 zx::socket output_;
71 void TestDevice::TestSetOutputSocket(zx::socket socket) { in TestSetOutputSocket() argument
72 output_ = std::move(socket); in TestSetOutputSocket()
75 void TestDevice::TestGetOutputSocket(zx::socket* out_socket) { in TestGetOutputSocket()
99 zx::socket socket(raw_socket); in fidl_SetOutputSocket() local
101 dev->TestSetOutputSocket(std::move(socket)); in fidl_SetOutputSocket()
/system/ulib/syslog/
A Dlogger.cpp18 zx::socket connect_to_logger() { in connect_to_logger()
19 zx::socket invalid; in connect_to_logger()
27 zx::socket local, remote; in connect_to_logger()
28 if (zx::socket::create(ZX_SOCKET_DATAGRAM, &local, &remote) != ZX_OK) { in connect_to_logger()
34 req.socket = FIDL_HANDLE_PRESENT; in connect_to_logger()
97 zx::socket sock = connect_to_logger(); in fx_logger_create()
/system/banjo/ddk-protocol-test/
A Dtest.banjo22 /// Sets test output socket.
23 SetOutputSocket(handle<socket> @handle) -> ();
25 /// Gets test output socket.
26 GetOutputSocket() -> (handle<socket> h);
/system/utest/fidl-simple/
A Dfakesocket_tests.cpp27 zx_handle_t socket; member
35 return fidl_socket_write_control(conn->socket, msg->bytes, msg->num_bytes); in fidl_socket_reply()
70 .socket = wait->object, in fidl_socket_message_handler()
90 zx_status_t fidl_bind_socket(async_dispatcher_t* dispatcher, zx_handle_t socket, in fidl_bind_socket() argument
95 binding->wait.object = socket; in fidl_bind_socket()
127 zx::socket client, server; in basic_test()
128 ASSERT_EQ(ZX_OK, zx::socket::create(ZX_SOCKET_HAS_CONTROL, &client, &server)); in basic_test()
/system/host/netprotocol/
A Dnetcp.c41 int socket; member
106 struct pollfd poll_fds = {.fd = transport_info->socket, in transport_send()
117 send_result = sendto(transport_info->socket, data, len, 0, in transport_send()
121 send_result = send(transport_info->socket, data, len, 0); in transport_send()
135 int flags = fcntl(transport_info->socket, F_GETFL, 0); in transport_recv()
144 if (fcntl(transport_info->socket, F_SETFL, flags)) { in transport_recv()
151 recv_result = recvfrom(transport_info->socket, data, len, 0, in transport_recv()
155 recv_result = recv(transport_info->socket, data, len, 0); in transport_recv()
164 if (connect(transport_info->socket, (struct sockaddr*)&connection_addr, in transport_recv()
182 return setsockopt(transport_info->socket, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv)); in transport_timeout_set()
[all …]
/system/ulib/tftp/
A Dtftp-example.c44 int socket; member
61 …ssize_t send_result = sendto(connection->socket, data, len, 0, (struct sockaddr*)&connection->out_… in connection_send()
72 int fl = fcntl(connection->socket, F_GETFL, 0); in connection_receive()
84 int ret = fcntl(connection->socket, F_SETFL, fl); in connection_receive()
91 ssize_t recv_result = recvfrom(connection->socket, data, len, 0, in connection_receive()
111 return setsockopt(connection->socket, SOL_SOCKET, SO_RCVTIMEO, &tv, sizeof(tv)); in connection_set_timeout()
122 if ((connection->socket = socket(AF_INET, SOCK_DGRAM, 0)) < 0) { in create_connection()
142 …if (bind(connection->socket, (struct sockaddr*)&connection->in_addr, sizeof(struct sockaddr_in)) =… in create_connection()
151 if (connection->socket) close(connection->socket); in create_connection()
/system/dev/serial/serial/
A Dserial.c21 zx_handle_t socket; // socket used for communicating with our client member
53 items[WAIT_ITEM_SOCKET].handle = port->socket; in platform_serial_thread()
127 status = zx_socket_read(port->socket, 0, out_buffer + out_buffer_count, in platform_serial_thread()
144 zx_handle_close(port->socket); in platform_serial_thread()
146 port->socket = ZX_HANDLE_INVALID; in platform_serial_thread()
178 if (port->socket != ZX_HANDLE_INVALID) { in platform_serial_state_cb()
206 zx_handle_t socket = ZX_HANDLE_INVALID; in serial_port_open_socket() local
207 zx_status_t status = zx_socket_create(ZX_SOCKET_STREAM, &port->socket, &socket); in serial_port_open_socket()
233 *out_handle = socket; in serial_port_open_socket()
239 zx_handle_close(socket); in serial_port_open_socket()
[all …]
/system/utest/core/socket/
A Drules.mk14 $(LOCAL_DIR)/socket.c \
16 MODULE_NAME := socket-test
A Dsocket.c384 zx_handle_t socket[2]; in socket_peer_closed_signal() local
385 ASSERT_EQ(zx_socket_create(0, &socket[0], &socket[1]), ZX_OK, ""); in socket_peer_closed_signal()
396 zx_handle_t socket[2]; in socket_peer_closed_set_property() local
397 ASSERT_EQ(zx_socket_create(0, &socket[0], &socket[1]), ZX_OK, ""); in socket_peer_closed_set_property()
1130 zx_handle_t socket[2]; in socket_share_invalid_handle() local
1131 zx_status_t status = zx_socket_create(0, &socket[0], &socket[1]); in socket_share_invalid_handle()
1146 zx_handle_t socket[2]; in socket_zero_size() local
1147 zx_status_t status = zx_socket_create(0, &socket[0], &socket[1]); in socket_zero_size()
1163 status = zx_socket_create(ZX_SOCKET_DATAGRAM, &socket[0], &socket[1]); in socket_zero_size()
1184 zx_handle_t socket[2]; in socket_share_consumes_on_failure() local
[all …]
/system/utest/kernel-unittests/
A Dkernel-unittests.cpp32 zx::socket local, remote; in run_kernel_unittests()
33 ASSERT_EQ(zx::socket::create(0, &local, &remote), ZX_OK); in run_kernel_unittests()
/system/utest/libzx/
A Dtraits.cpp244 zx::socket socket, socket2; in traits_test() local
245 ASSERT_EQ(zx::socket::create(0u, &socket, &socket2), ZX_OK); in traits_test()
246 duplicating(socket); in traits_test()
247 user_signaling(socket); in traits_test()
248 waiting(socket); in traits_test()
249 peering(socket); in traits_test()
/system/utest/ethernet/
A Dethernet.cpp516 zx::socket sock; in EthernetStartTest()
558 zx::socket sock; in EthernetLinkStatusTest()
593 zx::socket sock; in EthernetSetPromiscMultiClientTest()
622 zx::socket sock; in EthernetSetPromiscClearOnCloseTest()
652 zx::socket sock; in EthernetClearMulticastPromiscTest()
667 zx::socket sock; in EthernetMulticastRejectsUnicastAddress()
683 zx::socket sock; in EthernetMulticastSetsAddresses()
710 zx::socket sock; in EthernetMulticastPromiscOnOverflow()
760 zx::socket sock; in EthernetSetMulticastPromiscMultiClientTest()
791 zx::socket sock; in EthernetSetMulticastPromiscClearOnCloseTest()
[all …]
/system/utest/driver-tests/
A Dmain.cpp35 const char* drv_libname, const zx::socket& output, in do_one_test()
103 zx::socket output_copy; in do_one_test()
131 zx::socket h(static_cast<zx_handle_t>(reinterpret_cast<uintptr_t>(arg))); in output_thread()
168 zx::socket local_socket, remote_socket; in main()
169 status = zx::socket::create(0u, &local_socket, &remote_socket); in main()

Completed in 75 milliseconds

123