Merge branch 'io-uring-madvise' into 'master'

[IO] add a madvise Future

See merge request !206

emper/io/Future.hpp

@@ -112,6 +112,11 @@ class Future : public Logger<LogSubsystem::IO> {
 
 	virtual void prepareSqe(io_uring_sqe* sqe) = 0;
 
+	void submitAndForget() {
+		state.forgotten = true;
+		submit();
+	}
+
 	void setCompletion(int32_t res) {
 		assert(!state.completed);
 		LOGD("Complete " << this);
@@ -578,10 +583,7 @@ class CloseFuture : public Future {
  public:
 	CloseFuture(int fildes) : Future(Operation::CLOSE, fildes, nullptr, 0, 0){};
 
-	void submitAndForget() {
-		state.forgotten = true;
-		submit();
-	}
+	void submitAndForget() { Future::submitAndForget(); }
 };
 
 /*
@@ -647,4 +649,17 @@ class CancelWrapper : public Future {
  public:
 	CancelWrapper(Future& future) : Future(Operation::CANCEL, 0, &future, 0, 0){};
 };
+
+/*
+ * @brief Request a madvise operation
+ */
+class MadviseFuture : public Future {
+	void prepareSqe(io_uring_sqe* sqe) override { io_uring_prep_madvise(sqe, buf, len, flags); }
+
+ public:
+	MadviseFuture(void* addr, size_t len, int advise)
+			: Future(Operation::MADVISE, 0, addr, len, advise){};
+
+	void submitAndForget() { Future::submitAndForget(); }
+};
 }	 // namespace emper::io

emper/io/Operation.cpp

@@ -44,6 +44,9 @@ auto operator<<(std::ostream& os, const Operation& op) -> std::ostream& {
 		case Operation::CANCEL:
 			os << "cancel";
 			break;
+		case Operation::MADVISE:
+			os << "madvise";
+			break;
 		default:
 			abort();
 	}

emper/io/Operation.hpp

@@ -19,6 +19,7 @@ enum class Operation {
 	LINK_TIMEOUT,
 	TIMEOUT,
 	CANCEL,
+	MADVISE,
 	NUMBER_OF_OPERATIONS
 };