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;
734 nghttp2_outbound_item *item;
740 item = stream->item;
742 if (item && !item->queued && item != session->aob.item) {
743 nghttp2_outbound_item_free(item, mem);
744 nghttp2_mem_free(mem, item);
754 nghttp2_outbound_item *item, *next;
755 for (item = q->head; item;) {
756 next = item->qnext;
757 nghttp2_outbound_item_free(item, mem);
758 nghttp2_mem_free(mem, item);
759 item = next;
820 stream->item->queued */
974 nghttp2_outbound_item *item) {
977 rv = nghttp2_stream_attach_item(stream, item);
1044 return stream->item;
1110 nghttp2_outbound_item *item) {
1117 frame = &item->frame;
1126 if (stream->item) {
1130 rv = session_attach_stream_item(session, stream, item);
1146 nghttp2_outbound_queue_push(&session->ob_syn, item);
1147 item->queued = 1;
1152 nghttp2_outbound_queue_push(&session->ob_reg, item);
1153 item->queued = 1;
1157 nghttp2_outbound_queue_push(&session->ob_urgent, item);
1158 item->queued = 1;
1164 nghttp2_outbound_queue_push(&session->ob_reg, item);
1165 item->queued = 1;
1171 aux_data = &item->aux_data.headers;
1191 nghttp2_outbound_queue_push(&session->ob_reg, item);
1192 item->queued = 1;
1202 nghttp2_outbound_queue_push(&session->ob_reg, item);
1203 item->queued = 1;
1206 nghttp2_outbound_queue_push(&session->ob_reg, item);
1207 item->queued = 1;
1215 nghttp2_outbound_item *item;
1250 for (item = session->ob_syn.head; item; item = item->qnext) {
1251 aux_data = &item->aux_data.headers;
1253 if (item->frame.hd.stream_id < stream_id) {
1259 if (item->frame.hd.stream_id > stream_id || aux_data->canceled) {
1271 item = nghttp2_mem_malloc(mem, sizeof(nghttp2_outbound_item));
1272 if (item == NULL) {
1276 nghttp2_outbound_item_init(item);
1278 frame = &item->frame;
1281 rv = nghttp2_session_add_item(session, item);
1284 nghttp2_mem_free(mem, item);
1478 if (stream->item) {
1479 nghttp2_outbound_item *item;
1481 item = stream->item;
1485 /* If item is queued, it will be deleted when it is popped
1486 (nghttp2_session_prep_frame() will fail). If session->aob.item
1487 points to this item, let active_outbound_item_reset()
1488 free the item. */
1489 if (!item->queued && item != session->aob.item) {
1490 nghttp2_outbound_item_free(item, mem);
1491 nghttp2_mem_free(mem, item);
1813 nghttp2_outbound_item *item) {
1814 if (item->aux_data.headers.canceled) {
2305 nghttp2_outbound_item *item) {
2311 frame = &item->frame;
2321 assert(stream->item == item);
2327 // returns NULL, but item is still attached to the stream.
2342 /* This must be true since we only pop DATA frame item from
2349 session->aob.item = NULL;
2355 next_readmax, frame, &item->aux_data.data,
2364 session->aob.item = NULL;
2389 aux_data = &item->aux_data.headers;
2407 rv = session_predicate_request_headers_send(session, item);
2593 aux_data = &item->aux_data.ext;
2648 nghttp2_outbound_item *item;
2665 item = nghttp2_stream_next_outbound_item(&session->root);
2666 if (item) {
2667 return item;
2678 nghttp2_outbound_item *item;
2680 item = nghttp2_outbound_queue_top(&session->ob_urgent);
2681 if (item) {
2683 item->queued = 0;
2684 return item;
2687 item = nghttp2_outbound_queue_top(&session->ob_reg);
2688 if (item) {
2690 item->queued = 0;
2691 return item;
2695 item = nghttp2_outbound_queue_top(&session->ob_syn);
2696 if (item) {
2698 item->queued = 0;
2699 return item;
2704 item = nghttp2_stream_next_outbound_item(&session->root);
2705 if (item) {
2706 return item;
2821 stream->last_writelen = stream->item->frame.hd.length;
2859 nghttp2_outbound_item *item = aob->item;
2864 frame = &item->frame;
2869 aux_data = &item->aux_data.data;
2956 aux_data = &item->aux_data.headers;
2965 DATA frame item. We might have to handle it here. */
2985 aux_data = &item->aux_data.headers;
2993 DATA frame item. We might have to handle it here. */
3045 aux_data = &item->aux_data.goaway;
3117 nghttp2_outbound_item *item = aob->item;
3125 frame = &item->frame;
3149 aux_data = &item->aux_data.data;
3178 aob->item = NULL;
3185 nghttp2_outbound_item *item,
3194 frame = &item->frame;
3196 aux_data = &item->aux_data.data;
3236 nghttp2_outbound_item *item;
3238 item = nghttp2_session_pop_next_ob_item(session);
3239 if (item == NULL) {
3243 rv = session_prep_frame(session, item);
3260 if (item->frame.hd.type != NGHTTP2_DATA &&
3262 nghttp2_frame *frame = &item->frame;
3270 nghttp2_outbound_item_free(item, mem);
3271 nghttp2_mem_free(mem, item);
3278 switch (item->frame.hd.type) {
3280 if (item->frame.headers.cat == NGHTTP2_HCAT_REQUEST) {
3281 opened_stream_id = item->frame.hd.stream_id;
3282 if (item->aux_data.headers.canceled) {
3283 error_code = item->aux_data.headers.error_code;
3292 opened_stream_id = item->frame.push_promise.promised_stream_id;
3301 nghttp2_outbound_item_free(item, mem);
3302 nghttp2_mem_free(mem, item);
3321 aob->item = item;
3325 if (item->frame.hd.type != NGHTTP2_DATA) {
3328 frame = &item->frame;
3353 switch (item->frame.hd.type) {
3355 if (item->frame.headers.cat == NGHTTP2_HCAT_REQUEST) {
3356 opened_stream_id = item->frame.hd.stream_id;
3358 item->aux_data.headers.canceled since it has already
3366 opened_stream_id = item->frame.push_promise.promised_stream_id;
3387 if (item->aux_data.data.no_copy) {
3442 frame = &aob->item->frame;
3453 rv = session_call_send_data(session, aob->item, framebufs);
3528 if (session->aob.item) {
7375 return session->aob.item || nghttp2_outbound_queue_top(&session->ob_urgent) ||
7387 nghttp2_outbound_item *item;
7398 item = nghttp2_mem_malloc(mem, sizeof(nghttp2_outbound_item));
7399 if (item == NULL) {
7403 nghttp2_outbound_item_init(item);
7405 frame = &item->frame;
7409 rv = nghttp2_session_add_item(session, item);
7413 nghttp2_mem_free(mem, item);
7428 nghttp2_outbound_item *item;
7451 item = nghttp2_mem_malloc(mem, sizeof(nghttp2_outbound_item));
7452 if (item == NULL) {
7457 nghttp2_outbound_item_init(item);
7459 frame = &item->frame;
7468 aux_data = &item->aux_data.goaway;
7471 rv = nghttp2_session_add_item(session, item);
7474 nghttp2_mem_free(mem, item);
7487 nghttp2_outbound_item *item;
7492 item = nghttp2_mem_malloc(mem, sizeof(nghttp2_outbound_item));
7493 if (item == NULL) {
7497 nghttp2_outbound_item_init(item);
7499 frame = &item->frame;
7504 rv = nghttp2_session_add_item(session, item);
7508 nghttp2_mem_free(mem, item);
7527 nghttp2_outbound_item *item;
7567 item = nghttp2_mem_malloc(mem, sizeof(nghttp2_outbound_item));
7568 if (item == NULL) {
7575 nghttp2_mem_free(mem, item);
7587 nghttp2_mem_free(mem, item);
7592 nghttp2_outbound_item_init(item);
7594 frame = &item->frame;
7597 rv = nghttp2_session_add_item(session, item);
7605 nghttp2_mem_free(mem, item);
7801 nghttp2_outbound_item *item;
7822 for (item = session->ob_syn.head; item; item = item->qnext) {
7823 if (item->frame.hd.stream_id < stream_id) {
7827 if (item->frame.hd.stream_id > stream_id) {
7831 item->aux_data.headers.stream_user_data = stream_user_data;
7860 /* TODO account for item attached to stream */