/haiku/src/servers/media/ |
H A D | media_server.cpp | 235 // send a quit request to the media_addon_server 278 const server_change_flavor_instances_count_request& request local 284 if (request.delta == 1) { 286 request.add_on_id, request.flavor_id, request.team); 287 } else if (request.delta == -1) { 289 request.add_on_id, request.flavor_id, request 303 const server_register_app_request& request = *static_cast< local 315 const server_unregister_app_request& request = *static_cast< local 326 const server_get_add_on_ref_request& request = *static_cast< local 340 const server_node_id_for_request& request local 352 const server_get_live_node_info_request& request = *static_cast< local 364 const server_get_live_nodes_request& request local 417 const server_get_node_for_request& request local 429 const server_release_node_request& request local 441 const server_release_node_request& request local 452 const server_register_node_request& request local 465 const server_unregister_node_request& request local 477 const server_publish_inputs_request& request local 506 const server_publish_outputs_request& request local 535 const server_get_node_request& request local 547 const server_set_node_request& request local 561 const server_get_dormant_node_for_request& request local 574 const server_get_instances_for_request& request local 593 const server_set_node_timesource_request& request local 604 const server_register_add_on_request& request = *static_cast< local 615 const server_unregister_add_on_command& request = *static_cast< local 639 const server_get_dormant_nodes_request& request local 671 const server_get_dormant_flavor_info_request& request local 708 const server_set_node_creator_request& request local 719 const server_get_shared_buffer_area_request& request local 732 const server_register_buffer_request& request local 757 const server_unregister_buffer_command& request = *static_cast< local 766 const server_get_media_types_request& request local 793 const server_get_media_items_request& request local 822 const server_get_ref_for_request& request local 838 const server_set_ref_for_request& request local 851 const server_invalidate_item_request& request local 863 const server_remove_media_item_request& request local 875 const server_get_item_audio_gain_request& request local 887 const server_set_item_audio_gain_request& request local [all...] |
/haiku/src/add-ons/kernel/file_systems/userlandfs/server/ |
H A D | UserlandRequestHandler.cpp | 52 UserlandRequestHandler::HandleRequest(Request* request) argument 54 if (fExpectReply && request->GetType() == fExpectedReply) { 59 switch (request->GetType()) { 62 return _HandleRequest((MountVolumeRequest*)request); 64 return _HandleRequest((UnmountVolumeRequest*)request); 66 return _HandleRequest((SyncVolumeRequest*)request); 68 return _HandleRequest((ReadFSInfoRequest*)request); 70 return _HandleRequest((WriteFSInfoRequest*)request); 74 return _HandleRequest((LookupRequest*)request); 76 return _HandleRequest((GetVNodeNameRequest*)request); 231 _HandleRequest(MountVolumeRequest* request) argument 292 _HandleRequest(UnmountVolumeRequest* request) argument 316 _HandleRequest(SyncVolumeRequest* request) argument 341 _HandleRequest(ReadFSInfoRequest* request) argument 368 _HandleRequest(WriteFSInfoRequest* request) argument 398 _HandleRequest(LookupRequest* request) argument 429 _HandleRequest(GetVNodeNameRequest* request) argument 468 _HandleRequest(ReadVNodeRequest* request) argument 505 _HandleRequest(WriteVNodeRequest* request) argument 533 _HandleRequest(FSRemoveVNodeRequest* request) argument 564 _HandleRequest(DoIORequest* request) argument 594 _HandleRequest(CancelIORequest* request) argument 624 _HandleRequest(IterativeIOGetVecsRequest* request) argument 665 _HandleRequest(IterativeIOFinishedRequest* request) argument 699 _HandleRequest(IOCtlRequest* request) argument 755 _HandleRequest(SetFlagsRequest* request) argument 784 _HandleRequest(SelectRequest* request) argument 813 _HandleRequest(DeselectRequest* request) argument 842 _HandleRequest(FSyncRequest* request) argument 870 _HandleRequest(ReadSymlinkRequest* request) argument 911 _HandleRequest(CreateSymlinkRequest* request) argument 941 _HandleRequest(LinkRequest* request) argument 970 _HandleRequest(UnlinkRequest* request) argument 999 _HandleRequest(RenameRequest* request) argument 1029 _HandleRequest(AccessRequest* request) argument 1057 _HandleRequest(ReadStatRequest* request) argument 1087 _HandleRequest(WriteStatRequest* request) argument 1119 _HandleRequest(CreateRequest* request) argument 1153 _HandleRequest(OpenRequest* request) argument 1183 _HandleRequest(CloseRequest* request) argument 1211 _HandleRequest(FreeCookieRequest* request) argument 1239 _HandleRequest(ReadRequest* request) argument 1283 _HandleRequest(WriteRequest* request) argument 1319 _HandleRequest(CreateDirRequest* request) argument 1348 _HandleRequest(RemoveDirRequest* request) argument 1377 _HandleRequest(OpenDirRequest* request) argument 1407 _HandleRequest(CloseDirRequest* request) argument 1435 _HandleRequest(FreeDirCookieRequest* request) argument 1463 _HandleRequest(ReadDirRequest* request) argument 1520 _HandleRequest(RewindDirRequest* request) argument 1552 _HandleRequest(OpenAttrDirRequest* request) argument 1582 _HandleRequest(CloseAttrDirRequest* request) argument 1610 _HandleRequest(FreeAttrDirCookieRequest* request) argument 1639 _HandleRequest(ReadAttrDirRequest* request) argument 1684 _HandleRequest(RewindAttrDirRequest* request) argument 1716 _HandleRequest(CreateAttrRequest* request) argument 1748 _HandleRequest(OpenAttrRequest* request) argument 1780 _HandleRequest(CloseAttrRequest* request) argument 1808 _HandleRequest(FreeAttrCookieRequest* request) argument 1836 _HandleRequest(ReadAttrRequest* request) argument 1881 _HandleRequest(WriteAttrRequest* request) argument 1913 _HandleRequest(ReadAttrStatRequest* request) argument 1944 _HandleRequest(WriteAttrStatRequest* request) argument 1973 _HandleRequest(RenameAttrRequest* request) argument 2003 _HandleRequest(RemoveAttrRequest* request) argument 2036 _HandleRequest(OpenIndexDirRequest* request) argument 2066 _HandleRequest(CloseIndexDirRequest* request) argument 2094 _HandleRequest(FreeIndexDirCookieRequest* request) argument 2122 _HandleRequest(ReadIndexDirRequest* request) argument 2166 _HandleRequest(RewindIndexDirRequest* request) argument 2194 _HandleRequest(CreateIndexRequest* request) argument 2223 _HandleRequest(RemoveIndexRequest* request) argument 2251 _HandleRequest(ReadIndexStatRequest* request) argument 2286 _HandleRequest(OpenQueryRequest* request) argument 2317 _HandleRequest(CloseQueryRequest* request) argument 2345 _HandleRequest(FreeQueryCookieRequest* request) argument 2373 _HandleRequest(ReadQueryRequest* request) argument 2417 _HandleRequest(RewindQueryRequest* request) argument 2449 _HandleRequest(NodeMonitoringEventRequest* request) argument [all...] |
H A D | kernel_emu.cpp | 114 // get the request thread 134 // get the request port and the file system 141 // prepare the request 143 NotifyListenerRequest* request; local 144 error = AllocateRequest(allocator, &request); 148 request->operation = operation; 149 request->details = details; 150 request->device = device; 151 request->oldDirectory = oldDirectory; 152 request 189 NotifySelectEventRequest* request; local 227 NotifyQueryRequest* request; local 273 GetVNodeRequest* request; local 309 PutVNodeRequest* request; local 344 AcquireVNodeRequest* request; local 380 NewVNodeRequest* request; local 418 PublishVNodeRequest* request; local 480 RemoveVNodeRequest* request; local 515 UnremoveVNodeRequest* request; local 551 GetVNodeRemovedRequest* request; local 590 FileCacheCreateRequest* request; local 625 FileCacheDeleteRequest* request; local 660 FileCacheSetEnabledRequest* request; local 696 FileCacheSetSizeRequest* request; local 731 FileCacheSyncRequest* request; local 766 FileCacheReadRequest* request; local 819 FileCacheWriteRequest* request; local 867 DoIterativeFDIORequest* request; local 910 ReadFromIORequestRequest* request; local 956 WriteToIORequestRequest* request; local 994 NotifyIORequestRequest* request; local 1032 AddNodeListenerRequest* request; local 1068 RemoveNodeListenerRequest* request; local [all...] |
/haiku/src/servers/registrar/ |
H A D | PackageWatchingManager.cpp | 34 PackageWatchingManager::HandleStartStopWatching(BMessage* request) argument 36 status_t error = request->what == B_REG_PACKAGE_START_WATCHING 37 ? _AddWatcher(request) : _RemoveWatcher(request); 41 request->SendReply(&reply); 45 request->SendReply(&reply); 75 PackageWatchingManager::_AddWatcher(const BMessage* request) argument 80 if ((error = request->FindMessenger("target", &target)) != B_OK 81 || (error = request->FindUInt32("events", &eventMask)) != B_OK) { 96 PackageWatchingManager::_RemoveWatcher(const BMessage* request) argument [all...] |
H A D | TRoster.h | 37 void HandleAddApplication(BMessage* request); 38 void HandleCompleteRegistration(BMessage* request); 39 void HandleIsAppRegistered(BMessage* request); 40 void HandleRemovePreRegApp(BMessage* request); 41 void HandleRemoveApp(BMessage* request); 42 void HandleSetThreadAndTeam(BMessage* request); 43 void HandleSetSignature(BMessage* request); 44 void HandleGetAppInfo(BMessage* request); 45 void HandleGetAppList(BMessage* request); 46 void HandleUpdateActiveApp(BMessage* request); [all...] |
/haiku/src/add-ons/kernel/file_systems/netfs/netfs_server_prefs/ |
H A D | NetFSServerRoster.cpp | 84 // prepare the request 85 BMessage request(NETFS_REQUEST_SAVE_SETTINGS); 87 // send the request 88 return _SendRequest(&request); 102 // prepare the request 103 BMessage request(NETFS_REQUEST_ADD_USER); 104 if (request.AddString("user", user) != B_OK 105 || (password && request.AddString("password", password) != B_OK)) { 109 // send the request 110 return _SendRequest(&request); 387 _SendRequest(BMessage* request, BMessage* reply) argument [all...] |
/haiku/src/kits/media/ |
H A D | MediaFiles.cpp | 44 server_get_media_types_request request; local 45 request.team = BPrivate::current_team(); 48 status_t status = QueryServer(SERVER_GET_MEDIA_FILE_TYPES, &request, 49 sizeof(request), &reply, sizeof(reply)); 94 server_get_media_items_request request; local 95 request.team = BPrivate::current_team(); 96 strlcpy(request.type, type, B_MEDIA_NAME_LENGTH); 99 status_t status = QueryServer(SERVER_GET_MEDIA_FILE_ITEMS, &request, 100 sizeof(request), &reply, sizeof(reply)); 147 server_get_ref_for_request request; 195 server_set_ref_for_request request; local 217 server_set_item_audio_gain_request request; local 240 server_invalidate_item_request request; local 261 server_remove_media_item_request request; local [all...] |
/haiku/src/add-ons/kernel/file_systems/netfs/server/ |
H A D | ClientConnection.h | 68 ConnectionBrokenRequest* request); 70 InitConnectionRequest* request); 71 virtual status_t VisitMountRequest(MountRequest* request); 72 virtual status_t VisitUnmountRequest(UnmountRequest* request); 74 ReadVNodeRequest* request); 76 WriteStatRequest* request); 78 CreateFileRequest* request); 79 virtual status_t VisitOpenRequest(OpenRequest* request); 80 virtual status_t VisitCloseRequest(CloseRequest* request); 81 virtual status_t VisitReadRequest(ReadRequest* request); [all...] |
/haiku/src/add-ons/kernel/file_systems/netfs/client/ |
H A D | SendReceiveRequest.h | 19 SendRequest(RequestConnection* connection, Request* request, argument 23 status_t error = connection->SendRequest(request, &reply); 40 Request* request; local 41 status_t error = channel->ReceiveRequest(&request); 44 *_request = dynamic_cast<SpecificRequest*>(request); 46 delete request;
|
/haiku/src/add-ons/kernel/file_systems/netfs/headers/shared/ |
H A D | RequestChannel.h | 16 status_t SendRequest(Request* request); 17 status_t ReceiveRequest(Request** request); 20 status_t _GetRequestSize(Request* request, int32* size);
|
H A D | RequestHandler.h | 16 virtual status_t HandleRequest(Request* request, 20 virtual status_t VisitAny(Request* request);
|
/haiku/src/add-ons/kernel/file_systems/userlandfs/private/ |
H A D | SingleReplyRequestHandler.cpp | 27 SingleReplyRequestHandler::HandleRequest(Request* request) argument 29 if (!fAcceptAnyRequest && request->GetType() != fExpectedReply) { 31 "request: %" B_PRIu32 " expected was: %" B_PRIu32 "\n", 32 request->GetType(), fExpectedReply)); 35 "request!");
|
/haiku/src/add-ons/kernel/bus_managers/scsi/ |
H A D | dma_buffer.cpp | 11 If the peripheral driver hasn't made sure that the data of a request 17 To be able to copy data back after the request was finished, we need a 35 /*! Check whether S/G list of request is supported DMA controller */ 37 is_sg_list_dma_safe(scsi_ccb *request) argument 39 scsi_bus_info *bus = request->bus; 40 const physical_entry *sg_list = request->sg_list; 41 uint32 sg_count = request->sg_count; 99 scsi_copy_dma_buffer(scsi_ccb *request, uint32 size, bool to_buffer) argument 101 dma_buffer *buffer = request->dma_buffer; 109 size = min_c(size, request 326 scsi_dma_buffer_compose_sg_orig(dma_buffer *buffer, scsi_ccb *request) argument 349 scsi_get_dma_buffer(scsi_ccb *request) argument 432 scsi_release_dma_buffer(scsi_ccb *request) argument [all...] |
H A D | queuing.h | 19 void scsi_add_queued_request( scsi_ccb *request ); 20 void scsi_add_queued_request_first( scsi_ccb *request ); 21 void scsi_remove_queued_request( scsi_ccb *request ); 24 static inline void scsi_add_req_queue_first( scsi_ccb *request ) 26 scsi_device_info *device = request->device; 28 SHOW_FLOW( 3, "request=%p", request ); 30 ADD_CDL_LIST_HEAD( request, scsi_ccb, device->queued_reqs, ); 33 static inline void scsi_add_req_queue_last( scsi_ccb *request ) 35 scsi_device_info *device = request [all...] |
/haiku/src/add-ons/kernel/busses/scsi/ahci/ |
H A D | ahci_port.h | 30 void ScsiExecuteRequest(scsi_ccb *request); 31 uchar ScsiAbortRequest(scsi_ccb *request); 32 uchar ScsiTerminateRequest(scsi_ccb *request); 37 void ScsiTestUnitReady(scsi_ccb *request); 38 void ScsiInquiry(scsi_ccb *request); 39 void ScsiVPDInquiry(scsi_ccb* request, ata_device_infoblock* ataData); 41 void ScsiReadCapacity(scsi_ccb *request); 42 void ScsiReadCapacity16(scsi_ccb *request); 43 void ScsiReadWrite(scsi_ccb *request, uint64 lba, size_t sectorCount, bool isWrite); 44 void ScsiSynchronizeCache(scsi_ccb *request); [all...] |
H A D | ahci_port.cpp | 86 fRequestSem = create_sem(1, "ahci request"); 584 AHCIPort::ScsiTestUnitReady(scsi_ccb* request) argument 587 request->subsys_status = SCSI_REQ_CMP; 588 gSCSI->finished(request, 1); 593 AHCIPort::ScsiVPDInquiry(scsi_ccb* request, ata_device_infoblock* ataData) argument 597 const scsi_cmd_inquiry* cmd = (const scsi_cmd_inquiry*)request->cdb; 627 transactionResult = sg_memcpy(request->sg_list, request->sg_count, 651 transactionResult = sg_memcpy(request->sg_list, request 698 ScsiInquiry(scsi_ccb* request) argument 875 ScsiSynchronizeCache(scsi_ccb* request) argument 894 ScsiReadCapacity(scsi_ccb* request) argument 933 ScsiReadCapacity16(scsi_ccb* request) argument 978 ScsiReadWrite(scsi_ccb* request, uint64 lba, size_t sectorCount, bool isWrite) argument 1030 ScsiUnmap(scsi_ccb* request, scsi_unmap_parameter_list* unmapBlocks) argument 1182 ExecuteSataRequest(sata_request* request, bool isWrite) argument 1282 ScsiExecuteRequest(scsi_ccb* request) argument 1461 ScsiAbortRequest(scsi_ccb* request) argument 1468 ScsiTerminateRequest(scsi_ccb* request) argument [all...] |
/haiku/src/add-ons/kernel/bus_managers/ata/ |
H A D | ATADevice.cpp | 38 ATADevice::TestUnitReady(ATARequest *request) argument 40 TRACE_FUNCTION("%p\n", request); 45 request->SetTimeout(15 * 1000 * 1000); 46 status_t result = fChannel->SendRequest(request, ATA_DEVICE_READY_REQUIRED); 48 TRACE_ERROR("failed to send test unit ready request\n"); 52 return fChannel->FinishRequest(request, ATA_WAIT_FINISH 59 ATADevice::SynchronizeCache(ATARequest *request) argument 61 TRACE_FUNCTION("%p\n", request); 73 request->SetTimeout(60 * 1000 * 1000); 74 status_t result = fChannel->SendRequest(request, ATA_DEVICE_READY_REQUIRE 86 Eject(ATARequest *request) argument 106 Inquiry(ATARequest *request) argument 168 ReadCapacity(ATARequest *request) argument 199 ReadCapacity16(ATARequest *request) argument 232 ExecuteIO(ATARequest *request) argument 642 ExecuteReadWrite(ATARequest *request, uint64 address, uint32 sectorCount) argument 710 _FillTaskFile(ATARequest *request, uint64 address) argument [all...] |
/haiku/src/kits/app/ |
H A D | LaunchRoster.cpp | 42 BMessage request(B_REGISTER_SESSION_DAEMON); 43 status_t status = request.AddInt32("user", getuid()); 45 status = request.AddMessenger("daemon", daemon); 49 // send the request 51 status = fRoster->fMessenger.SendMessage(&request, &result); 98 BMessage request(B_GET_LAUNCH_DATA); 99 status_t status = request.AddString("name", signature); 101 status = request.AddInt32("user", getuid()); 105 return _SendRequest(request, data); 154 BMessage request(B_LAUNCH_TARGE 373 _SendRequest(BMessage& request) argument 381 _SendRequest(BMessage& request, BMessage& result) argument [all...] |
/haiku/src/kits/bluetooth/ |
H A D | DiscoveryAgent.cpp | 69 BMessage request(BT_MSG_HANDLE_SIMPLE_REQUEST); 72 request.AddInt32("hci_id", fLocalDevice->ID()); 78 request.AddData("raw command", B_ANY_TYPE, startInquiryCommand, size); 79 request.AddInt16("eventExpected", HCI_EVENT_CMD_STATUS); 80 request.AddInt16("opcodeExpected", 84 request.AddInt16("eventExpected", HCI_EVENT_INQUIRY_RESULT); 87 request.AddInt16("eventExpected", HCI_EVENT_INQUIRY_COMPLETE); 90 if (fMessenger->SendMessage(&request, listener) == B_OK) 113 BMessage request(BT_MSG_HANDLE_SIMPLE_REQUEST); 116 request [all...] |
/haiku/src/system/libroot/os/ |
H A D | launch.cpp | 36 BPrivate::send_request_to_launch_daemon(KMessage& request, KMessage& reply) argument 38 status_t status = request.SendTo(get_launch_daemon_port(), 50 BPrivate::KMessage request(B_GET_LAUNCH_DATA); 51 request.AddString("name", signature); 53 return BPrivate::send_request_to_launch_daemon(request, data);
|
/haiku/src/add-ons/kernel/network/ppp/shared/libkernelppp/ |
H A D | KPPPReportManager.cpp | 95 ppp_report_request *request = new ppp_report_request; local 96 request->type = type; 97 request->thread = thread; 98 request->flags = flags; 100 fReportRequests.AddItem(request); 104 //! Removes a report request. 113 ppp_report_request *request; local 116 request = fReportRequests.ItemAt(i); 118 if (request->thread != thread) 121 if (request 142 ppp_report_request *request; local 193 ppp_report_request *request; local [all...] |
/haiku/src/system/kernel/fs/ |
H A D | vfs_request_io.cpp | 30 AsyncIOCallback::IORequestCallback(void* data, io_request* request, argument 138 do_iterative_fd_io_iterate(void* _cookie, io_request* request, argument 141 TRACE_RIO("[%ld] do_iterative_fd_io_iterate(request: %p)\n", 142 find_thread(NULL), request); 148 request->DeleteSubRequests(); 151 size_t requestLength = request->Length() 152 - (requestOffset - request->Offset()); 157 status_t error = cookie->get_vecs(cookie->cookie, request, requestOffset, 183 if (request->IsWrite()) { 190 error = request 261 do_iterative_fd_io_finish(void* _cookie, io_request* request, status_t status, bool partialTransfer, generic_size_t transferEndOffset) argument 285 do_synchronous_iterative_vnode_io(struct vnode* vnode, void* openCookie, io_request* request, iterative_io_get_vecs getVecs, iterative_io_finished finished, void* cookie) argument 343 synchronous_io(io_request* request, DoIO& io) argument 393 vfs_vnode_io(struct vnode* vnode, void* cookie, io_request* request) argument 408 vfs_synchronous_io(io_request* request, status_t (*doIO)(void* cookie, off_t offset, void* buffer, size_t* length), void* cookie) argument 422 IORequest* request = IORequest::Create((flags & B_VIP_IO_REQUEST) != 0); local 448 IORequest* request = IORequest::Create((flags & B_VIP_IO_REQUEST) != 0); local 473 do_fd_io(int fd, io_request* request) argument 489 do_iterative_fd_io(int fd, io_request* request, iterative_io_get_vecs getVecs, iterative_io_finished finished, void* cookie) argument [all...] |
/haiku/src/add-ons/kernel/busses/usb/ |
H A D | ehci_rh.cpp | 139 usb_request_data *request = transfer->RequestData(); 140 TRACE_MODULE("request: %d\n", request->Request); 144 switch (request->Request) { 146 if (request->Index == 0) { 159 if (ehci->GetPortStatus(request->Index - 1, &portStatus) >= B_OK) { 169 if (request->Value >= 128) { 174 TRACE_MODULE("set address: %d\n", request->Value); 179 TRACE_MODULE("get descriptor: %d\n", request->Value >> 8); 181 switch (request [all...] |
H A D | ohci_rh.cpp | 141 usb_request_data *request = transfer->RequestData(); 142 TRACE_MODULE("request: %d\n", request->Request); 146 switch (request->Request) { 148 if (request->Index == 0) { 161 if (ohci->GetPortStatus(request->Index - 1, &portStatus) >= B_OK) { 171 if (request->Value >= 128) { 176 TRACE_MODULE("set address: %d\n", request->Value); 181 TRACE_MODULE("get descriptor: %d\n", request->Value >> 8); 183 switch (request [all...] |
H A D | uhci_rh.cpp | 140 usb_request_data *request = transfer->RequestData(); 141 TRACE_MODULE("request: %d\n", request->Request); 145 switch (request->Request) { 147 if (request->Index == 0) { 160 if (uhci->GetPortStatus(request->Index - 1, &portStatus) >= B_OK) { 170 if (request->Value >= 128) { 175 TRACE_MODULE("set address: %d\n", request->Value); 180 TRACE_MODULE("get descriptor: %d\n", request->Value >> 8); 182 switch (request [all...] |