Searched refs:request (Results 1 - 25 of 395) sorted by relevance

1234567891011>>

/haiku/src/add-ons/kernel/file_systems/netfs/shared/
H A DRequests.cpp17 RequestVisitor::VisitConnectionBrokenRequest(ConnectionBrokenRequest* request) argument
19 return VisitAny(request);
24 RequestVisitor::VisitInitConnectionRequest(InitConnectionRequest* request) argument
26 return VisitAny(request);
31 RequestVisitor::VisitInitConnectionReply(InitConnectionReply* request) argument
33 return VisitAny(request);
38 RequestVisitor::VisitMountRequest(MountRequest* request) argument
40 return VisitAny(request);
45 RequestVisitor::VisitMountReply(MountReply* request) argument
47 return VisitAny(request);
52 VisitUnmountRequest(UnmountRequest* request) argument
59 VisitReadVNodeRequest(ReadVNodeRequest* request) argument
66 VisitReadVNodeReply(ReadVNodeReply* request) argument
73 VisitWriteStatRequest(WriteStatRequest* request) argument
80 VisitWriteStatReply(WriteStatReply* request) argument
87 VisitCreateFileRequest(CreateFileRequest* request) argument
94 VisitCreateFileReply(CreateFileReply* request) argument
101 VisitOpenRequest(OpenRequest* request) argument
108 VisitOpenReply(OpenReply* request) argument
115 VisitCloseRequest(CloseRequest* request) argument
122 VisitCloseReply(CloseReply* request) argument
129 VisitReadRequest(ReadRequest* request) argument
136 VisitReadReply(ReadReply* request) argument
143 VisitWriteRequest(WriteRequest* request) argument
150 VisitWriteReply(WriteReply* request) argument
157 VisitCreateLinkRequest(CreateLinkRequest* request) argument
164 VisitCreateLinkReply(CreateLinkReply* request) argument
171 VisitUnlinkRequest(UnlinkRequest* request) argument
178 VisitUnlinkReply(UnlinkReply* request) argument
185 VisitCreateSymlinkRequest(CreateSymlinkRequest* request) argument
192 VisitCreateSymlinkReply(CreateSymlinkReply* request) argument
199 VisitReadLinkRequest(ReadLinkRequest* request) argument
206 VisitReadLinkReply(ReadLinkReply* request) argument
213 VisitRenameRequest(RenameRequest* request) argument
220 VisitRenameReply(RenameReply* request) argument
227 VisitMakeDirRequest(MakeDirRequest* request) argument
234 VisitMakeDirReply(MakeDirReply* request) argument
241 VisitRemoveDirRequest(RemoveDirRequest* request) argument
248 VisitRemoveDirReply(RemoveDirReply* request) argument
255 VisitOpenDirRequest(OpenDirRequest* request) argument
262 VisitOpenDirReply(OpenDirReply* request) argument
269 VisitReadDirRequest(ReadDirRequest* request) argument
276 VisitReadDirReply(ReadDirReply* request) argument
283 VisitWalkRequest(WalkRequest* request) argument
290 VisitWalkReply(WalkReply* request) argument
297 VisitMultiWalkRequest(MultiWalkRequest* request) argument
304 VisitMultiWalkReply(MultiWalkReply* request) argument
311 VisitOpenAttrDirRequest(OpenAttrDirRequest* request) argument
318 VisitOpenAttrDirReply(OpenAttrDirReply* request) argument
325 VisitReadAttrDirRequest(ReadAttrDirRequest* request) argument
332 VisitReadAttrDirReply(ReadAttrDirReply* request) argument
339 VisitReadAttrRequest(ReadAttrRequest* request) argument
346 VisitReadAttrReply(ReadAttrReply* request) argument
353 VisitWriteAttrRequest(WriteAttrRequest* request) argument
360 VisitWriteAttrReply(WriteAttrReply* request) argument
367 VisitRemoveAttrRequest(RemoveAttrRequest* request) argument
374 VisitRemoveAttrReply(RemoveAttrReply* request) argument
381 VisitRenameAttrRequest(RenameAttrRequest* request) argument
388 VisitRenameAttrReply(RenameAttrReply* request) argument
395 VisitStatAttrRequest(StatAttrRequest* request) argument
402 VisitStatAttrReply(StatAttrReply* request) argument
409 VisitOpenQueryRequest(OpenQueryRequest* request) argument
416 VisitOpenQueryReply(OpenQueryReply* request) argument
423 VisitReadQueryRequest(ReadQueryRequest* request) argument
430 VisitReadQueryReply(ReadQueryReply* request) argument
437 VisitNodeMonitoringRequest(NodeMonitoringRequest* request) argument
444 VisitEntryCreatedRequest(EntryCreatedRequest* request) argument
451 VisitEntryRemovedRequest(EntryRemovedRequest* request) argument
458 VisitEntryMovedRequest(EntryMovedRequest* request) argument
465 VisitStatChangedRequest(StatChangedRequest* request) argument
472 VisitAttributeChangedRequest(AttributeChangedRequest* request) argument
479 VisitServerInfoRequest(ServerInfoRequest* request) argument
486 VisitAny(Request* request) argument
[all...]
H A DRequestFactory.cpp20 RequestFactory::CreateRequest(uint32 type, Request** request) argument
22 if (!request)
26 *request = new(std::nothrow) InitConnectionRequest;
29 *request = new(std::nothrow) InitConnectionReply;
32 *request = new(std::nothrow) MountRequest;
35 *request = new(std::nothrow) MountReply;
38 *request = new(std::nothrow) UnmountRequest;
41 *request = new(std::nothrow) ReadVNodeRequest;
44 *request = new(std::nothrow) ReadVNodeReply;
47 *request
[all...]
H A DRequestHandler.cpp20 RequestHandler::HandleRequest(Request* request, RequestChannel* channel) argument
22 if (!request)
28 return request->Accept(this);
33 RequestHandler::VisitAny(Request* request) argument
35 // unexpected request
/haiku/src/add-ons/kernel/generic/scsi_periph/
H A Dsync.cpp22 periph_synchronize_cache(scsi_periph_device_info *device, scsi_ccb *request) argument
24 scsi_cmd_sync_cache* cmd = (scsi_cmd_sync_cache*)request->cdb;
26 request->flags = SCSI_DIR_NONE;
28 request->data = NULL;
29 request->sg_list = NULL;
30 request->data_length = 0;
31 request->timeout = device->std_timeout;
32 request->sort = -1;
42 request->cdb_length = sizeof(*cmd);
44 device->scsi->sync_io(request);
[all...]
H A Dremovable.cpp18 periph_media_changed(scsi_periph_device_info *device, scsi_ccb *request) argument
44 backup_flags = request->flags;
45 memcpy(backup_cdb, request->cdb, SCSI_MAX_CDB_SIZE);
46 backup_cdb_len = request->cdb_length;
47 backup_sort = request->sort;
48 backup_timeout = request->timeout;
49 backup_data = request->data;
50 backup_sg_list = request->sg_list;
51 backup_sg_count = request->sg_count;
52 backup_data_len = request
88 send_tur(scsi_periph_device_info *device, scsi_ccb *request) argument
115 wait_for_ready(scsi_periph_device_info *device, scsi_ccb *request) argument
151 scsi_ccb *request; local
201 periph_send_start_stop(scsi_periph_device_info *device, scsi_ccb *request, bool start, bool withLoadEject) argument
[all...]
H A Dscsi_periph.cpp52 periph_safe_exec(scsi_periph_device_info *device, scsi_ccb *request) argument
58 device->scsi->sync_io(request);
61 res = periph_check_error(device, request);
63 // backup request, as we need it temporarily for sending "start"
77 backup_flags = request->flags;
78 memcpy(backup_cdb, request->cdb, SCSI_MAX_CDB_SIZE);
79 backup_cdb_len = request->cdb_length;
80 backup_sort = request->sort;
81 backup_timeout = request->timeout;
82 backup_data = request
[all...]
/haiku/src/system/kernel/device_manager/
H A Dio_requests.cpp15 transfer_io_request_data(io_request* request, void* buffer, size_t size, argument
18 if (writeToRequest == request->IsWrite()
19 || request->RemainingBytes() < size) {
23 // lock the request buffer memory, if it is user memory
24 IOBuffer* ioBuffer = request->Buffer();
26 status_t error = ioBuffer->LockMemory(request->TeamID(),
33 off_t offset = request->Offset() + request->TransferredBytes();
35 ? request->CopyData(buffer, offset, size)
36 : request
50 io_request_is_write(const io_request* request) argument
58 io_request_is_vip(const io_request* request) argument
69 io_request_offset(const io_request* request) argument
80 io_request_length(const io_request* request) argument
92 read_from_io_request(io_request* request, void* buffer, size_t size) argument
104 write_to_io_request(io_request* request, const void* buffer, size_t size) argument
114 notify_io_request(io_request* request, status_t status) argument
[all...]
/haiku/headers/os/drivers/
H A Dio_requests.h9 /*! I/O request interface */
22 bool io_request_is_write(const io_request* request);
23 bool io_request_is_vip(const io_request* request);
24 off_t io_request_offset(const io_request* request);
25 off_t io_request_length(const io_request* request);
26 status_t read_from_io_request(io_request* request, void* buffer,
28 status_t write_to_io_request(io_request* request, const void* buffer,
30 void notify_io_request(io_request* request, status_t status);
/haiku/src/add-ons/kernel/file_systems/userlandfs/server/
H A DUserlandRequestHandler.h110 virtual status_t HandleRequest(Request* request);
114 status_t _HandleRequest(MountVolumeRequest* request);
115 status_t _HandleRequest(UnmountVolumeRequest* request);
116 status_t _HandleRequest(SyncVolumeRequest* request);
117 status_t _HandleRequest(ReadFSInfoRequest* request);
118 status_t _HandleRequest(WriteFSInfoRequest* request);
121 status_t _HandleRequest(LookupRequest* request);
122 status_t _HandleRequest(GetVNodeNameRequest* request);
123 status_t _HandleRequest(ReadVNodeRequest* request);
124 status_t _HandleRequest(WriteVNodeRequest* request);
[all...]
/haiku/src/add-ons/kernel/bus_managers/scsi/
H A Dscsi_io.cpp19 /** put request back in queue because of device/bus overflow */
22 scsi_requeue_request(scsi_ccb *request, bool bus_overflow) argument
24 scsi_bus_info *bus = request->bus;
25 scsi_device_info *device = request->device;
30 if (request->state != SCSI_STATE_SENT) {
31 panic("Unsent ccb was request to requeue\n");
35 request->state = SCSI_STATE_QUEUED;
44 if (device->left_slots++ == 0 || request->ordered)
47 // make sure it's the next request for this device
48 scsi_add_req_queue_first(request);
84 scsi_resubmit_request(scsi_ccb *request) argument
140 submit_autosense(scsi_ccb *request) argument
174 scsi_ccb *request = device->auto_sense_request; local
204 scsi_device_queue_overflow(scsi_ccb *request, uint num_requests) argument
238 scsi_request_finished(scsi_ccb *request, uint num_requests) argument
339 scsi_check_enqueue_request(scsi_ccb *request) argument
391 scsi_async_io(scsi_ccb *request) argument
497 scsi_sync_io(scsi_ccb *request) argument
595 scsi_ccb *request; local
[all...]
H A Demulation.cpp24 static void set_sense(scsi_ccb *request, int sense_key, int sense_asc);
25 static bool copy_sg_data(scsi_ccb *request, uint offset, uint allocation_length,
27 static void get_emulation_buffer(scsi_ccb *request);
28 static void replace_request_data(scsi_ccb *request);
29 static void release_emulation_buffer(scsi_ccb *request);
30 static void restore_request_data(scsi_ccb *request);
113 scsi_read_write_6(scsi_ccb *request) argument
115 scsi_cmd_rw_6 *cmd = (scsi_cmd_rw_6 *)request->orig_cdb;
116 scsi_cmd_rw_10 *cdb = (scsi_cmd_rw_10 *)request->cdb;
120 request
166 scsi_start_mode_sense_6(scsi_ccb *request) argument
205 scsi_start_mode_select_6(scsi_ccb *request) argument
277 scsi_start_emulation(scsi_ccb *request) argument
304 scsi_finish_mode_sense_10_6(scsi_ccb *request) argument
357 scsi_finish_mode_select_10_6(scsi_ccb *request) argument
373 scsi_finish_inquiry(scsi_ccb *request) argument
400 scsi_finish_emulation(scsi_ccb *request) argument
426 set_sense(scsi_ccb *request, int sense_key, int sense_asc) argument
465 copy_sg_data(scsi_ccb *request, uint offset, uint allocation_length, void *buffer, int size, bool to_buffer) argument
518 get_emulation_buffer(scsi_ccb *request) argument
532 replace_request_data(scsi_ccb *request) argument
550 release_emulation_buffer(scsi_ccb *request) argument
560 restore_request_data(scsi_ccb *request) argument
[all...]
/haiku/src/servers/bluetooth/
H A DLocalDeviceImpl.h34 status_t ProcessSimpleRequest(BMessage* request);
39 BMessage* request);
42 void CommandComplete(struct hci_ev_cmd_complete* event, BMessage* request,
44 void CommandStatus(struct hci_ev_cmd_status* event, BMessage* request,
50 void InquiryResult(uint8* numberOfResponses, BMessage* request);
51 void InquiryComplete(uint8* status, BMessage* request);
53 remotename, BMessage* request);
56 void ConnectionComplete(struct hci_ev_conn_complete* event, BMessage* request);
57 void ConnectionRequest(struct hci_ev_conn_request* event, BMessage* request);
59 BMessage* request);
[all...]
/haiku/src/add-ons/kernel/file_systems/userlandfs/server/fuse/
H A DFUSELowLevel.cpp90 fuse_req request;
91 ops->lookup(&request, parent, name);
92 request.Wait();
93 *st = request.fReplyEntry.attr;
94 st->st_ino = request.fReplyEntry.ino;
95 return request.fReplyResult;
105 fuse_req request;
106 request.fReplyAttr = st;
107 ops->getattr(&request, ino, NULL);
108 request
316 fuse_req request; local
[all...]
/haiku/src/kits/interface/
H A DDeskbar.cpp44 BMessage request(B_GET_PROPERTY);
45 request.AddSpecifier("Frame");
46 request.AddSpecifier("Window", (int32)0);
49 result = deskbar.SendMessage(&request, &reply);
97 BMessage request(kMsgLocation);
109 if (fMessenger->SendMessage(&request, &reply) == B_OK) {
125 BMessage request(kMsgSetLocation);
126 request.AddInt32("location", static_cast<int32>(location));
127 request.AddBool("expand", expanded);
129 return fMessenger->SendMessage(&request);
[all...]
/haiku/src/add-ons/kernel/file_systems/userlandfs/kernel_add_on/
H A DKernelRequestHandler.h51 virtual status_t HandleRequest(Request* request);
55 status_t _HandleRequest(NotifyListenerRequest* request);
57 NotifySelectEventRequest* request);
58 status_t _HandleRequest(NotifyQueryRequest* request);
60 status_t _HandleRequest(GetVNodeRequest* request);
61 status_t _HandleRequest(PutVNodeRequest* request);
62 status_t _HandleRequest(AcquireVNodeRequest* request);
63 status_t _HandleRequest(NewVNodeRequest* request);
64 status_t _HandleRequest(PublishVNodeRequest* request);
65 status_t _HandleRequest(RemoveVNodeRequest* request);
[all...]
H A DKernelRequestHandler.cpp60 KernelRequestHandler::HandleRequest(Request* request) argument
62 if (request->GetType() == fExpectedReply) {
66 switch (request->GetType()) {
69 return _HandleRequest((NotifyListenerRequest*)request);
71 return _HandleRequest((NotifySelectEventRequest*)request);
73 return _HandleRequest((NotifyQueryRequest*)request);
76 return _HandleRequest((GetVNodeRequest*)request);
78 return _HandleRequest((PutVNodeRequest*)request);
80 return _HandleRequest((AcquireVNodeRequest*)request);
82 return _HandleRequest((NewVNodeRequest*)request);
132 _HandleRequest(NotifyListenerRequest* request) argument
250 _HandleRequest(NotifySelectEventRequest* request) argument
284 _HandleRequest(NotifyQueryRequest* request) argument
350 _HandleRequest(GetVNodeRequest* request) argument
373 _HandleRequest(PutVNodeRequest* request) argument
395 _HandleRequest(AcquireVNodeRequest* request) argument
419 _HandleRequest(NewVNodeRequest* request) argument
444 _HandleRequest(PublishVNodeRequest* request) argument
470 _HandleRequest(RemoveVNodeRequest* request) argument
491 _HandleRequest(UnremoveVNodeRequest* request) argument
512 _HandleRequest(GetVNodeRemovedRequest* request) argument
539 _HandleRequest(FileCacheCreateRequest* request) argument
564 _HandleRequest(FileCacheDeleteRequest* request) argument
589 _HandleRequest(FileCacheSetEnabledRequest* request) argument
614 _HandleRequest(FileCacheSetSizeRequest* request) argument
639 _HandleRequest(FileCacheSyncRequest* request) argument
664 _HandleRequest(FileCacheReadRequest* request) argument
708 _HandleRequest(FileCacheWriteRequest* request) argument
746 _HandleRequest(DoIterativeFDIORequest* request) argument
776 _HandleRequest(ReadFromIORequestRequest* request) argument
816 _HandleRequest(WriteToIORequestRequest* request) argument
843 _HandleRequest(NotifyIORequestRequest* request) argument
867 _HandleRequest(AddNodeListenerRequest* request) argument
888 _HandleRequest(RemoveNodeListenerRequest* request) argument
[all...]
/haiku/src/kits/bluetooth/
H A DLocalDevice.cpp32 LocalDevice::RequestLocalDeviceID(BMessage* request) argument
43 if (messenger->SendMessage(request, &reply) == B_OK
63 BMessage request(BT_MSG_ACQUIRE_LOCAL_DEVICE);
65 return RequestLocalDeviceID(&request);
72 BMessage request(BT_MSG_ACQUIRE_LOCAL_DEVICE);
73 request.AddInt32("hci_id", hid);
75 return RequestLocalDeviceID(&request);
82 BMessage request(BT_MSG_ACQUIRE_LOCAL_DEVICE);
83 request.AddData("bdaddr", B_ANY_TYPE, &bdaddr, sizeof(bdaddr_t));
85 return RequestLocalDeviceID(&request);
[all...]
/haiku/src/bin/network/traceroute/
H A Dfindsaddr-haiku.c27 struct route_entry *request = (struct route_entry *)buffer; local
33 memset(request, 0, sizeof(struct route_entry));
34 request->destination = (struct sockaddr *)to;
41 if (request->source != NULL && request->source->sa_family == AF_INET)
42 memcpy(from, request->source, sizeof(struct sockaddr_in));
46 if (request->source == NULL || request->source->sa_family != AF_INET)
/haiku/src/tools/fs_shell/
H A Dvfs_request_io.cpp15 fssh_do_fd_io(int fd, fssh_io_request* request) argument
23 fssh_do_iterative_fd_io(int fd, fssh_io_request* request, argument
/haiku/src/add-ons/kernel/bus_managers/ata/
H A DATAPIDevice.cpp24 ATAPIDevice::SendPacket(ATARequest *request) argument
26 TRACE_FUNCTION("%p\n", request);
34 request->SetUseDMA(UseDMA() && request->CCB()->sg_list != NULL
39 && fChannel->PrepareDMA(request) == B_OK);
40 TRACE("using dma: %s\n", request->UseDMA() ? "yes" : "no");
42 if (!request->UseDMA())
43 request->PrepareSGInfo();
45 if (_FillTaskFilePacket(request) != B_OK) {
46 TRACE_ERROR("failed to setup transfer request\
188 ExecuteIO(ATARequest *request) argument
231 _FillTaskFilePacket(ATARequest *request) argument
245 _FinishRequest(ATARequest *request, uint32 flags) argument
[all...]
/haiku/src/system/libroot/posix/glibc/libio/
H A Diofwrite_u.c40 _IO_size_t request = size * count; local
43 if (request == 0)
47 written = _IO_sputn (fp, (const char *) buf, request);
48 if (written == request)
/haiku/src/tests/kits/net/service/
H A DFileTest.cpp27 StopTestListener(BUrlRequest* request = NULL)
29 SetRequest(request);
38 void SetRequest(BUrlRequest* request) argument
40 fRequest = request;
67 BUrlRequest *request = BUrlProtocolRoster::MakeRequest(url, &listener); local
68 CHK(request != NULL);
70 listener.SetRequest(request);
71 thread_id thr = request->Run();
75 CHK(request->Status() == B_INTERRUPTED);
77 delete request;
[all...]
/haiku/src/kits/network/libnetapi/
H A DNetworkInterface.cpp44 ifaliasreq request;
45 strlcpy(request.ifra_name, name, IF_NAMESIZE);
46 request.ifra_index = address.Index();
47 request.ifra_flags = address.Flags();
49 memcpy(&request.ifra_addr, &address.Address().SockAddr(),
51 memcpy(&request.ifra_mask, &address.Mask().SockAddr(),
53 memcpy(&request.ifra_broadaddr, &address.Broadcast().SockAddr(),
56 if (ioctl(socket.Get(), option, &request, sizeof(struct ifaliasreq)) < 0)
60 address.SetFlags(request.ifra_flags);
61 address.Address().SetTo(request
80 do_request(int family, T& request, const char* name, int option) argument
197 ifreq request; local
212 ifreq request; local
227 ifreq request; local
238 ifreq request; local
249 ifreq request; local
260 ifreq request; local
271 ifreq request; local
282 ifreq request; local
293 ifreq request; local
313 ifreq request; local
322 ifreq request; local
331 ifreq request; local
340 ifreq request; local
349 ifreq request; local
437 ifreq request; local
449 ifreq request; local
526 ifreq request; local
[all...]
/haiku/src/add-ons/kernel/file_systems/nfs4/
H A DRPCCallback.cpp27 Callback::EnqueueRequest(CallbackRequest* request, Connection* connection) argument
29 ASSERT(request != NULL);
31 return fServer->PrivateData()->ProcessCallback(request, connection);
/haiku/src/servers/registrar/
H A DPackageWatchingManager.h17 void HandleStartStopWatching(BMessage* request);
21 status_t _AddWatcher(const BMessage* request);
22 status_t _RemoveWatcher(const BMessage* request);

Completed in 281 milliseconds

1234567891011>>