216     mbedtls_test_ssl_message_queue *queue, size_t capacity)  in mbedtls_test_ssl_message_queue_setup()  argument
218     queue->messages = (size_t *) mbedtls_calloc(capacity, sizeof(size_t));  in mbedtls_test_ssl_message_queue_setup()
219     if (NULL == queue->messages) {  in mbedtls_test_ssl_message_queue_setup()
223     queue->capacity = (capacity > INT_MAX) ? INT_MAX : (int) capacity;  in mbedtls_test_ssl_message_queue_setup()
224     queue->pos = 0;  in mbedtls_test_ssl_message_queue_setup()
225     queue->num = 0;  in mbedtls_test_ssl_message_queue_setup()
231     mbedtls_test_ssl_message_queue *queue)  in mbedtls_test_ssl_message_queue_free()  argument
233     if (queue == NULL) {  in mbedtls_test_ssl_message_queue_free()
237     if (queue->messages != NULL) {  in mbedtls_test_ssl_message_queue_free()
238         mbedtls_free(queue->messages);  in mbedtls_test_ssl_message_queue_free()
241     memset(queue, 0, sizeof(*queue));  in mbedtls_test_ssl_message_queue_free()
245     mbedtls_test_ssl_message_queue *queue, size_t len)  in mbedtls_test_ssl_message_queue_push_info()  argument
248     if (queue == NULL) {  in mbedtls_test_ssl_message_queue_push_info()
252     if (queue->num >= queue->capacity) {  in mbedtls_test_ssl_message_queue_push_info()
256     place = (queue->pos + queue->num) % queue->capacity;  in mbedtls_test_ssl_message_queue_push_info()
257     queue->messages[place] = len;  in mbedtls_test_ssl_message_queue_push_info()
258     queue->num++;  in mbedtls_test_ssl_message_queue_push_info()
263     mbedtls_test_ssl_message_queue *queue, size_t buf_len)  in mbedtls_test_ssl_message_queue_pop_info()  argument
266     if (queue == NULL) {  in mbedtls_test_ssl_message_queue_pop_info()
269     if (queue->num == 0) {  in mbedtls_test_ssl_message_queue_pop_info()
273     message_length = queue->messages[queue->pos];  in mbedtls_test_ssl_message_queue_pop_info()
274     queue->messages[queue->pos] = 0;  in mbedtls_test_ssl_message_queue_pop_info()
275     queue->num--;  in mbedtls_test_ssl_message_queue_pop_info()
276     queue->pos++;  in mbedtls_test_ssl_message_queue_pop_info()
277     queue->pos %= queue->capacity;  in mbedtls_test_ssl_message_queue_pop_info()
278     if (queue->pos < 0) {  in mbedtls_test_ssl_message_queue_pop_info()
279         queue->pos += queue->capacity;  in mbedtls_test_ssl_message_queue_pop_info()
299     mbedtls_test_ssl_message_queue *queue,  in test_ssl_message_queue_peek_info()  argument
302     if (queue == NULL || msg_len == NULL) {  in test_ssl_message_queue_peek_info()
305     if (queue->num == 0) {  in test_ssl_message_queue_peek_info()
309     *msg_len = queue->messages[queue->pos];  in test_ssl_message_queue_peek_info()
485     mbedtls_test_ssl_message_queue *queue;  in mbedtls_test_mock_tcp_send_msg()  local
495     queue = context->queue_output;  in mbedtls_test_mock_tcp_send_msg()
498     if (queue->num >= queue->capacity) {  in mbedtls_test_mock_tcp_send_msg()
506     return mbedtls_test_ssl_message_queue_push_info(queue, len);  in mbedtls_test_mock_tcp_send_msg()
512     mbedtls_test_ssl_message_queue *queue;  in mbedtls_test_mock_tcp_recv_msg()  local
525     queue = context->queue_input;  in mbedtls_test_mock_tcp_recv_msg()
530     ret = test_ssl_message_queue_peek_info(queue, buf_len, &msg_len);  in mbedtls_test_mock_tcp_recv_msg()
554     ret = mbedtls_test_ssl_message_queue_pop_info(queue, buf_len);  in mbedtls_test_mock_tcp_recv_msg()