+ static String toBitString(T val)
+ {
+ std::ostringstream os;
+ T mask = 0x01 << (CHAR_BIT * sizeof(T) - 1);
+ while(mask != 0)
+ {
+ os << ((val & mask) ? "1" : "0");
+ mask >>= 1;
+ }
+ return os.str();
+ }
+
+private:
+ static String _whiteSpaces;
+};
+
+XERIAL_NAMESPACE_END
+
+#endif // __STRINGUTIL_H_01
+
Index: /sandbox/trunk/pdp/src/xerial/util/NonCopyable.hpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/NonCopyable.hpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/NonCopyable.hpp (revision 939)
@@ -0,0 +1,48 @@
+//--------------------------------------------------
+// Xerial -- Transactional XML Database System
+//
+// NonCopyable.hpp
+// Since 2005/07/13 15:25:58
+//
+// $Date: 2006-10-04 12:29:44 +0900 (豌ｴ, 04 10 2006) $
+// $Author: leo $
+//--------------------------------------------------
+#pragma once
+#ifndef __NONCOPYABLE_HPP
+#define __NONCOPYABLE_HPP
+#include "xerial/common/xerial.hpp"
+
+XERIAL_NAMESPACE_BEGIN
+
+/**
+ * A class NonCopyable is useful to protect duplication of objects which should not be copied.
+ * By inheriting NonCopyable (no matter which inheritance you choose (public, protected, or private), it works well),
+ * you can see invocations of copy constructors and assignment operations at compile time (statically).
+ *
+ * usage:
+ *
+ *
+ * class YourClass : private NonCopyable
+ * {
+ * .....
+ * }
+ *
+ *
+ * This class is based on by Dave Abrahams.
+ */
+class NonCopyable
+{
+protected:
+ NonCopyable() {}
+ ~NonCopyable() {}
+private:
+ // restrict the copy constructor
+ NonCopyable(const NonCopyable& );
+ // restrict the assignment operator
+ const NonCopyable& operator=(const NonCopyable& );
+};
+
+XERIAL_NAMESPACE_END
+
+
+#endif //__NONCOPYABLE_HPP
Index: /sandbox/trunk/pdp/src/xerial/util/List.hpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/List.hpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/List.hpp (revision 939)
@@ -0,0 +1,38 @@
+//--------------------------------------------------
+// Xerial -- Transactional XML Database System
+//
+// List.hpp
+// Since 2006/05/16 12:55:10
+//
+// $Date: 2006-10-04 12:29:44 +0900 (豌ｴ, 04 10 2006) $
+// $URL: http://www.xerial.org/svn/project/Xerial/trunk/src/xerial/util/List.hpp $
+// $Author: leo $
+//--------------------------------------------------
+#pragma once
+#ifndef __LIST_HPP_20060516_125509
+#define __LIST_HPP_20060516_125509
+#include "xerial/common/xerial.hpp"
+#include "xerial/util/NonConstructable.hpp"
+#include "xerial/util/Collection.hpp"
+
+XERIAL_NAMESPACE_BEGIN
+
+namespace impl
+{
+
+} // impl
+
+template
+class XERIAL_API List : public virtual Collection
+{
+public:
+ virtual Reference operator[](size_t index) = 0;
+ virtual ConstReference operator[](size_t index) const = 0;
+private:
+
+};
+
+XERIAL_NAMESPACE_END
+
+
+#endif //__LIST_HPP_20060516_125509
Index: /sandbox/trunk/pdp/src/xerial/util/Printable.cpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/Printable.cpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/Printable.cpp (revision 939)
@@ -0,0 +1,33 @@
+//--------------------------------------------------
+// Xerial -- Transactional XML Database System
+//
+// Printable.cpp
+// Since 2006/07/26 14:19:24
+//
+// $Date: 2006-09-18 17:03:25 +0900 (譛� 18 9 2006) $
+// $URL: http://www.xerial.org/svn/project/Xerial/trunk/src/xerial/util/Printable.cpp $
+// $Author: leo $
+//--------------------------------------------------
+#include "xerial/util/Printable.hpp"
+#include "xerial/common/xerial_last.hpp"
+
+XERIAL_NAMESPACE_BEGIN
+
+std::ostream&
+Printable::operator<<(std::ostream& os) const
+{
+ os << this->toString();
+ return os;
+}
+
+
+
+std::ostream&
+operator<<(std::ostream& os, const Printable& obj)
+{
+ os << obj.toString();
+ return os;
+}
+
+
+XERIAL_NAMESPACE_END
Index: /sandbox/trunk/pdp/src/xerial/util/detail/IteratorImpl.hpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/detail/IteratorImpl.hpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/detail/IteratorImpl.hpp (revision 939)
@@ -0,0 +1,89 @@
+//--------------------------------------------------
+// Xerial -- Transactional XML Database System
+//
+// IteratorImpl.hpp
+// Since 2006/08/22 13:55:01
+//
+// $Date$
+// $Author$
+//--------------------------------------------------
+#ifndef __ITERATORIMPL_HPP_20060822_135501
+#define __ITERATORIMPL_HPP_20060822_135501
+#include "xerial/common/xerial.hpp"
+#include "xerial/exception/ExceptionUtil.hpp"
+#include "xerial/exception/assert.hpp"
+#include
+
+XERIAL_NAMESPACE_BEGIN
+
+namespace detail
+{
+ template
+ class IteratorBase : NonConstructable
+ {
+ protected:
+ typedef typename boost::add_const::type const_type;
+ public:
+ typedef T& Reference;
+ typedef const_type& ConstReference;
+
+ };
+
+ template
+ class ConstIteratorBase : NonConstructable
+ {
+ protected:
+ typedef typename boost::add_const::type const_type;
+ public:
+ typedef const_type& Reference;
+ typedef const_type& ConstReference;
+ };
+
+ // specialized version for pointers
+ /*
+ template
+ class IteratorBase : NonConstructable
+ {
+ protected:
+ typedef typename boost::add_const::type const_type;
+ public:
+ typedef T* Reference;
+ typedef const_type* ConstReference;
+
+ };
+
+ template
+ class ConstIteratorBase : NonConstructable
+ {
+ protected:
+ typedef typename boost::add_const::type const_type;
+ public:
+ typedef const_type* Reference;
+ typedef const_type* ConstReference;
+ };
+ */
+
+ template
+ class IteratorImpl : NonConstructable
+ {
+ public:
+ virtual bool hasNext() const = 0;
+ virtual bool hasPrevious() const = 0;
+ virtual Reference next() = 0;
+ virtual Reference previous() = 0;
+ virtual Reference peekNext() const = 0;
+ virtual Reference peekPrevious() const = 0;
+ virtual void remove()
+ {
+ XERIAL_THROW(UnsupportedOperation, "remove() is not supported");
+ }
+
+ virtual IteratorImpl* clone() const = 0;
+ };
+
+} // namespace detail
+
+XERIAL_NAMESPACE_END
+
+
+#endif //__ITERATORIMPL_HPP_20060822_135501
Index: /sandbox/trunk/pdp/src/xerial/util/detail/STLIteratorWrapper.hpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/detail/STLIteratorWrapper.hpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/detail/STLIteratorWrapper.hpp (revision 939)
@@ -0,0 +1,129 @@
+//--------------------------------------------------
+// Xerial -- Transactional XML Database System
+//
+// STLIteratorWrapper.hpp
+// Since 2006/08/25 0:23:06
+//
+// $Date$
+// $Author$
+//--------------------------------------------------
+#pragma once
+#ifndef __STLITERATORWRAPPER_HPP_20060825_02306
+#define __STLITERATORWRAPPER_HPP_20060825_02306
+#include "xerial/common/xerial.hpp"
+#include "xerial/util/detail/IteratorImpl.hpp"
+#include "xerial/exception/OutOfRangeException.hpp"
+#include
+
+XERIAL_NAMESPACE_BEGIN
+
+template
+class STLIterator : public detail::IteratorImpl
+{
+ typedef detail::IteratorImpl Base;
+
+ Container& _container;
+ IteratorType _previous;
+ IteratorType _next;
+public:
+ STLIterator(Container& container)
+ : _container(container)
+ {
+ _previous = _container.end();
+ _next = _container.begin();
+ }
+ STLIterator(Container& container, IteratorType nextIterator)
+ : _container(container)
+ {
+ _next = nextIterator;
+ _previous = boost::prior(_next);
+ }
+ virtual ~STLIterator() {}
+
+ virtual bool hasNext() const
+ {
+ return (_next != _container.end());
+ }
+ virtual bool hasPrevious() const
+ {
+ return (_next != _container.begin());
+ }
+ virtual ReferenceType next()
+ {
+ if(!hasNext())
+ {
+ XERIAL_THROW(Exception, "no such element");
+ }
+ else
+ {
+ _previous = _next;
+ ++_next;
+ return *_previous;
+ }
+ }
+ virtual ReferenceType previous()
+ {
+ if(!hasPrevious())
+ {
+ XERIAL_THROW(Exception, "no such element");
+ }
+ else
+ {
+ _previous = boost::prior(_previous);
+ _next = boost::prior(_next);
+ return *_next;
+ }
+ }
+ virtual ReferenceType peekNext() const
+ {
+ return *_next;
+ }
+ virtual ReferenceType peekPrevious() const
+ {
+ return *_previous;
+ }
+
+ virtual detail::IteratorImpl* clone() const
+ {
+ return new STLIterator(*this);
+ }
+
+};
+
+namespace detail
+{
+ template
+ ConstRef getNthElement(const Container& container, size_t n)
+ {
+ Container::ConstIterator it = container.getIterator();
+ size_t count = 0;
+ while(it.hasNext())
+ {
+ Container::ConstReference r = it.next();
+ if(count++ == n)
+ return r;
+ }
+ XERIAL_THROW(OutOfRangeException, "out of range: " << n << " is out of container sieze " << container.size() );
+ }
+
+ template
+ Ref getNthElement(Container& container, size_t n)
+ {
+ Container::Iterator it = container.getIterator();
+ size_t count = 0;
+ while(it.hasNext())
+ {
+ Container::Reference r = it.next();
+ if(count++ == n)
+ return r;
+ }
+ XERIAL_THROW(OutOfRangeException, "out of range: " << n << " is out of container sieze " << container.size() );
+ }
+
+}
+
+
+XERIAL_NAMESPACE_END
+
+
+#endif //__STLITERATORWRAPPER_HPP_20060825_02306
Index: /sandbox/trunk/pdp/src/xerial/util/ScopedPointer.hpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/ScopedPointer.hpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/ScopedPointer.hpp (revision 939)
@@ -0,0 +1,193 @@
+//--------------------------------------------------
+// Xerial -- Transactional XML Database System
+//
+// ScopedPointer.hpp
+// Since 2006/05/16 13:57:18
+//
+// $Date: 2006-10-04 12:29:44 +0900 (豌ｴ, 04 10 2006) $
+// $URL: http://www.xerial.org/svn/project/Xerial/trunk/src/xerial/util/ScopedPointer.hpp $
+// $Author: leo $
+//--------------------------------------------------
+#pragma once
+#ifndef __SCOPEDPOINTER_HPP_20060516_135717
+#define __SCOPEDPOINTER_HPP_20060516_135717
+#include "xerial/common/xerial.hpp"
+#include "xerial/util/NonCopyable.hpp"
+#include "xerial/util/NonConstructable.hpp"
+#include "xerial/exception/assert.hpp"
+#include "xerial/exception/UnsupportedOperation.hpp"
+#include "xerial/detail/MemoryChunkAllocator.hpp"
+
+XERIAL_NAMESPACE_BEGIN
+
+namespace detail
+{
+ template struct ScopedPtrTypeTraits { typedef T& reference; };
+ template<> struct ScopedPtrTypeTraits { typedef void reference; };
+ template<> struct ScopedPtrTypeTraits { typedef void reference; };
+ template<> struct ScopedPtrTypeTraits { typedef void reference; };
+ template<> struct ScopedPtrTypeTraits { typedef void reference; };
+
+ template inline void checked_delete(T * x)
+ {
+ // intentionally complex - simplification causes regressions
+ typedef char type_must_be_complete[ sizeof(T)? 1: -1 ];
+ (void) sizeof(type_must_be_complete);
+ delete x;
+ }
+
+} // namespace detail
+
+template
+class ScopedPtr : NonCopyable
+{
+ class DeleteProcessHolder : NonCopyable
+ {
+ public:
+ virtual void dispose() = 0;
+ };
+
+ template
+ class UserDefinedDeleteProcess : public DeleteProcessHolder
+ {
+ typedef UserDefinedDeleteProcess ThisType;
+
+ DeleteProcess _dp;
+ Ptr* _ptr;
+ public:
+ explicit UserDefinedDeleteProcess(Ptr* ptr, DeleteProcess d)
+ : _dp(d), _ptr(ptr)
+ {}
+ void* operator new(std::size_t)
+ {
+ return detail::MemoryChunkAllocator::allocate();
+ }
+ void operator delete(void* p)
+ {
+ return detail::MemoryChunkAllocator::deallocate(p);
+ }
+
+ virtual void dispose()
+ {
+ _dp(_ptr);
+ }
+ };
+
+ T * _ptr;
+ DeleteProcessHolder* _deleteProcess;
+public:
+ typedef typename detail::ScopedPtrTypeTraits::reference reference;
+
+ ScopedPtr()
+ : _ptr(0), _deleteProcess(0)
+ {
+
+ }
+
+ template
+ explicit ScopedPtr(V* ptr)
+ : _ptr(ptr), _deleteProcess(0)
+ {
+ }
+
+
+
+ template
+ explicit ScopedPtr(V * ptr, DeleteProcess deleteProcess)
+ : _ptr(ptr), _deleteProcess(0)
+ {
+ try
+ {
+ _deleteProcess = new UserDefinedDeleteProcess(ptr, deleteProcess);
+ }
+ catch(...)
+ {
+ deleteProcess(ptr);
+ throw;
+ }
+ }
+
+ ~ScopedPtr()
+ {
+ if(_deleteProcess)
+ {
+ _deleteProcess->dispose();
+ delete _deleteProcess;
+ }
+ else
+ {
+ detail::checked_delete(_ptr);
+ }
+ }
+
+ void reset(T* p = 0)
+ {
+ XERIAL_ASSERT(p == 0 || p != _ptr); // avoid self-reset
+ if(_deleteProcess)
+ XERIAL_THROW(UnsupportedOperation, "reset() of SharedPtr with user defined deleter is not supported");
+
+ ScopedPtr(p).swap(*this);
+ }
+
+ reference operator*() const
+ {
+ XERIAL_ASSERT(_ptr != 0);
+ return *_ptr;
+ }
+ T* operator->() const
+ {
+ XERIAL_ASSERT(_ptr != 0);
+ return _ptr;
+ }
+ T* get() const
+ {
+ return _ptr;
+ }
+
+ void swap(ScopedPtr &other)
+ {
+ if(_deleteProcess)
+ XERIAL_THROW(UnsupportedOperation, "swap() of SharedPtr with user defined deleter is not supported");
+
+ T* tmp = other._ptr;
+ other._ptr = _ptr;
+ _ptr = tmp;
+ }
+
+ /**
+ * Reset the ScopedPtr, and release the management of the allocated resource
+ * @return A pointer that have been managed by this ScopedPtr. Deallocation of
+ * the returned pointer must be performed by the callee of this release() function.
+ */
+ T* release()
+ {
+ if(_deleteProcess)
+ XERIAL_THROW(UnsupportedOperation, "release() of SharedPtr with user defined deleter is not supported");
+
+ T* tmp = _ptr;
+ _ptr = 0;
+ return tmp;
+ }
+
+private:
+
+};
+
+template <>
+ScopedPtr::~ScopedPtr()
+{
+ if(_deleteProcess)
+ {
+ _deleteProcess->dispose();
+ delete _deleteProcess;
+ }
+
+}
+
+
+
+
+XERIAL_NAMESPACE_END
+
+
+#endif //__SCOPEDPOINTER_HPP_20060516_135717
Index: /sandbox/trunk/pdp/src/xerial/util/NonConstructable.cpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/NonConstructable.cpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/NonConstructable.cpp (revision 939)
@@ -0,0 +1,14 @@
+//--------------------------------------------------
+// Xerial -- Transactional XML Database System
+//
+// NonConstructable.cpp
+// Since 2006/05/16 23:45:19
+//
+// $Date$
+// $Author$
+//--------------------------------------------------
+#include "xerial/util/NonConstructable.hpp"
+
+using namespace xerial;
+
+NonConstructable::~NonConstructable() {}
Index: /sandbox/trunk/pdp/src/xerial/util/Message.cpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/Message.cpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/Message.cpp (revision 939)
@@ -0,0 +1,38 @@
+//--------------------------------------------------
+// Xerial -- Transactional XML Database System
+//
+// Message.cpp
+// Since 2006/08/26 7:07:56
+//
+// $Date$
+// $Author$
+//--------------------------------------------------
+#include "xerial/util/Message.hpp"
+#include "xerial/util/Printable.hpp"
+#include "xerial/common/xerial_last.hpp"
+
+std::string
+Message::toString() const
+{
+ return _message.str();
+}
+
+Message&
+Message::operator<<(size_t message)
+{
+ _message << static_cast(message);
+ return *this;
+}
+Message&
+Message::operator<<(uint8 message)
+{
+ _message << static_cast(message);
+ return *this;
+}
+
+Message&
+Message::operator<<(const Printable& printable)
+{
+ _message << printable.toString();
+ return *this;
+}
Index: /sandbox/trunk/pdp/src/xerial/util/Printable.hpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/Printable.hpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/Printable.hpp (revision 939)
@@ -0,0 +1,35 @@
+//--------------------------------------------------
+// Xerial -- Transactional XML Database System
+//
+// Printable.hpp
+// Since 2006/07/24 16:31:40
+//
+// $Date: 2006-10-04 12:29:44 +0900 (豌ｴ, 04 10 2006) $
+// $URL: http://www.xerial.org/svn/project/Xerial/trunk/src/xerial/util/Printable.hpp $
+// $Author: leo $
+//--------------------------------------------------
+#pragma once
+#ifndef __PRINTABLE_HPP_20060724_163140
+#define __PRINTABLE_HPP_20060724_163140
+#include "xerial/common/xerial.hpp"
+#include "xerial/util/NonConstructable.hpp"
+#include
+#include
+
+XERIAL_NAMESPACE_BEGIN
+
+class XERIAL_API Printable : NonConstructable
+{
+public:
+ virtual std::string toString() const = 0;
+ virtual std::ostream& operator<<(std::ostream& os) const;
+
+private:
+};
+
+std::ostream& operator<<(std::ostream& os, const Printable& obj);
+
+XERIAL_NAMESPACE_END
+
+
+#endif //__PRINTABLE_HPP_20060724_163140
Index: /sandbox/trunk/pdp/src/xerial/util/hash_map.hpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/hash_map.hpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/hash_map.hpp (revision 939)
@@ -0,0 +1,24 @@
+//--------------------------------------------------
+// Xerial -- Transactional XML Database System
+//
+// hash_map.hpp
+// Since 2005/11/15 12:01:06
+//
+// $Date: 2006-10-04 12:29:44 +0900 (豌ｴ, 04 10 2006) $
+// $URL: http://www.xerial.org/svn/project/Xerial/trunk/src/xerial/util/hash_map.hpp $
+// $Author: leo $
+//--------------------------------------------------
+#pragma once
+#ifndef __HASH_MAP_HPP_20051115_120106
+#define __HASH_MAP_HPP_20051115_120106
+#include "xerial/common/xerial.hpp"
+
+
+#ifdef _WIN32
+
+#pragma warning(disable:4996)
+#include
+#endif // _WIN32
+
+
+#endif //__HASH_MAP_HPP_20051115_120106
Index: /sandbox/trunk/pdp/src/xerial/util/io/FileUtil.hpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/io/FileUtil.hpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/io/FileUtil.hpp (revision 939)
@@ -0,0 +1,70 @@
+//------------------------------------------------
+// Xerial -- Transaction Enabled XML Database
+//
+// FileUtil.hpp
+// Since 2003/08/30 03:01:38
+//
+// $Date: 2006-10-06 16:23:13 +0900 (驥� 06 10 2006) $
+// $Author: leo $
+//------------------------------------------------
+
+#pragma once
+#ifndef __FILEUTIL_HPP_33
+#define __FILEUTIL_HPP_33
+
+#include
+#include "xerial/common/xerial.hpp"
+#include "xerial/common/xerial_types.hpp"
+
+XERIAL_NAMESPACE_BEGIN
+
+/**
+ * an utility package for handling files, directories, and paths
+ */
+class XERIAL_API FileUtil
+{
+public:
+ /**
+ * test whether the file exists or not
+ * @param fileName
+ * @return true if the file exists.
+ */
+ static bool existFile(const std::string &fileName);
+ static bool existDir(const std::string &dirName);
+
+ static uint64 fileSize(const std::string& filePath);
+ /**
+ *
+ * @param fileName
+ * @return
+ */
+ static int removeFile(const std::string &fileName);
+ static void mkdir(const std::string &fileName);
+ /**
+ * replace extension in the filename. ex. somefile.hpp to somefile.cpp
+ * @param fileName
+ * @param ext a new extension
+ * @return a new file name after the replacement of its extension
+ */
+ static std::string replaceExtension(const std::string &fileName, const std::string &ext);
+ /**
+ * remove a file extension. ex. sample.txt -> sample
+ * @param path
+ * @rXeturn no extension filename
+ */
+ static std::string removeExtension(const std::string &path);
+ /**
+ *
+ * @param path
+ * @return an only filename without its precedent path
+ */
+ static std::string getLeaf(const std::string &path);
+
+ static std::string appendPath(const std::string &parentPath, const std::string& file);
+
+
+};
+
+XERIAL_NAMESPACE_END
+
+#endif // __FILEUTIL_HPP_33
Index: /sandbox/trunk/pdp/src/xerial/util/io/FileUtil.cpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/io/FileUtil.cpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/io/FileUtil.cpp (revision 939)
@@ -0,0 +1,160 @@
+//------------------------------------------------
+// Xerial -- Transaction Enabled XML Database
+//
+// FileUtil.cpp
+// Since 2003/10/10 17:43:51
+//
+// $Date: 2006-10-06 16:23:13 +0900 (驥� 06 10 2006) $
+// $Author: leo $
+//------------------------------------------------
+
+#include "xerial/util/io/FileUtil.hpp"
+#include
+#include
+#include
+#include
+#include "xerial/exception/ExceptionUtil.hpp"
+#include
+#include "xerial/common/xerial_last.hpp"
+
+
+
+XERIAL_NAMESPACE_BEGIN
+
+void
+FileUtil::mkdir(const string &dirName)
+{
+ using namespace boost::filesystem;
+ try
+ {
+ path dir(dirName);
+ stack nonExistentPath;
+ while(!exists(dir))
+ {
+ nonExistentPath.push(dir);
+ if(!dir.empty())
+ dir = dir.branch_path();
+ else
+ break;
+ }
+ while(!nonExistentPath.empty())
+ {
+ create_directory(nonExistentPath.top());
+ nonExistentPath.pop();
+ }
+ }
+ catch(std::runtime_error &e)
+ {
+ XERIAL_THROW(Exception, "filesystem error: " << e.what());
+ }
+}
+
+bool
+FileUtil::existFile(const string &fileName)
+{
+ if(fileName == "")
+ return false;
+ FILE *tmp;
+ if((tmp = fopen(fileName.c_str(), "r")) == NULL)
+ {
+ return false;
+ }
+ fclose(tmp);
+ return true;
+}
+
+int
+FileUtil::removeFile(const string &fileName)
+{
+ if(fileName == "")
+ return -1;
+ return remove(fileName.c_str());
+}
+
+string
+FileUtil::replaceExtension(const string &fileName, const string &ext)
+{
+ size_t dotPosition = fileName.find_last_of(".");
+
+ if(dotPosition == (size_t) string::npos)
+ {
+ return fileName + "." + ext;
+ }
+
+ string tmp = fileName;
+ tmp.erase(dotPosition+1, tmp.size()-dotPosition+1);
+ return tmp + ext;
+}
+
+string
+FileUtil::removeExtension(const string &path)
+{
+ string leafFileName = getLeaf(path);
+ size_t dotPosition = leafFileName.find_last_of(".");
+ if(dotPosition == (size_t) string::npos)
+ {
+ return path;
+ }
+
+ string tmp = path;
+ size_t noLeafSize = path.size() - leafFileName.size();
+ size_t absoluteDotPos = noLeafSize + dotPosition;
+ tmp.erase(absoluteDotPos, tmp.size()-absoluteDotPos);
+ return tmp;
+}
+
+string
+FileUtil::getLeaf(const string &path)
+{
+ size_t lastSeparatorPosition = path.find_last_of("/\\");
+ if(lastSeparatorPosition == (size_t) string::npos)
+ {
+ return path;
+ }
+
+ string tmp = path;
+ tmp.erase(0, lastSeparatorPosition+1);
+ return tmp;
+}
+
+bool
+FileUtil::existDir(const std::string& dirName)
+{
+ using namespace boost::filesystem;
+ try
+ {
+ path dir(dirName);
+ return exists(dir);
+ }
+ catch(exception &e)
+ {
+ XERIAL_THROW(Exception, "filesystem error: " << e.what());
+ }
+}
+
+std::string
+FileUtil::appendPath(const std::string &parentPath, const std::string &file)
+{
+ using namespace boost::filesystem;
+ path p(parentPath, native);
+ p /= file;
+ return p.string();
+}
+
+uint64
+FileUtil::fileSize(const std::string& filePath)
+{
+ using namespace boost::filesystem;
+ try
+ {
+ path p(filePath);
+ return static_cast(file_size(p));
+ }
+ catch(exception &e)
+ {
+ XERIAL_THROW(Exception, "filesystem error: " << e.what());
+ }
+}
+
+
+XERIAL_NAMESPACE_END
Index: /sandbox/trunk/pdp/src/xerial/util/thread/LightMutex.hpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/thread/LightMutex.hpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/thread/LightMutex.hpp (revision 939)
@@ -0,0 +1,74 @@
+//--------------------------------------------------
+// Xerial -- Transactional XML Database System
+//
+// LightMutex.hpp
+// Since 2005/07/19 15:29:29
+//
+// $Date: 2006-10-06 16:23:13 +0900 (驥� 06 10 2006) $
+// $Author: leo $
+//--------------------------------------------------
+#pragma once
+#ifndef __LIGHTMUTEX_HPP
+#define __LIGHTMUTEX_HPP
+#include "xerial/common/xerial.hpp"
+#include "xerial/util/thread/ScopeGuard.hpp"
+#include "xerial/util/NonCopyable.hpp"
+#include "xerial/util/thread/Lock.hpp"
+#include "xerial/util/thread/CompareAndSwap.hpp"
+#include "xerial/exception/assert.hpp"
+
+#ifdef WIN32
+// Exclude rarely-used stuff from Windows headers
+#define WIN32_LEAN_AND_MEAN
+#include
+// ignore warnings for unreferenced formal parameters
+#pragma warning(disable : 4100)
+#else
+#error LightMutex is not supported yet in other than win32
+#endif
+
+XERIAL_NAMESPACE_BEGIN
+
+/**
+ * LightMutex is a user-mode lock that uses atomic compare-and-swap operations
+ * in order to manage simultaneous access to the lock object.
+ *
+ * Note that the LightMutex cannot protect concurrent accesses
+ * of threads belonging to different processes.
+ *
+ * @author leo
+ */
+class XERIAL_API LightMutex : private Lock, private NonCopyable
+{
+public:
+ LightMutex()
+ : _lock(0)
+ {}
+ ~LightMutex()
+ { XERIAL_ASSERT(_lock == 0); }
+
+ void acquire()
+ {
+ while(AtomicCompareAndSwap32(&_lock, 0, 1) != 0)
+ ::Sleep(0);
+ }
+
+ bool tryAcquire(unsigned long timeout = 0)
+ {
+ return AtomicCompareAndSwap32(&_lock, 0, 1) == 0;
+ }
+
+ void release()
+ {
+ XERIAL_ASSERT(_lock == 1); // the caller must be the lock owner
+ AtomicSwap32(&_lock, 0);
+ }
+
+private:
+ uint32 volatile _lock;
+};
+
+XERIAL_NAMESPACE_END
+
+
+#endif //__LIGHTMUTEX_HPP
Index: /sandbox/trunk/pdp/src/xerial/util/thread/ScopeGuard.hpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/thread/ScopeGuard.hpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/thread/ScopeGuard.hpp (revision 939)
@@ -0,0 +1,127 @@
+//--------------------------------------------------
+// Xerial -- Transactional XML Database System
+//
+// ScopeGuard.hpp
+// Since 2005/07/19 10:16:20
+//
+// $Date: 2006-10-06 16:23:13 +0900 (驥� 06 10 2006) $
+// $Author: leo $
+//--------------------------------------------------
+#pragma once
+#ifndef __SCOPEGUARD_HPP
+#define __SCOPEGUARD_HPP
+#include "xerial/common/xerial.hpp"
+#include "xerial/util/NonCopyable.hpp"
+
+XERIAL_NAMESPACE_BEGIN
+
+/**
+* LockHolder holds any type of lock object.
+* This design is modeled on in Boost C++ library.
+*/
+template
+class LockHolder : private NonCopyable
+{
+ LockType& _lock;
+public:
+ template
+ LockHolder(T& lock)
+ : _lock(cast(t)._lock)
+ {}
+
+ LockHolder(LockHolder& holder)
+ : _lock(holder._lock)
+ {}
+
+ LockHolder(LockType& lock)
+ : _lock(lock)
+ {}
+
+ LockType& getLock() { return _lock; }
+
+
+ template
+ static LockHolder& cast(T& t)
+ {
+ return static_cast(t);
+ }
+};
+
+class ScopeLocking;
+class ScopeUnlocking;
+
+template
+class ScopeGuard : private NonCopyable
+{
+public:
+ ScopeGuard(LockType& lock)
+ : _lockHolder(lock)
+ {
+ LockingPolicy::enterScope(_lockHolder);
+ }
+
+ template
+ ScopeGuard(ScopeGuard& guard)
+ : _lockHolder(guard.getLockHolder())
+ {
+ LockingPolicy::enterNestedScope(_lockHolder);
+ }
+
+ ~ScopeGuard() throw() // no throw
+ {
+ LockingPolicy::leaveScope(_lockHolder);
+ }
+
+ LockHolder& getLockHolder()
+ {
+ return _lockHolder;
+ }
+private:
+ LockHolder _lockHolder;
+};
+
+
+
+class ScopeLocking
+{
+public:
+ template
+ static void enterScope(LockHolder& lockHolder)
+ {
+ lockHolder.getLock().acquire();
+ }
+
+ template
+ static void leaveScope(LockHolder& lockHolder)
+ {
+ lockHolder.getLock().release();
+ }
+};
+
+class ScopeUnlocking
+{
+public:
+ template
+ static void enterScope(LockHolder& lockHolder)
+ {
+ lockHolder.getLock().release();
+ }
+
+ template
+ static void enterNestedScope(LockHolder& lockHolder)
+ {
+ lockHolder.getLock().release();
+ }
+
+ template
+ static void leaveScope(LockHolder& lockHolder)
+ {
+ lockHolder.getLock().acquire();
+ }
+};
+
+
+XERIAL_NAMESPACE_END
+
+
+#endif //__SCOPEGUARD_HPP
Index: /sandbox/trunk/pdp/src/xerial/util/thread/CompareAndSwap.cpp
===================================================================
--- /sandbox/trunk/pdp/src/xerial/util/thread/CompareAndSwap.cpp (revision 939)
+++ /sandbox/trunk/pdp/src/xerial/util/thread/CompareAndSwap.cpp (revision 939)
@@ -0,0 +1,28 @@
+//--------------------------------------------------
+// Xerial -- Transactional XML Database System
+//
+// CompareAndSwap.cpp
+// Since 2005/07/22 0:27:58
+//
+// $Date$
+// $Author$
+//--------------------------------------------------
+#include "xerial/util/thread/CompareAndSwap.hpp"
+#include