Method read_impl

fdbrpc/include/fdbrpc/AsyncFileEIO.actor.h:332–359

	}

	ACTOR static Future<int> read_impl(int fd, void* data, int length, int64_t offset) {
		state TaskPriority taskID = g_network->getCurrentTask();
		state Promise<Void> p;
		// fprintf(stderr, "eio_read (fd=%d length=%d offset=%lld)\n", fd, length, offset);
		state eio_req* r = eio_read(fd, data, length, offset, 0, eio_callback, &p);
		try {
			wait(p.getFuture());
		} catch (...) {
			g_network->setCurrentTask(taskID);
			eio_cancel(r);
			throw;
		}
		try {
			state int result = r->result;
			// printf("eio read: %d/%d\n", r->result, length);
			if (result == -1) {
				error("ReadError", fd, r);
				throw internal_error();
			} else {
				wait(delay(0, taskID));
				return result;
			}
		} catch (Error& _e) {
			state Error e = _e;
			wait(delay(0, taskID));
			throw e;
		}
	}

	ACTOR static Future<Void> write_impl(int fd, Reference<ErrorInfo> err, StringRef data, int64_t offset) {
		state TaskPriority taskID = g_network->getCurrentTask();