Home
last modified time | relevance | path

Searched refs:transport (Results 1 – 25 of 304) 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
47 Enable this if the SCMI transport layer uses static channels.
50 transport layer drivers which can use the default channel
55 int "SCMI transport layer initialization priority"
58 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/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/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.c231 static int init(const struct shell_transport *transport, in init() argument
238 ws = (struct shell_websocket *)transport->ctx; in init()
254 static int uninit(const struct shell_transport *transport) in uninit() argument
256 ARG_UNUSED(transport); in uninit()
261 static int enable(const struct shell_transport *transport, bool blocking) in enable() argument
263 ARG_UNUSED(transport); in enable()
269 static int sh_write(const struct shell_transport *transport, in sh_write() argument
279 ws = (struct shell_websocket *)transport->ctx; in sh_write()
331 static int sh_read(const struct shell_transport *transport, in sh_read() argument
337 ws = (struct shell_websocket *)transport->ctx; in sh_read()
/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/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()
/Zephyr-latest/tests/subsys/mgmt/mcumgr/cb_notifications/
DCMakeLists.txt16 …directories(app PRIVATE ${ZEPHYR_BASE}/subsys/mgmt/mcumgr/transport/include/mgmt/mcumgr/transport/)

12345678910>>...13