fReply
BMessage fReply;
void SetReply(BMessage* m) { fReply = *m; }
req->fReply = reply;
*request->fReply = NULL;
*req->fReply = reply;
Reply** fReply;
fReply->Stream().AddUInt(OpCallbackRecall);
fReply->Stream().AddUInt(_HaikuErrorToNFS4(fStatus));
delete fReply;
fStatusPosition = fReply->Stream().Current();
fReply->Stream().AddUInt(0);
fReply->Stream().AddOpaque(NULL, 0);
fOpCountPosition = fReply->Stream().Current();
fReply->Stream().AddUInt(0);
if (fReply == NULL)
fReply->Stream().InsertUInt(fStatusPosition, _HaikuErrorToNFS4(fStatus));
fReply->Stream().InsertUInt(fOpCountPosition, fOpCount);
if (fReply->Stream().Error() == B_OK)
return fReply;
fReply->Stream().AddUInt(OpCallbackGetAttr);
fReply->Stream().AddUInt(_HaikuErrorToNFS4(fStatus));
fReply->Stream().AddUInt(1);
fReply->Stream().AddUInt(bitmap);
fReply->Stream().AddOpaque(str);
RPC::CallbackReply* fReply;
delete fReply;
fNFS4Error = fReply->Stream().GetUInt();
fReply->Stream().GetOpaque(NULL);
fReply->Stream().GetUInt();
uint32 support = fReply->Stream().GetUInt();
uint32 allow = fReply->Stream().GetUInt();
return ProcessStream(fReply, __func__);
fReply->Stream().GetUInt();
fReply->Stream().GetUInt();
fReply->Stream().GetUInt();
fReply->Stream().GetUInt();
return ProcessStream(fReply, __func__);
fReply->Stream().GetOpaque(NULL);
return ProcessStream(fReply, __func__);
atomic = fReply->Stream().GetBoolean();
*before = fReply->Stream().GetUHyper();
*after = fReply->Stream().GetUHyper();
uint32 count = fReply->Stream().GetUInt();
fReply->Stream().GetUInt();
return ProcessStream(fReply, __func__);
return _DecodeAttrs(fReply->Stream(), attrs, count);
const void* ptr = fReply->Stream().GetOpaque(&size);
return ProcessStream(fReply, __func__);
atomic = fReply->Stream().GetBoolean();
*before = fReply->Stream().GetUHyper();
*after = fReply->Stream().GetUHyper();
return ProcessStream(fReply, __func__);
linfo->fOwner->fStateSeq = fReply->Stream().GetUInt();
linfo->fOwner->fStateId[0] = fReply->Stream().GetUInt();
linfo->fOwner->fStateId[1] = fReply->Stream().GetUInt();
linfo->fOwner->fStateId[2] = fReply->Stream().GetUInt();
return ProcessStream(fReply, __func__);
*pos = fReply->Stream().GetUHyper();
*len = fReply->Stream().GetUHyper();
*type = static_cast<LockType>(fReply->Stream().GetInt());
fReply->Stream().GetUHyper();
fReply->Stream().GetOpaque(NULL);
return ProcessStream(fReply, __func__);
linfo->fOwner->fStateSeq = fReply->Stream().GetUInt();
linfo->fOwner->fStateId[0] = fReply->Stream().GetUInt();
linfo->fOwner->fStateId[1] = fReply->Stream().GetUInt();
linfo->fOwner->fStateId[2] = fReply->Stream().GetUInt();
return ProcessStream(fReply, __func__);
*seq = fReply->Stream().GetUInt();
id[0] = fReply->Stream().GetUInt();
id[1] = fReply->Stream().GetUInt();
id[2] = fReply->Stream().GetUInt();
bool atomic = fReply->Stream().GetBoolean();
uint64 before = fReply->Stream().GetUHyper();
uint64 after = fReply->Stream().GetUHyper();
uint32 flags = fReply->Stream().GetUInt();
uint32 bcount = fReply->Stream().GetUInt();
fReply->Stream().GetUInt();
uint32 delegation = fReply->Stream().GetUInt();
return ProcessStream(fReply, __func__);
delegData->fStateSeq = fReply->Stream().GetUInt();
delegData->fStateID[0] = fReply->Stream().GetUInt();
delegData->fStateID[1] = fReply->Stream().GetUInt();
delegData->fStateID[2] = fReply->Stream().GetUInt();
delegData->fRecall = fReply->Stream().GetBoolean();
int32 limitBy = fReply->Stream().GetInt();
delegData->fSpaceLimit = fReply->Stream().GetUHyper();
uint32 numBlocks = fReply->Stream().GetUInt();
delegData->fSpaceLimit = fReply->Stream().GetUInt() * numBlocks;
fReply->Stream().GetUInt();
fReply->Stream().GetUInt();
fReply->Stream().GetUInt();
fReply->Stream().GetOpaque(NULL);
return ProcessStream(fReply, __func__);
*stateSeq = fReply->Stream().GetUInt();
fReply->Stream().GetUInt();
fReply->Stream().GetUInt();
fReply->Stream().GetUInt();
return ProcessStream(fReply, __func__);
*eof = fReply->Stream().GetBoolean();
const void* ptr = fReply->Stream().GetOpaque(size);
return ProcessStream(fReply, __func__);
*cookieVerf = fReply->Stream().GetUHyper();
XDR::Stream::Position dataStart = fReply->Stream().Current();
isNext = fReply->Stream().GetBoolean();
fReply->Stream().GetUHyper();
free(fReply->Stream().GetString());
_DecodeAttrs(fReply->Stream(), &values, &attrCount);
isNext = fReply->Stream().GetBoolean();
fReply->Stream().SetPosition(dataStart);
isNext = fReply->Stream().GetBoolean();
*cookie = fReply->Stream().GetUHyper();
entries[count].fName = fReply->Stream().GetString();
_DecodeAttrs(fReply->Stream(), &entries[count].fAttrs,
isNext = fReply->Stream().GetBoolean();
*eof = fReply->Stream().GetBoolean();
if (fReply->Stream().IsEOF()) {
const void* ptr = fReply->Stream().GetOpaque(size);
return ProcessStream(fReply, __func__);
atomic = fReply->Stream().GetBoolean();
*before = fReply->Stream().GetUHyper();
*after = fReply->Stream().GetUHyper();
return ProcessStream(fReply, __func__);
fromAtomic = fReply->Stream().GetBoolean();
*fromBefore = fReply->Stream().GetUHyper();
*fromAfter = fReply->Stream().GetUHyper();
toAtomic = fReply->Stream().GetBoolean();
*toBefore = fReply->Stream().GetUHyper();
*toAfter = fReply->Stream().GetUHyper();
return ProcessStream(fReply, __func__);
uint32 bcount = fReply->Stream().GetUInt();
fReply->Stream().GetUInt();
return ProcessStream(fReply, __func__);
*clientid = fReply->Stream().GetUHyper();
*verifier = fReply->Stream().GetUHyper();
return ProcessStream(fReply, __func__);
*size = fReply->Stream().GetUInt();
fReply->Stream().GetInt();
fReply->Stream().GetUHyper();
return ProcessStream(fReply, __func__);
uint32 bcount = fReply->Stream().GetUInt();
if (fReply == NULL)
if (fReply->Error() != B_OK || fReply->Stream().IsEOF()) {
return fReply->Error();
if (fReply->Stream().GetInt() != op) {
status_t result = _NFS4ErrorToHaiku(fReply->Stream().GetUInt());
RPC::Reply* fReply;
if (fReply != NULL)
fReply = _reply;
if (fReply != NULL)
delete fReply;
fReply = NULL;
fReply.SetTo(rpl);
fReply.Reset();
fReply.SetTo(rpl);
ReplyInterpreter fReply;
return fReply;
fSender->SendReply(&fReply);