/fuchsia/zircon/system/dev/block/block/ |
H A D | server.cpp | 307 void BlockServer::ProcessRequest(block_fifo_request_t* request) { argument 308 reqid_t reqid = request->reqid; 309 groupid_t group = request->group; 310 vmoid_t vmoid = request->vmoid; 312 switch (request->opcode & BLOCKIO_OP_MASK) { 326 if ((request->length < 1) || 327 (request->length > fbl::numeric_limits<uint32_t>::max())) { 337 zx_status_t status = iobuf->ValidateVmoHack(bsz * request->length, 338 bsz * request->vmo_offset); 354 msg.op()->command = OpcodeToCommand(request [all...] |
/fuchsia/zircon/system/ulib/blobfs/ |
H A D | common.cpp | 190 extend_request_t request; local 191 request.length = 1; 192 request.offset = kFVMBlockMapStart / kBlocksPerSlice; 193 if (ioctl_block_fvm_extend(fd, &request) < 0) { 197 request.offset = kFVMNodeMapStart / kBlocksPerSlice; 198 if (ioctl_block_fvm_extend(fd, &request) < 0) { 202 request.offset = kFVMDataStart / kBlocksPerSlice; 203 request.length = fbl::round_up(kMinimumDataBlocks, kBlocksPerSlice) / kBlocksPerSlice; 204 if (ioctl_block_fvm_extend(fd, &request) < 0) { 211 info.dat_slices = static_cast<uint32_t>(request [all...] |
/fuchsia/zircon/system/utest/fs/ |
H A D | filesystems.cpp | 110 alloc_req_t request; local 111 memset(&request, 0, sizeof(request)); 112 request.slice_count = 1; 113 strcpy(request.name, "fs-test-partition"); 114 memcpy(request.type, kTestPartGUID, sizeof(request.type)); 115 memcpy(request.guid, kTestUniqueGUID, sizeof(request.guid)); 117 if ((fd = fvm_allocate_partition(fvm_fd, &request)) < [all...] |
/fuchsia/zircon/system/host/fidl/lib/ |
H A D | c_generator.cpp | 183 const std::vector<CGenerator::Member>& request, 186 for (const auto& member : request) { 198 const std::vector<CGenerator::Member>& request, 201 for (const auto& member : request) { 284 const std::vector<CGenerator::Member>& request) { 285 if (CountSecondaryObjects(request) > 0) 287 for (const auto& member : request) { 507 std::vector<CGenerator::Member>* request, 509 if (request) { 510 request 182 EmitClientMethodDecl(std::ostream* file, StringView method_name, const std::vector<CGenerator::Member>& request, const std::vector<CGenerator::Member>& response) argument 197 EmitServerMethodDecl(std::ostream* file, StringView method_name, const std::vector<CGenerator::Member>& request, bool has_response) argument 281 EmitLinearizeMessage(std::ostream* file, StringView receiver, StringView bytes, const std::vector<CGenerator::Member>& request) argument 505 GetMethodParameters(const flat::Library* library, const CGenerator::NamedMethod& method_info, std::vector<CGenerator::Member>* request, std::vector<CGenerator::Member>* response) argument 872 std::vector<Member> request; local 886 std::vector<Member> request; local 1078 std::vector<Member> request; local 1122 std::vector<Member> request; local [all...] |
/fuchsia/zircon/system/uapp/disk-pave/ |
H A D | pave-lib.cpp | 106 size_t block_size, block_fifo_request_t* request) { 141 request->length = static_cast<uint32_t>(length); 142 request->vmo_offset = 0; 143 request->dev_offset = offset / block_size; 146 if ((r = client.Transaction(request, 1)) != ZX_OK) { 167 request->length = static_cast<uint32_t>(length); 168 request->vmo_offset = 0; 169 request->dev_offset = offset / block_size; 172 if ((status = client.Transaction(request, 1)) != ZX_OK) { 177 offset += request 104 StreamFvmPartition(fvm::SparseReader* reader, PartitionInfo* part, fzl::MappedVmo* mvmo, const block_client::Client& client, size_t block_size, block_fifo_request_t* request) argument 232 block_fifo_request_t request; local 640 extend_request_t request; local 766 block_fifo_request_t request; local [all...] |
/fuchsia/zircon/system/utest/ramdisk/ |
H A D | ramdisk.cpp | 410 block_fifo_request_t request; local 411 request.group = group; 412 request.vmoid = vmoid; 413 request.opcode = BLOCKIO_WRITE; 414 request.length = 1; 415 request.vmo_offset = 0; 416 request.dev_offset = 0; 419 block_fifo_request_t* request; member in struct:tests::thread_args 428 while ((status = ta->client->Transaction(ta->request, 1)) == ZX_OK) {} 433 args.request 763 block_fifo_request_t request; local 1144 block_fifo_request_t request; local 1179 block_fifo_request_t request; local 1217 block_fifo_request_t request; local 1291 block_fifo_request_t request; local [all...] |
/fuchsia/zircon/system/ulib/minfs/ |
H A D | minfs.cpp | 50 extend_request_t request; local 53 request.length = info->ibm_slices; 54 request.offset = kFVMBlockInodeBmStart / kBlocksPerSlice; 55 bc->FVMShrink(&request); 58 request.length = info->abm_slices; 59 request.offset = kFVMBlockDataBmStart / kBlocksPerSlice; 60 bc->FVMShrink(&request); 63 request.length = info->ino_slices; 64 request.offset = kFVMBlockInodeStart / kBlocksPerSlice; 65 bc->FVMShrink(&request); 138 query_request_t request; local 832 extend_request_t request; local [all...] |
/fuchsia/zircon/system/dev/ethernet/usb-cdc-ecm/ |
H A D | usb-cdc-ecm.c | 226 static void usb_write_complete(usb_request_t* request, void* cookie) { argument 229 if (request->response.status == ZX_ERR_IO_NOT_PRESENT) { 230 usb_req_release(&ctx->usb, request); 237 list_add_tail(&ctx->tx_txn_bufs, &request->node); 239 if (request->response.status == ZX_ERR_IO_REFUSED) { 244 if (request->response.status == ZX_ERR_IO_INVALID) { 279 static void usb_recv(ecm_ctx_t* ctx, usb_request_t* request) { argument 280 size_t len = request->response.actual; 283 zx_status_t status = usb_req_mmap(&ctx->usb, request, (void*)&read_data); 297 static void usb_read_complete(usb_request_t* request, voi argument 368 ecm_interrupt_complete(usb_request_t* request, void* cookie) argument 373 ecm_handle_interrupt(ecm_ctx_t* ctx, usb_request_t* request) argument [all...] |
/fuchsia/zircon/system/dev/usb/xhci/ |
H A D | xhci-transfer.h | 16 int xhci_control_request(xhci_t* xhci, uint32_t slot_id, uint8_t request_type, uint8_t request,
|
H A D | xdc.h | 9 #include <ddk/usb-request/usb-request.h> 43 usb_request_t* current_req; // request currently being processed
|
/fuchsia/zircon/system/core/crashanalyzer/ |
H A D | crashanalyzer.cpp | 359 auto* request = message.GetBytesAs<fuchsia_crash_AnalyzerAnalyzeRequest>(); local 368 response.hdr.txid = request->hdr.txid; 369 response.hdr.ordinal = request->hdr.ordinal; 372 process_report(request->process, request->thread, use_libunwind); 385 auto* request = message.GetBytesAs<fuchsia_crash_AnalyzerProcessRequest>(); local 386 zx_handle_close(request->crashlog.vmo); 442 zx_handle_t request) { 444 auto wait = new async::Wait(request, 451 zx_handle_close(request); 441 connect(void* ctx, async_dispatcher_t* dispatcher, const char* service_name, zx_handle_t request) argument [all...] |
/fuchsia/zircon/system/dev/serial/ftdi/ |
H A D | ftdi.c | 78 static void ftdi_read_complete(usb_request_t* request, void* cookie) { argument 81 if (request->response.status == ZX_ERR_IO_NOT_PRESENT) { 83 usb_req_release(&ftdi->usb, request); 88 if ((request->response.status == ZX_OK) && (request->response.actual > 2)) { 89 list_add_tail(&ftdi->completed_reads, &request->node); 92 usb_request_queue(&ftdi->usb, request); 97 static void ftdi_write_complete(usb_request_t* request, void* cookie) { argument 100 if (request->response.status == ZX_ERR_IO_NOT_PRESENT) { 101 usb_req_release(&ftdi->usb, request); [all...] |
/fuchsia/zircon/system/dev/block/fvm/ |
H A D | fvm.cpp | 565 // Remove device, VPartition if this was a request to free all slices. 656 const alloc_req_t* request = static_cast<const alloc_req_t*>(cmd); 658 if (request->slice_count >= fbl::numeric_limits<uint32_t>::max()) { 660 } else if (request->slice_count == 0) { 678 entry->init(request->type, request->guid, 679 static_cast<uint32_t>(request->slice_count), 680 request->name, request->flags & kVPartAllocateMask); 683 request [all...] |
/fuchsia/zircon/system/dev/usb/dwc2/ |
H A D | rules.mk | 17 system/dev/lib/usb-request \
|
/fuchsia/zircon/system/dev/usb/dwc3/ |
H A D | rules.mk | 21 system/dev/lib/usb-request \
|
/fuchsia/zircon/system/dev/usb/usb-bus/ |
H A D | rules.mk | 20 system/dev/lib/usb-request \
|
/fuchsia/zircon/system/dev/usb/usb-hub/ |
H A D | rules.mk | 15 system/dev/lib/usb-request \
|
/fuchsia/zircon/system/core/svchost/ |
H A D | svchost.cpp | 48 fbl::MakeRefCounted<fs::Service>([instance, dispatcher, service_name](zx::channel request) { 49 return instance->provider->ops->connect(instance->ctx, dispatcher, service_name, request.release()); 89 // We should host the tracelink service ourselves instead of routing the request 95 fbl::MakeRefCounted<fs::Service>([service_name](zx::channel request) { 96 return fdio_service_connect_at(appmgr_svc, service_name, request.release()); 136 fbl::MakeRefCounted<fs::Service>([service_name](zx::channel request) { 137 return fdio_service_connect_at(appmgr_svc, service_name, request.release());
|
/fuchsia/zircon/system/dev/ethernet/rndis/ |
H A D | rndishost.c | 118 static void rndis_read_complete(usb_request_t* request, void* cookie) { argument 122 if (request->response.status == ZX_ERR_IO_NOT_PRESENT) { 123 usb_req_release(ð->usb, request); 128 if (request->response.status == ZX_ERR_IO_REFUSED) { 131 } else if (request->response.status == ZX_ERR_IO_INVALID) { 139 if ((request->response.status == ZX_OK) && eth->ifc) { 140 size_t len = request->response.actual; 143 zx_status_t status = usb_req_mmap(ð->usb, request, (void*)&read_data); 155 usb_request_queue(ð->usb, request); 160 static void rndis_write_complete(usb_request_t* request, voi argument [all...] |
/fuchsia/zircon/system/ulib/fs-test-utils/ |
H A D | fixture.cpp | 162 alloc_req_t request; local 163 memset(&request, 0, sizeof(request)); 164 request.slice_count = 1; 165 strcpy(request.name, kFsPartitionName); 166 memcpy(request.type, kTestPartGUID, sizeof(request.type)); 167 memcpy(request.guid, kTestUniqueGUID, sizeof(request.guid)); 169 fbl::unique_fd partition_fd(fvm_allocate_partition(fvm_fd.get(), &request)); [all...] |
/fuchsia/zircon/system/dev/ethernet/asix-88179/ |
H A D | asix-88179.c | 65 // interrupt in request 75 // Whether a request has been queued to the USB device. 79 // request from free_write_reqs must be added to the list. 234 static zx_status_t ax88179_recv(ax88179_t* eth, usb_request_t* request) { argument 235 zxlogf(SPEW, "request len %" PRIu64"\n", request->response.actual); 237 if (request->response.actual < 4) { 243 zx_status_t status = usb_req_mmap(ð->usb, request, (void*)&read_data); 249 ptrdiff_t rxhdr_off = request->response.actual - sizeof(ax88179_rx_hdr_t); 311 static void ax88179_read_complete(usb_request_t* request, voi argument 358 ax88179_write_complete(usb_request_t* request, void* cookie) argument 415 ax88179_interrupt_complete(usb_request_t* request, void* cookie) argument 420 ax88179_handle_interrupt(ax88179_t* eth, usb_request_t* request) argument [all...] |
/fuchsia/zircon/system/ulib/block-client/ |
H A D | client.c | 15 static zx_status_t do_write(zx_handle_t fifo, block_fifo_request_t* request, size_t count) { argument 19 status = zx_fifo_write(fifo, sizeof(block_fifo_request_t), request, count, &actual); 32 request += actual;
|
/fuchsia/zircon/system/dev/audio/intel-hda/dsp/ |
H A D | intel-dsp-ipc.cpp | 39 dsp_.SendIpcMessage(txn.request); 97 txn->request.primary = IPC_PRI(MsgTarget::MODULE_MSG, MsgDir::MSG_REQUEST, 99 txn->request.extension = IPC_LARGE_CONFIG_EXT(true, false, large_param_id, data_off_size); 226 // Check if the reply matches the pending request. 227 IpcMessage* req = &pending.request; 262 ZX_DEBUG_ASSERT_MSG(txn->request.large_param_id() == txn->reply.large_param_id(), 264 txn->request.large_param_id(), txn->reply.large_param_id());
|
H A D | intel-dsp-ipc.h | 31 : request(pri, ext), tx_data(tx), tx_size(txs), rx_data(rx), rx_size(rxs) { } 39 IpcMessage request; member in class:audio::intel_hda::IntelDspIpc::Txn
|
/fuchsia/zircon/system/ulib/trace-provider/ |
H A D | provider_impl.cpp | 129 auto request = reinterpret_cast<fuchsia_tracelink_ProviderStartRequest*>(buffer); local 130 auto buffering_mode = request->buffering_mode; 131 auto buffer = zx::vmo(request->buffer); 132 auto fifo = zx::fifo(request->fifo); 134 auto strings = reinterpret_cast<fidl_string_t*>(request->categories.data); 135 for (size_t i = 0; i < request->categories.count; i++) {
|