/haiku/src/add-ons/kernel/file_systems/nfs4/ |
H A D | NFS4Inode.cpp | 41 ReplyInterpreter& reply = request.Reply(); 43 if (HandleErrors(attempt, reply.NFS4Error(), serv)) 46 reply.PutFH(); 50 result = reply.GetAttr(&values, &count); 79 ReplyInterpreter& reply = request.Reply(); 81 if (HandleErrors(attempt, reply.NFS4Error(), serv)) 84 reply.PutFH(); 85 return reply.Commit(); 108 ReplyInterpreter& reply = request.Reply(); 110 if (HandleErrors(attempt, reply 498 ReplyInterpreter& reply = request.Reply(); local 597 ReplyInterpreter& reply = request.Reply(); local 685 ReplyInterpreter& reply = request.Reply(); local 1133 ReplyInterpreter& reply = request.Reply(); local [all...] |
H A D | OpenState.cpp | 129 ReplyInterpreter& reply = request.Reply(); 131 if (HandleErrors(attempt, reply.NFS4Error(), server)) 134 return reply.ReleaseLockOwner(); 187 ReplyInterpreter& reply = request.Reply(); local 189 result = reply.PutFH(); 191 sequence += IncrementSequence(reply.NFS4Error()); 193 if (reply.NFS4Error() != NFS4ERR_STALE_CLIENTID 194 && HandleErrors(attempt, reply.NFS4Error(), server, NULL, NULL, 199 result = reply.Open(fStateID, &fStateSeq, &confirm, &delegation); 255 ReplyInterpreter& reply local 307 ReplyInterpreter& reply = request.Reply(); local [all...] |
/haiku/src/kits/media/ |
H A D | Controllable.cpp | 59 // small data transfer uses buffer in reply 208 controllable_get_parameter_data_reply reply; local 210 ReceiveTransfer transfer(request, reply.raw_data); 212 request.SendReply(transfer.InitCheck(), &reply, sizeof(reply)); 216 reply.size = request.request_size; 218 &reply.last_change, transfer.Data(), &reply.size); 220 request.SendReply(status, &reply, sizeof(reply)); 229 controllable_set_parameter_data_reply reply; local 257 controllable_get_parameter_web_reply reply; local 307 controllable_start_control_panel_reply reply; local [all...] |
H A D | Buffer.cpp | 220 server_register_buffer_reply reply; local 233 if (QueryServer(SERVER_REGISTER_BUFFER, &request, sizeof(request), &reply, 234 sizeof(reply)) != B_OK) { 240 ASSERT(reply.info.buffer > 0); 241 ASSERT(reply.info.area > 0); 242 ASSERT(reply.info.size > 0); 245 B_READ_AREA | B_WRITE_AREA, reply.info.area); 251 cmd.buffer_id = reply.info.buffer; 258 fSize = reply.info.size; 259 fFlags = reply [all...] |
/haiku/src/servers/input/ |
H A D | AddOnManager.h | 65 BMessage* reply); 67 BMessage* reply); 69 BMessage* reply); 71 BMessage* reply); 73 BMessage* reply); 75 BMessage* reply); 77 BMessage* reply); 79 BMessage* reply); 87 int32 uid, BMessage* reply) const; 89 BMessage* reply) cons [all...] |
/haiku/src/add-ons/kernel/file_systems/nfs/ |
H A D | nfs_add_on.c | 365 is_successful_reply(struct XDRInPacket *reply) argument 369 int32 xid = XDRInPacketGetInt32(reply); 370 rpc_msg_type mtype=(rpc_msg_type)XDRInPacketGetInt32(reply); 371 rpc_reply_stat replyStat=(rpc_reply_stat)XDRInPacketGetInt32(reply); 376 rpc_reject_stat rejectStat = (rpc_reject_stat)XDRInPacketGetInt32(reply); 379 int32 low = XDRInPacketGetInt32(reply); 380 int32 high = XDRInPacketGetInt32(reply); 385 rpc_auth_stat authStat = (rpc_auth_stat)XDRInPacketGetInt32(reply); 390 rpc_auth_flavor flavor = (rpc_auth_flavor)XDRInPacketGetInt32(reply); 393 XDRInPacketGetDynamic(reply, bod 435 struct XDRInPacket reply; local 460 struct XDRInPacket reply; local 508 struct XDRInPacket reply; local 564 struct XDRInPacket reply; local 608 struct XDRInPacket reply; local 659 get_nfs_attr(struct XDRInPacket *reply, struct stat *st) argument 972 struct XDRInPacket reply; local 1378 struct XDRInPacket reply; local 1518 struct XDRInPacket reply; local 1599 struct XDRInPacket reply; local 1660 struct XDRInPacket reply; local 1779 struct XDRInPacket reply; local 1886 struct XDRInPacket reply; local 2005 struct XDRInPacket reply; local 2100 struct XDRInPacket reply; local 2183 struct XDRInPacket reply; local 2280 struct XDRInPacket reply; local 2336 struct XDRInPacket reply; local [all...] |
/haiku/src/kits/print/ |
H A D | PrintAddOnServer.cpp | 36 BMessage reply; local 37 status_t result = SendRequest(message, reply); 41 return GetResult(reply); 54 BMessage reply; local 55 status_t result = SendRequest(message, reply); 59 return GetResultAndUpdateSettings(reply, settings); 72 BMessage reply; local 73 status_t result = SendRequest(message, reply); 77 return GetResultAndUpdateSettings(reply, settings); 89 BMessage reply; local 107 BMessage reply; local 193 SendRequest(BMessage& request, BMessage& reply) argument 204 GetResult(BMessage& reply) argument 216 GetResultAndUpdateSettings(BMessage& reply, BMessage* settings) argument [all...] |
/haiku/src/apps/cortex/support/ |
H A D | ObservableHandler.cpp | 218 BMessage reply; local 226 // send reply? +++++ 232 reply.what = M_BAD_TARGET; 233 reply.AddMessenger("target", BMessenger(this)); 234 reply.AddMessenger("observer", observer); 235 message->SendReply(&reply); 241 reply.what = M_BAD_OBSERVER; 242 reply.AddMessenger("target", BMessenger(this)); 243 reply.AddMessenger("observer", observer); 244 message->SendReply(&reply); 267 BMessage reply; local [all...] |
H A D | ObservableLooper.cpp | 250 BMessage reply; local 258 // send reply? +++++ 262 // at this point, a reply of some sort will be sent 263 reply.AddMessenger("target", BMessenger(this)); 264 reply.AddMessenger("observer", observer); 268 reply.what = M_BAD_TARGET; 272 reply.what = M_BAD_OBSERVER; 278 reply.what = M_OBSERVER_ADDED; 281 // send reply 282 message->SendReply(&reply); 293 BMessage reply; local [all...] |
/haiku/src/bin/debug/strace/ |
H A D | MemoryReader.cpp | 39 fReplyPort = create_port(1, "memory reader reply"); 41 fprintf(stderr, "Failed to create memory reader reply port: %s\n", 101 // get reply 103 debug_nub_read_memory_reply reply; local 105 ssize_t bytesRead = read_port(fReplyPort, &code, &reply, sizeof(reply)); 112 if (reply.error != B_OK) 113 return reply.error; 115 bytesRead = reply.size; 116 memcpy(buffer, reply [all...] |
/haiku/src/kits/app/ |
H A D | KeyStore.cpp | 84 BMessage reply; local 85 status_t result = _SendKeyMessage(message, &reply); 90 if (reply.FindMessage("key", &keyMessage) != B_OK) 173 BMessage reply; local 174 status_t result = _SendKeyMessage(message, &reply); 179 if (reply.FindMessage("key", &keyMessage) != B_OK) 182 reply.FindUInt32("cookie", &cookie); 214 BMessage reply; local 215 status_t result = _SendKeyMessage(message, &reply); 219 if (reply 292 BMessage reply; local 314 BMessage reply; local 361 BMessage reply; local [all...] |
H A D | Clipboard.cpp | 43 BMessage message(B_REG_GET_CLIPBOARD_MESSENGER), reply; local 44 if (BRoster::Private().SendTo(&message, &reply, false) == B_OK 45 && reply.what == B_REG_SUCCESS 46 && reply.FindMessenger("messenger", &fClipHandler) == B_OK) { 102 BMessage message(B_REG_GET_CLIPBOARD_COUNT), reply; local 104 && fClipHandler.SendMessage(&message, &reply) == B_OK 105 && reply.FindInt32("count", &value) == B_OK) 118 BMessage message(B_REG_CLIPBOARD_START_WATCHING), reply; 121 && fClipHandler.SendMessage(&message, &reply) == B_OK) { 123 reply 204 BMessage message(B_REG_UPLOAD_CLIPBOARD), reply; local 291 BMessage message(B_REG_DOWNLOAD_CLIPBOARD), reply; local [all...] |
H A D | RosterPrivate.cpp | 47 If \a reply is not \c NULL, the function waits for a reply. 50 \param reply A pointer to a pre-allocated BMessage into which the reply 61 BRoster::Private::SendTo(BMessage *message, BMessage *reply, bool mime) argument 73 return reply != NULL 74 ? messenger.SendMessage(message, reply)
|
/haiku/src/tools/remote_disk_server/ |
H A D | remote_disk_server.cpp | 182 remote_disk_header reply; local 183 reply.offset = htonll(fImageSize); 185 reply.command = REMOTE_DISK_HELLO_REPLY; 186 _SendReply(&reply, sizeof(remote_disk_header)); 194 remote_disk_header *reply = (remote_disk_header*)buffer; local 211 ssize_t bytesRead = read(fImageFD, reply->data, size); 226 // send reply 227 reply->command = REMOTE_DISK_READ_REPLY; 228 reply->offset = htonll(offset); 229 reply 237 remote_disk_header reply; local 278 _SendReply(remote_disk_header *reply, int size) argument [all...] |
/haiku/src/servers/registrar/ |
H A D | MIMEManager.cpp | 112 BMessage reply; local 135 reply.what = B_REG_RESULT; 136 reply.AddInt32("result", err); 137 message->SendReply(&reply, this); 150 reply.what = B_REG_RESULT; 151 reply.AddInt32("result", err); 152 message->SendReply(&reply, this); 161 err = fDatabase.GetInstalledTypes(&reply); 163 err = fDatabase.GetInstalledTypes(supertype, &reply); 165 reply [all...] |
H A D | PackageWatchingManager.cpp | 40 BMessage reply(B_REG_SUCCESS); 41 request->SendReply(&reply); 43 BMessage reply(B_REG_ERROR); 44 reply.AddInt32("error", error); 45 request->SendReply(&reply);
|
/haiku/src/add-ons/kernel/file_systems/userlandfs/kernel_add_on/ |
H A D | KernelRequestHandler.cpp | 235 // prepare the reply 237 NotifyListenerReply* reply; local 238 status_t error = AllocateRequest(allocator, &reply); 242 reply->error = result; 244 // send the reply 269 // prepare the reply 271 NotifySelectEventReply* reply; local 272 status_t error = AllocateRequest(allocator, &reply); 276 reply->error = result; 278 // send the reply 334 NotifyQueryReply* reply; local 361 GetVNodeReply* reply; local 383 PutVNodeReply* reply; local 406 AcquireVNodeReply* reply; local 432 NewVNodeReply* reply; local 457 PublishVNodeReply* reply; local 480 RemoveVNodeReply* reply; local 501 UnremoveVNodeReply* reply; local 524 GetVNodeRemovedReply* reply; local 551 FileCacheCreateReply* reply; local 576 FileCacheDeleteReply* reply; local 601 FileCacheSetEnabledReply* reply; local 626 FileCacheSetSizeReply* reply; local 651 FileCacheSyncReply* reply; local 675 FileCacheReadReply* reply; local 732 FileCacheWriteReply* reply; local 764 DoIterativeFDIOReply* reply; local 787 ReadFromIORequestReply* reply; local 830 WriteToIORequestReply* reply; local 855 NotifyIORequestReply* reply; local 875 AddNodeListenerReply* reply; local 896 RemoveNodeListenerReply* reply; local [all...] |
/haiku/src/preferences/printers/ |
H A D | TransportMenu.cpp | 47 BMessage reply; local 48 if (fMessenger.SendMessage(&msg, &reply) != B_OK) 53 if (reply.FindString("port_id", &portId) != B_OK) { 62 for (int32 i = 0; reply.FindString("port_id", i, &portId) == B_OK; 64 if (reply.FindString("port_name", i, &portName) != B_OK
|
/haiku/src/tests/kits/app/bmessenger/ |
H A D | ForwardMessageTest.cpp | 43 BMessage reply; local 44 BMessenger(&looper1).SendMessage('toto', &reply); 45 printf("message sent and replied\ncheck there is only a 'couc' what in the reply\n"); 46 reply.PrintToStream();
|
/haiku/src/system/libroot/os/ |
H A D | launch.cpp | 36 BPrivate::send_request_to_launch_daemon(KMessage& request, KMessage& reply) argument 39 B_PREFERRED_TOKEN, &reply); 43 return (status_t)reply.What();
|
/haiku/src/add-ons/kernel/file_systems/netfs/client/ |
H A D | ShareVolume.cpp | 491 ReadVNodeReply* reply; local 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; local 593 status_t error = SendRequest(fConnection, &request, &reply); 596 ObjectDeleter<Request> replyDeleter(reply); 598 if (reply 644 CreateFileReply* reply; local 725 OpenReply* reply; local 789 ReadReply* reply = dynamic_cast<ReadReply*>(_reply); local 812 ProcessReply(ReadReply* reply) argument 869 WriteReply* reply; local 922 CreateLinkReply* reply; local 948 UnlinkReply* reply; local 977 CreateSymlinkReply* reply; local 1002 ReadLinkReply* reply; local 1045 RenameReply* reply; local 1078 MakeDirReply* reply; local 1104 RemoveDirReply* reply; local 1162 OpenDirReply* reply; local 1217 CloseReply* reply; local 1354 WalkReply* reply; local 1423 OpenAttrDirReply* reply; local 1558 ReadAttrDirReply* reply; local 1677 ReadAttrReply* reply = dynamic_cast<ReadAttrReply*>(_reply); local 1700 ProcessReply(ReadAttrReply* reply) argument 1771 WriteAttrReply* reply; local 1828 RemoveAttrReply* reply; local 1877 RenameAttrReply* reply; local 1927 StatAttrReply* reply; local 2085 ReadDirReply* reply; local 2899 WalkReply* reply; local 2939 MultiWalkReply* reply; local 2964 CloseReply* reply; local 3055 MountReply* reply = NULL; local [all...] |
H A D | AuthenticationServer.cpp | 61 KMessage reply; 62 error = request.SendTo(fServerPort, -1, &reply); 65 // process the reply 67 if (reply.FindInt32("error", &error) != B_OK) 73 if (reply.FindBool("cancelled", &cancelled) != B_OK) 82 if (reply.FindString("user", &foundUser) != B_OK 83 || reply.FindString("password", &foundPassword) != B_OK) {
|
/haiku/src/kits/storage/ |
H A D | MimeType.cpp | 266 BMessage reply; local 269 // Build and send the message, read the reply 274 err = BRoster::Private().SendTo(&message, &reply, true); 277 err = (status_t)(reply.what == B_REG_RESULT ? B_OK : B_BAD_REPLY); 280 err = reply.FindInt32("result", &result); 296 BMessage reply; local 299 // Build and send the message, read the reply 304 err = BRoster::Private().SendTo(&message, &reply, true); 307 err = (status_t)(reply.what == B_REG_RESULT ? B_OK : B_BAD_REPLY); 310 err = reply 479 BMessage reply; local 519 BMessage reply; local 549 BMessage reply; local 586 BMessage reply; local 626 BMessage reply; local 783 BMessage reply; local 865 BMessage reply; local 925 BMessage reply; local 987 BMessage reply; local 1032 BMessage reply; local 1069 BMessage reply; local 1106 BMessage reply; local 1141 BMessage reply; local 1168 BMessage reply; local 1272 BMessage reply; local 1321 BMessage &reply = *types; local [all...] |
/haiku/src/tests/kits/app/blooper/ |
H A D | QuitTest.cpp | 43 BMessage reply; local 44 BMessenger(looper).SendMessage(B_QUIT_REQUESTED, &reply);
|
/haiku/src/servers/print/ |
H A D | Printer.Scripting.cpp | 70 BMessage reply(B_REPLY); 71 reply.AddString("result", result); 72 reply.AddInt32("error", rc); 73 msg->SendReply(&reply); 80 BMessage reply(B_REPLY); 81 reply.AddMessenger("result", BMessenger(this)); 82 reply.AddInt32("error", B_OK); 83 msg->SendReply(&reply);
|