Lines Matching refs:q
30 d->unprocessed_rcds.q = pqueue_new(); in DTLS_RECORD_LAYER_new()
31 d->processed_rcds.q = pqueue_new(); in DTLS_RECORD_LAYER_new()
32 d->buffered_app_data.q = pqueue_new(); in DTLS_RECORD_LAYER_new()
34 if (d->unprocessed_rcds.q == NULL || d->processed_rcds.q == NULL in DTLS_RECORD_LAYER_new()
35 || d->buffered_app_data.q == NULL) { in DTLS_RECORD_LAYER_new()
36 pqueue_free(d->unprocessed_rcds.q); in DTLS_RECORD_LAYER_new()
37 pqueue_free(d->processed_rcds.q); in DTLS_RECORD_LAYER_new()
38 pqueue_free(d->buffered_app_data.q); in DTLS_RECORD_LAYER_new()
53 pqueue_free(rl->d->unprocessed_rcds.q); in DTLS_RECORD_LAYER_free()
54 pqueue_free(rl->d->processed_rcds.q); in DTLS_RECORD_LAYER_free()
55 pqueue_free(rl->d->buffered_app_data.q); in DTLS_RECORD_LAYER_free()
71 while ((item = pqueue_pop(d->unprocessed_rcds.q)) != NULL) { in DTLS_RECORD_LAYER_clear()
78 while ((item = pqueue_pop(d->processed_rcds.q)) != NULL) { in DTLS_RECORD_LAYER_clear()
87 while ((item = pqueue_pop(d->buffered_app_data.q)) != NULL) { in DTLS_RECORD_LAYER_clear()
96 unprocessed_rcds = d->unprocessed_rcds.q; in DTLS_RECORD_LAYER_clear()
97 processed_rcds = d->processed_rcds.q; in DTLS_RECORD_LAYER_clear()
98 buffered_app_data = d->buffered_app_data.q; in DTLS_RECORD_LAYER_clear()
100 d->unprocessed_rcds.q = unprocessed_rcds; in DTLS_RECORD_LAYER_clear()
101 d->processed_rcds.q = processed_rcds; in DTLS_RECORD_LAYER_clear()
102 d->buffered_app_data.q = buffered_app_data; in DTLS_RECORD_LAYER_clear()
152 if (pqueue_size(queue->q) >= 100) in dtls1_buffer_record()
194 if (pqueue_insert(queue->q, item) == NULL) { in dtls1_buffer_record()
208 item = pqueue_pop(queue->q); in dtls1_retrieve_buffered_record()
238 item = pqueue_peek(s->rlayer.d->unprocessed_rcds.q); in dtls1_process_buffered_records()
259 while (pqueue_peek(s->rlayer.d->unprocessed_rcds.q)) { in dtls1_process_buffered_records()
393 item = pqueue_pop(s->rlayer.d->buffered_app_data.q); in dtls1_read_bytes()