MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-06-10 22:18:54 +02:00
Code Issues Releases Wiki Activity

ircd::server: Add a request log.

Browse source
This commit is contained in:
Jason Volk 2019-07-25 23:05:15 -07:00
parent dd640266f5
commit 3f418bf1ed
2 changed files with 38 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
include/ircd/server/request.h
View file

@ -110,6 +110,7 @@ struct ircd::server::request
using each_closure = std::function<bool (const peer &, const link &, const request &)>;
static const opts opts_default;
static log::log log;
server::tag *tag {nullptr};

45
ircd/server.cc
View file

@ -349,7 +349,7 @@ ircd::server::cancel(request &request)
log::debug
{
log, "cancel %s commit:%d w:%zu hr:%zu cr:%zu",
request::log, "%s cancel commit:%d w:%zu hr:%zu cr:%zu",
loghead(request),
tag.committed(),
tag.state.written,
@ -989,7 +989,7 @@ noexcept try
{
log::debug
{
log, "%s [%s] => [%u] done wt:%zu rt:%zu hr:%zu cr:%zu cl:%zu chunks:%zu %zu more in queue",
log, "%s [%s] => [%u] done wt:%zu rt:%zu %zu more in queue",
loghead(link),
tag.request?
loghead(*tag.request):
@ -997,15 +997,23 @@ noexcept try
uint(tag.state.status),
tag.write_size(),
tag.read_size(),
tag.state.head_read,
tag.state.content_read,
tag.state.content_length,
tag.request?
tag.request->in.chunks.size():
0UL,
link.tag_count() - 1
};
if(tag.request)
log::debug
{
request::log, "%s [%u] wt:%zu rt:%zu hr:%zu cr:%zu cl:%zu chunks:%zu",
loghead(*tag.request),
uint(tag.state.status),
tag.write_size(),
tag.read_size(),
tag.state.head_read,
tag.state.content_read,
tag.state.content_length,
tag.request->in.chunks.size(),
};
if(link.tag_committed() >= link.tag_commit_max())
link.wait_writable();
}
@ -1986,6 +1994,7 @@ bool
ircd::server::link::process_write(tag &tag)
{
if(!tag.committed())
{
log::debug
{
log, "%s starting on tag:%lu %zu of %zu: wt:%zu [%s]",
@ -1999,6 +2008,16 @@ ircd::server::link::process_write(tag &tag)
"<no attached request>"_sv
};
if(tag.request)
log::debug
{
request::log, "%s wt:%zu on %s",
loghead(*tag.request),
tag.write_size(),
loghead(*this),
};
}
while(tag.write_remaining())
{
const const_buffer buffer
@ -2460,6 +2479,16 @@ const
});
}
//
// request
//
decltype(ircd::server::request::log)
ircd::server::request::log
{
"server.request"
};
//
// tag
//