MClientLock

diff --git a/src/messages/MClientLock.h b/src/messages/MClientLock.h
new file mode 100644 (file)
index 0000000..e0312cf
--- /dev/null
+++ b/src/messages/MClientLock.h
@@ -0,0 +1,79 @@
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- 
+// vim: ts=8 sw=2 smarttab
+/*
+ * Ceph - scalable distributed file system
+ *
+ * Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
+ *
+ * This is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License version 2.1, as published by the Free Software 
+ * Foundation.  See file COPYING.
+ * 
+ */
+
+
+#ifndef __MCLIENTLOCK_H
+#define __MCLIENTLOCK_H
+
+#include "msg/Message.h"
+#include "mds/SimpleLock.h"
+
+static const char *get_clientlock_action_name(int a) {
+  switch (a) {
+  case CEPH_MDS_LOCK_REVOKE: return "revoke";
+  case CEPH_MDS_LOCK_RELEASE: return "release";
+  case CEPH_MDS_LOCK_RENEW: return "renew";
+  default: assert(0); return 0;
+  }
+}
+
+
+struct MClientLock : public Message {
+  __u8 lock_type;
+  __u8 action;
+  __u64 ino;
+  string dname;
+
+  MClientLock(int l, int ac, __u64 i) :
+    Message(CEPH_MSG_CLIENT_LOCK),
+    lock(l), actiong(ac), ino(i) {}
+  MClientLock(int l, int ac, __u64 i, const string& d) :
+    Message(CEPH_MSG_CLIENT_LOCK),
+    lock(l), actiong(ac), ino(i), dname(d) {}
+  MClientLock(SimpleLock *lock, int ac, __u64 i) :
+    Message(CEPH_MSG_CLIENT_LOCK),
+    lock_type(lock->get_type()),
+    action(ac), ino(i) {}
+  MClientLock(SimpleLock *lock, int ac, __u64 i, const string& d) :
+    Message(CEPH_MSG_CLIENT_LOCK),
+    lock_type(lock->get_type()),
+    action(ac), ino(i), dname(d) {}
+
+  const char *get_type_name() { return "client_lock"; }
+  void print(ostream& out) {
+    out << "lock(a=" << get_clientlock_action_name(action)
+       << " " << get_lock_type_name(lock_type)
+       << " " << ino;
+    if (dname.length())
+      out << "/" << dname;
+    << ")";
+  }
+  
+  void decode_payload() {
+    int off = 0;
+    ::_decode(lock_type, payload, off);
+    ::_decode(action, payload, off);
+    ::_decode(ino, payload, off);
+    ::_decode(dname, payload, off);
+  }
+  virtual void encode_payload() {
+    ::_encode(lock_type, payload);
+    ::_encode(action, payload);
+    ::_encode(ino, payload);
+    ::_encode(dname, payload);
+  }
+
+};
+
+#endif