| /trusty/kernel/app/list-ports/ |
| D | main.c | 38 struct ipc_port* port = port_list + port_idx; in TEST() local
40 trusty_unittest_printf("|%.64s|", port->path); in TEST()
42 if (port->flags & IPC_PORT_ALLOW_TA_CONNECT) { in TEST()
48 if (port->flags & IPC_PORT_ALLOW_NS_CONNECT) { in TEST()
55 if (port->state == IPC_PORT_STATE_INVALID) { in TEST()
57 } else if (port->state == IPC_PORT_STATE_LISTENING) { in TEST()
63 trusty_unittest_printf("%.12u|", port->num_recv_bufs); in TEST()
64 trusty_unittest_printf("%.12zu|", port->recv_buf_size); in TEST()
|
| /trusty/kernel/lib/shared/binder_discover/ |
| D | binder_discover.cpp | 38 std::string port; member
42 DiscoveryTreeNode(std::string&& port) in DiscoveryTreeNode()
43 : node(BST_NODE_INITIAL_VALUE), port(std::move(port)) {} in DiscoveryTreeNode()
44 DiscoveryTreeNode(std::string&& port, in DiscoveryTreeNode()
46 : node(BST_NODE_INITIAL_VALUE), port(std::move(port)), binder(ib) {} in DiscoveryTreeNode()
51 return nodea->port.compare(nodeb->port); in compare_by_port()
72 int binder_discover_get_service(const char* port, in binder_discover_get_service() argument
76 DiscoveryTreeNode key{port}; in binder_discover_get_service()
91 int srv_fd = connect(port, IPC_CONNECT_WAIT_FOR_PORT); in binder_discover_get_service()
108 int binder_discover_add_service(const char* port, in binder_discover_add_service() argument
[all …]
|
| /trusty/user/base/lib/tipc/ |
| D | tipc_srv.c | 50 struct port_ctx* port; member
88 struct tipc_srv* srv = chan->port->srv; in tipc_chan_close()
134 struct tipc_srv* srv = chan->port->srv; in chan_event_handler_proc()
143 rc = srv->ops->on_message(chan->port->cfg, chan->handle, in chan_event_handler_proc()
160 srv->ops->on_disconnect(chan->port->cfg, chan->handle, in chan_event_handler_proc()
170 rc = srv->ops->on_send_unblocked(chan->port->cfg, chan->handle, in chan_event_handler_proc()
210 static void handle_connect(struct port_ctx* port) { in handle_connect() argument
216 struct tipc_srv* srv = port->srv; in handle_connect()
218 TLOGD("Incoming connection on %s\n", port->cfg->name); in handle_connect()
221 rc = accept(port->handle, &peer); in handle_connect()
[all …]
|
| /trusty/kernel/lib/vmm_obj_service/ |
| D | vmm_obj_service.c | 34 struct ktipc_port port; member
39 int vmm_obj_service_create_ro(const char* port, in vmm_obj_service_create_ro() argument
83 srv->port.name = port; in vmm_obj_service_create_ro()
84 srv->port.uuid = &kernel_uuid; in vmm_obj_service_create_ro()
85 srv->port.msg_max_size = sizeof(uint64_t); in vmm_obj_service_create_ro()
86 srv->port.msg_queue_len = 1; in vmm_obj_service_create_ro()
87 srv->port.acl = acl; in vmm_obj_service_create_ro()
115 static int vmm_obj_service_handle_msg(const struct ktipc_port* port, in vmm_obj_service_handle_msg() argument
122 static int vmm_obj_service_handle_connect(const struct ktipc_port* port, in vmm_obj_service_handle_connect() argument
127 containerof(port, struct vmm_obj_service, port); in vmm_obj_service_handle_connect()
[all …]
|
| /trusty/kernel/lib/ktipc/ |
| D | ktipc.c | 49 const struct ktipc_port* port; member
56 const struct ktipc_port* port; member
99 rc = kchan->ops->on_message(kchan->port, kchan->href.handle, in chan_event_handler()
115 kchan->ops->on_disconnect(kchan->port, kchan->href.handle, in chan_event_handler()
126 rc = kchan->ops->on_send_unblocked(kchan->port, kchan->href.handle, in chan_event_handler()
177 TRACEF("failed (%d) to accept on port %s\n", rc, kport->port->name); in handle_connect()
182 if (!client_is_allowed(kport->port->acl, peer)) { in handle_connect()
183 TRACEF("access denied on port %s\n", kport->port->name); in handle_connect()
189 TRACEF("oom handling connect on port %s\n", kport->port->name); in handle_connect()
195 kchan->port = kport->port; in handle_connect()
[all …]
|
| /trusty/user/base/app/metrics/ |
| D | client.h | 36 static inline void set_srv_state(struct tipc_port* port, in set_srv_state() argument
38 port->priv = state; in set_srv_state()
41 static inline struct srv_state* get_srv_state(const struct tipc_port* port) { in get_srv_state() argument
42 return (struct srv_state*)(port->priv); in get_srv_state()
|
| D | consumer.c | 44 static int on_connect(const struct tipc_port* port, in on_connect() argument
49 struct srv_state* state = get_srv_state(port); in on_connect()
62 static int on_message(const struct tipc_port* port, handle_t chan, void* ctx) { in on_message() argument
75 struct srv_state* state = get_srv_state(port); in on_message()
111 static struct tipc_port port = { in add_metrics_consumer_service() local
121 set_srv_state(&port, state); in add_metrics_consumer_service()
123 return tipc_add_service(hset, &port, 1, MAX_METRICS_TA_CONNECTIONS, &ops); in add_metrics_consumer_service()
|
| /trusty/kernel/lib/trusty/ |
| D | ipc.c | 67 static int port_attach_client(struct ipc_port* port, struct ipc_chan* client);
198 struct ipc_port* port; in ipc_get_port_list() local
207 list_for_every_entry(&ipc_port_list, port, struct ipc_port, node) { in ipc_get_port_list()
208 memcpy(current_port, port, sizeof(struct ipc_port)); in ipc_get_port_list()
254 struct ipc_port* port = containerof(phandle, struct ipc_port, handle); in port_shutdown() local
256 LTRACEF("shutting down port %p\n", port); in port_shutdown()
260 if (list_in_list(&port->node)) { in port_shutdown()
261 list_delete(&port->node); in port_shutdown()
265 is_startup_port = trusty_app_is_startup_port(port->path); in port_shutdown()
269 list_for_every_entry_safe(&port->pending_list, server, temp, in port_shutdown()
[all …]
|
| /trusty/kernel/lib/shared/binder_discover/include/lib/shared/binder_discover/ |
| D | binder_discover.h | 36 int binder_discover_get_service(const char* port,
47 int binder_discover_add_service(const char* port,
58 int binder_discover_remove_service(const char* port);
|
| /trusty/user/base/lib/tipc/include/lib/tipc/ |
| D | tipc_srv.h | 145 int (*on_connect)(const struct tipc_port* port,
150 int (*on_message)(const struct tipc_port* port, handle_t chan, void* ctx);
152 void (*on_disconnect)(const struct tipc_port* port,
158 int (*on_send_unblocked)(const struct tipc_port* port,
|
| /trusty/user/base/app/line-coverage/ |
| D | coverage.h | 46 static inline void set_srv_state(struct tipc_port* port, in set_srv_state() argument
48 port->priv = state; in set_srv_state()
51 static inline struct srv_state* get_srv_state(const struct tipc_port* port) { in get_srv_state() argument
52 return (struct srv_state*)(port->priv); in get_srv_state()
|
| D | aggregator.c | 76 static int on_connect(const struct tipc_port* port, in on_connect() argument
82 struct srv_state* state = get_srv_state(port); in on_connect()
107 static int on_message(const struct tipc_port* port, handle_t chan, void* ctx) { in on_message() argument
111 struct srv_state* state = get_srv_state(port); in on_message()
139 static struct tipc_port port = { in coverage_aggregator_init() local
152 set_srv_state(&port, state); in coverage_aggregator_init()
154 return tipc_add_service(state->hset, &port, 1, MAX_NUM_APPS, &ops); in coverage_aggregator_init()
|
| D | client.c | 143 static int on_connect(const struct tipc_port* port, in on_connect() argument
153 struct srv_state* state = get_srv_state(port); in on_connect()
160 static int on_message(const struct tipc_port* port, handle_t chan, void* _ctx) { in on_message() argument
165 struct srv_state* state = get_srv_state(port); in on_message()
199 static struct tipc_port port = { in coverage_client_init() local
211 set_srv_state(&port, state); in coverage_client_init()
213 return tipc_add_service(state->hset, &port, 1, 1, &ops); in coverage_client_init()
|
| /trusty/user/base/app/coverage/ |
| D | coverage.h | 46 static inline void set_srv_state(struct tipc_port* port, in set_srv_state() argument
48 port->priv = state; in set_srv_state()
51 static inline struct srv_state* get_srv_state(const struct tipc_port* port) { in get_srv_state() argument
52 return (struct srv_state*)(port->priv); in get_srv_state()
|
| D | aggregator.c | 74 static int on_connect(const struct tipc_port* port, in on_connect() argument
80 struct srv_state* state = get_srv_state(port); in on_connect()
105 static int on_message(const struct tipc_port* port, handle_t chan, void* ctx) { in on_message() argument
109 struct srv_state* state = get_srv_state(port); in on_message()
137 static struct tipc_port port = { in coverage_aggregator_init() local
150 set_srv_state(&port, state); in coverage_aggregator_init()
152 return tipc_add_service(state->hset, &port, 1, MAX_NUM_APPS, &ops); in coverage_aggregator_init()
|
| D | client.c | 95 static int on_connect(const struct tipc_port* port, in on_connect() argument
110 static int on_message(const struct tipc_port* port, handle_t chan, void* _ctx) { in on_message() argument
115 struct srv_state* state = get_srv_state(port); in on_message()
146 static struct tipc_port port = { in coverage_client_init() local
159 set_srv_state(&port, state); in coverage_client_init()
161 return tipc_add_service(state->hset, &port, 1, 1, &ops); in coverage_client_init()
|
| /trusty/user/base/lib/secure_fb/srv/ |
| D | secure_fb_server.c | 71 static int secure_fb_on_connect(const struct tipc_port* port, in secure_fb_on_connect() argument
81 ctx->ops = (const struct secure_fb_impl_ops*)port->priv; in secure_fb_on_connect()
188 static int secure_fb_on_message(const struct tipc_port* port, in secure_fb_on_message() argument
272 struct tipc_port* port = calloc(num_ops, sizeof(struct tipc_port)); in add_secure_fb_service() local
273 if (port == NULL) { in add_secure_fb_service()
288 port[i].name = port_name; in add_secure_fb_service()
289 port[i].msg_max_size = 1024; in add_secure_fb_service()
290 port[i].msg_queue_len = 1; in add_secure_fb_service()
291 port[i].acl = &acl; in add_secure_fb_service()
292 port[i].priv = (void*)&impl_ops[i]; in add_secure_fb_service()
[all …]
|
| /trusty/user/app/sample/app-mgmt-test/client/ |
| D | rules.mk | 26 PORT_START_APP := $(TRUSTY_APP_BUILDDIR)/trusty/user/app/sample/app-mgmt-test/port-start-srv/port-…
27 … := $(TRUSTY_APP_BUILDDIR)/trusty/user/app/sample/app-mgmt-test/port-start-fail-srv/port-start-fai…
29 PORT_WAITER_APP := $(TRUSTY_APP_BUILDDIR)/trusty/user/app/sample/app-mgmt-test/port-waiter-srv/port…
|
| /trusty/user/base/lib/tipc/rust/src/service/ |
| D | handle_set.rs | 54 for port in &ports {
55 if !port.is_port() {
67 for port in &handle_set.ports {
71 port,
144 for port in &self.ports { in mask_all_ports()
145 self.do_set_ctrl(sys::HSET_MOD as u32, 0, &port).expect("Failed to mask port"); in mask_all_ports()
150 for port in &self.ports { in unmask_all_ports()
151 self.do_set_ctrl(sys::HSET_MOD as u32, trusty_sys::uevent::ALL_EVENTS, &port) in unmask_all_ports()
|
| /trusty/user/app/secretkeeper/ |
| D | tests.rs | 29 let port = CString::try_new(port_name).unwrap(); in port_connect() localVariable
30 let result = Handle::connect(port.as_c_str()); in port_connect()
59 let port = CString::try_new(BL_PORT_NAME).unwrap(); in bootloader_retrieve_key() localVariable
60 let session = Handle::connect(port.as_c_str()).unwrap(); in bootloader_retrieve_key()
|
| /trusty/user/app/storage/test/storage-benchmark/ |
| D | main.c | 40 const char* port; member
74 storage_state.port = in BENCH_SETUP()
77 rc = storage_open_session(&storage_state.ss, storage_state.port); in BENCH_SETUP()
79 TLOGE("failed (%d) to open %s session\n", rc, storage_state.port); in BENCH_SETUP()
94 storage_state.port = NULL; in BENCH_TEARDOWN()
|
| /trusty/user/base/lib/uirq/test/ |
| D | main.c | 149 handle_t port; in TEST() local
154 port = (handle_t)rc; in TEST()
157 rc = uirq_ack_handled(port); in TEST()
162 rc = trusty_write(port, &cmd, sizeof(cmd)); in TEST()
166 rc = trusty_read(port, &cmd, sizeof(cmd)); in TEST()
169 close(port); in TEST()
|
| /trusty/hardware/nxp/platform/imx/drivers/ |
| D | imx_uart.c | 92 void uart_flush_tx(int port) { in uart_flush_tx() argument
97 int uart_getc(int port, bool wait) { in uart_getc() argument
107 int uart_putc(int port, char c) { in uart_putc() argument
|
| /trusty/user/base/interface/boot_done/generated/include/ |
| D | BnBootDone.h | 14 static int on_connect(const ::tidl::Service::Port* port,
19 static int on_message(const ::tidl::Service::Port* port,
|
| /trusty/user/base/interface/boot_done/generated/ |
| D | IBootDone.cpp | 51 int BpBootDone::connect(const char* port, uint32_t flags) { in connect() argument
55 return ::tidl::ipc::connect(port, flags, mChan); in connect()
81 BnBootDone::BnBootDone(const char* port, in BnBootDone() argument
85 port, in BnBootDone()
98 int BnBootDone::on_connect(const ::tidl::Service::Port* port, in on_connect() argument
103 reinterpret_cast<Service*>(const_cast<void*>(port->priv))); in on_connect()
118 int BnBootDone::on_message(const ::tidl::Service::Port* port, in on_message() argument
123 reinterpret_cast<Service*>(const_cast<void*>(port->priv))); in on_message()
|