diff options
| author | Dan Engelbrecht <[email protected]> | 2023-09-15 07:36:58 -0400 |
|---|---|---|
| committer | GitHub <[email protected]> | 2023-09-15 13:36:58 +0200 |
| commit | 6163987f858597e92e68a61ed35be35bd4e7a552 (patch) | |
| tree | 94e78c3865f7f288df041636f9471b5a1511792b /src/zenhttp/httpsys.cpp | |
| parent | updated CHANGELOG.md release versions (diff) | |
| download | zen-6163987f858597e92e68a61ed35be35bd4e7a552.tar.xz zen-6163987f858597e92e68a61ed35be35bd4e7a552.zip | |
add more trace scopes (#362)
* more trace scopes
* Make sure ReplayLogEntries uses the correct size for oplog buffer
* changelog
Diffstat (limited to 'src/zenhttp/httpsys.cpp')
| -rw-r--r-- | src/zenhttp/httpsys.cpp | 13 |
1 files changed, 12 insertions, 1 deletions
diff --git a/src/zenhttp/httpsys.cpp b/src/zenhttp/httpsys.cpp index 342fdd047..3bcaa5861 100644 --- a/src/zenhttp/httpsys.cpp +++ b/src/zenhttp/httpsys.cpp @@ -351,6 +351,8 @@ HttpMessageResponseRequest::~HttpMessageResponseRequest() void HttpMessageResponseRequest::InitializeForPayload(uint16_t ResponseCode, std::span<IoBuffer> BlobList) { + ZEN_TRACE_CPU("httpsys::InitializeForPayload"); + const uint32_t ChunkCount = gsl::narrow<uint32_t>(BlobList.size()); m_HttpDataChunks.reserve(ChunkCount); @@ -459,6 +461,7 @@ HttpMessageResponseRequest::HandleCompletion(ULONG IoResult, ULONG_PTR NumberOfB void HttpMessageResponseRequest::IssueRequest(std::error_code& ErrorCode) { + ZEN_TRACE_CPU("httpsys::Response::IssueRequest"); HttpSysTransaction& Tx = Transaction(); HTTP_REQUEST* const HttpReq = Tx.HttpRequest(); PTP_IO const Iocp = Tx.Iocp(); @@ -663,6 +666,7 @@ HttpAsyncWorkRequest::~HttpAsyncWorkRequest() void HttpAsyncWorkRequest::IssueRequest(std::error_code& ErrorCode) { + ZEN_TRACE_CPU("httpsys::AsyncWork::IssueRequest"); ErrorCode.clear(); Transaction().Server().WorkPool().ScheduleWork(m_WorkItem); @@ -697,7 +701,10 @@ HttpAsyncWorkRequest::AsyncWorkItem::Execute() ThisRequest.m_NextCompletionHandler = nullptr; - Handler(ThisRequest); + { + ZEN_TRACE_CPU("httpsys::HandleRequest"); + Handler(ThisRequest); + } // TODO: should Handler be destroyed at this point to ensure there // are no outstanding references into state which could be @@ -1152,6 +1159,8 @@ HttpSysTransaction::IoCompletionCallback(PTP_CALLBACK_INSTANCE Instance, bool HttpSysTransaction::IssueNextRequest(HttpSysRequestHandler* NewCompletionHandler) { + ZEN_TRACE_CPU("httpsys::Transaction::IssueNextRequest"); + HttpSysRequestHandler* CurrentHandler = m_CompletionHandler; m_CompletionHandler = NewCompletionHandler; @@ -1479,6 +1488,8 @@ InitialRequestHandler::~InitialRequestHandler() void InitialRequestHandler::IssueRequest(std::error_code& ErrorCode) { + ZEN_TRACE_CPU("httpsys::Request::IssueRequest"); + HttpSysTransaction& Tx = Transaction(); PTP_IO Iocp = Tx.Iocp(); HTTP_REQUEST* HttpReq = Tx.HttpRequest(); |