| /components/libc/posix/io/aio/ |
| A D | aio.c | 49 if (!cb) return -EINVAL; in aio_cancel() 70 if (cb) in aio_error() 160 rt_work_init(&(cb->aio_work), aio_fync_work, cb); in aio_fsync() 186 lseek(cb->aio_fildes, cb->aio_offset, SEEK_SET); in aio_read_work() 187 len = read(cb->aio_fildes, &buf_ptr[cb->aio_offset], cb->aio_nbytes); in aio_read_work() 259 rt_work_init(&(cb->aio_work), aio_read_work, cb); in aio_read() 280 if (cb) in aio_return() 340 lseek(cb->aio_fildes, SEEK_SET, cb->aio_offset); in aio_write_work() 344 len = write(cb->aio_fildes, buf_ptr, cb->aio_nbytes); in aio_write_work() 401 if (!cb || (cb->aio_buf == NULL)) return -EINVAL; in aio_write() [all …]
|
| A D | aio.h | 34 int aio_cancel(int fd, struct aiocb *cb); 35 int aio_error (const struct aiocb *cb); 37 int aio_fsync(int op, struct aiocb *cb); 39 int aio_read(struct aiocb *cb); 40 ssize_t aio_return(struct aiocb *cb); 43 int aio_write(struct aiocb *cb);
|
| /components/legacy/usb/usbhost/class/ |
| A D | mass.c | 314 cmd.cb[0] = SCSI_READ_10; in rt_usbh_storage_read10() 315 cmd.cb[1] = 0; in rt_usbh_storage_read10() 319 cmd.cb[5] = (rt_uint8_t)sector; in rt_usbh_storage_read10() 320 cmd.cb[6] = 0; in rt_usbh_storage_read10() 360 cmd.cb[0] = SCSI_WRITE_10; in rt_usbh_storage_write10() 361 cmd.cb[1] = 0; in rt_usbh_storage_write10() 365 cmd.cb[5] = (rt_uint8_t)sector; in rt_usbh_storage_write10() 366 cmd.cb[6] = 0; in rt_usbh_storage_write10() 405 cmd.cb[4] = 18; in rt_usbh_storage_request_sense() 476 cmd.cb[0] = SCSI_INQUIRY_CMD; in rt_usbh_storage_inquiry() [all …]
|
| /components/net/lwip/lwip-2.0.3/src/include/lwip/apps/ |
| A D | mqtt.h | 161 mqtt_request_cb_t cb; member 209 …ect(mqtt_client_t *client, const ip_addr_t *ipaddr, u16_t port, mqtt_connection_cb_t cb, void *arg, 226 err_t mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void… 230 #define mqtt_subscribe(client, topic, qos, cb, arg) mqtt_sub_unsub(client, topic, qos, cb, arg, 1) argument 233 #define mqtt_unsubscribe(client, topic, cb, arg) mqtt_sub_unsub(client, topic, 0, cb, arg, 0) argument 238 mqtt_request_cb_t cb, void *arg);
|
| /components/net/lwip/lwip-2.1.2/src/include/lwip/apps/ |
| A D | mqtt.h | 176 …ect(mqtt_client_t *client, const ip_addr_t *ipaddr, u16_t port, mqtt_connection_cb_t cb, void *arg, 189 err_t mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void… 193 #define mqtt_subscribe(client, topic, qos, cb, arg) mqtt_sub_unsub(client, topic, qos, cb, arg, 1) argument 196 #define mqtt_unsubscribe(client, topic, cb, arg) mqtt_sub_unsub(client, topic, 0, cb, arg, 0) argument 199 mqtt_request_cb_t cb, void *arg);
|
| A D | mqtt_priv.h | 54 mqtt_request_cb_t cb; member
|
| A D | mdns.h | 74 void mdns_resp_register_name_result_cb(mdns_name_result_cb_t cb);
|
| /components/net/lwip/lwip-2.1.2/src/api/ |
| A D | tcpip.c | 196 msg->msg.cb.function(msg->msg.cb.ctx); in tcpip_thread_handle_msg() 202 msg->msg.cb.function(msg->msg.cb.ctx); in tcpip_thread_handle_msg() 321 msg->msg.cb.function = function; in tcpip_callback() 322 msg->msg.cb.ctx = ctx; in tcpip_callback() 357 msg->msg.cb.function = function; in tcpip_try_callback() 358 msg->msg.cb.ctx = ctx; in tcpip_try_callback() 538 msg->msg.cb.function = function; in tcpip_callbackmsg_new() 539 msg->msg.cb.ctx = ctx; in tcpip_callbackmsg_new()
|
| /components/net/lwip/lwip-1.4.1/src/api/ |
| A D | tcpip.c | 135 msg->msg.cb.function(msg->msg.cb.ctx); in tcpip_thread() 141 msg->msg.cb.function(msg->msg.cb.ctx); in tcpip_thread() 222 msg->msg.cb.function = function; in tcpip_callback_with_block() 223 msg->msg.cb.ctx = ctx; in tcpip_callback_with_block() 415 msg->msg.cb.function = function; in tcpip_callbackmsg_new() 416 msg->msg.cb.ctx = ctx; in tcpip_callbackmsg_new()
|
| /components/legacy/usb/usbdevice/class/ |
| A D | mstorage.c | 478 data->block = cbw->cb[2]<<24 | cbw->cb[3]<<16 | cbw->cb[4]<<8 | in _read_10() 479 cbw->cb[5]<<0; in _read_10() 480 data->count = cbw->cb[7]<<8 | cbw->cb[8]<<0; in _read_10() 518 data->block = cbw->cb[2]<<24 | cbw->cb[3]<<16 | cbw->cb[4]<<8 | in _write_10() 519 cbw->cb[5]<<0; in _write_10() 520 data->count = cbw->cb[7]<<8 | cbw->cb[8]; in _write_10() 672 LOG_D("cb[0] 0x%x", cbw->cb[0]); in cbw_dump() 704 data->cb_data_size = cbw->cb[4]; in _cb_len_calc() 721 data->cb_data_size = cbw->cb[7]<<8 | cbw->cb[8]; in _cb_len_calc() 724 data->cb_data_size = (cbw->cb[7]<<8 | cbw->cb[8]) * in _cb_len_calc() [all …]
|
| /components/net/lwip/lwip-2.0.3/src/api/ |
| A D | tcpip.c | 144 msg->msg.cb.function(msg->msg.cb.ctx); in tcpip_thread() 150 msg->msg.cb.function(msg->msg.cb.ctx); in tcpip_thread() 246 msg->msg.cb.function = function; in tcpip_callback_with_block() 247 msg->msg.cb.ctx = ctx; in tcpip_callback_with_block() 422 msg->msg.cb.function = function; in tcpip_callbackmsg_new() 423 msg->msg.cb.ctx = ctx; in tcpip_callbackmsg_new()
|
| /components/net/lwip/lwip-2.0.3/src/apps/mqtt/ |
| A D | mqtt.c | 267 r->cb = cb; in mqtt_create_request() 372 if (r->cb != NULL) { in mqtt_request_time_elapsed() 373 r->cb(r->arg, ERR_TIMEOUT); in mqtt_request_time_elapsed() 627 if (r->cb != NULL) { in mqtt_incomming_suback() 628 r->cb(r->arg, result < 3 ? ERR_OK : ERR_ABRT); in mqtt_incomming_suback() 754 } else if (r->cb != NULL) { in mqtt_message_received() 755 r->cb(r->arg, ERR_OK); in mqtt_message_received() 920 if (r->cb != NULL) { in mqtt_tcp_sent_cb() 921 r->cb(r->arg, ERR_OK); in mqtt_tcp_sent_cb() 1026 mqtt_request_cb_t cb, void *arg) in mqtt_publish() argument [all …]
|
| /components/net/lwip/lwip-2.1.2/src/apps/mqtt/ |
| A D | mqtt.c | 297 r->cb = cb; in mqtt_create_request() 402 if (r->cb != NULL) { in mqtt_request_time_elapsed() 403 r->cb(r->arg, ERR_TIMEOUT); in mqtt_request_time_elapsed() 658 if (r->cb != NULL) { in mqtt_incomming_suback() 659 r->cb(r->arg, result < 3 ? ERR_OK : ERR_ABRT); in mqtt_incomming_suback() 814 } else if (r->cb != NULL) { in mqtt_message_received() 815 r->cb(r->arg, ERR_OK); in mqtt_message_received() 992 if (r->cb != NULL) { in mqtt_tcp_sent_cb() 993 r->cb(r->arg, ERR_OK); in mqtt_tcp_sent_cb() 1098 mqtt_request_cb_t cb, void *arg) in mqtt_publish() argument [all …]
|
| /components/net/lwip/lwip-1.4.1/src/netif/ppp/ |
| A D | ppp.h | 155 #define pppOpen(fd,cb,ls) pppOverSerialOpen(fd,cb,ls) argument
|
| /components/lwp/ |
| A D | lwp_runtime.c | 140 sysret_t lwp_teardown(struct rt_lwp *lwp, void (*cb)(void)) in lwp_teardown() 151 rt_work_init(work, _teardown_entry, cb); in lwp_teardown()
|
| A D | lwp_pid.h | 30 int lwp_pid_for_each(int (*cb)(pid_t pid, void *data), void *data);
|
| A D | lwp_pid.c | 115 int (*cb)(pid_t pid, void *data); member 123 return param->cb(pid, param->data); in _before_cb() 126 int lwp_pid_for_each(int (*cb)(pid_t pid, void *data), void *data) in lwp_pid_for_each() 131 .cb = cb, in lwp_pid_for_each()
|
| /components/drivers/usb/cherryusb/core/ |
| A D | usbd_core.c | 37 usbd_endpoint_callback cb; member 1360 if (g_usbd_core[busid].tx_msg[ep & 0x7f].cb) { 1361 g_usbd_core[busid].tx_msg[ep & 0x7f].cb(busid, ep, nbytes); 1367 if (g_usbd_core[busid].rx_msg[ep & 0x7f].cb) { 1368 g_usbd_core[busid].rx_msg[ep & 0x7f].cb(busid, ep, nbytes); 1381 g_usbd_core[busid].tx_msg[0].cb = usbd_event_ep0_in_complete_handler; 1383 g_usbd_core[busid].rx_msg[0].cb = usbd_event_ep0_out_complete_handler; 1394 g_usbd_core[busid].tx_msg[0].cb = usbd_event_ep0_in_complete_handler; 1396 g_usbd_core[busid].rx_msg[0].cb = usbd_event_ep0_out_complete_handler; 1433 g_usbd_core[busid].tx_msg[ep->ep_addr & 0x7f].cb = ep->ep_cb; [all …]
|
| /components/net/lwip/lwip-1.4.1/src/include/lwip/ |
| A D | tcpip.h | 150 } cb; member
|
| /components/net/lwip/lwip-2.0.3/src/include/lwip/priv/ |
| A D | tcpip_priv.h | 143 } cb; member
|
| /components/net/lwip/lwip-2.1.2/src/include/lwip/priv/ |
| A D | tcpip_priv.h | 153 } cb; member
|
| /components/net/netdev/include/ |
| A D | netdev.h | 162 int netdev_getnetdev(struct msg_buf *msg, int (*cb)(struct msg_buf *m_buf, struct netdev *nd, int n…
|
| /components/net/at/at_socket/ |
| A D | at_socket.h | 81 void (*at_set_event_cb)(at_socket_evt_t event, at_evt_cb_t cb);
|
| /components/legacy/usb/usbhost/core/ |
| A D | hub.c | 670 msg.content.cb.function(msg.content.cb.context); in rt_usbh_hub_thread_entry()
|
| /components/drivers/include/drivers/ |
| A D | usb_host.h | 162 }cb; member
|