/haiku/src/add-ons/kernel/file_systems/userlandfs/server/ |
H A D | RequestThread.cpp | 23 KernelRequest* request) 28 fRequest(request) 95 fThread = spawn_thread(_ThreadEntry, "request thread", B_NORMAL_PRIORITY, 22 RequestThreadContext(Volume* volume, KernelRequest* request) argument
|
/haiku/src/add-ons/kernel/file_systems/nfs4/ |
H A D | RequestInterpreter.cpp | 17 RequestInterpreter::RequestInterpreter(RPC::CallbackRequest* request) argument 19 fRequest(request)
|
/haiku/src/add-ons/kernel/network/ppp/shared/libkernelppp/ |
H A D | KPPPOptionHandler.cpp | 106 /*! \brief Add request item. 110 request, too. 113 KPPPOptionHandler::AddToRequest(KPPPConfigurePacket& request) argument 160 \param request The requested values. 161 \param index Index of item in \a request. 166 KPPPOptionHandler::ParseRequest(const KPPPConfigurePacket& request, argument
|
H A D | _KPPPAuthenticationHandler.cpp | 53 _KPPPAuthenticationHandler::AddToRequest(KPPPConfigurePacket& request) argument 56 // add an authentication request if needed. This request is added 103 return authenticator->OptionHandler()->AddToRequest(request); 104 // let protocol add its request 118 // the request was not rejected 149 // an authentication request must not be rejected! 166 // the ack does not contain our request 181 _KPPPAuthenticationHandler::ParseRequest(const KPPPConfigurePacket& request, argument 187 authentication_item *item = (authentication_item*) request [all...] |
/haiku/src/add-ons/kernel/network/ppp/pap/ |
H A D | Protocol.h | 38 virtual status_t AddToRequest(KPPPConfigurePacket& request); 40 virtual status_t ParseRequest(const KPPPConfigurePacket& request, 96 // the ID we used for the last configure/terminate request
|
/haiku/headers/private/app/ |
H A D | LaunchRoster.h | 68 status_t _SendRequest(BMessage& request); 69 status_t _SendRequest(BMessage& request,
|
/haiku/src/add-ons/kernel/file_systems/websearchfs/ |
H A D | websearchfs.h | 78 struct duckduckgo_request *request; /* set on root folder for a query */ member in struct:fs_node 129 extern int websearchfs_push_result_to_query(struct duckduckgo_request *request,
|
/haiku/src/system/kernel/debug/ |
H A D | system_profiler.cpp | 98 IORequest* request); 100 IORequest* request); 102 IORequest* request, IOOperation* operation); 104 IORequest* request, IOOperation* operation); 705 IORequest* request = (IORequest*)event->GetPointer("request", NULL); 719 _IORequestScheduled(scheduler, request); 723 _IORequestFinished(scheduler, request); 727 _IOOperationStarted(scheduler, request, operation); 731 _IOOperationFinished(scheduler, request, operatio 1097 _IORequestScheduled(IOScheduler* scheduler, IORequest* request) argument 1127 _IORequestFinished(IOScheduler* scheduler, IORequest* request) argument 1151 _IOOperationStarted(IOScheduler* scheduler, IORequest* request, IOOperation* operation) argument 1178 _IOOperationFinished(IOScheduler* scheduler, IORequest* request, IOOperation* operation) argument [all...] |
/haiku/src/add-ons/tracker/zipomatic/ |
H A D | ZipperThread.cpp | 430 BMessage request, reply; 431 request.what = B_REFS_RECEIVED; 432 request.AddRef("refs", &parentRef); 433 status_t status = trackerMessenger.SendMessage(&request, &reply); 440 request.MakeEmpty(); 441 request.what = BPrivate::kSelect; 442 request.AddRef("refs", &fOutputEntryRef); 445 return trackerMessenger.SendMessage(&request, &reply);
|
/haiku/src/kits/bluetooth/ |
H A D | CommandManager.cpp | 39 // This is for request that only require a Command complete in reply. 56 BMessage request(BT_MSG_HANDLE_SIMPLE_REQUEST); 59 request.AddInt32("hci_id", hId); 60 request.AddData("raw command", B_ANY_TYPE, 62 request.AddInt16("eventExpected", HCI_EVENT_CMD_COMPLETE); 63 request.AddInt16("opcodeExpected", PACK_OPCODE(ofg, ocf)); 65 if (messenger->SendMessage(&request, &reply) == B_OK) {
|
/haiku/src/add-ons/kernel/drivers/disk/mmc/ |
H A D | mmc_disk.cpp | 416 IORequest request; local 417 status_t status = request.Init(position, (addr_t)buffer, length, false, 0); 421 status = handle->info->scheduler->ScheduleRequest(&request); 425 status = request.Wait(0, 0); 426 *_length = request.TransferredBytes(); 444 IORequest request; local 445 status_t status = request.Init(position, (addr_t)buffer, length, true, 0); 449 status = handle->info->scheduler->ScheduleRequest(&request); 453 status = request.Wait(0, 0); 454 *_length = request 460 mmc_block_io(void* cookie, io_request* request) argument [all...] |
/haiku/src/kits/package/ |
H A D | PackageRoster.cpp | 289 // compose the registrar request 290 BMessage request(::BPrivate::B_REG_PACKAGE_START_WATCHING); 292 if ((error = request.AddMessenger("target", target)) != B_OK 293 || (error = request.AddUInt32("events", eventMask)) != B_OK) { 299 error = BRoster::Private().SendTo(&request, &reply, false); 324 // compose the registrar request 325 BMessage request(::BPrivate::B_REG_PACKAGE_STOP_WATCHING); 326 status_t error = request.AddMessenger("target", target); 332 error = BRoster::Private().SendTo(&request, &reply, false);
|
/haiku/src/kits/media/ |
H A D | MediaNode.cpp | 315 // finished handling a stop request. 384 TRACE("BMediaNode::WaitForMessage request is: %#" B_PRIx32 ", node %" 670 const node_sync_to_request* request local 681 status_t status = AddTimer(request->performance_time, 682 request->port); 684 request->SendReply(status, &reply, sizeof(reply)); 723 const node_get_timesource_request* request local 731 request->SendReply(B_OK, &reply, sizeof(reply)); 737 const node_get_attributes_for_request *request = local 748 request 802 const request_data* request = static_cast<const request_data* >(buffer); local [all...] |
/haiku/src/servers/registrar/ |
H A D | Registrar.cpp | 391 /*! \brief Handle a shut down request message. 392 \param request The request to be handled. 395 Registrar::_HandleShutDown(BMessage *request) argument 408 error = fShutdownProcess->Init(request); 422 ShutdownProcess::SendReply(request, error); 426 /*! \brief Handle a is shut down in progress request message. 427 \param request The request to be handled. 430 Registrar::_HandleIsShutDownInProgress(BMessage *request) argument [all...] |
H A D | ShutdownProcess.h | 33 status_t Init(BMessage* request); 37 static void SendReply(BMessage* request, status_t error);
|
/haiku/src/kits/network/libnetservices/ |
H A D | HttpRequest.cpp | 44 CheckedSecureSocket(BHttpRequest* request); 54 CheckedSecureSocket::CheckedSecureSocket(BHttpRequest* request) argument 57 fRequest(request) 73 CheckedProxySecureSocket(const BNetworkAddress& proxy, BHttpRequest* request); 84 BHttpRequest* request) 87 fRequest(request) 241 // allow setting it before sending the request. 251 // allow setting it before sending the request. 402 // Initialize the request redirection loop 439 // Prepare the referer for the next request i 83 CheckedProxySecureSocket(const BNetworkAddress& proxy, BHttpRequest* request) argument [all...] |
/haiku/src/apps/haikudepot/server/ |
H A D | WebAppInterface.cpp | 95 BUrlRequest* request = BUrlProtocolRoster::MakeRequest(url, output, local 97 BHttpRequest* httpRequest = dynamic_cast<BHttpRequest*>(request); 99 delete request; 257 also authenticate the request with the details of the credentials and will 273 // request. 965 HDINFO("%s; empty request payload", PROTOCOL_NAME); 970 HDDEBUG("%s; dropping request to ...[%s] as network is not" 977 HDDEBUG("%s; dropping request to ...[%s] as client is too old", 986 HDDEBUG("%s; dropping request to ...[%s] as access token is not valid", 994 HDDEBUG("%s; will make request t 1016 BHttpRequest* request = make_http_request(url, NULL, &listener, &context); local 1110 BHttpRequest *request = make_http_request(url, stream, &listener); local [all...] |
/haiku/src/add-ons/kernel/drivers/disk/scsi/scsi_disk/ |
H A D | scsi_disk.cpp | 169 scsi_ccb* request = device->scsi->alloc_ccb(device->scsi_device); local 170 if (request == NULL) 212 request, blockRanges, trimData->range_count, &trimmedBlocks); 214 device->scsi->free_ccb(request); 247 scsi_ccb *request = info->scsi->alloc_ccb(info->scsi_device); local 248 if (request == NULL) 251 sSCSIPeripheral->check_capacity(info->scsi_periph_device, request); 252 info->scsi->free_ccb(request); 315 das_io(void *cookie, io_request *request) argument 319 return handle->info->io_scheduler->ScheduleRequest(request); 448 das_media_changed(das_driver_info *device, scsi_ccb *request) argument [all...] |
/haiku/src/add-ons/kernel/busses/scsi/virtio/ |
H A D | VirtioSCSIPrivate.h | 58 status_t ExecuteRequest(scsi_ccb* request); 59 uchar AbortRequest(scsi_ccb* request); 60 uchar TerminateRequest(scsi_ccb* request);
|
/haiku/src/add-ons/kernel/file_systems/netfs/client/ |
H A D | ShareVolume.h | 144 NodeMonitoringRequest* request); 162 EntryCreatedRequest* request); 164 EntryRemovedRequest* request); 166 EntryMovedRequest* request); 168 StatChangedRequest* request); 170 AttributeChangedRequest* request);
|
/haiku/src/add-ons/kernel/file_systems/userlandfs/server/haiku/ |
H A D | HaikuKernelVolume.cpp | 389 // create a request object 390 HaikuKernelIORequest* request 392 if (request == NULL) 395 status_t error = _FileSystem()->AddIORequest(request); 397 delete request; 402 error = node->ops->io(&fVolume, node, cookie, (io_request*)request); 404 // directly put our reference to the request, if the call failed 406 _FileSystem()->PutIORequest(request); 410 // TODO: ATM we don't release our reference when the request is finished 425 // get the request 451 HaikuKernelIORequest* request = _FileSystem()->GetIORequest(requestID); local 478 HaikuKernelIORequest* request = _FileSystem()->GetIORequest(requestID); local [all...] |
/haiku/src/servers/input/ |
H A D | AddOnManager.cpp | 595 BMessage request(B_GET_PROPERTY); 599 request.AddSpecifier("Messenger"); 600 request.AddSpecifier("Shelf"); 603 request.AddSpecifier("View", "Status"); 604 request.AddSpecifier("Window", "Deskbar"); 609 if (to.SendMessage(&request, &reply) == B_OK 645 BMessage request(B_GET_PROPERTY);// We're getting the ID property 649 request.AddSpecifier("ID");// want the ID 650 request.AddSpecifier("Replicant", index);// of the index'th replicant 652 if ((err = target.SendMessage(&request, [all...] |
/haiku/src/add-ons/kernel/drivers/disk/virtual/ram_disk/ |
H A D | ram_disk.cpp | 609 status_t DoIO(IORequest* request) argument 611 return fIOScheduler->ScheduleRequest(request); 1004 ioctl_register(ControlDevice* controlDevice, ram_disk_ioctl_register* request) argument 1009 if (request->path[0] != '\0') { 1011 if (strnlen(request->path, sizeof(request->path)) 1012 == sizeof(request->path)) { 1017 status_t error = path.SetTo(request->path, true); 1020 request->path, strerror(error)); 1038 deviceSize = request 1047 ioctl_unregister(ControlDevice* controlDevice, ram_disk_ioctl_unregister* request) argument 1084 ioctl_info(RawDevice* device, ram_disk_ioctl_info* request) argument 1353 IORequest request; local 1383 IORequest request; local 1401 ram_disk_raw_device_io(void* _cookie, io_request* request) argument [all...] |
/haiku/src/add-ons/kernel/drivers/disk/usb/usb_disk/ |
H A D | usb_disk.cpp | 178 // devices that do not support multiple LUNs may stall this request 364 // Step 1 : send the SCSI operation as a class specific request 367 USB_REQTYPE_CLASS | USB_REQTYPE_INTERFACE_OUT, 0 /*request*/, 374 // There was an error, we have to do a request sense to reset the device 661 TRACE_ALWAYS("getting request sense data failed: %s\n", 980 // this device reported an illegal request when syncing or repeatedly 1259 usb_disk_needs_bounce(device_lun *lun, io_request *request) argument 1261 if (!request->Buffer()->IsVirtual()) 1263 if ((request->Offset() % lun->block_size) != 0) 1265 if ((request 1805 usb_disk_bounced_io(device_lun *lun, io_request *request) argument 1870 usb_disk_direct_io(device_lun *lun, io_request *request) argument 1902 usb_disk_io(void *cookie, io_request *request) argument [all...] |
/haiku/src/tests/system/kernel/device_manager/ |
H A D | dma_resource_test.cpp | 549 IORequest request; local 550 status_t status = request.Init(fOffset, fSourceVecs, fSourceCount, 553 _Panic("request init failed: %s\n", strerror(status)); 558 while (request.RemainingBytes() > 0) { 562 status_t status = resource.TranslateNext(&request, &operation, 0); 587 request.RemainingBytes()); 646 request.OperationFinished(&operation, operation.Status(), 1235 IORequest request; local 1236 status_t status = request.Init(pos, (addr_t)buffer, length, false, 0); 1240 status = sIOScheduler->ScheduleRequest(&request); 1267 IORequest request; local 1291 dma_test_io(void *cookie, io_request *request) argument [all...] |