/haiku/headers/private/userlandfs/fuse/ |
H A D | fuse_lowlevel_compat.h | 15 void (*lookup) (fuse_req_t req, fuse_ino_t parent, const char *name); 16 void (*forget) (fuse_req_t req, fuse_ino_t ino, unsigned long nlookup); 17 void (*getattr) (fuse_req_t req, fuse_ino_t ino, 19 void (*setattr) (fuse_req_t req, fuse_ino_t ino, struct stat *attr, 21 void (*readlink) (fuse_req_t req, fuse_ino_t ino); 22 void (*mknod) (fuse_req_t req, fuse_ino_t parent, const char *name, 24 void (*mkdir) (fuse_req_t req, fuse_ino_t parent, const char *name, 26 void (*unlink) (fuse_req_t req, fuse_ino_t parent, const char *name); 27 void (*rmdir) (fuse_req_t req, fuse_ino_t parent, const char *name); 28 void (*symlink) (fuse_req_t req, cons [all...] |
H A D | fuse_lowlevel.h | 201 * @param req request handle 205 void (*lookup) (fuse_req_t req, fuse_ino_t parent, const char *name); 239 * @param req request handle 243 void (*forget) (fuse_req_t req, fuse_ino_t ino, unsigned long nlookup); 252 * @param req request handle 256 void (*getattr) (fuse_req_t req, fuse_ino_t ino, 277 * @param req request handle 286 void (*setattr) (fuse_req_t req, fuse_ino_t ino, struct stat *attr, 296 * @param req request handle 299 void (*readlink) (fuse_req_t req, fuse_ino_ [all...] |
/haiku/src/add-ons/kernel/drivers/disk/nvme/libnvme/ |
H A D | nvme_request.c | 41 struct nvme_request *req; local 45 req = STAILQ_FIRST(&qpair->free_req); 46 if (req) { 48 memset(&req->cmd, 0, sizeof(struct nvme_cmd)); 53 return req; 84 struct nvme_request *req; local 100 req = &qpair->reqs[i]; 101 req->qpair = qpair; 102 STAILQ_INSERT_TAIL(&qpair->free_req, req, stailq); 103 req 111 struct nvme_request *req; local 132 struct nvme_request *req; local 176 nvme_request_free_locked(struct nvme_request *req) argument 183 nvme_request_free(struct nvme_request *req) argument [all...] |
H A D | nvme_ns.c | 239 struct nvme_request *req, 267 if (req->child_reqs) { 269 TAILQ_FOREACH_SAFE(child, &req->children, 271 nvme_request_remove_child(req, child); 284 nvme_request_add_child(req, child); 293 return req; 306 struct nvme_request *req; local 327 req = nvme_request_allocate(qpair, payload, 329 if (req == NULL) 342 io_flags, req, sectors_per_strip 232 _nvme_ns_split_request(struct nvme_ns *ns, struct nvme_qpair *qpair, const struct nvme_payload *payload, uint64_t lba, uint32_t lba_count, nvme_cmd_cb cb_fn, void *cb_arg, uint32_t opc, uint32_t io_flags, struct nvme_request *req, uint32_t sectors_per_max_io, uint32_t sector_mask, uint16_t apptag_mask, uint16_t apptag) argument 383 struct nvme_request *req; local 405 struct nvme_request *req; local 427 struct nvme_request *req; local 453 struct nvme_request *req; local 475 struct nvme_request *req; local 497 struct nvme_request *req; local 522 struct nvme_request *req; local 549 struct nvme_request *req; local 575 struct nvme_request *req; local 596 struct nvme_request *req; local 626 struct nvme_request *req; local 656 struct nvme_request *req; local 684 struct nvme_request *req; local [all...] |
H A D | nvme_qpair.c | 345 struct nvme_request *req = tr->req; local 355 (int)tr->req->cmd.cid); 358 nvme_qpair_copy_command(&qpair->cmd[qpair->sq_tail], &req->cmd); 372 struct nvme_request *req = tr->req; local 375 if (!req) { 383 (req->retries < NVME_MAX_RETRY_COUNT); 385 nvme_qpair_print_command(qpair, &req->cmd); 391 if (cpl->cid != req 429 struct nvme_request *req = STAILQ_FIRST(&req_queue); local 461 nvme_qpair_manual_complete_request(struct nvme_qpair *qpair, struct nvme_request *req, uint32_t sct, uint32_t sc, bool print_on_error) argument 527 _nvme_qpair_build_contig_request(struct nvme_qpair *qpair, struct nvme_request *req, struct nvme_tracker *tr) argument 583 _nvme_qpair_build_hw_sgl_request(struct nvme_qpair *qpair, struct nvme_request *req, struct nvme_tracker *tr) argument 664 _nvme_qpair_build_prps_sgl_request(struct nvme_qpair *qpair, struct nvme_request *req, struct nvme_tracker *tr) argument 779 struct nvme_request *req; local 1005 nvme_qpair_submit_request(struct nvme_qpair *qpair, struct nvme_request *req) argument 1209 struct nvme_request *req; local [all...] |
H A D | nvme_admin.c | 45 struct nvme_request *req; local 48 req = nvme_request_allocate_contig(&ctrlr->adminq, buf, len, 51 req = nvme_request_allocate_null(&ctrlr->adminq, cb_fn, cb_arg); 52 if (!req) 55 memcpy(&req->cmd, cmd, sizeof(req->cmd)); 57 return nvme_qpair_submit_request(&ctrlr->adminq, req);
|
/haiku/src/add-ons/kernel/file_systems/websearchfs/ |
H A D | duckduckgo_request.cpp | 41 status_t duckduckgo_request_process(struct duckduckgo_request *req) argument 53 req->cnx = cnx; 55 p = urlify_string(req->query_string); 106 &req->nextid, &req->results); 110 while ((res = SLL_DEQUEUE(req->results, next))) { 112 websearchfs_push_result_to_query(req, res); 127 req->cnx = NULL; 131 status_t duckduckgo_request_process_async(struct duckduckgo_request *req) argument 136 status_t duckduckgo_request_close(struct duckduckgo_request *req) argument 147 duckduckgo_request_open(const char *query_string, struct fs_volume *volume, struct fs_node *query_node, struct duckduckgo_request **req) argument 163 duckduckgo_request_free(struct duckduckgo_request *req) argument [all...] |
H A D | duckduckgo_request.h | 43 extern status_t duckduckgo_request_process(struct duckduckgo_request *req); 44 extern status_t duckduckgo_request_process_async(struct duckduckgo_request *req); 45 extern status_t duckduckgo_request_close(struct duckduckgo_request *req); 46 extern status_t duckduckgo_request_open(const char *query_string, struct fs_volume *volume, struct fs_node *query_node, struct duckduckgo_request **req); 47 extern status_t duckduckgo_request_free(struct duckduckgo_request *req);
|
/haiku/src/add-ons/kernel/drivers/network/wlan/realtekwifi/dev/rtwn/usb/ |
H A D | rtwn_usb_reg.c | 62 rtwn_do_request(struct rtwn_softc *sc, struct usb_device_request *req, argument 73 req, data, 0, NULL, 250 /* ms */); 93 usb_device_request_t req; local 95 req.bmRequestType = UT_WRITE_VENDOR_DEVICE; 96 req.bRequest = R92C_REQ_REGS; 97 USETW(req.wValue, addr); 98 USETW(req.wIndex, 0); 99 USETW(req.wLength, len); 100 return (rtwn_do_request(sc, &req, buf)); 127 usb_device_request_t req; local [all...] |
/haiku/src/add-ons/kernel/file_systems/userlandfs/server/fuse/ |
H A D | FUSELowLevel.cpp | 435 fuse_reply_attr(fuse_req_t req, const struct stat *attr, double attr_timeout) argument 437 *req->fReplyAttr = *attr; 438 req->Notify(); 444 fuse_reply_create(fuse_req_t req, const struct fuse_entry_param* e, const struct fuse_file_info* fi) argument 446 req->fReplyEntry = *e; 447 req->Notify(); 453 fuse_reply_readlink(fuse_req_t req, const char* link) argument 455 strlcpy(req->fReplyBuf, link, req->fReplyResult); 456 req 463 fuse_reply_open(fuse_req_t req, const struct fuse_file_info* f) argument 472 fuse_reply_buf(fuse_req_t req, const char *buf, size_t size) argument 485 fuse_reply_entry(fuse_req_t req, const struct fuse_entry_param *e) argument 494 fuse_reply_err(fuse_req_t req, int err) argument 504 fuse_reply_statfs(fuse_req_t req, const struct statvfs* stat) argument 513 fuse_reply_write(fuse_req_t req, size_t count) argument 523 fuse_add_direntry(fuse_req_t req, char *buf, size_t bufsize, const char *name, const struct stat *stbuf, off_t off) argument [all...] |
/haiku/src/add-ons/kernel/file_systems/nfs4/ |
H A D | NFS4Inode.cpp | 27 RequestBuilder& req = request.Builder(); local 30 req.PutFH(fInfo.fAttrDir); 32 req.PutFH(fInfo.fHandle); 35 req.GetAttr(attr, sizeof(attr) / sizeof(Attribute)); 70 RequestBuilder& req = request.Builder(); local 72 req.PutFH(fInfo.fHandle); 73 req.Commit(0, 0); 99 RequestBuilder& req = request.Builder(); local 101 req.PutFH(fInfo.fHandle); 102 req 130 RequestBuilder& req = request.Builder(); local 220 RequestBuilder& req = request.Builder(); local 256 RequestBuilder& req = request.Builder(); local 291 RequestBuilder& req = request.Builder(); local 329 RequestBuilder& req = request.Builder(); local 375 RequestBuilder& req = request.Builder(); local 464 RequestBuilder& req = request.Builder(); local 562 RequestBuilder& req = request.Builder(); local 671 RequestBuilder& req = request.Builder(); local 732 RequestBuilder& req = request.Builder(); local 768 RequestBuilder& req = request.Builder(); local 808 RequestBuilder& req = request.Builder(); local 888 RequestBuilder& req = request.Builder(); local 969 RequestBuilder& req = request.Builder(); local 1041 RequestBuilder& req = request.Builder(); local 1079 RequestBuilder& req = request.Builder(); local 1122 RequestBuilder& req = request.Builder(); local 1171 RequestBuilder& req = request.Builder(); local [all...] |
H A D | Delegation.cpp | 47 RequestBuilder& req = request.Builder(); local 49 req.PutFH(fInfo.fHandle); 50 req.DelegReturn(fData.fStateID, fData.fStateSeq);
|
H A D | RPCServer.cpp | 58 Request* req = fQueueHead; local 60 while (req != NULL) { 61 if (req->fXID == xid) { 63 prev->fNext = req->fNext; 64 if (fQueueTail == req) 66 if (fQueueHead == req) 67 fQueueHead = req->fNext; 69 return req; 72 prev = req; 73 req 199 Request* req = fRequests.FindRequest(request->fXID); local 293 Request* req = fRequests.FindRequest(reply->GetXID()); local [all...] |
H A D | OpenState.cpp | 121 RequestBuilder& req = request.Builder(); local 123 req.ReleaseLockOwner(this, owner); 174 RequestBuilder& req = request.Builder(); local 176 req.PutFH(fInfo.fHandle); 177 req.Open(CLAIM_PREVIOUS, sequence, sModeToAccess(fMode), newClientID, 244 RequestBuilder& req = request.Builder(); local 246 req.PutFH(fInfo.fHandle); 247 req.Lock(this, linfo, &sequence, true); 296 RequestBuilder& req = request.Builder(); local 298 req [all...] |
H A D | FileInfo.cpp | 138 RequestBuilder& req = request.Builder(); local 140 req.PutRootFH(); 146 req.LookUp(path[lookupCount]); 173 req.LookUp(pathNames[i - 1]->fNames.Head()->fName); 179 req.GetFH(); 186 req.Verify(&attr, 1);
|
H A D | RootInode.cpp | 65 RequestBuilder& req = request.Builder(); local 67 req.PutFH(fInfo.fHandle); 71 req.GetAttr(attr, sizeof(attr) / sizeof(Attribute)); 156 RequestBuilder& req = request.Builder(); local 158 req.PutFH(fInfo.fHandle); 159 req.Access(); 187 RequestBuilder& req = request.Builder(); local 189 req.PutFH(fInfo.fHandle); 191 req.GetAttr(attr, sizeof(attr) / sizeof(Attribute));
|
H A D | Cookie.h | 72 status_t RegisterRequest(RPC::Request* req); 73 status_t UnregisterRequest(RPC::Request* req);
|
H A D | FileSystem.cpp | 160 RequestBuilder& req = request.Builder(); local 162 req.PutRootFH(); 165 status_t result = _ParsePath(req, lookupCount, fsPath); 169 req.GetFH(); 170 req.Access(); 174 req.GetAttr(attr, sizeof(attr) / sizeof(Attribute)); 478 FileSystem::_ParsePath(RequestBuilder& req, uint32& count, const char* _path) argument 498 req.LookUpUp(); 501 req.LookUp(pathStart);
|
H A D | NFS4Object.cpp | 205 RequestBuilder& req = request.Builder(); local 207 req.PutFH(fh); 208 req.OpenConfirm(*sequence, state->fStateID, state->fStateSeq);
|
/haiku/src/add-ons/kernel/drivers/disk/virtual/nbd/ |
H A D | nbd.c | 77 struct nbd_request req; /* net byte order */ member in struct:nbd_request_entry 95 uint64 req; /* next ID for requests */ member in struct:nbd_device 111 status_t nbd_alloc_request(struct nbd_device *dev, struct nbd_request_entry **req, uint32 type, off_t from, size_t len, const char *data); 112 status_t nbd_queue_request(struct nbd_device *dev, struct nbd_request_entry *req); 113 status_t nbd_dequeue_request(struct nbd_device *dev, uint64 handle, struct nbd_request_entry **req); 114 status_t nbd_free_request(struct nbd_device *dev, struct nbd_request_entry *req); 121 status_t nbd_post_request(struct nbd_device *dev, struct nbd_request_entry *req); 169 status_t nbd_alloc_request(struct nbd_device *dev, struct nbd_request_entry **req, uint32 type, off_t from, size_t len, const char *data) argument 180 if (!dev || !req || from < 0) 189 handle = dev->req 230 nbd_queue_request(struct nbd_device *dev, struct nbd_request_entry *req) argument 239 nbd_dequeue_request(struct nbd_device *dev, uint64 handle, struct nbd_request_entry **req) argument 262 nbd_free_request(struct nbd_device *dev, struct nbd_request_entry *req) argument 278 struct nbd_request_entry *req = NULL; local 435 nbd_post_request(struct nbd_device *dev, struct nbd_request_entry *req) argument 626 struct nbd_request_entry *req; local 696 struct nbd_request_entry *req; local [all...] |
H A D | nbd-server.py | 106 req = nbd_request(asock) 107 if req.type == read_request: 108 asock.send(req.reply(error=0, 109 data=''.join(abuf[req.range()]))) 110 elif req.type == write_request: 111 abuf[req.range()] = req.data 112 afile.seek(req.offset) 113 afile.write(req.data) 115 asock.send(req [all...] |
/haiku/src/system/boot/platform/riscv/ |
H A D | virtio.cpp | 178 VirtioDevice::ScheduleIO(IORequest* req) argument 180 ScheduleIO(&req, 1); 190 IORequest* req = fReqs[fLastUsed % fQueueLen]; 192 req->state = ioStateDone; 201 return req; 278 IORequest* req = gKeyboardDev->ConsumeIO(); 279 if (req == NULL) 282 VirtioInputPacket &pkt = *(VirtioInputPacket*)req->buf; 288 free(req->buf); req [all...] |
/haiku/src/add-ons/kernel/drivers/network/wlan/atheroswifi/dev/ath/ |
H A D | if_ath_sysctl.c | 121 error = sysctl_handle_int(oidp, &slottime, 0, req); 122 if (error || !req->newptr) 147 error = sysctl_handle_int(oidp, &acktimeout, 0, req); 148 if (error || !req->newptr) 173 error = sysctl_handle_int(oidp, &ctstimeout, 0, req); 174 if (error || !req->newptr) 194 error = sysctl_handle_int(oidp, &softled, 0, req); 195 if (error || !req->newptr) 215 error = sysctl_handle_int(oidp, &ledpin, 0, req); 216 if (error || !req [all...] |
/haiku/src/libs/compat/freebsd_wlan/net80211/ |
H A D | ieee80211_ratectl.c | 92 error = sysctl_wire_old_buffer(req, 0); 97 sbuf_new_for_sysctl(&sb, NULL, 8, req);
|
/haiku/src/add-ons/kernel/drivers/network/wlan/ralinkwifi/dev/usb/wlan/ |
H A D | if_ural.c | 132 struct usb_device_request *req, void *data); 542 struct usb_device_request *req, void *data) 549 req, data, 0, NULL, 250 /* ms */); 1371 struct usb_device_request req; local 1374 req.bmRequestType = UT_WRITE_VENDOR_DEVICE; 1375 req.bRequest = RAL_VENDOR_REQUEST; 1376 USETW(req.wValue, 4); 1377 USETW(req.wIndex, 1); 1378 USETW(req.wLength, 0); 1380 error = ural_do_request(sc, &req, NUL 541 ural_do_request(struct ural_softc *sc, struct usb_device_request *req, void *data) argument 1390 struct usb_device_request req; local 1409 struct usb_device_request req; local 1432 struct usb_device_request req; local 1451 struct usb_device_request req; local 1470 struct usb_device_request req; local [all...] |