From 61b3aaaa0791ca6ac327de6c44a107b99ce78926 Mon Sep 17 00:00:00 2001
From: Max Kellermann <max@duempel.org>
Date: Mon, 6 Oct 2014 09:01:46 +0200
Subject: lib/nfs/Connection: add method Stat(path)

---
 src/lib/nfs/Connection.cxx | 30 ++++++++++++++++++++++++++++++
 1 file changed, 30 insertions(+)

(limited to 'src/lib/nfs/Connection.cxx')

diff --git a/src/lib/nfs/Connection.cxx b/src/lib/nfs/Connection.cxx
index e5dc87727..33e75a7c5 100644
--- a/src/lib/nfs/Connection.cxx
+++ b/src/lib/nfs/Connection.cxx
@@ -34,6 +34,21 @@ extern "C" {
 
 #include <poll.h> /* for POLLIN, POLLOUT */
 
+inline bool
+NfsConnection::CancellableCallback::Stat(nfs_context *ctx,
+					 const char *path,
+					 Error &error)
+{
+	int result = nfs_stat_async(ctx, path, Callback, this);
+	if (result < 0) {
+		error.Format(nfs_domain, "nfs_stat_async() failed: %s",
+			     nfs_get_error(ctx));
+		return false;
+	}
+
+	return true;
+}
+
 inline bool
 NfsConnection::CancellableCallback::Open(nfs_context *ctx,
 					 const char *path, int flags,
@@ -176,6 +191,21 @@ NfsConnection::RemoveLease(NfsLease &lease)
 	active_leases.remove(&lease);
 }
 
+bool
+NfsConnection::Stat(const char *path, NfsCallback &callback, Error &error)
+{
+	assert(!callbacks.Contains(callback));
+
+	auto &c = callbacks.Add(callback, *this, false);
+	if (!c.Stat(context, path, error)) {
+		callbacks.Remove(c);
+		return false;
+	}
+
+	ScheduleSocket();
+	return true;
+}
+
 bool
 NfsConnection::Open(const char *path, int flags, NfsCallback &callback,
 		    Error &error)
-- 
cgit v1.2.3