| /Zephyr-latest/subsys/ipc/ipc_service/ |
| D | ipc_service.c | 66 struct ipc_ept *ept, in ipc_service_register_endpoint() argument
71 if (!instance || !ept || !cfg) { in ipc_service_register_endpoint()
85 ept->instance = instance; in ipc_service_register_endpoint()
87 return backend->register_endpoint(instance, &ept->token, cfg); in ipc_service_register_endpoint()
90 int ipc_service_deregister_endpoint(struct ipc_ept *ept) in ipc_service_deregister_endpoint() argument
95 if (!ept) { in ipc_service_deregister_endpoint()
100 if (!ept->instance) { in ipc_service_deregister_endpoint()
105 backend = ept->instance->api; in ipc_service_deregister_endpoint()
112 err = backend->deregister_endpoint(ept->instance, ept->token); in ipc_service_deregister_endpoint()
117 ept->instance = 0; in ipc_service_deregister_endpoint()
[all …]
|
| /Zephyr-latest/include/zephyr/ipc/ |
| D | ipc_service.h | 262 struct ipc_ept *ept,
281 int ipc_service_deregister_endpoint(struct ipc_ept *ept);
301 int ipc_service_send(struct ipc_ept *ept, const void *data, size_t len);
319 int ipc_service_get_tx_buffer_size(struct ipc_ept *ept);
368 int ipc_service_get_tx_buffer(struct ipc_ept *ept, void **data, uint32_t *size, k_timeout_t wait);
390 int ipc_service_drop_tx_buffer(struct ipc_ept *ept, const void *data);
424 int ipc_service_send_nocopy(struct ipc_ept *ept, const void *data, size_t len);
449 int ipc_service_hold_rx_buffer(struct ipc_ept *ept, void *data);
475 int ipc_service_release_rx_buffer(struct ipc_ept *ept, void *data);
|
| D | ipc_rpmsg.h | 39 typedef void (*rpmsg_ept_bound_cb)(struct ipc_rpmsg_ept *ept);
143 struct ipc_rpmsg_ept *ept);
|
| /Zephyr-latest/subsys/ipc/ipc_service/lib/ |
| D | ipc_rpmsg.c | 19 struct ipc_rpmsg_ept *ept; in ns_bind_cb() local
26 ept = &instance->endpoint[i]; in ns_bind_cb()
28 if (strcmp(name, ept->name) == 0) { in ns_bind_cb()
35 err = rpmsg_create_ept(&ept->ep, rdev, name, RPMSG_ADDR_ANY, in ns_bind_cb()
41 ept->bound = true; in ns_bind_cb()
43 instance->bound_cb(ept); in ns_bind_cb()
50 struct ipc_rpmsg_ept *ept) in ipc_rpmsg_register_ept() argument
54 if (!instance || !ept) { in ipc_rpmsg_register_ept()
65 return rpmsg_create_ept(&ept->ep, rdev, ept->name, RPMSG_ADDR_ANY, in ipc_rpmsg_register_ept()
|
| D | icmsg_me.c | 157 const struct ipc_ept_cfg *ept; in icmsg_me_received_data() local
160 r = icmsg_me_get_ept_cfg(data, id, &ept); in icmsg_me_received_data()
165 if (ept == NULL) { in icmsg_me_received_data()
174 if (ept->cb.received) { in icmsg_me_received_data()
175 ept->cb.received(icmsg_buffer_to_user_buffer(msg), in icmsg_me_received_data()
176 user_buffer_len, ept->priv); in icmsg_me_received_data()
|
| /Zephyr-latest/subsys/ipc/ipc_service/backends/ |
| D | ipc_icbmsg.c | 191 struct ept_data ept[NUM_EPT]; /* Array of registered endpoints. */ member
613 struct ept_data *ept; in find_ept_by_name() local
624 ept = &dev_data->ept[i]; in find_ept_by_name()
625 if (atomic_get(&ept->state) == EPT_CONFIGURED && in find_ept_by_name()
626 strncmp(ept->cfg->name, name, name_size) == 0) { in find_ept_by_name()
652 struct ept_data *ept; in match_bound_msg() local
665 ept = &dev_data->ept[ept_index]; in match_bound_msg()
666 ept->addr = ept_addr; in match_bound_msg()
667 dev_data->ept_map[ept->addr] = ept_index; in match_bound_msg()
668 valid_state = atomic_cas(&ept->state, EPT_CONFIGURED, EPT_READY); in match_bound_msg()
[all …]
|
| D | ipc_rpmsg_static_vrings.c | 127 struct ipc_rpmsg_ept *ept; in get_ept() local
129 ept = get_ept_slot_with_name(rpmsg_inst, name); in get_ept()
130 if (ept != NULL) { in get_ept()
131 (*rpmsg_ept) = ept; in get_ept()
135 ept = get_available_ept_slot(rpmsg_inst); in get_ept()
136 if (ept != NULL) { in get_ept()
137 (*rpmsg_ept) = ept; in get_ept()
209 static void bound_cb(struct ipc_rpmsg_ept *ept) in bound_cb() argument
211 rpmsg_send(&ept->ep, (uint8_t *)"", 0); in bound_cb()
213 if (ept->cb->bound) { in bound_cb()
[all …]
|
| D | ipc_icmsg_me_follower.c | 68 static int cache_ept_loc(struct backend_data_t *data, const struct ipc_ept_cfg *ept) in cache_ept_loc() argument
72 data->ept_disc_loc_cache[i] = ept; in cache_ept_loc()
99 struct backend_data_t *data, const struct ipc_ept_cfg *ept, in bind_ept() argument
110 r = icmsg_me_set_ept_cfg(&data->icmsg_me_data, id, ept); in bind_ept()
122 if (ept->cb.bound) { in bind_ept()
123 ept->cb.bound(ept->priv); in bind_ept()
157 const struct ipc_ept_cfg *ept = in received() local
159 if (ept == NULL) { in received()
175 bind_ept(conf, dev_data, ept, ept_id); in received()
|
| D | ipc_icmsg_me_initiator.c | 44 const struct ipc_ept_cfg *ept; in received() local
53 &ept); in received()
58 if (ept && ept->cb.bound) { in received()
59 ept->cb.bound(ept->priv); in received()
|
| /Zephyr-latest/subsys/shell/backends/ |
| D | shell_rpmsg.c | 14 static int rpmsg_shell_cb(struct rpmsg_endpoint *ept, void *data, in rpmsg_shell_cb() argument
31 rpmsg_hold_rx_buffer(ept, data); in rpmsg_shell_cb()
45 rpmsg_destroy_ept(&sh_rpmsg->ept); in uninit()
72 ret = rpmsg_create_ept(&sh_rpmsg->ept, rdev, CONFIG_SHELL_RPMSG_SERVICE_NAME, in init()
79 sh_rpmsg->ept.priv = (void *)transport; in init()
114 ret = rpmsg_send(&sh_rpmsg->ept, data, (int)length); in write()
116 ret = rpmsg_trysend(&sh_rpmsg->ept, data, (int)length); in write()
167 rpmsg_release_rx_buffer(&sh_rpmsg->ept, rx->data); in read()
|
| /Zephyr-latest/subsys/logging/backends/ |
| D | log_backend_ipc_service.c | 14 struct ipc_ept ept; member
44 int err = ipc_service_send(&backend_ipc_service->ept, data, len); in backend_ipc_service_send()
71 err = ipc_service_register_endpoint(ipc_instance, &backend_ipc_service->ept, &ept_cfg); in backend_ipc_service_init()
|
| /Zephyr-latest/subsys/logging/ |
| D | log_link_ipc_service.c | 17 struct ipc_ept ept; member
48 return ipc_service_send(&link_ipc_service->ept, data, len); in link_ipc_service_send()
74 err = ipc_service_register_endpoint(ipc_instance, &link_ipc_service->ept, &ept_cfg); in link_ipc_service_init()
|
| /Zephyr-latest/modules/hal_nordic/nrf_802154/serialization/platform/ |
| D | nrf_802154_spinel_backend_ipc.c | 34 static struct ipc_ept ept; variable
80 err = ipc_service_register_endpoint(ipc_instance, &ept, &ept_cfg); in nrf_802154_backend_init()
147 int ret = ipc_service_send(&ept, buf->data, buf->len); in spinel_packet_send_thread_fn()
172 int ret = ipc_service_send(&ept, p_data, data_len); in nrf_802154_spinel_encoded_packet_send()
|
| /Zephyr-latest/samples/subsys/ipc/openamp/remote/src/ |
| D | main.c | 85 int endpoint_cb(struct rpmsg_endpoint *ept, void *data, in endpoint_cb() argument
100 static void rpmsg_service_unbind(struct rpmsg_endpoint *ept) in rpmsg_service_unbind() argument
102 (void)ept; in rpmsg_service_unbind()
|
| /Zephyr-latest/include/zephyr/shell/ |
| D | shell_rpmsg.h | 43 struct rpmsg_endpoint ept; member
|
| /Zephyr-latest/samples/subsys/ipc/openamp/src/ |
| D | main.c | 97 int endpoint_cb(struct rpmsg_endpoint *ept, void *data, in endpoint_cb() argument
112 static void rpmsg_service_unbind(struct rpmsg_endpoint *ept) in rpmsg_service_unbind() argument
114 (void)ept; in rpmsg_service_unbind()
|
| /Zephyr-latest/samples/subsys/ipc/rpmsg_service/remote/src/ |
| D | main.c | 29 int endpoint_cb(struct rpmsg_endpoint *ept, void *data, in endpoint_cb() argument
|
| /Zephyr-latest/samples/subsys/ipc/rpmsg_service/src/ |
| D | main.c | 28 int endpoint_cb(struct rpmsg_endpoint *ept, void *data, in endpoint_cb() argument
|
| /Zephyr-latest/samples/subsys/ipc/openamp_rsc_table/src/ |
| D | main_remote.c | 92 static int rpmsg_recv_cs_callback(struct rpmsg_endpoint *ept, void *data, in rpmsg_recv_cs_callback() argument
102 static int rpmsg_recv_tty_callback(struct rpmsg_endpoint *ept, void *data, in rpmsg_recv_tty_callback() argument
107 rpmsg_hold_rx_buffer(ept, data); in rpmsg_recv_tty_callback()
|
