From 26bb069c535e3fd5b0e0fb28fb54a2a540b60a84 Mon Sep 17 00:00:00 2001
From: Mike Buland <eichlan@xagasoft.com>
Date: Fri, 18 Feb 2011 17:41:24 +0000
Subject: Some Uuid tweaks, not much, just figuring out the format.  MyriadFs
 is coming along quite nicely.  It looks like it works great for normal
 programs, but there need to be some tweaks made to a few things before it's
 working 100% via fuse.

Also, the fuse module won't let you specify a file, a little odd.
---
 src/tools/myriadfs.cpp | 124 ++++++++++++++++++++++++++++++++++++++++++++++++-
 1 file changed, 122 insertions(+), 2 deletions(-)

(limited to 'src/tools/myriadfs.cpp')

diff --git a/src/tools/myriadfs.cpp b/src/tools/myriadfs.cpp
index 88db0c0..3956311 100644
--- a/src/tools/myriadfs.cpp
+++ b/src/tools/myriadfs.cpp
@@ -10,36 +10,156 @@
 #include <fuse.h>
 
 #include <string.h>
+#include <errno.h>
+
+#include <bu/file.h>
+#include <bu/myriadfs.h>
+#include <bu/myriadstream.h>
+#include <bu/hash.h>
+
+Bu::File *pF = NULL;
+Bu::MyriadFs *pFs = NULL;
+
+typedef Bu::Hash<int64_t, Bu::MyriadStream> FileHash;
+FileHash hOpenFiles;
+int64_t iNextFileId = 0;
 
 extern "C" {
 	static int myriadfs_getattr( const char *sPath, struct stat *stbuf )
 	{
-
+		try
+		{
+			printf("myriadfs_getattr: Statting file: %s\n", sPath );
+			Bu::MyriadFs::Stat st;
+			pFs->stat( sPath, st );
+			stbuf->st_ino = st.iNode;
+			stbuf->st_mode = st.uPerms;
+			stbuf->st_nlink = st.iLinks;
+			stbuf->st_uid = st.iUser;
+			stbuf->st_gid = st.iGroup;
+			stbuf->st_rdev = Bu::MyriadFs::devToSys( st.uDev );
+			stbuf->st_size = st.iSize;
+			stbuf->st_blocks = 8;
+			stbuf->st_atime = st.iATime;
+			stbuf->st_mtime = st.iMTime;
+			stbuf->st_ctime = st.iCTime;
+			return 0;
+		}
+		catch(...)
+		{
+			return -ENOENT;
+		}
 	}
 
 	static int myriadfs_readdir( const char *sPath, void *buf,
 			fuse_fill_dir_t filler, off_t offset, struct fuse_file_info *fi )
 	{
+		fprintf( stderr, "Reading dir...\n");
+		Bu::MyriadFs::Dir lDir = pFs->readDir( sPath );
+		filler( buf, ".", NULL, 0 );
+		filler( buf, "..", NULL, 0 );
+		for( Bu::MyriadFs::Dir::iterator i = lDir.begin(); i; i++ )
+		{
+			fprintf( stderr, "Adding file: '%s'\n", (*i).sName.getStr() );
+			filler( buf, (*i).sName.getStr(), NULL, 0 );
+		}
+
+		return 0;
+	}
+
+	static int myriadfs_mkdir( const char *sPath, mode_t uMode )
+	{
+		pFs->mkDir( sPath, uMode );
+		return 0;
 	}
 
 	static int myriadfs_open( const char *sPath, struct fuse_file_info *fi )
 	{
+		try
+		{
+			Bu::MyriadStream ms = pFs->open( sPath, 0 );
+			fi->fh = iNextFileId;
+			hOpenFiles.insert( iNextFileId++, ms );
+			return 0;
+		}
+		catch(...)
+		{
+			return -EACCES;
+		}
 	}
 
 	static int myriadfs_read( const char *sPath, char *buf, size_t iSize,
 			off_t iOffset, struct fuse_file_info *fi )
 	{
+		Bu::MyriadStream &ms = hOpenFiles.get( fi->fh );
+		ms.setPos( iOffset );
+		return ms.read( buf, iSize );
+	}
+
+	static int myriadfs_write( const char *sPath, const char *buf, size_t iSize,
+			off_t iOffset, struct fuse_file_info *fi )
+	{
+		Bu::MyriadStream &ms = hOpenFiles.get( fi->fh );
+		ms.setPos( iOffset );
+		return ms.write( buf, iSize );
+	}
+
+	static int myriadfs_create( const char *sPath, mode_t uPerms,
+			struct fuse_file_info *fi )
+	{
+		try
+		{
+			Bu::MyriadStream ms = pFs->open( sPath, 0 );
+			fi->fh = iNextFileId;
+			hOpenFiles.insert( iNextFileId++, ms );
+			return 0;
+		}
+		catch(...)
+		{
+			return -EACCES;
+		}
+	}
+	
+	static int myriadfs_mknod( const char *sPath, mode_t uPerms, dev_t Dev )
+	{
+		try
+		{
+			pFs->create( sPath, uPerms, Bu::MyriadFs::sysToDev( Dev ) );
+			return 0;
+		}
+		catch(...)
+		{
+			return -EACCES;
+		}
+	}
+
+	static int myriadfs_release( const char *sPath, struct fuse_file_info *fi )
+	{
+		hOpenFiles.erase( fi->fh );
+
+		return 0;
 	}
 
 	static struct fuse_operations myriadfs_oper;
 
 	int main( int argc, char *argv[] )
 	{
+		pF = new Bu::File("store.myr", Bu::File::Read|Bu::File::Write|Bu::File::Create );
+		pFs = new Bu::MyriadFs( *pF, 512 );
 		memset( &myriadfs_oper, sizeof(myriadfs_oper), 0 );
 		myriadfs_oper.getattr    = myriadfs_getattr;
 		myriadfs_oper.readdir    = myriadfs_readdir;
+		myriadfs_oper.mkdir		 = myriadfs_mkdir;
 		myriadfs_oper.open       = myriadfs_open;
 		myriadfs_oper.read       = myriadfs_read;
-		return fuse_main( argc, argv, &myriadfs_oper, NULL );
+		myriadfs_oper.write      = myriadfs_write;
+		myriadfs_oper.create	 = myriadfs_create;
+		myriadfs_oper.mknod		 = myriadfs_mknod;
+		printf("Starting fuse_main.\n");
+		int iRet = fuse_main( argc, argv, &myriadfs_oper, NULL );
+		printf("Done with fuse_main.\n");
+		delete pFs;
+		delete pF;
+		return iRet;
 	}
 }
-- 
cgit v1.2.3