Searched refs:request (Results 126 - 150 of 395) sorted by relevance

1234567891011>>

/haiku/src/system/kernel/device_manager/
H A DAbstractModuleDevice.cpp74 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 DIOSchedulerSimple.h27 virtual status_t ScheduleRequest(IORequest* request);
29 virtual void AbortRequest(IORequest* request,
52 bool _PrepareRequestOperations(IORequest* request,
55 bool _PrepareRequestOperations(IORequest* request,
H A DIOSchedulerRoster.cpp46 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 DRequestHandler.h22 virtual status_t HandleRequest(Request* request) = 0;
/haiku/src/add-ons/kernel/network/ppp/shared/libkernelppp/
H A D_KPPPPFCHandler.cpp24 _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 DACFCHandler.cpp24 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 Damd_pstates.cpp77 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 DRootInode.cpp64 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 DNFS4Server.h40 virtual status_t ProcessCallback(RPC::CallbackRequest* request,
43 status_t CallbackRecall(RequestInterpreter* request,
47 status_t CallbackGetAttr(RequestInterpreter* request,
H A DRPCServer.cpp40 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 DDataExchange.cpp106 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 Dqueuing.cpp9 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 Dahci_controller.h23 void ExecuteRequest(scsi_ccb *request);
24 uchar AbortRequest(scsi_ccb *request);
25 uchar TerminateRequest(scsi_ccb *request);
H A Dahci_controller.cpp378 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 DHttpSession.cpp61 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 Dlink.cpp283 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 Dfifo.cpp173 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 DFetchFileJob.cpp105 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 DServerVolume.cpp243 // 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 Droute.cpp99 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 DNetworkDevice.cpp97 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 DNetworkRoster.cpp113 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 DProtocol.cpp46 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 DRequests.h16 // 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 DCommandManager.h84 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) {

Completed in 151 milliseconds

1234567891011>>