57 void init_datagram_queue(struct phdr_desc_queue *queue, int queue_num)  in init_datagram_queue()  argument
59 	queue->head = descriptors[queue_num];  in init_datagram_queue()
62 		queue->tail = &descriptors[queue_num][i];  in init_datagram_queue()
63 		descriptors[queue_num][i].ptr = (uint8_t *)&headers[queue_num][i];  in init_datagram_queue()
68 				descriptors[queue_num][i].ptr[j] = sys_rand8_get();  in init_datagram_queue()
70 				descriptors[queue_num][i].ptr[j] = 0;  in init_datagram_queue()
77 			    descriptors[queue_num][i].ptr, SIZE_OF_HEADER);  in init_datagram_queue()
80 		descriptors[queue_num][i].ptr[CRC_BYTE_1] = (uint8_t)(crc >> 8);  in init_datagram_queue()
81 		descriptors[queue_num][i].ptr[CRC_BYTE_2] = (uint8_t)(crc);  in init_datagram_queue()
83 		descriptors[queue_num][i].next = &descriptors[queue_num][i+1];  in init_datagram_queue()
94 	int queue_num = *(int *)arg3;  in test_thread()  local
99 	qin_ptr = phdr_desc_dequeue(sender_queue, &sender_queue_mtx[queue_num]);  in test_thread()
113 						 &receiver_queue_mtx[queue_num]);  in test_thread()
117 						&sender_queue_mtx[queue_num]);  in test_thread()
128 	int queue_num;  in queue_thread()  local
132 	queue_num = current_queue;  in queue_thread()
137 		k_thread_create(&tthread[i+THREADS_NUM*queue_num],  in queue_thread()
138 			tstack[i+THREADS_NUM*queue_num], STACK_SIZE,  in queue_thread()
140 			(void *)&sender[queue_num],  in queue_thread()
141 			(void *)&receiver[queue_num], (void *)&queue_num,  in queue_thread()
146 	while (sender[queue_num].count != 0) {  in queue_thread()