Skip to content

Commit

Permalink
MsgHandler must not be enqueued in InQueue on virtual redirect, fixes #…
Browse files Browse the repository at this point in the history
  • Loading branch information
simonmichal committed Apr 6, 2018
1 parent 97ca085 commit 9b16750
Show file tree
Hide file tree
Showing 4 changed files with 2 additions and 5 deletions.
2 changes: 1 addition & 1 deletion src/XrdCl/XrdClMessageUtils.cc
Expand Up @@ -177,7 +177,7 @@ namespace XrdCl
//--------------------------------------------------------------------------
// Redirect the message
//--------------------------------------------------------------------------
st = postMaster->Redirect( url, msg, msgHandler, msgHandler );
st = postMaster->Redirect( url, msg, msgHandler );
if( !st.IsOK() )
{
XRootDTransport::UnMarshallRequest( msg );
Expand Down
2 changes: 0 additions & 2 deletions src/XrdCl/XrdClPostMaster.cc
Expand Up @@ -193,14 +193,12 @@ namespace XrdCl

Status PostMaster::Redirect( const URL &url,
Message *msg,
OutgoingMsgHandler *outHandler,
IncomingMsgHandler *inHandler )
{
RedirectorRegistry &registry = RedirectorRegistry::Instance();
VirtualRedirector *redirector = registry.Get( url );
if( !redirector )
return Status( stError, errInvalidOp );
outHandler->OnStatusReady( msg, Status() );
return redirector->HandleRequest( msg, inHandler );
}

Expand Down
1 change: 0 additions & 1 deletion src/XrdCl/XrdClPostMaster.hh
Expand Up @@ -125,7 +125,6 @@ namespace XrdCl
//------------------------------------------------------------------------
Status Redirect( const URL &url,
Message *msg,
OutgoingMsgHandler *outHandler,
IncomingMsgHandler *handler);

//------------------------------------------------------------------------
Expand Down
2 changes: 1 addition & 1 deletion src/XrdCl/XrdClXRootDMsgHandler.cc
Expand Up @@ -1962,7 +1962,7 @@ namespace XrdCl
}
pUrl = url;
if( pUrl.IsMetalink() && pFollowMetalink )
return pPostMaster->Redirect( pUrl, pRequest, this, this );
return pPostMaster->Redirect( pUrl, pRequest, this );
else if( pUrl.IsLocalFile() )
{
HandleLocalRedirect( &pUrl );
Expand Down

0 comments on commit 9b16750

Please sign in to comment.