if (APR_SUCCESS == status) {
task = h2_tq_pop_first(m->q);
if (task) {
- h2_io *io = h2_io_set_get(m->stream_ios, task->stream_id);
- if (io) {
- task->c = h2_conn_create(m->c, io->pool);
- }
h2_task_set_started(task);
}
*has_more = !h2_tq_empty(m->q);
}
status = apr_thread_mutex_lock(m->lock);
if (APR_SUCCESS == status) {
+ conn_rec *c = h2_conn_create(m->c, stream->pool);
stream->task = h2_task_create(m->id, stream->id,
- stream->pool, m, NULL);
+ stream->pool, m, c);
apr_thread_mutex_unlock(m->lock);
}