Chris@16: //////////////////////////////////////////////////////////////////////////////
Chris@16: //
Chris@16: // (C) Copyright Ion Gaztanaga 2005-2012. Distributed under the Boost
Chris@16: // Software License, Version 1.0. (See accompanying file
Chris@16: // LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
Chris@16: //
Chris@16: // See http://www.boost.org/libs/interprocess for documentation.
Chris@16: //
Chris@16: //////////////////////////////////////////////////////////////////////////////
Chris@16: 
Chris@16: #ifndef BOOST_INTERPROCESS_DETAIL_OS_FILE_FUNCTIONS_HPP
Chris@16: #define BOOST_INTERPROCESS_DETAIL_OS_FILE_FUNCTIONS_HPP
Chris@16: 
Chris@101: #ifndef BOOST_CONFIG_HPP
Chris@101: #  include <boost/config.hpp>
Chris@101: #endif
Chris@101: #
Chris@101: #if defined(BOOST_HAS_PRAGMA_ONCE)
Chris@101: #  pragma once
Chris@101: #endif
Chris@101: 
Chris@16: #include <boost/interprocess/detail/config_begin.hpp>
Chris@16: #include <boost/interprocess/detail/workaround.hpp>
Chris@16: #include <boost/interprocess/errors.hpp>
Chris@16: #include <boost/interprocess/permissions.hpp>
Chris@16: 
Chris@16: #include <string>
Chris@16: #include <limits>
Chris@16: #include <climits>
Chris@101: #include <boost/move/detail/type_traits.hpp> //make_unsigned
Chris@16: 
Chris@101: #if defined (BOOST_INTERPROCESS_WINDOWS)
Chris@16: #  include <boost/interprocess/detail/win32_api.hpp>
Chris@16: #else
Chris@16: #  ifdef BOOST_HAS_UNISTD_H
Chris@16: #     include <fcntl.h>
Chris@16: #     include <unistd.h>
Chris@16: #     include <sys/types.h>
Chris@16: #     include <sys/stat.h>
Chris@16: #     include <errno.h>
Chris@16: #     include <cstdio>
Chris@16: #     include <dirent.h>
Chris@16: #     if 0
Chris@16: #        include <sys/file.h>
Chris@16: #     endif
Chris@16: #  else
Chris@16: #    error Unknown platform
Chris@16: #  endif
Chris@16: #endif
Chris@16: 
Chris@16: #include <cstring>
Chris@16: #include <cstdlib>
Chris@16: 
Chris@16: namespace boost {
Chris@16: namespace interprocess {
Chris@16: 
Chris@101: #if defined (BOOST_INTERPROCESS_WINDOWS)
Chris@16: 
Chris@101: typedef void *                   file_handle_t;
Chris@101: typedef __int64  offset_t;
Chris@16: typedef struct mapping_handle_impl_t{
Chris@16:    void *   handle;
Chris@16:    bool     is_shm;
Chris@16: }  mapping_handle_t;
Chris@16: 
Chris@16: typedef enum { read_only      = winapi::generic_read
Chris@16:              , read_write     = winapi::generic_read | winapi::generic_write
Chris@16:              , copy_on_write
Chris@16:              , read_private
Chris@16:              , invalid_mode   = 0xffff
Chris@16:              } mode_t;
Chris@16: 
Chris@16: typedef enum { file_begin     = winapi::file_begin
Chris@16:              , file_end       = winapi::file_end
Chris@16:              , file_current   = winapi::file_current
Chris@16:              } file_pos_t;
Chris@16: 
Chris@16: typedef unsigned long      map_options_t;
Chris@16: static const map_options_t default_map_options = map_options_t(-1);
Chris@16: 
Chris@16: namespace ipcdetail{
Chris@16: 
Chris@16: inline mapping_handle_t mapping_handle_from_file_handle(file_handle_t hnd)
Chris@16: {
Chris@16:    mapping_handle_t ret;
Chris@16:    ret.handle = hnd;
Chris@16:    ret.is_shm = false;
Chris@16:    return ret;
Chris@16: }
Chris@16: 
Chris@16: inline mapping_handle_t mapping_handle_from_shm_handle(file_handle_t hnd)
Chris@16: {
Chris@16:    mapping_handle_t ret;
Chris@16:    ret.handle = hnd;
Chris@16:    ret.is_shm = true;
Chris@16:    return ret;
Chris@16: }
Chris@16: 
Chris@16: inline file_handle_t file_handle_from_mapping_handle(mapping_handle_t hnd)
Chris@16: {  return hnd.handle; }
Chris@16: 
Chris@16: inline bool create_directory(const char *path)
Chris@16: {  return winapi::create_directory(path); }
Chris@16: 
Chris@101: inline bool get_temporary_path(char *buffer, std::size_t buf_len, std::size_t &required_len)
Chris@101: {
Chris@101:    required_len = 0;
Chris@101:    //std::size_t is always bigger or equal than unsigned long in Windows systems
Chris@101:    //In case std::size_t is bigger than unsigned long
Chris@101:    unsigned long buf = buf_len;
Chris@101:    if(buf_len != buf){   //maybe overflowed
Chris@101:       return false;
Chris@101:    }
Chris@101:    required_len = winapi::get_temp_path(buf_len, buffer);
Chris@101:    const bool ret = !(buf_len < required_len);
Chris@101:    if(ret && buffer[required_len-1] == '\\'){
Chris@101:       buffer[required_len-1] = 0;
Chris@101:    }
Chris@101:    return ret;
Chris@101: }
Chris@16: 
Chris@16: inline file_handle_t create_new_file
Chris@16:    (const char *name, mode_t mode, const permissions & perm = permissions(), bool temporary = false)
Chris@16: {
Chris@16:    unsigned long attr = temporary ? winapi::file_attribute_temporary : 0;
Chris@16:    return winapi::create_file
Chris@16:       ( name, (unsigned int)mode, winapi::create_new, attr
Chris@16:       , (winapi::interprocess_security_attributes*)perm.get_permissions());
Chris@16: }
Chris@16: 
Chris@16: inline file_handle_t create_or_open_file
Chris@16:    (const char *name, mode_t mode, const permissions & perm = permissions(), bool temporary = false)
Chris@16: {
Chris@16:    unsigned long attr = temporary ? winapi::file_attribute_temporary : 0;
Chris@16:    return winapi::create_file
Chris@16:       ( name, (unsigned int)mode, winapi::open_always, attr
Chris@16:       , (winapi::interprocess_security_attributes*)perm.get_permissions());
Chris@16: }
Chris@16: 
Chris@16: inline file_handle_t open_existing_file
Chris@16:    (const char *name, mode_t mode, bool temporary = false)
Chris@16: {
Chris@16:    unsigned long attr = temporary ? winapi::file_attribute_temporary : 0;
Chris@16:    return winapi::create_file
Chris@16:       (name, (unsigned int)mode, winapi::open_existing, attr, 0);
Chris@16: }
Chris@16: 
Chris@16: inline bool delete_file(const char *name)
Chris@16: {  return winapi::unlink_file(name);   }
Chris@16: 
Chris@16: inline bool truncate_file (file_handle_t hnd, std::size_t size)
Chris@16: {
Chris@16:    offset_t filesize;
Chris@16:    if(!winapi::get_file_size(hnd, filesize))
Chris@16:       return false;
Chris@16: 
Chris@101:    typedef ::boost::move_detail::make_unsigned<offset_t>::type uoffset_t;
Chris@16:    const uoffset_t max_filesize = uoffset_t((std::numeric_limits<offset_t>::max)());
Chris@101:    const uoffset_t uoff_size = uoffset_t(size);
Chris@16:    //Avoid unused variable warnings in 32 bit systems
Chris@101:    if(uoff_size > max_filesize){
Chris@16:       winapi::set_last_error(winapi::error_file_too_large);
Chris@16:       return false;
Chris@16:    }
Chris@16: 
Chris@16:    if(offset_t(size) > filesize){
Chris@16:       if(!winapi::set_file_pointer_ex(hnd, filesize, 0, winapi::file_begin)){
Chris@16:          return false;
Chris@16:       }
Chris@16:       //We will write zeros in the end of the file
Chris@16:       //since set_end_of_file does not guarantee this
Chris@16:       for(std::size_t remaining = size - filesize, write_size = 0
Chris@16:          ;remaining > 0
Chris@16:          ;remaining -= write_size){
Chris@16:          const std::size_t DataSize = 512;
Chris@16:          static char data [DataSize];
Chris@16:          write_size = DataSize < remaining ? DataSize : remaining;
Chris@16:          unsigned long written;
Chris@16:          winapi::write_file(hnd, data, (unsigned long)write_size, &written, 0);
Chris@16:          if(written != write_size){
Chris@16:             return false;
Chris@16:          }
Chris@16:       }
Chris@16:    }
Chris@16:    else{
Chris@16:       if(!winapi::set_file_pointer_ex(hnd, size, 0, winapi::file_begin)){
Chris@16:          return false;
Chris@16:       }
Chris@16:       if(!winapi::set_end_of_file(hnd)){
Chris@16:          return false;
Chris@16:       }
Chris@16:    }
Chris@16:    return true;
Chris@16: }
Chris@16: 
Chris@16: inline bool get_file_size(file_handle_t hnd, offset_t &size)
Chris@16: {  return winapi::get_file_size(hnd, size);  }
Chris@16: 
Chris@16: inline bool set_file_pointer(file_handle_t hnd, offset_t off, file_pos_t pos)
Chris@16: {  return winapi::set_file_pointer_ex(hnd, off, 0, (unsigned long) pos); }
Chris@16: 
Chris@16: inline bool get_file_pointer(file_handle_t hnd, offset_t &off)
Chris@16: {  return winapi::set_file_pointer_ex(hnd, 0, &off, winapi::file_current); }
Chris@16: 
Chris@16: inline bool write_file(file_handle_t hnd, const void *data, std::size_t numdata)
Chris@16: {
Chris@16:    unsigned long written;
Chris@16:    return 0 != winapi::write_file(hnd, data, (unsigned long)numdata, &written, 0);
Chris@16: }
Chris@16: 
Chris@16: inline file_handle_t invalid_file()
Chris@16: {  return winapi::invalid_handle_value;  }
Chris@16: 
Chris@16: inline bool close_file(file_handle_t hnd)
Chris@16: {  return 0 != winapi::close_handle(hnd);   }
Chris@16: 
Chris@16: inline bool acquire_file_lock(file_handle_t hnd)
Chris@16: {
Chris@16:    static winapi::interprocess_overlapped overlapped;
Chris@16:    const unsigned long len = ((unsigned long)-1);
Chris@16: //   winapi::interprocess_overlapped overlapped;
Chris@16: //   std::memset(&overlapped, 0, sizeof(overlapped));
Chris@16:    return winapi::lock_file_ex
Chris@16:       (hnd, winapi::lockfile_exclusive_lock, 0, len, len, &overlapped);
Chris@16: }
Chris@16: 
Chris@16: inline bool try_acquire_file_lock(file_handle_t hnd, bool &acquired)
Chris@16: {
Chris@16:    const unsigned long len = ((unsigned long)-1);
Chris@16:    winapi::interprocess_overlapped overlapped;
Chris@16:    std::memset(&overlapped, 0, sizeof(overlapped));
Chris@16:    if(!winapi::lock_file_ex
Chris@16:       (hnd, winapi::lockfile_exclusive_lock | winapi::lockfile_fail_immediately,
Chris@16:        0, len, len, &overlapped)){
Chris@16:       return winapi::get_last_error() == winapi::error_lock_violation ?
Chris@16:                acquired = false, true : false;
Chris@16: 
Chris@16:    }
Chris@16:    return (acquired = true);
Chris@16: }
Chris@16: 
Chris@16: inline bool release_file_lock(file_handle_t hnd)
Chris@16: {
Chris@16:    const unsigned long len = ((unsigned long)-1);
Chris@16:    winapi::interprocess_overlapped overlapped;
Chris@16:    std::memset(&overlapped, 0, sizeof(overlapped));
Chris@16:    return winapi::unlock_file_ex(hnd, 0, len, len, &overlapped);
Chris@16: }
Chris@16: 
Chris@16: inline bool acquire_file_lock_sharable(file_handle_t hnd)
Chris@16: {
Chris@16:    const unsigned long len = ((unsigned long)-1);
Chris@16:    winapi::interprocess_overlapped overlapped;
Chris@16:    std::memset(&overlapped, 0, sizeof(overlapped));
Chris@16:    return winapi::lock_file_ex(hnd, 0, 0, len, len, &overlapped);
Chris@16: }
Chris@16: 
Chris@16: inline bool try_acquire_file_lock_sharable(file_handle_t hnd, bool &acquired)
Chris@16: {
Chris@16:    const unsigned long len = ((unsigned long)-1);
Chris@16:    winapi::interprocess_overlapped overlapped;
Chris@16:    std::memset(&overlapped, 0, sizeof(overlapped));
Chris@16:    if(!winapi::lock_file_ex
Chris@16:       (hnd, winapi::lockfile_fail_immediately, 0, len, len, &overlapped)){
Chris@16:       return winapi::get_last_error() == winapi::error_lock_violation ?
Chris@16:                acquired = false, true : false;
Chris@16:    }
Chris@16:    return (acquired = true);
Chris@16: }
Chris@16: 
Chris@16: inline bool release_file_lock_sharable(file_handle_t hnd)
Chris@16: {  return release_file_lock(hnd);   }
Chris@16: 
Chris@16: inline bool delete_subdirectories_recursive
Chris@16:    (const std::string &refcstrRootDirectory, const char *dont_delete_this, unsigned int count)
Chris@16: {
Chris@16:    bool               bSubdirectory = false;       // Flag, indicating whether
Chris@16:                                                    // subdirectories have been found
Chris@16:    void *             hFile;                       // Handle to directory
Chris@16:    std::string        strFilePath;                 // Filepath
Chris@16:    std::string        strPattern;                  // Pattern
Chris@101:    winapi::win32_find_data  FileInformation;     // File information
Chris@16: 
Chris@16:    //Find all files and directories
Chris@16:    strPattern = refcstrRootDirectory + "\\*.*";
Chris@16:    hFile = winapi::find_first_file(strPattern.c_str(), &FileInformation);
Chris@16:    if(hFile != winapi::invalid_handle_value){
Chris@16:       do{
Chris@16:          //If it's not "." or ".." or the pointed root_level dont_delete_this erase it
Chris@16:          if(FileInformation.cFileName[0] != '.' &&
Chris@16:             !(dont_delete_this && count == 0 && std::strcmp(dont_delete_this, FileInformation.cFileName) == 0)){
Chris@16:             strFilePath.erase();
Chris@16:             strFilePath = refcstrRootDirectory + "\\" + FileInformation.cFileName;
Chris@16: 
Chris@16:             //If it's a directory, go recursive
Chris@16:             if(FileInformation.dwFileAttributes & winapi::file_attribute_directory){
Chris@16:                // Delete subdirectory
Chris@101:                if(!delete_subdirectories_recursive(strFilePath, dont_delete_this, count+1)){
Chris@101:                   winapi::find_close(hFile);
Chris@16:                   return false;
Chris@101:                }
Chris@16:             }
Chris@16:             //If it's a file, just delete it
Chris@16:             else{
Chris@16:                // Set file attributes
Chris@16:                //if(::SetFileAttributes(strFilePath.c_str(), winapi::file_attribute_normal) == 0)
Chris@16:                //return winapi::get_last_error();
Chris@16:                // Delete file
Chris@16:                winapi::unlink_file(strFilePath.c_str());
Chris@16:             }
Chris@16:          }
Chris@16:       //Go to the next file
Chris@16:       } while(winapi::find_next_file(hFile, &FileInformation) == 1);
Chris@16: 
Chris@16:       // Close handle
Chris@16:       winapi::find_close(hFile);
Chris@16: 
Chris@16:       //See if the loop has ended with an error or just because we've traversed all the files
Chris@16:       if(winapi::get_last_error() != winapi::error_no_more_files){
Chris@16:          return false;
Chris@16:       }
Chris@16:       else
Chris@16:       {
Chris@16:          //Erase empty subdirectories or original refcstrRootDirectory
Chris@16:          if(!bSubdirectory && count)
Chris@16:          {
Chris@16:             // Set directory attributes
Chris@16:             //if(::SetFileAttributes(refcstrRootDirectory.c_str(), FILE_ATTRIBUTE_NORMAL) == 0)
Chris@16:                //return ::GetLastError();
Chris@16:             // Delete directory
Chris@16:             if(winapi::remove_directory(refcstrRootDirectory.c_str()) == 0)
Chris@16:                return false;
Chris@16:          }
Chris@16:       }
Chris@16:    }
Chris@16:    return true;
Chris@16: }
Chris@16: 
Chris@16: //This function erases all the subdirectories of a directory except the one pointed by "dont_delete_this"
Chris@16: inline bool delete_subdirectories(const std::string &refcstrRootDirectory, const char *dont_delete_this)
Chris@16: {
Chris@16:    return delete_subdirectories_recursive(refcstrRootDirectory, dont_delete_this, 0u);
Chris@16: }
Chris@16: 
Chris@16: 
Chris@16: template<class Function>
Chris@16: inline bool for_each_file_in_dir(const char *dir, Function f)
Chris@16: {
Chris@16:    void *             hFile;                       // Handle to directory
Chris@101:    winapi::win32_find_data  FileInformation;     // File information
Chris@16: 
Chris@16:    //Get base directory
Chris@16:    std::string str(dir);
Chris@16:    const std::size_t base_root_dir_len = str.size();
Chris@16: 
Chris@16:    //Find all files and directories
Chris@16:    str  +=  "\\*.*";
Chris@16:    hFile = winapi::find_first_file(str.c_str(), &FileInformation);
Chris@16:    if(hFile != winapi::invalid_handle_value){
Chris@16:       do{   //Now loop every file
Chris@16:          str.erase(base_root_dir_len);
Chris@16:          //If it's not "." or ".." skip it
Chris@16:          if(FileInformation.cFileName[0] != '.'){
Chris@16:             str += "\\";   str += FileInformation.cFileName;
Chris@16:             //If it's a file, apply erase logic
Chris@16:             if(!(FileInformation.dwFileAttributes & winapi::file_attribute_directory)){
Chris@16:                f(str.c_str(), FileInformation.cFileName);
Chris@16:             }
Chris@16:          }
Chris@16:       //Go to the next file
Chris@16:       } while(winapi::find_next_file(hFile, &FileInformation) == 1);
Chris@16: 
Chris@16:       // Close handle and see if the loop has ended with an error
Chris@16:       winapi::find_close(hFile);
Chris@16:       if(winapi::get_last_error() != winapi::error_no_more_files){
Chris@16:          return false;
Chris@16:       }
Chris@16:    }
Chris@16:    return true;
Chris@16: }
Chris@16: 
Chris@16: 
Chris@101: #else    //#if defined (BOOST_INTERPROCESS_WINDOWS)
Chris@16: 
Chris@16: typedef int       file_handle_t;
Chris@16: typedef off_t     offset_t;
Chris@16: 
Chris@16: typedef struct mapping_handle_impl_t
Chris@16: {
Chris@16:    file_handle_t  handle;
Chris@16:    bool           is_xsi;
Chris@16: }  mapping_handle_t;
Chris@16: 
Chris@16: typedef enum { read_only      = O_RDONLY
Chris@16:              , read_write     = O_RDWR
Chris@16:              , copy_on_write
Chris@16:              , read_private
Chris@16:              , invalid_mode   = 0xffff
Chris@16:              } mode_t;
Chris@16: 
Chris@16: typedef enum { file_begin     = SEEK_SET
Chris@16:              , file_end       = SEEK_END
Chris@16:              , file_current   = SEEK_CUR
Chris@16:              } file_pos_t;
Chris@16: 
Chris@16: typedef int map_options_t;
Chris@16: static const map_options_t default_map_options = map_options_t(-1);
Chris@16: 
Chris@16: namespace ipcdetail{
Chris@16: 
Chris@16: inline mapping_handle_t mapping_handle_from_file_handle(file_handle_t hnd)
Chris@16: {
Chris@16:    mapping_handle_t ret;
Chris@16:    ret.handle = hnd;
Chris@16:    ret.is_xsi = false;
Chris@16:    return ret;
Chris@16: }
Chris@16: 
Chris@16: inline file_handle_t file_handle_from_mapping_handle(mapping_handle_t hnd)
Chris@16: {  return hnd.handle; }
Chris@16: 
Chris@16: inline bool create_directory(const char *path)
Chris@16: {  return ::mkdir(path, 0777) == 0 && ::chmod(path, 0777) == 0; }
Chris@16: 
Chris@101: inline bool get_temporary_path(char *buffer, std::size_t buf_len, std::size_t &required_len)
Chris@16: {
Chris@101:    required_len = 5u;
Chris@101:    if(buf_len < required_len)
Chris@101:       return false;
Chris@101:    else{
Chris@101:       std::strcpy(buffer, "/tmp");
Chris@16:    }
Chris@101:    return true;
Chris@16: }
Chris@16: 
Chris@16: inline file_handle_t create_new_file
Chris@16:    (const char *name, mode_t mode, const permissions & perm = permissions(), bool temporary = false)
Chris@16: {
Chris@16:    (void)temporary;
Chris@16:    int ret = ::open(name, ((int)mode) | O_EXCL | O_CREAT, perm.get_permissions());
Chris@16:    if(ret >= 0){
Chris@16:       ::fchmod(ret, perm.get_permissions());
Chris@16:    }
Chris@16:    return ret;
Chris@16: }
Chris@16: 
Chris@16: inline file_handle_t create_or_open_file
Chris@16:    (const char *name, mode_t mode, const permissions & perm = permissions(), bool temporary = false)
Chris@16: {
Chris@16:    (void)temporary;
Chris@16:    int ret = -1;
Chris@16:    //We need a loop to change permissions correctly using fchmod, since
Chris@16:    //with "O_CREAT only" ::open we don't know if we've created or opened the file.
Chris@16:    while(1){
Chris@16:       ret = ::open(name, ((int)mode) | O_EXCL | O_CREAT, perm.get_permissions());
Chris@16:       if(ret >= 0){
Chris@16:          ::fchmod(ret, perm.get_permissions());
Chris@16:          break;
Chris@16:       }
Chris@16:       else if(errno == EEXIST){
Chris@16:          if((ret = ::open(name, (int)mode)) >= 0 || errno != ENOENT){
Chris@16:             break;
Chris@16:          }
Chris@16:       }
Chris@101:       else{
Chris@101:          break;
Chris@101:       }
Chris@16:    }
Chris@16:    return ret;
Chris@16: }
Chris@16: 
Chris@16: inline file_handle_t open_existing_file
Chris@16:    (const char *name, mode_t mode, bool temporary = false)
Chris@16: {
Chris@16:    (void)temporary;
Chris@16:    return ::open(name, (int)mode);
Chris@16: }
Chris@16: 
Chris@16: inline bool delete_file(const char *name)
Chris@16: {  return ::unlink(name) == 0;   }
Chris@16: 
Chris@16: inline bool truncate_file (file_handle_t hnd, std::size_t size)
Chris@16: {
Chris@101:    typedef boost::move_detail::make_unsigned<off_t>::type uoff_t;
Chris@16:    if(uoff_t((std::numeric_limits<off_t>::max)()) < size){
Chris@16:       errno = EINVAL;
Chris@16:       return false;
Chris@16:    }
Chris@16:    return 0 == ::ftruncate(hnd, off_t(size));
Chris@16: }
Chris@16: 
Chris@16: inline bool get_file_size(file_handle_t hnd, offset_t &size)
Chris@16: {
Chris@16:    struct stat data;
Chris@16:    bool ret = 0 == ::fstat(hnd, &data);
Chris@16:    if(ret){
Chris@16:       size = data.st_size;
Chris@16:    }
Chris@16:    return ret;
Chris@16: }
Chris@16: 
Chris@16: inline bool set_file_pointer(file_handle_t hnd, offset_t off, file_pos_t pos)
Chris@16: {  return ((off_t)(-1)) != ::lseek(hnd, off, (int)pos); }
Chris@16: 
Chris@16: inline bool get_file_pointer(file_handle_t hnd, offset_t &off)
Chris@16: {
Chris@16:    off = ::lseek(hnd, 0, SEEK_CUR);
Chris@16:    return off != ((off_t)-1);
Chris@16: }
Chris@16: 
Chris@16: inline bool write_file(file_handle_t hnd, const void *data, std::size_t numdata)
Chris@16: {  return (ssize_t(numdata)) == ::write(hnd, data, numdata);  }
Chris@16: 
Chris@16: inline file_handle_t invalid_file()
Chris@16: {  return -1;  }
Chris@16: 
Chris@16: inline bool close_file(file_handle_t hnd)
Chris@16: {  return ::close(hnd) == 0;   }
Chris@16: 
Chris@16: inline bool acquire_file_lock(file_handle_t hnd)
Chris@16: {
Chris@16:    struct ::flock lock;
Chris@16:    lock.l_type    = F_WRLCK;
Chris@16:    lock.l_whence  = SEEK_SET;
Chris@16:    lock.l_start   = 0;
Chris@16:    lock.l_len     = 0;
Chris@16:    return -1 != ::fcntl(hnd, F_SETLKW, &lock);
Chris@16: }
Chris@16: 
Chris@16: inline bool try_acquire_file_lock(file_handle_t hnd, bool &acquired)
Chris@16: {
Chris@16:    struct ::flock lock;
Chris@16:    lock.l_type    = F_WRLCK;
Chris@16:    lock.l_whence  = SEEK_SET;
Chris@16:    lock.l_start   = 0;
Chris@16:    lock.l_len     = 0;
Chris@16:    int ret = ::fcntl(hnd, F_SETLK, &lock);
Chris@16:    if(ret == -1){
Chris@16:       return (errno == EAGAIN || errno == EACCES) ?
Chris@16:                acquired = false, true : false;
Chris@16:    }
Chris@16:    return (acquired = true);
Chris@16: }
Chris@16: 
Chris@16: inline bool release_file_lock(file_handle_t hnd)
Chris@16: {
Chris@16:    struct ::flock lock;
Chris@16:    lock.l_type    = F_UNLCK;
Chris@16:    lock.l_whence  = SEEK_SET;
Chris@16:    lock.l_start   = 0;
Chris@16:    lock.l_len     = 0;
Chris@16:    return -1 != ::fcntl(hnd, F_SETLK, &lock);
Chris@16: }
Chris@16: 
Chris@16: inline bool acquire_file_lock_sharable(file_handle_t hnd)
Chris@16: {
Chris@16:    struct ::flock lock;
Chris@16:    lock.l_type    = F_RDLCK;
Chris@16:    lock.l_whence  = SEEK_SET;
Chris@16:    lock.l_start   = 0;
Chris@16:    lock.l_len     = 0;
Chris@16:    return -1 != ::fcntl(hnd, F_SETLKW, &lock);
Chris@16: }
Chris@16: 
Chris@16: inline bool try_acquire_file_lock_sharable(file_handle_t hnd, bool &acquired)
Chris@16: {
Chris@16:    struct flock lock;
Chris@16:    lock.l_type    = F_RDLCK;
Chris@16:    lock.l_whence  = SEEK_SET;
Chris@16:    lock.l_start   = 0;
Chris@16:    lock.l_len     = 0;
Chris@16:    int ret = ::fcntl(hnd, F_SETLK, &lock);
Chris@16:    if(ret == -1){
Chris@16:       return (errno == EAGAIN || errno == EACCES) ?
Chris@16:                acquired = false, true : false;
Chris@16:    }
Chris@16:    return (acquired = true);
Chris@16: }
Chris@16: 
Chris@16: inline bool release_file_lock_sharable(file_handle_t hnd)
Chris@16: {  return release_file_lock(hnd);   }
Chris@16: 
Chris@16: #if 0
Chris@16: inline bool acquire_file_lock(file_handle_t hnd)
Chris@16: {  return 0 == ::flock(hnd, LOCK_EX); }
Chris@16: 
Chris@16: inline bool try_acquire_file_lock(file_handle_t hnd, bool &acquired)
Chris@16: {
Chris@16:    int ret = ::flock(hnd, LOCK_EX | LOCK_NB);
Chris@16:    acquired = ret == 0;
Chris@16:    return (acquired || errno == EWOULDBLOCK);
Chris@16: }
Chris@16: 
Chris@16: inline bool release_file_lock(file_handle_t hnd)
Chris@16: {  return 0 == ::flock(hnd, LOCK_UN); }
Chris@16: 
Chris@16: inline bool acquire_file_lock_sharable(file_handle_t hnd)
Chris@16: {  return 0 == ::flock(hnd, LOCK_SH); }
Chris@16: 
Chris@16: inline bool try_acquire_file_lock_sharable(file_handle_t hnd, bool &acquired)
Chris@16: {
Chris@16:    int ret = ::flock(hnd, LOCK_SH | LOCK_NB);
Chris@16:    acquired = ret == 0;
Chris@16:    return (acquired || errno == EWOULDBLOCK);
Chris@16: }
Chris@16: 
Chris@16: inline bool release_file_lock_sharable(file_handle_t hnd)
Chris@16: {  return 0 == ::flock(hnd, LOCK_UN); }
Chris@16: #endif
Chris@16: 
Chris@16: inline bool delete_subdirectories_recursive
Chris@16:    (const std::string &refcstrRootDirectory, const char *dont_delete_this)
Chris@16: {
Chris@16:    DIR *d = opendir(refcstrRootDirectory.c_str());
Chris@16:    if(!d) {
Chris@16:       return false;
Chris@16:    }
Chris@16: 
Chris@16:    struct dir_close
Chris@16:    {
Chris@16:       DIR *d_;
Chris@16:       dir_close(DIR *d) : d_(d) {}
Chris@16:       ~dir_close() { ::closedir(d_); }
Chris@16:    } dc(d); (void)dc;
Chris@16: 
Chris@16:    struct ::dirent *de;
Chris@16:    struct ::stat st;
Chris@16:    std::string fn;
Chris@16: 
Chris@16:    while((de=::readdir(d))) {
Chris@16:       if( de->d_name[0] == '.' && ( de->d_name[1] == '\0'
Chris@16:             || (de->d_name[1] == '.' && de->d_name[2] == '\0' )) ){
Chris@16:          continue;
Chris@16:       }
Chris@16:       if(dont_delete_this && std::strcmp(dont_delete_this, de->d_name) == 0){
Chris@16:          continue;
Chris@16:       }
Chris@16:       fn = refcstrRootDirectory;
Chris@16:       fn += '/';
Chris@16:       fn += de->d_name;
Chris@16: 
Chris@16:       if(std::remove(fn.c_str())) {
Chris@16:          if(::stat(fn.c_str(), & st)) {
Chris@16:             return false;
Chris@16:          }
Chris@16:          if(S_ISDIR(st.st_mode)) {
Chris@16:             if(!delete_subdirectories_recursive(fn, 0) ){
Chris@16:                return false;
Chris@16:             }
Chris@16:          } else {
Chris@16:             return false;
Chris@16:          }
Chris@16:       }
Chris@16:    }
Chris@16:    return std::remove(refcstrRootDirectory.c_str()) ? false : true;
Chris@16: }
Chris@16: 
Chris@16: template<class Function>
Chris@16: inline bool for_each_file_in_dir(const char *dir, Function f)
Chris@16: {
Chris@16:    std::string refcstrRootDirectory(dir);
Chris@16: 
Chris@16:    DIR *d = opendir(refcstrRootDirectory.c_str());
Chris@16:    if(!d) {
Chris@16:       return false;
Chris@16:    }
Chris@16: 
Chris@16:    struct dir_close
Chris@16:    {
Chris@16:       DIR *d_;
Chris@16:       dir_close(DIR *d) : d_(d) {}
Chris@16:       ~dir_close() { ::closedir(d_); }
Chris@16:    } dc(d); (void)dc;
Chris@16: 
Chris@16:    struct ::dirent *de;
Chris@16:    struct ::stat st;
Chris@16:    std::string fn;
Chris@16: 
Chris@16:    while((de=::readdir(d))) {
Chris@16:       if( de->d_name[0] == '.' && ( de->d_name[1] == '\0'
Chris@16:             || (de->d_name[1] == '.' && de->d_name[2] == '\0' )) ){
Chris@16:          continue;
Chris@16:       }
Chris@16:       fn = refcstrRootDirectory;
Chris@16:       fn += '/';
Chris@16:       fn += de->d_name;
Chris@16: 
Chris@16:       if(::stat(fn.c_str(), & st)) {
Chris@16:          return false;
Chris@16:       }
Chris@16:       //If it's a file, apply erase logic
Chris@16:       if(!S_ISDIR(st.st_mode)) {
Chris@16:          f(fn.c_str(), de->d_name);
Chris@16:       }
Chris@16:    }
Chris@16:    return true;
Chris@16: }
Chris@16: 
Chris@16: 
Chris@16: //This function erases all the subdirectories of a directory except the one pointed by "dont_delete_this"
Chris@16: inline bool delete_subdirectories(const std::string &refcstrRootDirectory, const char *dont_delete_this)
Chris@16: {
Chris@16:    return delete_subdirectories_recursive(refcstrRootDirectory, dont_delete_this );
Chris@16: }
Chris@16: 
Chris@101: #endif   //#if defined (BOOST_INTERPROCESS_WINDOWS)
Chris@16: 
Chris@16: inline bool open_or_create_directory(const char *dir_name)
Chris@16: {
Chris@16:    //If fails, check that it's because it already exists
Chris@16:    if(!create_directory(dir_name)){
Chris@16:       error_info info(system_error_code());
Chris@16:       if(info.get_error_code() != already_exists_error){
Chris@16:          return false;
Chris@16:       }
Chris@16:    }
Chris@16:    return true;
Chris@16: }
Chris@16: 
Chris@101: inline std::string get_temporary_path()
Chris@101: {
Chris@101:    std::size_t required_len = 0;
Chris@101:    get_temporary_path(0, 0, required_len);
Chris@101:    std::string ret_str(required_len, char(0));
Chris@101:    get_temporary_path(&ret_str[0], ret_str.size(), required_len);
Chris@101:    while(!ret_str.empty() && !ret_str[ret_str.size()-1]){
Chris@101:       ret_str.erase(ret_str.size()-1);
Chris@101:    }
Chris@101: 
Chris@101:    return ret_str;
Chris@101: }
Chris@16: 
Chris@16: }  //namespace ipcdetail{
Chris@16: }  //namespace interprocess {
Chris@16: }  //namespace boost {
Chris@16: 
Chris@16: #include <boost/interprocess/detail/config_end.hpp>
Chris@16: 
Chris@16: #endif   //BOOST_INTERPROCESS_DETAIL_OS_FILE_FUNCTIONS_HPP