Lines Matching defs:item
409 DEBUGF("send: aob->item = %p\n", aob->item);
410 nghttp2_outbound_item_free(aob->item, mem);
411 nghttp2_mem_free(mem, aob->item);
412 aob->item = NULL;
729 nghttp2_outbound_item *item;
735 item = stream->item;
737 if (item && !item->queued && item != session->aob.item) {
738 nghttp2_outbound_item_free(item, mem);
739 nghttp2_mem_free(mem, item);
749 nghttp2_outbound_item *item, *next;
750 for (item = q->head; item;) {
751 next = item->qnext;
752 nghttp2_outbound_item_free(item, mem);
753 nghttp2_mem_free(mem, item);
754 item = next;
815 stream->item->queued */
969 nghttp2_outbound_item *item) {
972 rv = nghttp2_stream_attach_item(stream, item);
1039 return stream->item;
1105 nghttp2_outbound_item *item) {
1112 frame = &item->frame;
1121 if (stream->item) {
1125 rv = session_attach_stream_item(session, stream, item);
1141 nghttp2_outbound_queue_push(&session->ob_syn, item);
1142 item->queued = 1;
1147 nghttp2_outbound_queue_push(&session->ob_reg, item);
1148 item->queued = 1;
1152 nghttp2_outbound_queue_push(&session->ob_urgent, item);
1153 item->queued = 1;
1159 nghttp2_outbound_queue_push(&session->ob_reg, item);
1160 item->queued = 1;
1166 aux_data = &item->aux_data.headers;
1186 nghttp2_outbound_queue_push(&session->ob_reg, item);
1187 item->queued = 1;
1197 nghttp2_outbound_queue_push(&session->ob_reg, item);
1198 item->queued = 1;
1201 nghttp2_outbound_queue_push(&session->ob_reg, item);
1202 item->queued = 1;
1210 nghttp2_outbound_item *item;
1245 for (item = session->ob_syn.head; item; item = item->qnext) {
1246 aux_data = &item->aux_data.headers;
1248 if (item->frame.hd.stream_id < stream_id) {
1254 if (item->frame.hd.stream_id > stream_id || aux_data->canceled) {
1266 item = nghttp2_mem_malloc(mem, sizeof(nghttp2_outbound_item));
1267 if (item == NULL) {
1271 nghttp2_outbound_item_init(item);
1273 frame = &item->frame;
1276 rv = nghttp2_session_add_item(session, item);
1279 nghttp2_mem_free(mem, item);
1473 if (stream->item) {
1474 nghttp2_outbound_item *item;
1476 item = stream->item;
1480 /* If item is queued, it will be deleted when it is popped
1481 (nghttp2_session_prep_frame() will fail). If session->aob.item
1482 points to this item, let active_outbound_item_reset()
1483 free the item. */
1484 if (!item->queued && item != session->aob.item) {
1485 nghttp2_outbound_item_free(item, mem);
1486 nghttp2_mem_free(mem, item);
1808 nghttp2_outbound_item *item) {
1809 if (item->aux_data.headers.canceled) {
2300 nghttp2_outbound_item *item) {
2306 frame = &item->frame;
2316 assert(stream->item == item);
2322 // returns NULL, but item is still attached to the stream.
2337 /* This must be true since we only pop DATA frame item from
2344 session->aob.item = NULL;
2350 next_readmax, frame, &item->aux_data.data,
2359 session->aob.item = NULL;
2384 aux_data = &item->aux_data.headers;
2402 rv = session_predicate_request_headers_send(session, item);
2588 aux_data = &item->aux_data.ext;
2643 nghttp2_outbound_item *item;
2660 item = nghttp2_stream_next_outbound_item(&session->root);
2661 if (item) {
2662 return item;
2673 nghttp2_outbound_item *item;
2675 item = nghttp2_outbound_queue_top(&session->ob_urgent);
2676 if (item) {
2678 item->queued = 0;
2679 return item;
2682 item = nghttp2_outbound_queue_top(&session->ob_reg);
2683 if (item) {
2685 item->queued = 0;
2686 return item;
2690 item = nghttp2_outbound_queue_top(&session->ob_syn);
2691 if (item) {
2693 item->queued = 0;
2694 return item;
2699 item = nghttp2_stream_next_outbound_item(&session->root);
2700 if (item) {
2701 return item;
2816 stream->last_writelen = stream->item->frame.hd.length;
2854 nghttp2_outbound_item *item = aob->item;
2859 frame = &item->frame;
2864 aux_data = &item->aux_data.data;
2951 aux_data = &item->aux_data.headers;
2960 DATA frame item. We might have to handle it here. */
2980 aux_data = &item->aux_data.headers;
2988 DATA frame item. We might have to handle it here. */
3040 aux_data = &item->aux_data.goaway;
3112 nghttp2_outbound_item *item = aob->item;
3120 frame = &item->frame;
3144 aux_data = &item->aux_data.data;
3173 aob->item = NULL;
3180 nghttp2_outbound_item *item,
3189 frame = &item->frame;
3191 aux_data = &item->aux_data.data;
3231 nghttp2_outbound_item *item;
3233 item = nghttp2_session_pop_next_ob_item(session);
3234 if (item == NULL) {
3238 rv = session_prep_frame(session, item);
3255 if (item->frame.hd.type != NGHTTP2_DATA &&
3257 nghttp2_frame *frame = &item->frame;
3265 nghttp2_outbound_item_free(item, mem);
3266 nghttp2_mem_free(mem, item);
3273 switch (item->frame.hd.type) {
3275 if (item->frame.headers.cat == NGHTTP2_HCAT_REQUEST) {
3276 opened_stream_id = item->frame.hd.stream_id;
3277 if (item->aux_data.headers.canceled) {
3278 error_code = item->aux_data.headers.error_code;
3287 opened_stream_id = item->frame.push_promise.promised_stream_id;
3296 nghttp2_outbound_item_free(item, mem);
3297 nghttp2_mem_free(mem, item);
3316 aob->item = item;
3320 if (item->frame.hd.type != NGHTTP2_DATA) {
3323 frame = &item->frame;
3348 switch (item->frame.hd.type) {
3350 if (item->frame.headers.cat == NGHTTP2_HCAT_REQUEST) {
3351 opened_stream_id = item->frame.hd.stream_id;
3353 item->aux_data.headers.canceled since it has already
3361 opened_stream_id = item->frame.push_promise.promised_stream_id;
3382 if (item->aux_data.data.no_copy) {
3437 frame = &aob->item->frame;
3448 rv = session_call_send_data(session, aob->item, framebufs);
3523 if (session->aob.item) {
7364 return session->aob.item || nghttp2_outbound_queue_top(&session->ob_urgent) ||
7376 nghttp2_outbound_item *item;
7387 item = nghttp2_mem_malloc(mem, sizeof(nghttp2_outbound_item));
7388 if (item == NULL) {
7392 nghttp2_outbound_item_init(item);
7394 frame = &item->frame;
7398 rv = nghttp2_session_add_item(session, item);
7402 nghttp2_mem_free(mem, item);
7417 nghttp2_outbound_item *item;
7440 item = nghttp2_mem_malloc(mem, sizeof(nghttp2_outbound_item));
7441 if (item == NULL) {
7446 nghttp2_outbound_item_init(item);
7448 frame = &item->frame;
7457 aux_data = &item->aux_data.goaway;
7460 rv = nghttp2_session_add_item(session, item);
7463 nghttp2_mem_free(mem, item);
7476 nghttp2_outbound_item *item;
7481 item = nghttp2_mem_malloc(mem, sizeof(nghttp2_outbound_item));
7482 if (item == NULL) {
7486 nghttp2_outbound_item_init(item);
7488 frame = &item->frame;
7493 rv = nghttp2_session_add_item(session, item);
7497 nghttp2_mem_free(mem, item);
7516 nghttp2_outbound_item *item;
7556 item = nghttp2_mem_malloc(mem, sizeof(nghttp2_outbound_item));
7557 if (item == NULL) {
7564 nghttp2_mem_free(mem, item);
7576 nghttp2_mem_free(mem, item);
7581 nghttp2_outbound_item_init(item);
7583 frame = &item->frame;
7586 rv = nghttp2_session_add_item(session, item);
7594 nghttp2_mem_free(mem, item);
7790 nghttp2_outbound_item *item;
7811 for (item = session->ob_syn.head; item; item = item->qnext) {
7812 if (item->frame.hd.stream_id < stream_id) {
7816 if (item->frame.hd.stream_id > stream_id) {
7820 item->aux_data.headers.stream_user_data = stream_user_data;
7849 /* TODO account for item attached to stream */