/haiku/src/add-ons/kernel/file_systems/netfs/shared/ |
H A D | Requests.cpp | 17 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 D | RequestFactory.cpp | 20 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 D | RequestHandler.cpp | 20 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 D | sync.cpp | 22 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 D | removable.cpp | 18 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 D | scsi_periph.cpp | 52 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 D | io_requests.cpp | 15 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 D | io_requests.h | 9 /*! 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 D | UserlandRequestHandler.h | 110 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 D | scsi_io.cpp | 19 /** 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 D | emulation.cpp | 24 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 D | LocalDeviceImpl.h | 34 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 D | FUSELowLevel.cpp | 90 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 D | Deskbar.cpp | 44 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 D | KernelRequestHandler.h | 51 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 D | KernelRequestHandler.cpp | 60 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 D | LocalDevice.cpp | 32 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 D | findsaddr-haiku.c | 27 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 D | vfs_request_io.cpp | 15 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 D | ATAPIDevice.cpp | 24 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 D | iofwrite_u.c | 40 _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 D | FileTest.cpp | 27 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 D | NetworkInterface.cpp | 44 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 D | RPCCallback.cpp | 27 Callback::EnqueueRequest(CallbackRequest* request, Connection* connection) argument 29 ASSERT(request != NULL); 31 return fServer->PrivateData()->ProcessCallback(request, connection);
|
/haiku/src/servers/registrar/ |
H A D | PackageWatchingManager.h | 17 void HandleStartStopWatching(BMessage* request); 21 status_t _AddWatcher(const BMessage* request); 22 status_t _RemoveWatcher(const BMessage* request);
|