netfs/client/ShareVolume.cpp

491 	ReadVNodeReply* reply;
492 	error = SendRequest(fConnection, &request, &reply);
495 	ObjectDeleter<Request> replyDeleter(reply);
496 	if (reply->error != B_OK)
497 		RETURN_ERROR(reply->error);
501 	error = _LoadNode(reply->nodeInfo, &node);
592 	WriteStatReply* reply;
593 	status_t error = SendRequest(fConnection, &request, &reply);
596 	ObjectDeleter<Request> replyDeleter(reply);
598 	if (reply->nodeInfoValid)
599 		_UpdateNode(reply->nodeInfo);
600 	if (reply->error != B_OK)
601 		RETURN_ERROR(reply->error);
644 	CreateFileReply* reply;
645 	status_t error = SendRequest(fConnection, &request, &reply);
648 	ObjectDeleter<Request> replyDeleter(reply);
649 	if (reply->error != B_OK)
650 		RETURN_ERROR(reply->error);
654 	EntryInfo* entryInfo = &reply->entryInfo;
659 			error = _Walk(reply->entryInfo.directoryID,
660 				reply->entryInfo.name.GetString(), false, &walkReply);
693 		*cookie = (void*)reply->cookie;
695 		_Close(reply->cookie);
725 	OpenReply* reply;
726 	status_t error = SendRequest(fConnection, &request, &reply);
729 	ObjectDeleter<Request> replyDeleter(reply);
730 	if (reply->error != B_OK)
731 		RETURN_ERROR(reply->error);
733 	_UpdateNode(reply->nodeInfo);
734 	*cookie = (void*)reply->cookie;
789 			ReadReply* reply = dynamic_cast<ReadReply*>(_reply);
790 			if (!reply)
792 			// process the reply
793 			status_t error = ProcessReply(reply);
796 			bool moreToCome = reply->moreToCome;
798 				// receive a reply
799 				error = ReceiveRequest(channel, &reply);
802 				moreToCome = reply->moreToCome;
803 				ObjectDeleter<Request> replyDeleter(reply);
804 				// process the reply
805 				error = ProcessReply(reply);
812 		status_t ProcessReply(ReadReply* reply)
814 			if (reply->error != B_OK)
815 				RETURN_ERROR(reply->error);
817 			if (reply->pos != pos)
819 			int32 bytesRead = reply->data.GetSize();
824 				memcpy(buffer, reply->data.GetData(), bytesRead);
869 		WriteReply* reply;
870 		status_t error = SendRequest(fConnection, &request, &reply);
873 		ObjectDeleter<Request> replyDeleter(reply);
874 		if (reply->error != B_OK)
875 			RETURN_ERROR(reply->error);
922 	CreateLinkReply* reply;
923 	status_t error = SendRequest(fConnection, &request, &reply);
926 	ObjectDeleter<Request> replyDeleter(reply);
927 	RETURN_ERROR(reply->error);
948 	UnlinkReply* reply;
949 	status_t error = SendRequest(fConnection, &request, &reply);
952 	ObjectDeleter<Request> replyDeleter(reply);
953 	RETURN_ERROR(reply->error);
977 	CreateSymlinkReply* reply;
978 	status_t error = SendRequest(fConnection, &request, &reply);
981 	ObjectDeleter<Request> replyDeleter(reply);
982 	RETURN_ERROR(reply->error);
1002 	ReadLinkReply* reply;
1003 	status_t error = SendRequest(fConnection, &request, &reply);
1006 	ObjectDeleter<Request> replyDeleter(reply);
1007 	if (reply->error != B_OK)
1008 		RETURN_ERROR(reply->error);
1009 	if (reply->data.GetSize() > (int32)bufferSize)
1011 	*bytesRead = reply->data.GetSize();
1013 		memcpy(buffer, reply->data.GetData(), *bytesRead);
1014 	_UpdateNode(reply->nodeInfo);
1045 	RenameReply* reply;
1046 	status_t error = SendRequest(fConnection, &request, &reply);
1049 	ObjectDeleter<Request> replyDeleter(reply);
1050 	RETURN_ERROR(reply->error);
1078 	MakeDirReply* reply;
1079 	status_t error = SendRequest(fConnection, &request, &reply);
1082 	ObjectDeleter<Request> replyDeleter(reply);
1083 	RETURN_ERROR(reply->error);
1104 	RemoveDirReply* reply;
1105 	status_t error = SendRequest(fConnection, &request, &reply);
1108 	ObjectDeleter<Request> replyDeleter(reply);
1109 	RETURN_ERROR(reply->error);
1162 	OpenDirReply* reply;
1163 	status_t error = SendRequest(fConnection, &request, &reply);
1166 	ObjectDeleter<Request> replyDeleter(reply);
1167 	if (reply->error != B_OK)
1172 		RETURN_ERROR(reply->error);
1176 	_UpdateNode(reply->nodeInfo);
1179 	iterator->SetCookie(reply->cookie);
1217 			CloseReply* reply;
1218 			error = SendRequest(fConnection, &request, &reply);
1220 				error = reply->error;
1221 				delete reply;
1354 	WalkReply* reply;
1358 			&reply);
1361 		ObjectDeleter<Request> replyDeleter(reply);
1366 		if (_IsObsoleteEntryInfo(reply->entryInfo))
1371 		error = _LoadEntry(dir, reply->entryInfo, &entry);
1377 		if (reply->linkPath.GetString() && resolvedPath) {
1378 			*resolvedPath = strdup(reply->linkPath.GetString());
1423 		OpenAttrDirReply* reply;
1424 		status_t error = SendRequest(fConnection, &request, &reply);
1427 		ObjectDeleter<Request> replyDeleter(reply);
1428 		if (reply->error != B_OK)
1429 			RETURN_ERROR(reply->error);
1433 		if (!reply->attrDirInfo.isValid) {
1434 			cookie->cookie = reply->cookie;
1444 		error = _LoadAttrDir(node, reply->attrDirInfo);
1503 	CloseReply* reply;
1504 	status_t error = SendRequest(fConnection, &request, &reply);
1507 	ObjectDeleter<Request> replyDeleter(reply);
1508 	if (reply->error != B_OK)
1509 		RETURN_ERROR(reply->error);
1558 	ReadAttrDirReply* reply;
1559 	status_t error = SendRequest(fConnection, &request, &reply);
1562 	ObjectDeleter<Request> replyDeleter(reply);
1563 	if (reply->error != B_OK)
1564 		RETURN_ERROR(reply->error);
1568 	if (reply->count == 0) {
1572 	const char* name = reply->name.GetString();
1573 	int32 nameLen = reply->name.GetSize();
1677 			ReadAttrReply* reply = dynamic_cast<ReadAttrReply*>(_reply);
1678 			if (!reply)
1680 			// process the reply
1681 			status_t error = ProcessReply(reply);
1684 			bool moreToCome = reply->moreToCome;
1686 				// receive a reply
1687 				error = ReceiveRequest(channel, &reply);
1690 				moreToCome = reply->moreToCome;
1691 				ObjectDeleter<Request> replyDeleter(reply);
1692 				// process the reply
1693 				error = ProcessReply(reply);
1700 		status_t ProcessReply(ReadAttrReply* reply)
1702 			if (reply->error != B_OK)
1703 				RETURN_ERROR(reply->error);
1705 			if (reply->pos != pos)
1707 			int32 bytesRead = reply->data.GetSize();
1712 				memcpy(buffer, reply->data.GetData(), bytesRead);
1771 		WriteAttrReply* reply;
1772 		status_t error = SendRequest(fConnection, &request, &reply);
1776 		ObjectDeleter<Request> replyDeleter(reply);
1777 		if (reply->error != B_OK)
1778 			RETURN_ERROR(reply->error);
1828 	RemoveAttrReply* reply;
1829 	status_t error = SendRequest(fConnection, &request, &reply);
1832 	ObjectDeleter<Request> replyDeleter(reply);
1836 	if (reply->error == B_OK && attrDirRevision >= 0) {
1843 	RETURN_ERROR(reply->error);
1877 	RenameAttrReply* reply;
1878 	status_t error = SendRequest(fConnection, &request, &reply);
1881 	ObjectDeleter<Request> replyDeleter(reply);
1885 	if (reply->error == B_OK && attrDirRevision >= 0) {
1892 	RETURN_ERROR(reply->error);
1927 	StatAttrReply* reply;
1928 	status_t error = SendRequest(fConnection, &request, &reply);
1931 	ObjectDeleter<Request> replyDeleter(reply);
1932 	if (reply->error != B_OK)
1933 		RETURN_ERROR(reply->error);
1936 	*attrInfo = reply->attrInfo.info;
2085 	ReadDirReply* reply;
2086 	status_t error = SendRequest(fConnection, &request, &reply);
2089 	ObjectDeleter<Request> replyDeleter(reply);
2090 	if (reply->error != B_OK)
2091 		RETURN_ERROR(reply->error);
2093 	RequestMemberArray<EntryInfo>* entryInfos = &reply->entryInfos;
2098 			error = _MultiWalk(reply->entryInfos, &walkReply);
2120 			iterator->SetRevision(reply->revision);
2123 		iterator->SetDone(reply->done);
2147 		if (reply->done && directory->GetEntryRemovedEventRevision()
2899 	WalkReply* reply;
2900 	status_t error = SendRequest(fConnection, &request, &reply);
2903 	ObjectDeleter<Request> replyDeleter(reply);
2904 	if (reply->error != B_OK)
2905 		RETURN_ERROR(reply->error);
2908 	*_reply = reply;
2939 	MultiWalkReply* reply;
2940 	status_t error = SendRequest(fConnection, &request, &reply);
2943 	ObjectDeleter<Request> replyDeleter(reply);
2944 	if (reply->error != B_OK)
2945 		RETURN_ERROR(reply->error);
2948 	*_reply = reply;
2964 	CloseReply* reply;
2965 	status_t error = SendRequest(fConnection, &request, &reply);
2968 	ObjectDeleter<Request> replyDeleter(reply);
2969 	if (reply->error != B_OK)
2970 		RETURN_ERROR(reply->error);
3055 	MountReply* reply = NULL;
3075 		error = SendRequest(fConnection, &request, &reply);
3078 		ObjectDeleter<Request> replyDeleter(reply);
3081 		badPassword = reply->noPermission;
3083 			if (reply->error != B_OK)
3084 				RETURN_ERROR(reply->error);
3085 			fSharePermissions = reply->sharePermissions;
3091 	fID = reply->volumeID;
3094 	fRootNode->Update(reply->nodeInfo);