96 inmsg = std::make_shared<Message>();
100 readstage = ReadHeader;
108 XRootDStatus st = xrdTransport.GetHeader( *inmsg, &socket );
113 strmname.c_str(), inmsg.get(), inmsg->GetCursor() );
119 "of message %p", strmname.c_str(), inmsg.get() );
120 inmsg->ReAllocate( 16 );
121 readstage = ReadAttn;
125 inmsgsize = inmsg->GetCursor();
126 inhandler = strm.InstallIncHandler( inmsg, substrmnb );
131 "of message %p", strmname.c_str(), inmsg.get() );
135 readstage = ReadRawData;
142 readstage = ReadMsgBody;
157 if( HasEmbeddedRsp() )
160 readstage = ReadHeader;
167 inmsgsize = inmsg->GetCursor();
168 readstage = ReadMsgBody;
177 XRootDStatus st = xrdTransport.GetMore( *inmsg, &socket );
180 inmsgsize = inmsg->GetCursor();
185 readstage = ReadDone;
194 uint32_t bytesRead = 0;
195 XRootDStatus st = inhandler->ReadMessageBody( inmsg.get(), &socket, bytesRead );
198 inmsgsize += bytesRead;
204 readstage = ReadDone;
212 XRootDStatus st = xrdTransport.GetBody( *inmsg, &socket );
215 inmsgsize = inmsg->GetCursor();
224 uint16_t action = strm.InspectStatusRsp( substrmnb,
235 readstage = ReadRawData;
246 readstage = ReadMore;
254 readstage = ReadDone;
264 strmname.c_str(), inmsg.get(), inmsgsize );
266 strm.OnIncoming( substrmnb, std::move( inmsg ), inmsgsize );