/haiku/src/system/kernel/device_manager/ |
H A D | AbstractModuleDevice.cpp | 74 IORequest request; local 75 status_t status = request.Init(pos, (addr_t)buffer, *_length, isWrite, 0); 79 status = IO(cookie, &request); 83 status = request.Wait(0, 0); 84 *_length = request.TransferredBytes(); 116 AbstractModuleDevice::IO(void* cookie, io_request* request) argument 119 return BaseDevice::IO(cookie, request); 120 return Module()->io(cookie, request);
|
H A D | IOSchedulerSimple.h | 27 virtual status_t ScheduleRequest(IORequest* request); 29 virtual void AbortRequest(IORequest* request, 52 bool _PrepareRequestOperations(IORequest* request, 55 bool _PrepareRequestOperations(IORequest* request,
|
H A D | IOSchedulerRoster.cpp | 46 IORequest* request, IOOperation* operation) 57 if (request != NULL) { 58 event.AddPointer("request", request); 45 Notify(uint32 eventCode, const IOScheduler* scheduler, IORequest* request, IOOperation* operation) argument
|
/haiku/headers/private/userlandfs/private/ |
H A D | RequestHandler.h | 22 virtual status_t HandleRequest(Request* request) = 0;
|
/haiku/src/add-ons/kernel/network/ppp/shared/libkernelppp/ |
H A D | _KPPPPFCHandler.cpp | 24 _KPPPPFCHandler::AddToRequest(KPPPConfigurePacket& request) argument 31 // add PFC request 35 return request.AddItem(&item) ? B_OK : B_ERROR; 81 _KPPPPFCHandler::ParseRequest(const KPPPConfigurePacket& request, argument 84 if (!request.ItemWithType(kPFCType))
|
/haiku/src/add-ons/kernel/network/ppp/modem/ |
H A D | ACFCHandler.cpp | 24 ACFCHandler::AddToRequest(KPPPConfigurePacket& request) argument 31 // add ACFC request 35 return request.AddItem(&item) ? B_OK : B_ERROR; 81 ACFCHandler::ParseRequest(const KPPPConfigurePacket& request, argument 84 if (!request.ItemWithType(kACFCType))
|
/haiku/src/add-ons/kernel/power/cpufreq/amd_pstates/ |
H A D | amd_pstates.cpp | 77 uint64 request = AMD_CPPC_MIN_PERF(sHWPEfficient); local 78 request |= AMD_CPPC_MAX_PERF(sAvoidBoost ? sHWPGuaranteed : sHWPHighest); 79 request |= AMD_CPPC_EPP_PERF( 81 x86_write_msr(MSR_AMD_CPPC_REQ, request & 0xffffffff);
|
/haiku/src/add-ons/kernel/file_systems/nfs4/ |
H A D | RootInode.cpp | 64 Request request(server, fFileSystem); 65 RequestBuilder& req = request.Builder(); 73 status_t result = request.Send(); 77 ReplyInterpreter& reply = request.Reply(); 155 Request request(server, fFileSystem); 156 RequestBuilder& req = request.Builder(); 161 status_t result = request.Send(); 165 ReplyInterpreter& reply = request.Reply(); 186 Request request(server, fFileSystem); 187 RequestBuilder& req = request [all...] |
H A D | NFS4Server.h | 40 virtual status_t ProcessCallback(RPC::CallbackRequest* request, 43 status_t CallbackRecall(RequestInterpreter* request, 47 status_t CallbackGetAttr(RequestInterpreter* request,
|
H A D | RPCServer.cpp | 40 RequestManager::AddRequest(Request* request) argument 42 ASSERT(request != NULL); 46 fQueueTail->fNext = request; 48 fQueueHead = request; 49 fQueueTail = request; 50 request->fNext = NULL; 140 Server::SendCallAsync(Call* call, Reply** reply, Request** request) argument 144 ASSERT(request != NULL); 164 *request = req; 173 Server::ResendCallAsync(Call* call, Request* request) argument 195 WakeCall(Request* request) argument [all...] |
/haiku/src/kits/media/ |
H A D | DataExchange.cpp | 106 QueryServer(BMessage& request, BMessage& reply) argument 108 status_t status = sMediaServerMessenger.SendMessage(&request, &reply, 112 DEBUG_ONLY(request.PrintToStream()); 127 QueryServer(int32 msgCode, request_data* request, size_t requestSize, argument 130 return QueryPort(sMediaServerPort, msgCode, request, requestSize, reply, 144 QueryAddOnServer(int32 msgCode, request_data* request, size_t requestSize, argument 147 return QueryPort(sMediaAddonServerPort, msgCode, request, requestSize, 185 QueryPort(port_id requestPort, int32 msgCode, request_data* request, argument 188 status_t status = write_port_etc(requestPort, msgCode, request, requestSize, 204 status = write_port_etc(requestPort, msgCode, request, requestSiz [all...] |
/haiku/src/add-ons/kernel/bus_managers/scsi/ |
H A D | queuing.cpp | 9 Queuing of SCSI request 11 Some words about queuing, i.e. making sure that no request 26 - detected by SIM which calls "requeue" for affected request 32 The first condition is automatically cleared when a request has 40 are added to a device-specific request queue in an elevator-sort style, 42 requeued request and autosense-requests, which are added first. Each bus 52 // add request to device queue, using evelvator sort 64 SHOW_FLOW0( 1, "no other queued request" ); 74 SHOW_FLOW0( 1, "adding synced request to tail" ); 80 SHOW_FLOW0( 1, "adding unsortable request t [all...] |
/haiku/src/add-ons/kernel/busses/scsi/ahci/ |
H A D | ahci_controller.h | 23 void ExecuteRequest(scsi_ccb *request); 24 uchar AbortRequest(scsi_ccb *request); 25 uchar TerminateRequest(scsi_ccb *request);
|
H A D | ahci_controller.cpp | 378 AHCIController::ExecuteRequest(scsi_ccb *request) argument 380 if (request->target_lun || !fPort[request->target_id]) { 381 request->subsys_status = SCSI_DEV_NOT_THERE; 382 gSCSI->finished(request, 1); 386 fPort[request->target_id]->ScsiExecuteRequest(request); 391 AHCIController::AbortRequest(scsi_ccb *request) argument 393 if (request->target_lun || !fPort[request 401 TerminateRequest(scsi_ccb *request) argument [all...] |
/haiku/src/kits/network/libnetservices2/ |
H A D | HttpSession.cpp | 61 Request(BHttpRequest&& request, BBorrow<BDataIO> target, BMessenger observer); 130 BHttpResult Execute(BHttpRequest&& request, BBorrow<BDataIO> target, BMessenger observer); 220 BHttpSession::Impl::Execute(BHttpRequest&& request, BBorrow<BDataIO> target, BMessenger observer) argument 222 auto wRequest = Request(std::move(request), std::move(target), observer); 237 fControlQueue.remove_if([&identifier](auto& request) { 238 if (request.Id() == identifier) { 242 request.SetError(std::current_exception()); 298 for (auto& request: requests) { 301 request.ResolveHostName(); 302 request 382 auto request = std::move(data->fDataQueue.front()); local 421 auto& request = data->connectionMap.find(item.object)->second; local 439 auto& request = data->connectionMap.find(item.object)->second; local 468 auto& request = data->connectionMap.find(item.object)->second; local 478 auto& request = data->connectionMap.find(item.object)->second; local 494 auto& request = data->connectionMap.find(item.object)->second; local 620 Execute(BHttpRequest&& request, BBorrow<BDataIO> target, BMessenger observer) argument 634 Cancel(const BHttpResult& request) argument 655 Request(BHttpRequest&& request, BBorrow<BDataIO> target, BMessenger observer) argument [all...] |
/haiku/src/add-ons/kernel/network/stack/ |
H A D | link.cpp | 283 user_request_get_device_interface(void* value, struct ifreq& request, argument 286 if (user_memcpy(&request, value, IF_NAMESIZE) < B_OK) 289 interface = get_device_interface(request.ifr_name); 364 struct ifreq request; local 365 if (!user_request_get_device_interface(value, request, interface)) 369 request.ifr_index = interface->device->index; 372 request.ifr_index = 0; 374 return user_memcpy(value, &request, sizeof(struct ifreq)); 379 struct ifreq request; local 380 if (user_memcpy(&request, valu 422 struct ifreq request; local 441 struct ifreq request; local 463 struct ifreq request; local 482 struct ifreq request; local 491 struct ifreq request; local [all...] |
/haiku/src/system/kernel/fs/ |
H A D | fifo.cpp | 173 ReadRequest& request); 179 void AddReadRequest(ReadRequest& request); 180 void RemoveReadRequest(ReadRequest& request); 181 status_t WaitForReadRequest(ReadRequest& request); 356 mutex_init(&fRequestLock, "pipe request"); 380 request lock must be held when calling this method. 398 // A request up to VFS_FIFO_ATOMIC_WRITE_SIZE bytes shall not be 414 WriteRequest request(thread_get_current_thread(), minToWrite); 415 fWriteRequests.Add(&request); 421 fWriteRequests.Remove(&request); 458 ReadDataFromBuffer(void* data, size_t* _length, bool nonBlocking, bool isUser, ReadRequest& request) argument 512 AddReadRequest(ReadRequest& request) argument 519 RemoveReadRequest(ReadRequest& request) argument 526 WaitForReadRequest(ReadRequest& request) argument 563 WriteRequest* request; local [all...] |
/haiku/src/kits/package/ |
H A D | FetchFileJob.cpp | 105 BUrlRequest* request = BUrlProtocolRoster::MakeRequest(fFileURL.String(), local 107 if (request == NULL) 112 BHttpRequest* http = dynamic_cast<BHttpRequest*>(request); 119 thread_id thread = request->Run(); 156 FetchFileJob::RequestCompleted(BUrlRequest* request, bool success) argument 158 fError = request->Status(); 162 (&request->Result());
|
/haiku/src/add-ons/kernel/file_systems/netfs/client/ |
H A D | ServerVolume.cpp | 243 // prepare the request 244 OpenQueryRequest request; local 245 request.queryString.SetTo(queryString); 246 request.flags = flags; 247 request.port = port; 248 request.token = token; 250 // send the request 252 error = SendRequest(connection, &request, &reply); 275 // prepare the close request 276 CloseRequest request; local 317 ReadQueryRequest request; local [all...] |
/haiku/src/bin/network/route/ |
H A D | route.cpp | 99 prepare_request(struct ifreq& request, const char* name) argument 107 strcpy(request.ifr_name, name); 297 ifreq request; local 298 if (!prepare_request(request, interface)) 301 request.ifr_route = route; 303 if (ioctl(socket, SIOCDELRT, &request, sizeof(request)) < 0) { 313 ifreq request; local 314 if (!prepare_request(request, interface)) 318 request 331 route_entry request; member in union:__anon47 [all...] |
/haiku/src/kits/network/libnetapi/ |
H A D | NetworkDevice.cpp | 97 do_request(T& request, const char* name, int option) argument 103 strlcpy(((struct ifreq&)request).ifr_name, name, IF_NAMESIZE); 105 if (ioctl(socket.Get(), option, &request, sizeof(T)) < 0) 113 do_request<ieee80211req>(ieee80211req& request, const char* name, int option) argument 119 strlcpy(((struct ieee80211req&)request).i_name, name, IFNAMSIZ); 121 if (ioctl(socket.Get(), option, &request, sizeof(request)) < 0) 544 struct ieee80211req_sta_req& request = *(ieee80211req_sta_req*)buffer; local 546 memcpy(request.is_u.macaddr, address->LinkLevelAddress(), 549 memset(request 640 ifreq request; local 648 ifreq request; local 659 ifreq request; local 677 ifreq request; local 688 ifreq request; local 697 ifreq request; local 722 Control(int option, void* request) argument 787 struct ieee80211_scan_req request; local [all...] |
H A D | NetworkRoster.cpp | 113 ifaliasreq request; 114 memset(&request, 0, sizeof(ifaliasreq)); 115 strlcpy(request.ifra_name, name, IF_NAMESIZE); 117 if (ioctl(socket.Get(), SIOCAIFADDR, &request, sizeof(request)) != 0) 138 ifreq request; 139 strlcpy(request.ifr_name, name, IF_NAMESIZE); 141 request.ifr_addr.sa_family = AF_UNSPEC; 143 if (ioctl(socket.Get(), SIOCDIFADDR, &request, sizeof(request)) ! [all...] |
/haiku/src/add-ons/kernel/network/ppp/pap/ |
H A D | Protocol.cpp | 46 PAPHandler::AddToRequest(KPPPConfigurePacket& request) argument 57 request.AddItem((ppp_configure_item*) &item); 64 PAPHandler::ParseRequest(const KPPPConfigurePacket& request, argument 72 authentication_item *item = (authentication_item*) request.ItemAt(index); 339 ppp_lcp_packet &request = bufferheader.Data(); 340 int32 length = ntohs(request.length); 341 uint8 *data = request.data; 381 // this packet is not a reply to our request 414 // this packet is not a reply to our request 456 ppp_lcp_packet *request; [all...] |
/haiku/src/add-ons/kernel/file_systems/netfs/headers/shared/ |
H A D | Requests.h | 16 // request types 173 ConnectionBrokenRequest* request); 175 InitConnectionRequest* request); 177 InitConnectionReply* request); 179 virtual status_t VisitMountRequest(MountRequest* request); 180 virtual status_t VisitMountReply(MountReply* request); 181 virtual status_t VisitUnmountRequest(UnmountRequest* request); 183 ReadVNodeRequest* request); 184 virtual status_t VisitReadVNodeReply(ReadVNodeReply* request); 186 WriteStatRequest* request); [all...] |
/haiku/headers/private/bluetooth/ |
H A D | CommandManager.h | 84 BMessage request(BT_MSG_HANDLE_SIMPLE_REQUEST); 89 request.AddInt32("hci_id", hId); 90 request.AddData("raw command", B_ANY_TYPE, simpleCommand.Data(), 92 request.AddInt16("eventExpected", HCI_EVENT_CMD_COMPLETE); 93 request.AddInt16("opcodeExpected", PACK_OPCODE(ofg, ocf)); 95 if (messenger->SendMessage(&request, &reply) == B_OK) {
|