| /samples/userspace/prod_consumer/src/ |
| A D | sample_driver_foo.c | 42 struct sample_driver_foo_dev_data *data = dev->data; in sample_driver_foo_set_callback() local 45 data->cb_context = context; in sample_driver_foo_set_callback() 46 data->cb = cb; in sample_driver_foo_set_callback() 54 struct sample_driver_foo_dev_data *data = dev->data; in sample_driver_foo_state_set() local 58 data->timer.user_data = data; in sample_driver_foo_state_set() 81 data->count); in sample_driver_foo_isr() 84 if (data->cb) { in sample_driver_foo_isr() 85 data->cb(data->dev, data->cb_context, data_payload); in sample_driver_foo_isr() 88 data->count++; in sample_driver_foo_isr() 98 struct sample_driver_foo_dev_data *data = dev->data; in sample_driver_foo_init() local [all …]
|
| /samples/modules/tflite-micro/magic_wand/train/ |
| A D | data_prepare_test.py | 36 self.data = [] 46 self.assertEqual(len(self.data), num) 47 self.assertIsInstance(self.data, list) 48 self.assertIsInstance(self.data[0], dict) 53 original_len = len(self.data) 54 generate_negative_data(self.data) 55 self.assertEqual(original_len + 300, len(self.data)) 57 for idx, data in enumerate(self.data): # pylint: disable=unused-variable 58 if data["name"] == "negative6" or data["name"] == "negative7" or data[ 65 write_data(self.data, data_path_test) [all …]
|
| A D | data_augmentation.py | 29 def time_wrapping(molecule, denominator, data): argument 32 for i in range(len(data[0]))] 33 for j in range((int(len(data) / molecule) - 1) * denominator)] 34 for i in range(int(len(data) / molecule) - 1): 35 for j in range(len(data[i])): 38 k][j] = (data[molecule * i + k][j] * (denominator - k) + 49 new_data.append(data) 53 new_data.append((np.array(data, dtype=np.float32) + 57 tmp_data = [[0 for i in range(len(data[0]))] for j in range(len(data))] 61 tmp_data[i][j] = data[i][j] + 5 * random.random() [all …]
|
| A D | data_split_person.py | 48 for idx, data in enumerate(whole_data): # pylint: disable=unused-variable 49 if data["name"] in train_names: 50 train_data.append(data) 51 elif data["name"] in valid_names: 52 valid_data.append(data) 53 elif data["name"] in test_names: 54 test_data.append(data) 62 data = read_data("./data/complete_data") variable 69 train_data, valid_data, test_data = person_split(data, train_names,
|
| A D | data_load.py | 52 data = [] 58 data.append(dic[DATA_NAME]) 61 data, label = augment_data(data, label) 64 return data, label, length 66 def pad(self, data, seq_length, dim): # pylint: disable=no-self-use argument 73 min(len(data), seq_length)):] = data[:min(len(data), seq_length)] 77 tmp_data[:min(len(data), seq_length)] = data[:min(len(data), seq_length)] 81 def format_support_func(self, padded_num, length, data, label): argument 88 …for idx, (data, label) in enumerate(zip(data, label)): # pylint: disable=redefined-argument-fro… 89 padded_data = self.pad(data, self.seq_length, self.dim) [all …]
|
| A D | data_split.py | 41 data = [] 46 data.append(dic) 47 print("data_length:" + str(len(data))) 48 return data 51 def split_data(data, train_ratio, valid_ratio): argument 57 for idx, item in enumerate(data): # pylint: disable=unused-variable 68 random.shuffle(data) 69 for idx, item in enumerate(data): 86 data = read_data("./data/complete_data") variable 87 train_data, valid_data, test_data = split_data(data, 0.6, 0.2)
|
| /samples/subsys/pm/latency/src/ |
| A D | test.c | 32 struct dev_test_data *data = dev->data; in dev_test_open() local 35 pm_policy_latency_request_add(&data->req, 20000); in dev_test_open() 37 pm_policy_latency_changed_subscribe(&data->subs, on_latency_changed); in dev_test_open() 42 struct dev_test_data *data = dev->data; in dev_test_close() local 45 pm_policy_latency_request_remove(&data->req); in dev_test_close() 47 pm_policy_latency_changed_unsubscribe(&data->subs); in dev_test_close() 60 static struct dev_test_data data; variable 62 DEVICE_DEFINE(dev_test, "dev_test", &dev_test_init, NULL, &data, NULL,
|
| /samples/subsys/logging/logger/src/ |
| A D | sample_instance.c | 18 uint8_t data[] = { 1, 2, 3, 4, 5, 6, 7, 8, in sample_instance_call() local 25 LOG_INST_HEXDUMP_WRN(inst->log, data, sizeof(data), in sample_instance_call() 27 (void)memset(data, 0, sizeof(data)); in sample_instance_call()
|
| /samples/sensor/stream_fifo/ |
| A D | README.rst | 11 This sample application demonstrates how to stream FIFO data using the 105 TP data for lsm6dsv16x@6b 1680572433340ns 24.347656 °C 106 TP data for lsm6dsv16x@6b 1680639100006ns 24.324218 °C 107 TP data for lsm6dsv16x@6b 1680705766672ns 24.316406 °C 108 TP data for lsm6dsv16x@6b 1680772433338ns 24.296875 °C 139 TP data for lsm6dsv16x@6b 1680839100004ns 24.339843 °C 140 TP data for lsm6dsv16x@6b 1680905766670ns 24.339843 °C 141 TP data for lsm6dsv16x@6b 1680972433336ns 24.289062 °C 142 TP data for lsm6dsv16x@6b 1681039100002ns 24.296875 °C 150 TP data for lsm6dsv16x@6b 1681105766668ns 24.289062 °C [all …]
|
| /samples/subsys/zbus/runtime_obs_registration/ |
| A D | README.rst | 32 I: >-- Raw data fetched 33 I: -|- Filtering data 35 I: >-- Raw data fetched 36 I: -|- Filtering data 38 I: >-- Raw data fetched 39 I: -|- Filtering data 41 I: >-- Raw data fetched 42 I: -|- Filtering data 44 I: >-- Raw data fetched 45 I: -|- Filtering data [all …]
|
| A D | sample.yaml | 18 - ".*I: >-- Raw data fetched" 19 - ".*I: -|- Filtering data" 20 - ".*I: --> Consuming data: Acc x=0, y=0, z=0" 21 - ".*I: --> Consuming data: Acc x=2, y=2, z=2" 22 - ".*I: --> Consuming data: Acc x=4, y=4, z=4" 23 - ".*I: --> Consuming data: Acc x=6, y=6, z=6" 24 - ".*I: --> Consuming data: Acc x=7, y=7, z=7" 25 - ".*I: --> Consuming data: Acc x=8, y=8, z=8" 26 - ".*I: --> Consuming data: Acc x=9, y=9, z=9" 46 - ".*I: >-- Raw data fetched" [all …]
|
| /samples/net/sockets/echo_client/src/ |
| A D | tcp.c | 58 data->tcp.received = 0U; in send_tcp_data() 60 ret = sendall(data->tcp.sock, lorem_ipsum, data->tcp.expecting); in send_tcp_data() 68 data->tcp.expecting); in send_tcp_data() 77 if (data->tcp.received + received > data->tcp.expecting) { in compare_tcp_data() 101 if (data->tcp.sock < 0) { in start_tcp_proto() 152 data->proto, errno); in start_tcp_proto() 160 data->proto, errno); in start_tcp_proto() 211 if (data->tcp.received < data->tcp.expecting) { in process_tcp_proto() 218 data->proto, data->tcp.received); in process_tcp_proto() 223 data->tcp.counter); in process_tcp_proto() [all …]
|
| A D | udp.c | 145 } while (data->udp.expecting == 0U || in send_udp_data() 146 data->udp.expecting > data->udp.mtu); in send_udp_data() 148 ret = send(data->udp.sock, lorem_ipsum, data->udp.expecting, 0); in send_udp_data() 151 LOG_DBG("%s UDP: Sent %d bytes", data->proto, data->udp.expecting); in send_udp_data() 161 if (received != data->udp.expecting) { in compare_udp_data() 204 if (data->udp.sock < 0) { in start_udp_proto() 222 data->proto, errno); in start_udp_proto() 230 data->proto, errno); in start_udp_proto() 276 "mismatch", data->proto, received); in process_udp_proto() 283 data->proto, received); in process_udp_proto() [all …]
|
| /samples/net/sockets/echo_server/src/ |
| A D | udp.c | 36 static int start_udp_proto(struct data *data, struct sockaddr *bind_addr, in start_udp_proto() argument 48 if (data->udp.sock < 0) { in start_udp_proto() 76 data->proto, errno); in start_udp_proto() 107 static int process_udp(struct data *data) in process_udp() argument 115 MY_PORT, data->proto); in process_udp() 119 received = recvfrom(data->udp.sock, data->udp.recv_buffer, in process_udp() 120 sizeof(data->udp.recv_buffer), 0, in process_udp() 133 ret = sendto(data->udp.sock, data->udp.recv_buffer, received, 0, in process_udp() 144 data->udp.counter); in process_udp() 148 data->proto, received); in process_udp() [all …]
|
| A D | tcp.c | 67 static int start_tcp_proto(struct data *data, in start_tcp_proto() argument 81 if (data->tcp.sock < 0) { in start_tcp_proto() 130 data->proto, errno); in start_tcp_proto() 140 struct data *data = ptr2; in handle_data() local 187 "closing socket", data->proto); in handle_data() 192 data->proto, offset); in handle_data() 212 static int get_free_slot(struct data *data) in get_free_slot() argument 225 static int process_tcp(struct data *data) in process_tcp() argument 233 MY_PORT, data->proto); in process_tcp() 242 slot = get_free_slot(data); in process_tcp() [all …]
|
| /samples/subsys/usb/dfu/src/ |
| A D | main.c | 71 err = disk_access_ioctl(data->name, DISK_IOCTL_GET_SECTOR_COUNT, &data->sector_count); in init_dfu_ramdisk_data() 76 err = disk_access_ioctl(data->name, DISK_IOCTL_GET_SECTOR_SIZE, &data->sector_size); in init_dfu_ramdisk_data() 82 data->name, data->sector_count, data->sector_size); in init_dfu_ramdisk_data() 104 data->last_block = 0; in ramdisk_read() 105 data->uploaded = 0; in ramdisk_read() 124 data->last_block = block; in ramdisk_read() 125 data->uploaded += MIN(size, data->sector_size); in ramdisk_read() 143 data->last_block = 0; in ramdisk_write() 144 data->downloaded = 0; in ramdisk_write() 163 data->last_block = block; in ramdisk_write() [all …]
|
| /samples/drivers/auxdisplay_digits/src/ |
| A D | main.c | 22 static uint8_t data[AUXDISPLAY_DIGIT_COUNT * 2]; variable 36 data[i * 2] = '8'; in main() 37 data[i * 2 + 1] = '.'; in main() 39 rc = auxdisplay_write(dev, data, strlen(data)); in main() 78 snprintf(data, sizeof(data), "%d", i); in main() 79 rc = auxdisplay_write(dev, data, strlen(data)); in main() 93 snprintk(data, sizeof(data), "%d", i); in main() 94 len = strlen(data); in main() 110 rc = auxdisplay_write(dev, data, len); in main()
|
| /samples/boards/raspberrypi/rpi_pico/uart_pio/src/ |
| A D | main.c | 13 char data; in main() local 26 if (!uart_poll_in(uart0, &data)) { in main() 27 uart_poll_out(uart0, data); in main() 30 if (!uart_poll_in(uart1, &data)) { in main() 31 uart_poll_out(uart1, data); in main()
|
| /samples/philosophers/src/ |
| A D | phil_obj_abstract.h | 38 int data; member 89 stack_data_t data; k_stack_pop(x, &data, K_FOREVER); \ 90 __ASSERT(data == MAGIC, "data was %lx\n", data); \ 101 struct packet data; member 105 ((fork_obj_t *)(x))->data.data = MAGIC; \ 110 struct packet *data; \ 112 __ASSERT(data->data == MAGIC, ""); \ 123 struct packet data; member 127 ((fork_obj_t *)(x))->data.data = MAGIC; \ 132 struct packet *data; \ [all …]
|
| /samples/net/sockets/coap_client/src/ |
| A D | coap-client.c | 89 uint8_t *data; in process_simple_coap_reply() local 96 if (!data) { in process_simple_coap_reply() 124 k_free(data); in process_simple_coap_reply() 134 uint8_t *data; in send_simple_coap_request() local 138 if (!data) { in send_simple_coap_request() 191 k_free(data); in send_simple_coap_request() 265 if (!data) { in process_large_coap_reply() 325 if (!data) { in send_large_coap_request() 398 if (!data) { in send_obs_reply_ack() 451 if (!data) { in process_obs_coap_reply() [all …]
|
| /samples/net/sockets/http_server/src/static_web_resources/ |
| A D | main.js | 62 const data = JSON.parse(event.data); 63 setNetStat(data, "bytes_recv"); 64 setNetStat(data, "bytes_sent"); 65 setNetStat(data, "ipv6_pkt_recv"); 66 setNetStat(data, "ipv6_pkt_sent"); 67 setNetStat(data, "ipv4_pkt_recv"); 68 setNetStat(data, "ipv4_pkt_sent"); 69 setNetStat(data, "tcp_bytes_recv"); 70 setNetStat(data, "tcp_bytes_sent");
|
| /samples/drivers/auxdisplay/src/ |
| A D | main.c | 19 uint8_t data[64]; in main() local 32 snprintk(data, sizeof(data), "Hello world from %s", CONFIG_BOARD); in main() 33 rc = auxdisplay_write(dev, data, strlen(data)); in main()
|
| /samples/drivers/spi_fujitsu_fram/src/ |
| A D | main.c | 35 .buf = data, in mb85rs64v_access() 165 data[0] = 0xAE; in main() 174 data[0] = 0x86; in main() 183 data[0] = 0x00; in main() 184 err = read_bytes(spi, &spi_cfg, 0x00, data, 1); in main() 192 data[0] = 0x00; in main() 193 err = read_bytes(spi, &spi_cfg, 0x01, data, 1); in main() 205 data[i] = 0x00; in main() 218 err = read_bytes(spi, &spi_cfg, 0x00, data, sizeof(data)); in main() 224 (uint32_t) sizeof(data)); in main() [all …]
|
| /samples/subsys/portability/cmsis_rtos_v2/timer_synchronization/src/ |
| A D | main.c | 26 uint32_t data; variable 28 static char __aligned(4) sample_mem[sizeof(data) * Q_LEN]; 36 .mq_size = sizeof(data) * Q_LEN, 57 status = osMessageQueuePut(message_id, &data, 0, osWaitForever); in send_msg_thread() 59 printk("Wrote to message queue: %d\n", data); in send_msg_thread() 72 data = INITIAL_DATA_VALUE; in main() 74 message_id = osMessageQueueNew(Q_LEN, sizeof(data), &mem_attrs); in main() 76 status = osMessageQueuePut(message_id, &data, 0, osWaitForever); in main() 79 printk("Wrote to message queue: %d\n", data); in main() 90 data++; in main()
|
| /samples/data_structures/min-heap/src/ |
| A D | main.c | 11 struct data { struct 18 const struct data *da = a; in compare() argument 19 const struct data *db = b; in compare() 26 const struct data *da = a; in match_key() 34 MIN_HEAP_DEFINE_STATIC(my_heap, HEAP_CAPACITY, sizeof(struct data), 35 __alignof__(struct data), compare); 42 struct data *top, *found, removed; in main() 46 struct data elements[] = { in main() 61 struct data *d = elem; in main() 81 struct data *d = elem; in main()
|