Home
last modified time | relevance | path

Searched refs:transport (Results 1 – 25 of 309) sorted by relevance

12345678910>>...13

/Zephyr-latest/include/zephyr/drivers/firmware/scmi/
Dtransport.h73 int (*init)(const struct device *transport);
74 int (*send_message)(const struct device *transport,
77 int (*setup_chan)(const struct device *transport,
80 int (*read_message)(const struct device *transport,
83 bool (*channel_is_free)(const struct device *transport,
85 struct scmi_channel *(*request_channel)(const struct device *transport,
110 scmi_transport_request_channel(const struct device *transport, in scmi_transport_request_channel() argument
114 (const struct scmi_transport_api *)transport->api; in scmi_transport_request_channel()
117 return api->request_channel(transport, proto, tx); in scmi_transport_request_channel()
142 static inline int scmi_transport_init(const struct device *transport) in scmi_transport_init() argument
[all …]
/Zephyr-latest/subsys/net/lib/mqtt/
Dmqtt_transport_websocket.c33 if (client->transport.type == MQTT_TRANSPORT_NON_SECURE_WEBSOCKET) { in mqtt_client_websocket_connect()
39 transport_sock = client->transport.tcp.sock; in mqtt_client_websocket_connect()
42 else if (client->transport.type == MQTT_TRANSPORT_SECURE_WEBSOCKET) { in mqtt_client_websocket_connect()
48 transport_sock = client->transport.tls.sock; in mqtt_client_websocket_connect()
55 if (client->transport.websocket.config.url == NULL) { in mqtt_client_websocket_connect()
56 client->transport.websocket.config.url = "/mqtt"; in mqtt_client_websocket_connect()
59 if (client->transport.websocket.config.host == NULL) { in mqtt_client_websocket_connect()
60 client->transport.websocket.config.host = "localhost"; in mqtt_client_websocket_connect()
69 client->transport.websocket.config.optional_headers = extra_headers; in mqtt_client_websocket_connect()
71 client->transport.websocket.sock = websocket_connect( in mqtt_client_websocket_connect()
[all …]
Dmqtt_transport_socket_tls.c24 struct mqtt_sec_config *tls_config = &client->transport.tls.config; in mqtt_client_tls_connect()
27 client->transport.tls.sock = zsock_socket(broker->sa_family, in mqtt_client_tls_connect()
29 if (client->transport.tls.sock < 0) { in mqtt_client_tls_connect()
33 NET_DBG("Created socket %d", client->transport.tls.sock); in mqtt_client_tls_connect()
36 if (client->transport.proxy.addrlen != 0) { in mqtt_client_tls_connect()
37 ret = setsockopt(client->transport.tls.sock, in mqtt_client_tls_connect()
39 &client->transport.proxy.addr, in mqtt_client_tls_connect()
40 client->transport.proxy.addrlen); in mqtt_client_tls_connect()
47 ret = zsock_setsockopt(client->transport.tls.sock, SOL_TLS, TLS_PEER_VERIFY, in mqtt_client_tls_connect()
55 ret = zsock_setsockopt(client->transport.tls.sock, SOL_TLS, in mqtt_client_tls_connect()
[all …]
Dmqtt_transport_socket_tcp.c26 client->transport.tcp.sock = zsock_socket(broker->sa_family, SOCK_STREAM, in mqtt_client_tcp_connect()
28 if (client->transport.tcp.sock < 0) { in mqtt_client_tcp_connect()
33 if (client->transport.proxy.addrlen != 0) { in mqtt_client_tcp_connect()
34 ret = setsockopt(client->transport.tcp.sock, in mqtt_client_tcp_connect()
36 &client->transport.proxy.addr, in mqtt_client_tcp_connect()
37 client->transport.proxy.addrlen); in mqtt_client_tcp_connect()
44 NET_DBG("Created socket %d", client->transport.tcp.sock); in mqtt_client_tcp_connect()
52 ret = zsock_connect(client->transport.tcp.sock, client->broker, in mqtt_client_tcp_connect()
62 (void)zsock_close(client->transport.tcp.sock); in mqtt_client_tcp_connect()
73 ret = zsock_send(client->transport.tcp.sock, data + offset, in mqtt_client_tcp_write()
[all …]
Dmqtt_transport.c63 return transport_fn[client->transport.type].connect(client); in mqtt_transport_connect()
69 return transport_fn[client->transport.type].write(client, data, in mqtt_transport_write()
76 return transport_fn[client->transport.type].write_msg(client, message); in mqtt_transport_write_msg()
82 return transport_fn[client->transport.type].read(client, data, buflen, in mqtt_transport_read()
88 return transport_fn[client->transport.type].disconnect(client); in mqtt_transport_disconnect()
/Zephyr-latest/drivers/firmware/scmi/
Dcore.c52 static int scmi_core_setup_chan(const struct device *transport, in scmi_core_setup_chan() argument
76 ret = scmi_transport_setup_chan(transport, chan, tx); in scmi_core_setup_chan()
96 ret = scmi_transport_send_message(proto->transport, proto->tx, msg); in scmi_send_message_pre_kernel()
108 while (!scmi_transport_channel_is_free(proto->transport, proto->tx)) { in scmi_send_message_pre_kernel()
111 ret = scmi_transport_read_message(proto->transport, proto->tx, reply); in scmi_send_message_pre_kernel()
136 ret = scmi_transport_send_message(proto->transport, proto->tx, msg); in scmi_send_message_post_kernel()
149 ret = scmi_transport_read_message(proto->transport, proto->tx, reply); in scmi_send_message_post_kernel()
179 static int scmi_core_protocol_setup(const struct device *transport) in scmi_core_protocol_setup() argument
184 it->transport = transport; in scmi_core_protocol_setup()
188 it->tx = scmi_transport_request_channel(transport, it->id, true); in scmi_core_protocol_setup()
[all …]
DKconfig14 bool "SCMI transport based on shared memory and doorbells"
20 Enable support for SCMI transport based on shared memory
54 Enable this if the SCMI transport layer uses static channels.
57 transport layer drivers which can use the default channel
62 int "SCMI transport layer initialization priority"
65 SCMI transport driver device initialization priority.
Dmailbox.c24 static int scmi_mbox_send_message(const struct device *transport, in scmi_mbox_send_message() argument
48 static int scmi_mbox_read_message(const struct device *transport, in scmi_mbox_read_message() argument
59 static bool scmi_mbox_channel_is_free(const struct device *transport, in scmi_mbox_channel_is_free() argument
68 static int scmi_mbox_setup_chan(const struct device *transport, in scmi_mbox_setup_chan() argument
/Zephyr-latest/samples/modules/thrift/hello/client/
Dhello_client.py22 from thrift.transport import TSocket, TTransport
36 transport = TSocket.TSocket(args.ip, 4242)
37 transport = TTransport.TBufferedTransport(transport)
38 protocol = TBinaryProtocol.TBinaryProtocol(transport)
41 transport.open()
52 transport.close()
/Zephyr-latest/subsys/shell/backends/
Dshell_dummy.c16 static int init(const struct shell_transport *transport, in init() argument
21 struct shell_dummy *sh_dummy = (struct shell_dummy *)transport->ctx; in init()
32 static int uninit(const struct shell_transport *transport) in uninit() argument
34 struct shell_dummy *sh_dummy = (struct shell_dummy *)transport->ctx; in uninit()
45 static int enable(const struct shell_transport *transport, bool blocking) in enable() argument
47 struct shell_dummy *sh_dummy = (struct shell_dummy *)transport->ctx; in enable()
56 static int write(const struct shell_transport *transport, in write() argument
59 struct shell_dummy *sh_dummy = (struct shell_dummy *)transport->ctx; in write()
79 static int read(const struct shell_transport *transport, in read() argument
82 struct shell_dummy *sh_dummy = (struct shell_dummy *)transport->ctx; in read()
Dshell_rpmsg.c17 const struct shell_transport *transport = (const struct shell_transport *)priv; in rpmsg_shell_cb() local
18 struct shell_rpmsg *sh_rpmsg = (struct shell_rpmsg *)transport->ctx; in rpmsg_shell_cb()
37 static int uninit(const struct shell_transport *transport) in uninit() argument
39 struct shell_rpmsg *sh_rpmsg = (struct shell_rpmsg *)transport->ctx; in uninit()
51 static int init(const struct shell_transport *transport, in init() argument
56 struct shell_rpmsg *sh_rpmsg = (struct shell_rpmsg *)transport->ctx; in init()
79 sh_rpmsg->ept.priv = (void *)transport; in init()
88 static int enable(const struct shell_transport *transport, bool blocking) in enable() argument
90 struct shell_rpmsg *sh_rpmsg = (struct shell_rpmsg *)transport->ctx; in enable()
101 static int write(const struct shell_transport *transport, in write() argument
[all …]
Dshell_adsp_memory_window.c40 static int init(const struct shell_transport *transport, in init() argument
46 (struct shell_adsp_memory_window *)transport->ctx; in init()
76 static int uninit(const struct shell_transport *transport) in uninit() argument
79 (struct shell_adsp_memory_window *)transport->ctx; in uninit()
86 static int enable(const struct shell_transport *transport, bool blocking) in enable() argument
91 static int write(const struct shell_transport *transport, in write() argument
95 (struct shell_adsp_memory_window *)transport->ctx; in write()
103 static int read(const struct shell_transport *transport, in read() argument
107 (struct shell_adsp_memory_window *)transport->ctx; in read()
Dshell_rtt.c46 static int init(const struct shell_transport *transport, in init() argument
51 struct shell_rtt *sh_rtt = (struct shell_rtt *)transport->ctx; in init()
74 static int uninit(const struct shell_transport *transport) in uninit() argument
76 struct shell_rtt *sh_rtt = (struct shell_rtt *)transport->ctx; in uninit()
83 static int enable(const struct shell_transport *transport, bool blocking) in enable() argument
85 struct shell_rtt *sh_rtt = (struct shell_rtt *)transport->ctx; in enable()
137 static int write(const struct shell_transport *transport, in write() argument
140 struct shell_rtt *sh_rtt = (struct shell_rtt *)transport->ctx; in write()
170 static int read(const struct shell_transport *transport, in read() argument
Dshell_uart.c287 static int init(const struct shell_transport *transport, in init() argument
292 struct shell_uart_common *common = (struct shell_uart_common *)transport->ctx; in init()
304 async_init((struct shell_uart_async *)transport->ctx); in init()
306 irq_init((struct shell_uart_int_driven *)transport->ctx); in init()
308 polling_init((struct shell_uart_polling *)transport->ctx); in init()
332 static int uninit(const struct shell_transport *transport) in uninit() argument
335 async_uninit((struct shell_uart_async *)transport->ctx); in uninit()
337 irq_uninit((struct shell_uart_int_driven *)transport->ctx); in uninit()
339 polling_uninit((struct shell_uart_polling *)transport->ctx); in uninit()
345 static int enable(const struct shell_transport *transport, bool blocking_tx) in enable() argument
[all …]
Dshell_websocket.c228 static int init(const struct shell_transport *transport, in init() argument
235 ws = (struct shell_websocket *)transport->ctx; in init()
251 static int uninit(const struct shell_transport *transport) in uninit() argument
253 ARG_UNUSED(transport); in uninit()
258 static int enable(const struct shell_transport *transport, bool blocking) in enable() argument
260 ARG_UNUSED(transport); in enable()
266 static int sh_write(const struct shell_transport *transport, in sh_write() argument
276 ws = (struct shell_websocket *)transport->ctx; in sh_write()
328 static int sh_read(const struct shell_transport *transport, in sh_read() argument
334 ws = (struct shell_websocket *)transport->ctx; in sh_read()
/Zephyr-latest/modules/thrift/src/thrift/server/
DTSimpleServer.h47 const std::shared_ptr<apache::thrift::transport::TServerTransport> &serverTransport,
48 const std::shared_ptr<apache::thrift::transport::TTransportFactory>
54 const std::shared_ptr<apache::thrift::transport::TServerTransport> &serverTransport,
55 const std::shared_ptr<apache::thrift::transport::TTransportFactory>
61 const std::shared_ptr<apache::thrift::transport::TServerTransport> &serverTransport,
62 const std::shared_ptr<apache::thrift::transport::TTransportFactory>
64 const std::shared_ptr<apache::thrift::transport::TTransportFactory>
73 const std::shared_ptr<apache::thrift::transport::TServerTransport> &serverTransport,
74 const std::shared_ptr<apache::thrift::transport::TTransportFactory>
76 const std::shared_ptr<apache::thrift::transport::TTransportFactory>
DTServerFramework.h60 const std::shared_ptr<apache::thrift::transport::TServerTransport> &serverTransport,
61 const std::shared_ptr<apache::thrift::transport::TTransportFactory>
67 const std::shared_ptr<apache::thrift::transport::TServerTransport> &serverTransport,
68 const std::shared_ptr<apache::thrift::transport::TTransportFactory>
74 const std::shared_ptr<apache::thrift::transport::TServerTransport> &serverTransport,
75 const std::shared_ptr<apache::thrift::transport::TTransportFactory>
77 const std::shared_ptr<apache::thrift::transport::TTransportFactory>
86 const std::shared_ptr<apache::thrift::transport::TServerTransport> &serverTransport,
87 const std::shared_ptr<apache::thrift::transport::TTransportFactory>
89 const std::shared_ptr<apache::thrift::transport::TTransportFactory>
/Zephyr-latest/modules/thrift/
DCMakeLists.txt19 ${ZEPHYR_THRIFT_MODULE_DIR}/lib/cpp/src/thrift/transport/SocketCommon.cpp
20 ${ZEPHYR_THRIFT_MODULE_DIR}/lib/cpp/src/thrift/transport/TBufferTransports.cpp
21 ${ZEPHYR_THRIFT_MODULE_DIR}/lib/cpp/src/thrift/transport/TFDTransport.cpp
22 ${ZEPHYR_THRIFT_MODULE_DIR}/lib/cpp/src/thrift/transport/TTransportException.cpp
23 ${ZEPHYR_THRIFT_MODULE_DIR}/lib/cpp/src/thrift/transport/TServerSocket.cpp
24 ${ZEPHYR_THRIFT_MODULE_DIR}/lib/cpp/src/thrift/transport/TSocket.cpp
35 src/thrift/transport/TSSLSocket.cpp
36 src/thrift/transport/TSSLServerSocket.cpp
/Zephyr-latest/samples/modules/thrift/hello/client/src/
Dmain.cpp26 using namespace apache::thrift::transport;
69 std::shared_ptr<TTransport> transport; in main() local
107 transport = std::make_shared<TBufferedTransport>(trans); in main()
110 protocol = std::make_shared<TCompactProtocol>(transport); in main()
112 protocol = std::make_shared<TBinaryProtocol>(transport); in main()
118 transport->open(); in main()
126 transport->close(); in main()
/Zephyr-latest/tests/bluetooth/classic/sdp_c/
DREADME.rst21 The HCI transport for ``bumble`` can be configured as follows:
24 a ``:`` (i.e. specify fixture ``usb_hci:usb:0`` to use the ``usb:0`` as hci transport for
26 * The configuration context can be overridden using the `hci transport`_ can be provided using the
27 ``--hci-transport`` test suite argument (i.e. run ``twister`` with the
28 ``--pytest-args=--hci-transport=usb:0`` argument to use the ``usb:0`` as hci transport for
39 On the host PC, a HCI transport needs to be required. Refer to `bumble platforms`_ page of
43 the HCI transport would be USB transport interface ``usb:<index>``.
45 If the HCI transport is ``usb:0`` and debug console port is ``COM4``, the test suite can be
55 Running the test suite on hardware requires a HCI transport connected to the host PC.
67 .. _hci transport:
/Zephyr-latest/subsys/mgmt/mcumgr/transport/
DKconfig5 # The Kconfig file is dedicated to transport subdirectory of MCUmgr
7 # transport, in general, that are not otherwise controlled by
8 # options belonging to transport specifically.
11 # MCUMGR_TRANSPORT_ -- general transport options;
16 int "MCUmgr transport workqueue stack size"
19 Stack size of the MCUmgr for transport subsystem work queue.
22 int "MCUmgr transport workqueue thread priority"
25 Scheduling priority of the MCUmgr transport subsystem work queue.
47 MCUMGR_TRANSPORT_NETBUF_SIZE >= transport-specific-MTU + transport-overhead
DKconfig.shell5 # The Kconfig file is dedicated to shell transport of MCUmgr
7 # the transport.
13 bool "Shell mcumgr SMP transport"
41 received via the shell transport after a given time. This prevents
51 transport before considering it as timed out and returning the shell
/Zephyr-latest/include/zephyr/net/
Dmqtt_sn.h176 int (*init)(struct mqtt_sn_transport *transport);
183 void (*deinit)(struct mqtt_sn_transport *transport);
237 #define UDP_TRANSPORT(transport) CONTAINER_OF(transport, struct mqtt_sn_transport_udp, tp) argument
274 struct mqtt_sn_transport *transport; member
337 struct mqtt_sn_transport *transport, mqtt_sn_evt_cb_t evt_cb, void *tx,
/Zephyr-latest/samples/net/mqtt_publisher/src/
Dmain.c111 if (client->transport.type == MQTT_TRANSPORT_NON_SECURE) { in prepare_fds()
112 fds[0].fd = client->transport.tcp.sock; in prepare_fds()
115 else if (client->transport.type == MQTT_TRANSPORT_SECURE) { in prepare_fds()
116 fds[0].fd = client->transport.tls.sock; in prepare_fds()
322 client->transport.type = MQTT_TRANSPORT_SECURE_WEBSOCKET; in client_init()
324 client->transport.type = MQTT_TRANSPORT_SECURE; in client_init()
327 struct mqtt_sec_config *tls_config = &client->transport.tls.config; in client_init()
341 client->transport.type = MQTT_TRANSPORT_NON_SECURE_WEBSOCKET; in client_init()
343 client->transport.type = MQTT_TRANSPORT_NON_SECURE; in client_init()
348 client->transport.websocket.config.host = SERVER_ADDR; in client_init()
[all …]
/Zephyr-latest/tests/modules/thrift/ThriftTest/src/
Dmain.cpp26 using namespace apache::thrift::transport;
62 std::shared_ptr<TTransport> transport; in setup_client() local
76 transport = std::make_shared<TBufferedTransport>(trans); in setup_client()
79 protocol = std::make_shared<TCompactProtocol>(transport); in setup_client()
81 protocol = std::make_shared<TBinaryProtocol>(transport); in setup_client()
83 transport->open(); in setup_client()

12345678910>>...13