From 5369c4d5ac882c9b255f02c81c361af2e920feb7 Mon Sep 17 00:00:00 2001 From: sage Date: Fri, 25 Aug 2006 02:44:31 +0000 Subject: [PATCH] *** empty log message *** git-svn-id: https://ceph.svn.sf.net/svnroot/ceph@816 29311d96-e01e-0410-9327-a35deaab8ce9 --- ceph/messages/MOSDIn.h | 42 +++++++++++++++++++++++++++++++++++++++++ ceph/messages/MOSDOut.h | 42 +++++++++++++++++++++++++++++++++++++++++ 2 files changed, 84 insertions(+) create mode 100644 ceph/messages/MOSDIn.h create mode 100644 ceph/messages/MOSDOut.h diff --git a/ceph/messages/MOSDIn.h b/ceph/messages/MOSDIn.h new file mode 100644 index 0000000000000..264e000feda6e --- /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 + * + * 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 index 0000000000000..464d13b32fd55 --- /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 + * + * 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 -- 2.39.5