io->c->bucket_alloc);
APR_BRIGADE_INSERT_TAIL(io->output, b);
#if LOG_SCRATCH
- ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, io->c,
+ ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, io->c, APLOGNO(),
"h2_conn_io(%ld): append_scratch(%ld)",
io->c->id, (long)io->slen);
#endif
}
status = apr_file_read(fd, io->scratch + io->slen, &len);
#if LOG_SCRATCH
- ap_log_cerror(APLOG_MARK, APLOG_INFO, status, io->c,
+ ap_log_cerror(APLOG_MARK, APLOG_INFO, status, io->c, APLOGNO(),
"h2_conn_io(%ld): FILE_to_scratch(%ld)",
io->c->id, (long)len);
#endif
status = apr_bucket_read(b, &data, &len, APR_BLOCK_READ);
if (status == APR_SUCCESS) {
#if LOG_SCRATCH
- ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, io->c,
+ ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, io->c, APLOGNO(),
"h2_conn_io(%ld): read_to_scratch(%ld)",
io->c->id, (long)b->length);
#endif
remain = assure_scratch_space(io);
if (remain >= length) {
#if LOG_SCRATCH
- ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, io->c,
+ ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, io->c, APLOGNO(),
"h2_conn_io(%ld): write_to_scratch(%ld)",
io->c->id, (long)length);
#endif
}
else {
#if LOG_SCRATCH
- ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, io->c,
+ ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, io->c, APLOGNO(),
"h2_conn_io(%ld): write_to_scratch(%ld)",
io->c->id, (long)remain);
#endif
APR_BUCKET_REMOVE(b);
APR_BRIGADE_INSERT_TAIL(io->output, b);
#if LOG_SCRATCH
- ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, io->c,
+ ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, io->c, APLOGNO(),
"h2_conn_io(%ld): pass bucket(%ld)",
io->c->id, (long)b->length);
#endif
task->worker_done);
}
else if (task) {
- ap_log_cerror(APLOG_MARK, APLOG_WARNING, 0, m->c, /* NO APLOGNO */
+ ap_log_cerror(APLOG_MARK, APLOG_WARNING, 0, m->c, APLOGNO(), /* NO APLOGNO */
"->03198: h2_stream(%ld-%d): NULL", m->id, task->stream_id);
}
else {
- ap_log_cerror(APLOG_MARK, APLOG_WARNING, 0, m->c, /* NO APLOGNO */
+ ap_log_cerror(APLOG_MARK, APLOG_WARNING, 0, m->c, APLOGNO(), /* NO APLOGNO */
"->03198: h2_stream(%ld-NULL): NULL", m->id);
}
return 1;
h2_response *r = h2_response_die(task->stream_id, 500,
task->request, m->pool);
status = out_open(m, task->stream_id, r);
- ap_log_cerror(APLOG_MARK, APLOG_DEBUG, status, m->c,
+ ap_log_cerror(APLOG_MARK, APLOG_DEBUG, status, m->c, APLOGNO(),
"h2_mplx(%s): close, no response, no rst", task->id);
}
ap_log_cerror(APLOG_MARK, APLOG_TRACE2, status, m->c,
void h2_ngn_shed_abort(h2_ngn_shed *shed)
{
- ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, shed->c,
+ ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, shed->c, APLOGNO(),
"h2_ngn_shed(%ld): abort", shed->c->id);
shed->aborted = 1;
}
status = einit(newngn, newngn->id, newngn->type, newngn->pool,
shed->req_buffer_size, task->r,
&newngn->out_consumed, &newngn->out_consumed_ctx);
- ap_log_cerror(APLOG_MARK, APLOG_DEBUG, status, task->c,
+ ap_log_cerror(APLOG_MARK, APLOG_DEBUG, status, task->c, APLOGNO(),
"h2_ngn_shed(%ld): create engine %s (%s)",
shed->c->id, newngn->id, newngn->type);
if (status == APR_SUCCESS) {
AP_DEBUG_ASSERT(ngn);
*ptask = NULL;
- ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, shed->c,
+ ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, shed->c, APLOGNO(),
"h2_ngn_shed(%ld): pull task for engine %s, shutdown=%d",
shed->c->id, ngn->id, want_shutdown);
if (shed->aborted) {
- ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, shed->c,
+ ap_log_cerror(APLOG_MARK, APLOG_INFO, 0, shed->c, APLOGNO(),
"h2_ngn_shed(%ld): abort while pulling requests %s",
shed->c->id, ngn->id);
ngn->shutdown = 1;
}
if ((entry = pop_detached(ngn))) {
- ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, entry->task->c,
+ ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, entry->task->c, APLOGNO(),
"h2_ngn_shed(%ld): pulled request %s for engine %s",
shed->c->id, entry->task->id, ngn->id);
ngn->no_live++;
if (1) {
h2_ngn_entry *entry = H2_REQ_ENTRIES_FIRST(&ngn->entries);
- ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, shed->c,
+ ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, shed->c, APLOGNO(),
"h2_ngn_shed(%ld): pull task, nothing, first task %s",
shed->c->id, entry->task->id);
}
static apr_status_t ngn_done_task(h2_ngn_shed *shed, h2_req_engine *ngn,
h2_task *task, int waslive, int aborted)
{
- ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, shed->c,
+ ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, shed->c, APLOGNO(),
"h2_ngn_shed(%ld): task %s %s by %s",
shed->c->id, task->id, aborted? "aborted":"done", ngn->id);
ngn->no_finished++;
break;
default:
- ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, session->c,
+ ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, session->c, APLOGNO(),
"h2_session(%ld): conn error -> shutdown", session->id);
h2_session_shutdown(session, arg, msg, 0);
break;
break;
default:
- ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, session->c,
+ ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, session->c, APLOGNO(),
"h2_session(%ld): proto error -> shutdown", session->id);
h2_session_shutdown(session, arg, msg, 0);
break;
}
else {
ap_log_cerror( APLOG_MARK, APLOG_DEBUG, status, c,
+ APLOGNO(),
"h2_session(%ld): idle, no data, error",
session->id);
dispatch_event(session, H2_SESSION_EV_CONN_ERROR, 0, "timeout");
}
else {
ap_log_cerror(APLOG_MARK, APLOG_WARNING, status, c,
+ APLOGNO(),
"h2_session(%ld): waiting on conditional",
session->id);
h2_session_shutdown(session, H2_ERR_INTERNAL_ERROR,
/* If the passed brigade is not empty, save it before return */
if (!APR_BRIGADE_EMPTY(bb)) {
- ap_log_cerror(APLOG_MARK, APLOG_DEBUG, status, task->c,
+ ap_log_cerror(APLOG_MARK, APLOG_DEBUG, status, task->c, APLOGNO(),
"h2_task(%s): could not write all, saving brigade",
task->id);
if (!task->output.bb) {
{
if (!task->frozen) {
task->frozen = 1;
- ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, task->c,
+ ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, task->c, APLOGNO(),
"h2_task(%s), frozen", task->id);
}
return APR_SUCCESS;
{
if (task->frozen) {
task->frozen = 0;
- ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, task->c,
+ ap_log_cerror(APLOG_MARK, APLOG_DEBUG, 0, task->c, APLOGNO(),
"h2_task(%s), thawed", task->id);
}
task->detached = 1;