SRCS=*.cc */*.cc
OBJS=osd/OSD.o\
- Messenger.o\
- Logger.o\
+ msg/Messenger.o\
mds/MDBalancer.o\
mds/MDS.o\
mds/CDentry.o\
mds/CInode.o\
mds/MDCache.o\
mds/MDStore.o\
- clock.o\
mds/LogStream.o\
mds/IdAllocator.o\
mds/MDLog.o\
- client/Client.o\
mds/MDCluster.o\
+ client/Client.o\
+ Logger.o\
+ clock.o\
config.o
TARGETS=test import pmds
all: depend ${TARGETS}
-test: test.cc FakeMessenger.o pmds.o
+test: test.cc msg/FakeMessenger.o pmds.o
test ! -e leak.out || rm leak.out
- ${CC} ${CFLAGS} ${LIBS} pmds.o FakeMessenger.o ${LEAKTRACER} test.cc -o test
+ ${CC} ${CFLAGS} ${LIBS} pmds.o msg/FakeMessenger.o ${LEAKTRACER} test.cc -o test
-import: pmds.o FakeMessenger.o import.cc
- ${CC} ${CFLAGS} ${LIBS} pmds.o FakeMessenger.o import.cc ${LEAKTRACER} -o import
+import: pmds.o msg/FakeMessenger.o import.cc
+ ${CC} ${CFLAGS} ${LIBS} pmds.o msg/FakeMessenger.o import.cc ${LEAKTRACER} -o import
-pmds: mpitest.cc MPIMessenger.cc pmds.o
- ${MPICC} ${MPICFLAGS} ${MPILIBS} mpitest.cc MPIMessenger.cc pmds.o -o pmds
+pmds: mpitest.cc msg/MPIMessenger.cc pmds.o
+ ${MPICC} ${MPICFLAGS} ${MPILIBS} mpitest.cc msg/MPIMessenger.cc pmds.o -o pmds
clean:
+CLIENT
+- structure.. multithreaded until messenger
+
+
+
+MDS
- qsync
- high level locker functions
- expand Lock
#include "include/types.h"
-#include "include/Messenger.h"
-#include "include/Message.h"
+
+#include "msg/Messenger.h"
+#include "msg/Message.h"
#include "mds/MDS.h"
#include "mds/MDCluster.h"
#ifndef __CLIENT_H
#define __CLIENT_H
-#include "../include/Dispatcher.h"
-#include "../include/lru.h"
+#include "msg/Dispatcher.h"
+#include "include/lru.h"
#include "ClNode.h"
#include <map>
#include "CDentry.h"
#include "MDS.h"
-#include "include/Message.h"
+#include "msg/Message.h"
#include "messages/MInodeSyncStart.h"
#include <string>
#include "MDCache.h"
#include "messages/MHeartbeat.h"
-
-#include "include/Messenger.h"
+#include "msg/Messenger.h"
#include "include/Context.h"
#include <vector>
#include "include/filepath.h"
-#include "include/Message.h"
-#include "include/Messenger.h"
+#include "msg/Message.h"
+#include "msg/Messenger.h"
#include "events/EInodeUpdate.h"
#include "events/EInodeUnlink.h"
#include "include/LogType.h"
#include "include/Logger.h"
-#include "include/Message.h"
+#include "msg/Message.h"
LogType mdlog_logtype;
#include "include/types.h"
-#include "include/Messenger.h"
#include "include/Clock.h"
+#include "msg/Messenger.h"
+
#include "MDS.h"
#include "MDCache.h"
#include "MDStore.h"
#include <ostream>
#include <ext/rope>
+#include "msg/Dispatcher.h"
#include "include/types.h"
#include "include/Context.h"
-#include "include/Dispatcher.h"
#include "include/DecayCounter.h"
#include "include/Logger.h"
#include "CDentry.h"
#include "MDCluster.h"
-#include "include/Message.h"
+#include "msg/Message.h"
#include <cassert>
#include <iostream>
#ifndef __MCLIENTREPLY_H
#define __MCLIENTREPLY_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include "mds/CInode.h"
#include <vector>
#ifndef __MCLIENTREQUEST_H
#define __MCLIENTREQUEST_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include "include/filepath.h"
#include "mds/MDS.h"
#ifndef __MDIRSYNCACK_H
#define __MDIRSYNCACK_H
-#include "include/Message.h"
+#include "msg/Message.h"
class MDirSyncAck : public Message {
inodeno_t ino;
#ifndef __MDIRSYNCRELEASE_H
#define __MDIRSYNCRELEASE_H
-#include "include/Message.h"
+#include "msg/Message.h"
class MDirSyncRelease : public Message {
inodeno_t ino;
#ifndef __MDIRSYNCSTART_H
#define __MDIRSYNCSTART_H
-#include "include/Message.h"
+#include "msg/Message.h"
class MDirSyncStart : public Message {
inodeno_t ino;
#ifndef __MDIRUPDATE_H
#define __MDIRUPDATE_H
-#include "include/Message.h"
+#include "msg/Message.h"
typedef struct {
inodeno_t ino;
#ifndef __MDISCOVER_H
#define __MDISCOVER_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include "mds/CDir.h"
#include "include/filepath.h"
#ifndef __MDISCOVERREPLY_H
#define __MDISCOVERREPLY_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include "mds/CDir.h"
#include "mds/CInode.h"
#include "include/filepath.h"
#ifndef __MEXPORTDIR_H
#define __MEXPORTDIR_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include <ext/rope>
using namespace std;
#ifndef __MEXPORTDIRDISCOVER_H
#define __MEXPORTDIRDISCOVER_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include "mds/CInode.h"
#include "include/types.h"
#ifndef __MEXPORTDIRDISCOVERACK_H
#define __MEXPORTDIRDISCOVERACK_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include "mds/CInode.h"
#include "include/types.h"
#ifndef __MEXPORTDIRNOTIFY_H
#define __MEXPORTDIRNOTIFY_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include <string>
using namespace std;
#ifndef __MEXPORTDIRNOTIFYACK_H
#define __MEXPORTDIRNOTIFYACK_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include <string>
using namespace std;
#ifndef __MEXPORTDIRPREP_H
#define __MEXPORTDIRPREP_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include "mds/CInode.h"
#include "include/types.h"
#ifndef __MEXPORTDIRPREPACK_H
#define __MEXPORTDIRPREPACK_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include "include/types.h"
class MExportDirPrepAck : public Message {
#ifndef __MEXPORTDIRWARNING_H
#define __MEXPORTDIRWARNING_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include "mds/CInode.h"
#include "include/types.h"
#ifndef __MHASHDIR_H
#define __MHASHDIR_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include <ext/rope>
using namespace std;
#ifndef __MHEARTBEAT_H
#define __MHEARTBEAT_H
-#include "include/Message.h"
#include "include/types.h"
+#include "msg/Message.h"
class MHeartbeat : public Message {
mds_load_t load;
#ifndef __MINODELOCKACK_H
#define __MINODELOCKACK_H
-#include "include/Message.h"
+#include "msg/Message.h"
class MInodeLockAck : public Message {
inodeno_t ino;
#ifndef __MINODELOCKRELEASE_H
#define __MINODELOCKRELEASE_H
-#include "include/Message.h"
+#include "msg/Message.h"
class MInodeLockRelease : public Message {
inode_t inode;
#ifndef __MINODELOCKSTART_H
#define __MINODELOCKSTART_H
-#include "include/Message.h"
+#include "msg/Message.h"
class MInodeLockStart : public Message {
inodeno_t ino;
#ifndef __MINODESYNCACK_H
#define __MINODESYNCACK_H
-#include "include/Message.h"
+#include "msg/Message.h"
class MInodeSyncAck : public Message {
inodeno_t ino;
#ifndef __MINODESYNCRECALL_H
#define __MINODESYNCRECALL_H
-#include "include/Message.h"
+#include "msg/Message.h"
class MInodeSyncRecall : public Message {
inodeno_t ino;
#ifndef __MINODESYNCRELEASE_H
#define __MINODESYNCRELEASE_H
-#include "include/Message.h"
+#include "msg/Message.h"
class MInodeSyncRelease : public Message {
inode_t inode;
#ifndef __MINODESYNCSTART_H
#define __MINODESYNCSTART_H
-#include "include/Message.h"
+#include "msg/Message.h"
class MInodeSyncStart : public Message {
inodeno_t ino;
#ifndef __MINODEUPDATE_H
#define __MINODEUPDATE_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include <set>
using namespace std;
#ifndef __MLOCK_H
#define __MLOCK_H
-#include "include/Message.h"
+#include "msg/Message.h"
#define LOCK_OTYPE_INO 1
#define LOCK_OTYPE_DIRINO 2
#ifndef __MOSDREAD_H
#define __MOSDREAD_H
-#include "include/Message.h"
+#include "msg/Message.h"
typedef struct {
long tid;
#ifndef __MOSDWRITE_H
#define __MOSDWRITE_H
-#include "include/Message.h"
+#include "msg/Message.h"
typedef struct {
long tid;
#ifndef __MPING_H
#define __MPING_H
-#include "../include/Message.h"
+#include "msg/Message.h"
class MPing : public Message {
public:
#ifndef __MUNHASHDIR_H
#define __MUNHASHDIR_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include <ext/rope>
using namespace std;
#ifndef __MUNHASHDIRACK_H
#define __MUNHASHDIRACK_H
-#include "include/Message.h"
+#include "msg/Message.h"
#include <ext/rope>
using namespace std;
using namespace std;
-#include "include/FakeMessenger.h"
+#include "Message.h"
+#include "FakeMessenger.h"
#include "mds/MDS.h"
#include "include/LogType.h"
#include "include/Logger.h"
-#include "include/Message.h"
#include <stdio.h>
#include <stdlib.h>
#include "include/config.h"
-#include "include/MPIMessenger.h"
-#include "include/Message.h"
+#include "MPIMessenger.h"
+#include "Message.h"
#include <iostream>
#include <cassert>
#define MSG_MDS_SHUTDOWNSTART 900
#define MSG_MDS_SHUTDOWNFINISH 901
-#include "config.h"
+//#include "config.h"
// address types
#include <ext/rope>
#include "include/types.h"
#include "include/config.h"
-#include "include/Message.h"
-#include "include/Messenger.h"
+
+#include "Message.h"
+#include "Messenger.h"
+
#include <cassert>
#include <iostream>
using namespace std;
#include "include/types.h"
-#include "include/Messenger.h"
-#include "include/Message.h"
#include "OSD.h"
+#include "msg/Messenger.h"
+#include "msg/Message.h"
+
#include "messages/MOSDRead.h"
#include "messages/MOSDReadReply.h"
#include "messages/MOSDWrite.h"
#ifndef __OSD_H
#define __OSD_H
-#include "include/Dispatcher.h"
+#include "msg/Dispatcher.h"
class Messenger;
class MOSDRead;
#include <iostream>
#include <string>
-#include "mds/MDCluster.h"
#include "mds/MDS.h"
#include "osd/OSD.h"
#include "client/Client.h"
+#include "mds/MDCluster.h"
#include "mds/MDCache.h"
#include "mds/MDStore.h"
-#include "include/FakeMessenger.h"
+#include "msg/FakeMessenger.h"
#include "messages/MPing.h"
#include "mds/MDCache.h"
#include "mds/MDStore.h"
-#include "include/MPIMessenger.h"
+#include "msg/MPIMessenger.h"
#include "messages/MPing.h"