-
Notifications
You must be signed in to change notification settings - Fork 306
HPCC-33491 Improve rowservice tracing #19796
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
- Added file process time tracking - Improved error reporting Signed-off-by: James McMullan [email protected]
Jira Issue: https://hpccsystems.atlassian.net//browse/HPCC-33491 Jirabot Action Result: |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@jpmcmu - looks fine overall, but 1 issue/question.
fs/dafsserver/dafsserver.cpp
Outdated
@@ -4919,6 +4932,10 @@ class CRemoteFileServer : implements IRemoteFileServer, public CInterface | |||
Owned<IRemoteActivity> outputActivity; | |||
OpenFileInfo fileInfo; | |||
|
|||
ISpan* requestSpan = queryNullSpan(); | |||
if (fileInfo.remoteRequest) | |||
requestSpan = fileInfo.remoteRequest->queryRequestSpan(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
fileInfo.remoteRequest is always going to be null here..
Should this be moved ?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@jakesmith It should only be null on the first request of newstream, with the subsequent continue requests it should have a value, but it isn't super useful outside of the continue context, so I will move it.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@jpmcmu - 1 minor comment/question, but looks good.
fs/dafsserver/dafsserver.cpp
Outdated
if (activity->queryIsReadActivity()) | ||
processRead(requestTree, responseMb); | ||
else if (activity->queryIsWriteActivity()) | ||
processWrite(requestTree, restMb, responseMb); | ||
|
||
if (activeSpan->isValid()) | ||
processingTimeNS += (nsTick() - processStartTime); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
if there's an exception in process* then this won't happen.
Can you use a RAII pattern, so the time guaranteed to be accounted for?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@jpmcmu - looks good afaics. Please squash.
Oops - merged before it had been squashed. |
Jirabot Action Result: |
Signed-off-by: James McMullan [email protected]
Type of change:
Checklist:
Smoketest:
Testing: