FileSystemStorage.cpp File Reference

#include "DCPS/DdsDcps_pch.h"
#include "FileSystemStorage.h"
#include "ace/Dirent.h"
#include "ace/Vector_T.h"
#include "ace/OS_NS_sys_stat.h"
#include "ace/OS_NS_macros.h"
#include "ace/OS_NS_unistd.h"
#include "ace/OS_NS_stdio.h"
#include <cstdio>
#include <cstring>
#include <stdexcept>
#include <fstream>

Include dependency graph for FileSystemStorage.cpp:

Go to the source code of this file.

Namespaces
namespace	OpenDDS
namespace	OpenDDS::FileSystemStorage
Typedefs
typedef size_t	String_Index_t
Functions
void	add_slash (ACE_TString &str)
bool	increment (ACE_TString &logical)
int	dds_mkdir (const ACE_TCHAR *path)
int	dds_chdir (const ACE_TCHAR *path)
bool	is_dir (const ACE_TCHAR *path)
int	dds_rmdir (const ACE_TCHAR *path)
ACE_TString	overflow_dir_name (unsigned int n)
void	recursive_remove (const ACE_TString &dirname)
ACE_TString	OpenDDS::FileSystemStorage::b32h_encode (const ACE_TCHAR *decoded)
ACE_TString	OpenDDS::FileSystemStorage::b32h_decode (const ACE_TCHAR *encoded)
Variables
const size_t	FSS_MAX_FILE_NAME = 150
const size_t	FSS_MAX_FILE_NAME_ENCODED = 240
const size_t	FSS_MAX_OVERFLOW_DIR = 9999
const ACE_TCHAR	FSS_DEFAULT_FILE_NAME [] = ACE_TEXT("F00000000000000")
const ACE_TCHAR	FSS_DEFAULT_DIR_NAME [] = ACE_TEXT("D00000000000000")
ACE_TString	cwd_

---

Typedef Documentation

typedef size_t String_Index_t

Definition at line 26 of file FileSystemStorage.cpp.

---

Function Documentation

void @6::add_slash

(

ACE_TString &

str

)

[static]

Definition at line 35 of file FileSystemStorage.cpp.

Referenced by OpenDDS::FileSystemStorage::Directory::Directory(), and OpenDDS::FileSystemStorage::Directory::scan_dir().

{
  if (str.length() == 0) return;

  if (str[str.length() - 1] == ACE_TEXT('\\')) {
    str[str.length() - 1] = ACE_TEXT('/');

  } else if (str[str.length() - 1] != ACE_TEXT('/')) {
    str += ACE_TEXT('/');
  }
}

int @6::dds_chdir

(

const ACE_TCHAR *

path

)

[inline, static]

Definition at line 158 of file FileSystemStorage.cpp.

Referenced by OpenDDS::FileSystemStorage::Directory::make_new_subdir().

{
  return ACE_OS::chdir(path);
}

int @6::dds_mkdir

(

const ACE_TCHAR *

path

)

[inline, static]

Definition at line 153 of file FileSystemStorage.cpp.

Referenced by OpenDDS::FileSystemStorage::Directory::add_entry(), OpenDDS::FileSystemStorage::Directory::Directory(), and OpenDDS::FileSystemStorage::Directory::make_new_subdir().

{
  return ACE_OS::mkdir(path);
}

int @6::dds_rmdir

(

const ACE_TCHAR *

path

)

[inline, static]

Definition at line 169 of file FileSystemStorage.cpp.

Referenced by OpenDDS::FileSystemStorage::Directory::make_new_subdir(), recursive_remove(), and OpenDDS::FileSystemStorage::Directory::removing().

{
  return ACE_OS::rmdir(path);
}

bool @6::increment

(

ACE_TString &

logical

)

[static]

Definition at line 48 of file FileSystemStorage.cpp.

Referenced by OpenDDS::FileSystemStorage::Directory::create_next_dir(), and OpenDDS::FileSystemStorage::Directory::create_next_file().

{
  for (size_t i = logical.length() - 1; i >= 1; --i) {
    //we could use the entire range of 255 values but we'll keep
    //these names to 7-bit ASCII
    if (logical[i] < 0x7F) {
      ++logical[i];
      return true;
    }
  }

  return false;
}

bool @6::is_dir

(

const ACE_TCHAR *

path

)

[inline, static]

Definition at line 163 of file FileSystemStorage.cpp.

Referenced by recursive_remove(), and OpenDDS::FileSystemStorage::Directory::scan_dir().

{
  ACE_stat st;
  return ACE_OS::stat(path, &st) != -1 && (st.st_mode & S_IFDIR);
}

ACE_TString @6::overflow_dir_name

(

unsigned int

n

)

[static]

Definition at line 176 of file FileSystemStorage.cpp.

Referenced by OpenDDS::FileSystemStorage::Directory::add_entry().

{
  ACE_TString of_name = ACE_TEXT("_overflow.    /");
  ACE_TCHAR* buf = &of_name[10];
  ACE_OS::snprintf(buf, 5, ACE_TEXT("%04u"), n);
  of_name[14] = L'/'; // snprintf has clobbered / with a null
  return of_name;
}

void @6::recursive_remove

(

const ACE_TString &

dirname

)

[static]

Definition at line 209 of file FileSystemStorage.cpp.

References DDS_DIRENT, DDS_Dirent, dds_rmdir(), and is_dir().

Referenced by OpenDDS::FileSystemStorage::Directory::remove().

{
  using namespace OpenDDS::FileSystemStorage;
  DDS_Dirent dir(dirname.c_str());
  {
    CwdGuard cg(dirname);

    for (DDS_DIRENT* ent = dir.read(); ent; ent = dir.read()) {
      if (ent->d_name[0] == ACE_TEXT('.') && (!ent->d_name[1] ||
          (ent->d_name[1] == ACE_TEXT('.') && !ent->d_name[2]))) {
        continue; // skip '.' and '..'
      }

      if (is_dir(ent->d_name)) {
        recursive_remove(ent->d_name);

      } else { // regular file
        ACE_OS::unlink(ent->d_name);
      }
    }
  }
  dds_rmdir(dirname.c_str());
}

---

Variable Documentation

ACE_TString cwd_

Definition at line 186 of file FileSystemStorage.cpp.

const ACE_TCHAR FSS_DEFAULT_DIR_NAME[] = ACE_TEXT("D00000000000000") [static]

Definition at line 33 of file FileSystemStorage.cpp.

const ACE_TCHAR FSS_DEFAULT_FILE_NAME[] = ACE_TEXT("F00000000000000") [static]

Definition at line 32 of file FileSystemStorage.cpp.

const size_t FSS_MAX_FILE_NAME = 150 [static]

Definition at line 30 of file FileSystemStorage.cpp.

const size_t FSS_MAX_FILE_NAME_ENCODED = 240 [static]

Definition at line 30 of file FileSystemStorage.cpp.

Referenced by OpenDDS::FileSystemStorage::Directory::scan_dir().

const size_t FSS_MAX_OVERFLOW_DIR = 9999 [static]

Definition at line 31 of file FileSystemStorage.cpp.

Referenced by OpenDDS::FileSystemStorage::Directory::add_entry().

---