*** empty log message ***

git-svn-id: https://ceph.svn.sf.net/svnroot/ceph@816 29311d96-e01e-0410-9327-a35deaab8ce9

diff --git a/ceph/messages/MOSDIn.h b/ceph/messages/MOSDIn.h
new file mode 100644 (file)
index 0000000..264e000
--- /dev/null
+++ b/ceph/messages/MOSDIn.h
@@ -0,0 +1,42 @@
+// -*- mode:C++; tab-width:4; c-basic-offset:2; indent-tabs-mode:t -*- 
+/*
+ * 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 __MOSDIN_H
+#define __MOSDIN_H
+
+#include "msg/Message.h"
+
+
+class MOSDIn : public Message {
+ public:
+  epoch_t map_epoch;
+
+  MOSDIn(epoch_t e) : Message(MSG_OSD_IN), map_epoch(e) {
+  }
+  MOSDIn() {}
+
+  virtual void decode_payload() {
+       int off = 0;
+       payload.copy(off, sizeof(map_epoch), (char*)&map_epoch);
+       off += sizeof(map_epoch);
+  }
+  virtual void encode_payload() {
+       payload.append((char*)&map_epoch, sizeof(map_epoch));
+  }
+
+  virtual char *get_type_name() { return "oin"; }
+};
+
+#endif

diff --git a/ceph/messages/MOSDOut.h b/ceph/messages/MOSDOut.h
new file mode 100644 (file)
index 0000000..464d13b
--- /dev/null
+++ b/ceph/messages/MOSDOut.h
@@ -0,0 +1,42 @@
+// -*- mode:C++; tab-width:4; c-basic-offset:2; indent-tabs-mode:t -*- 
+/*
+ * 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 __MOSDOUT_H
+#define __MOSDOUT_H
+
+#include "msg/Message.h"
+
+
+class MOSDOut : public Message {
+ public:
+  epoch_t map_epoch;
+
+  MOSDOut(epoch_t e) : Message(MSG_OSD_OUT), map_epoch(e) {
+  }
+  MOSDOut() {}
+
+  virtual void decode_payload() {
+       int off = 0;
+       payload.copy(off, sizeof(map_epoch), (char*)&map_epoch);
+       off += sizeof(map_epoch);
+  }
+  virtual void encode_payload() {
+       payload.append((char*)&map_epoch, sizeof(map_epoch));
+  }
+
+  virtual char *get_type_name() { return "oout"; }
+};
+
+#endif