tools::wroot::file Class Reference

Inheritance diagram for tools::wroot::file:

Collaboration diagram for tools::wroot::file:

Public Member Functions
virtual const std::string &	s_cls () const
virtual bool	verbose () const
virtual std::ostream &	out () const
virtual bool	byte_swap () const
virtual bool	set_pos (seek a_offset=0, from a_from=begin)
virtual seek	END () const
virtual void	set_END (seek a_end)
virtual bool	write_buffer (const char *a_buffer, uint32 a_length)
virtual uint32	version () const
virtual bool	synchronize ()
virtual bool	ziper (char a_key, compress_func &a_func) const
virtual uint32	compression () const
virtual void	compress_buffer (const buffer &a_buffer, char *&a_kbuf, uint32 &a_klen, bool &a_kdel)
	file (std::ostream &a_out, const std::string &a_path, bool a_verbose=false)
virtual	~file ()
const std::string &	path () const
void	set_compression (uint32 a_level)
bool	is_open () const
void	close ()
directory &	dir ()
const directory &	dir () const
bool	write (uint32 &a_nbytes)
bool	add_ziper (char a_key, compress_func a_func)
Public Member Functions inherited from tools::wroot::ifile
virtual	~ifile ()

Static Public Member Functions
static const std::string &	s_class ()

Protected Types
enum	EAccessMode { kFileExists = 0, kExecutePermission = 1, kWritePermission = 2, kReadPermission = 4 }

Protected Member Functions
	file (const file &a_from)
file &	operator= (const file &)
bool	write_header ()
bool	write_streamer_infos ()
bool	make_free_seg (seek a_first, seek a_last)
bool	write_free_segments ()
int	error_number ()
void	reset_error_number ()

Static Protected Member Functions
static bool	access_path (const std::string &a_path, EAccessMode a_mode)
static bool	unlink (const std::string &a_path)
static int	_open (const char *a_name, int a_flags, unsigned int a_mode)
static bool	zip (std::ostream &a_out, compress_func a_func, int a_level, uint32 a_srcsize, char *a_src, uint32 a_tgtsize, char *a_tgt, uint32 &a_irep)

Protected Attributes
std::ostream &	m_out
std::string	m_path
bool	m_verbose
int	m_file
std::string	m_title
directory	m_root_directory
std::map< char, compress_func >	m_zipers
std::list< free_seg * >	m_free_segs
uint32	m_version
seek	m_BEGIN
seek	m_END
seek	m_seek_free
uint32	m_nbytes_free
uint32	m_nbytes_name
char	m_units
uint32	m_compress
seek	m_seek_info
uint32	m_nbytes_info

Additional Inherited Members
Public Types inherited from tools::wroot::ifile
enum	from { begin, current, end }

Detailed Description

Definition at line 34 of file file.

Member Enumeration Documentation

EAccessMode

enum tools::wroot::file::EAccessMode

protected

Enumerator
kFileExists
kExecutePermission
kWritePermission
kReadPermission

Definition at line 458 of file file.

                   {
    kFileExists        = 0,
    kExecutePermission = 1,
    kWritePermission   = 2,
    kReadPermission    = 4
  };

Constructor & Destructor Documentation

file() [1/2]

tools::wroot::file::file ( std::ostream &  a_out, const std::string &  a_path, bool  a_verbose = false  )

inline

Definition at line 221 of file file.

  :m_out(a_out)
  ,m_path(a_path)
  ,m_verbose(a_verbose)
  ,m_file(not_open())
  //,m_bytes_write(0)
  ,m_root_directory(get_me(),nosuffix(a_path),m_title)
  // begin of record :
  ,m_version(0)
  ,m_BEGIN(0)
  ,m_END(0)
  ,m_seek_free(0)
  ,m_nbytes_free(0)
  ,m_nbytes_name(0)
  ,m_units(4)
  ,m_compress(1)
  ,m_seek_info(0)
  ,m_nbytes_info(0)
  {
#ifdef TOOLS_MEM
    mem::increment(s_class().c_str());
#endif
 
    m_version = version();
 
    if(access_path(m_path,kFileExists)) unlink(m_path);
 
    if(!m_root_directory.is_valid()) {
      m_out << "tools::wroot::file::file :"
            << " " << sout(m_path) << " root directory badly created."
            << std::endl;
      return;
    }
 
    m_file = _open(a_path.c_str(),
#ifdef _MSC_VER
                               O_RDWR | O_CREAT | O_BINARY,S_IREAD | S_IWRITE
#else
                               O_RDWR | O_CREAT,0644
#endif
    );
    if(m_file==not_open()) {
      m_out << "tools::wroot::file::file :"
            << " can't open " << sout(a_path) << "."
            << std::endl;
      return;
    }
 
    //initialize :
 
    m_BEGIN = kBegin();  // First used word in file following the file header.
    m_END = m_BEGIN;   // Pointer to end of file.
 
    m_free_segs.push_back(new free_seg(m_out,m_BEGIN,START_BIG_FILE()));
 
    // Write Directory info :
    uint32 namelen =
      key::std_string_record_size(m_path) +
      key::std_string_record_size(m_title);
    uint32 nbytes = namelen + m_root_directory.record_size();
    wroot::key key(m_out,*this,0,m_path,m_title,"TFile",nbytes); // It does a (*this).set_END().
 
    // m_nbytes_name = start point of directory info from key head.
    m_nbytes_name = key.key_length() + namelen;
    m_root_directory.set_nbytes_name(m_nbytes_name);
    m_root_directory.set_seek_directory(key.seek_key()); //at EOF.
 
    //the below write 45 bytes at BOF (Begin Of File).
    if(!write_header()) { //need m_nbytes_name, m_END after key written.
      m_out << "tools::wroot::file::file :"
            << " can't write file header."
            << std::endl;
      return;
    }
 
   {char* pos = key.data_buffer();
    wbuf wb(m_out,byte_swap(),key.eob(),pos);
    if(!wb.write(m_path)) return;
    if(!wb.write(m_title)) return;
    if(!m_root_directory.to_buffer(wb)) return;}
 
    if(m_verbose) {
      m_out << "tools::wroot::file::file :"
            << " write key ("
            << namelen
            << ", "
            << m_root_directory.record_size()
            << ", "
            << nbytes
            << ", "
            << m_nbytes_name
            << ", "
            << key.seek_key()
            << ")."
            << std::endl;
    }
 
    key.set_cycle(1);
    if(!key.write_self(*this)) {
      m_out << "tools::wroot::file::file :"
            << " key.write_self() failed."
            << std::endl;
      return;
    }
 
    //the below write at kBegin + nbytes.
    //64+52
    uint32 n;
    if(!key.write_file(*this,n)) {
      m_out << "tools::wroot::file::file :"
            << " can't write key in file."
            << std::endl;
      return;
    }
    //::printf("debug : file::file : write key : %d\n",n);
 
  }

~file()

virtual tools::wroot::file::~file ( )

inlinevirtual

Definition at line 338 of file file.

                  {
    close();
#ifdef TOOLS_MEM
    mem::decrement(s_class().c_str());
#endif
  }

file() [2/2]

tools::wroot::file::file ( const file &  a_from )

inlineprotected

Definition at line 345 of file file.

  :ifile(a_from)
  ,m_out(a_from.m_out)
  ,m_root_directory(get_me())
  {
#ifdef TOOLS_MEM
    mem::increment(s_class().c_str());
#endif
  }

Member Function Documentation

_open()

static int tools::wroot::file::_open ( const char *  a_name, int  a_flags, unsigned int  a_mode  )

inlinestaticprotected

Definition at line 491 of file file.

                                                                       {
#if defined(__linux__) && (__GLIBC__ == 2) && (__GLIBC_MINOR__ >= 2)
     return ::open64(a_name,a_flags,a_mode);
#else
     return ::open(a_name,a_flags,a_mode);
#endif
  }

access_path()

static bool tools::wroot::file::access_path ( const std::string &  a_path, EAccessMode  a_mode  )

inlinestaticprotected

Definition at line 464 of file file.

                                                                     {
    // Returns true if one can access a file using the specified access mode.
    // Mode is the same as for the WinNT access(2) function.
#ifdef _MSC_VER
    return (::_access(a_path.c_str(),a_mode) == 0) ? true : false;
#else
    return (::access(a_path.c_str(),a_mode) == 0) ? true : false;
#endif
  }

add_ziper()

bool tools::wroot::file::add_ziper ( char  a_key, compress_func  a_func  )

inline

Definition at line 447 of file file.

                                                 {
    std::map<char,compress_func>::const_iterator it = m_zipers.find(a_key);
    if(it!=m_zipers.end()) {
      //(*it).second = a_func; //override ?
      return false;
    } else {
      m_zipers[a_key] = a_func;
      return true;
    }
  }

byte_swap()

virtual bool tools::wroot::file::byte_swap ( ) const

inlinevirtual

Implements tools::wroot::ifile.

Definition at line 48 of file file.

{return is_little_endian();}

close()

void tools::wroot::file::close ( )

inline

Definition at line 369 of file file.

               {
    if(m_file==not_open()) return;
    m_root_directory.close();
 
    if(m_free_segs.size()) {
      if(!write_free_segments()) {
        m_out << "tools::wroot::file::close :"
              << " can't write free segments."
              << std::endl;
      }
      if(!write_header())  { // Now write file header
        m_out << "tools::wroot::file::close :"
              << " can't write file header."
              << std::endl;
      }
    }
 
   {std::list<free_seg*>::iterator it;
    for(it=m_free_segs.begin();
        it!=m_free_segs.end();
        it = m_free_segs.erase(it)) {
      delete (*it);
    }}
 
    ::close(m_file);
    m_file = not_open();
  }

compress_buffer()

virtual void tools::wroot::file::compress_buffer ( const buffer &  a_buffer, char *&  a_kbuf, uint32 &  a_klen, bool &  a_kdel  )

inlinevirtual

Implements tools::wroot::ifile.

Definition at line 169 of file file.

                                                                                                 {
    //NOTE : if(kdelete) delete [] kbuf;
 
    a_kbuf = 0;
    a_klen = 0;
    a_kdel = false;
 
    uint32 nbytes = a_buffer.length();
    uint32 cxlevel = m_compress;
    if(cxlevel && (nbytes>256)) {
      compress_func func;
      if(!ziper('Z',func)) {
        //m_out << "tools::wroot::directory::write_object :"
        //      << " zlib ziper not found."
        //      << std::endl;
        a_kbuf = (char*)a_buffer.buf();
        a_klen = a_buffer.length();
        a_kdel = false;
      } else {
        const uint32 kMAXBUF = 0xffffff;
        const uint32 HDRSIZE = 9;
        uint32 nbuffers = nbytes/kMAXBUF;
        uint32 buflen = nbytes+HDRSIZE*(nbuffers+1);
        a_kbuf = new char[buflen];
        a_kdel = true;
        char* src = (char*)a_buffer.buf();
        char* tgt = a_kbuf;
        uint32 nzip = 0;
        for(uint32 i=0;i<=nbuffers;i++) {
          uint32 bufmax = ((i == nbuffers) ? nbytes - nzip : kMAXBUF);
          uint32 nout;
          if(!zip(m_out,func,cxlevel,bufmax,src,bufmax,tgt,nout)) {
            delete [] a_kbuf;
            a_kbuf = (char*)a_buffer.buf();
            a_klen = a_buffer.length();
            a_kdel = false;
            break;
          }
          tgt += nout; //nout includes HDRSIZE
          a_klen += nout;
          src += kMAXBUF;
          nzip += kMAXBUF;
        }
        //::printf("debug : compress : end : %u %u\n",nbytes,klen);
      }
    } else {
      a_kbuf = (char*)a_buffer.buf();
      a_klen = a_buffer.length();
      a_kdel = false;
    }
  }

compression()

virtual uint32 tools::wroot::file::compression ( ) const

inlinevirtual

Implements tools::wroot::ifile.

Definition at line 168 of file file.

{return m_compress;}

dir() [1/2]

directory& tools::wroot::file::dir ( )

inline

Definition at line 397 of file file.

{return m_root_directory;}

dir() [2/2]

const directory& tools::wroot::file::dir ( ) const

inline

Definition at line 398 of file file.

{return m_root_directory;}

END()

virtual seek tools::wroot::file::END ( ) const

inlinevirtual

Implements tools::wroot::ifile.

Definition at line 79 of file file.

{return m_END;}

error_number()

int tools::wroot::file::error_number ( )

inlineprotected

Definition at line 761 of file file.

{return errno;}

is_open()

bool tools::wroot::file::is_open ( ) const

inline

Definition at line 367 of file file.

{return (m_file==not_open()?false:true);}

make_free_seg()

bool tools::wroot::file::make_free_seg ( seek  a_first, seek  a_last  )

inlineprotected

Definition at line 589 of file file.

                                               {
    // Mark unused bytes on the file :
    //  The list of free segments is in the m_free_segs list
    //  When an object is deleted from the file, the freed space is added
    //  into the FREE linked list (m_free_segs). The FREE list consists
    //  of a chain  of consecutive free segments on the file. At the same
    //  time, the first 4 bytes of the freed record on the file
    //  are overwritten by GAPSIZE where
    //    GAPSIZE = -(Number of bytes occupied by the record).
 
    if(m_free_segs.empty()) {
      m_out << "tools::wroot::file::make_free_seg :"
            << " free_seg list should not be empty here."
            << std::endl;
      return false;
    }
 
    free_seg* newfree = add_free(m_free_segs,a_first,a_last);
    if(!newfree) {
      m_out << "tools::wroot::file::make_free_seg :"
            << " add_free failed."
            << std::endl;
      return false;
    }
 
    seek nfirst = newfree->first();
    seek nlast = newfree->last();
 
    seek _nbytes = nlast-nfirst+1;
    if(_nbytes>START_BIG_FILE()) _nbytes = START_BIG_FILE();
    int nbytes = -int(_nbytes);
 
    int nb = sizeof(int);
 
    char psave[128];
    const char* eob = psave + nb;
    char* pos = psave;
 
    wbuf wb(m_out,byte_swap(),eob,pos);
    if(!wb.write(nbytes)) return false;
 
    if(nlast == (m_END-1)) m_END = nfirst;
    if(!set_pos(nfirst)) return false;
    if(!write_buffer(psave,nb)) return false;
    if(!synchronize()) return false;
    return true;
  }

operator=()

file& tools::wroot::file::operator= ( const file &  )

inlineprotected

Definition at line 354 of file file.

{return *this;}

out()

virtual std::ostream& tools::wroot::file::out ( ) const

inlinevirtual

Implements tools::wroot::ifile.

Definition at line 46 of file file.

{return m_out;}

path()

const std::string& tools::wroot::file::path ( ) const

inline

Definition at line 356 of file file.

{return m_path;}

reset_error_number()

void tools::wroot::file::reset_error_number ( )

inlineprotected

Definition at line 762 of file file.

{errno = 0;}

s_class()

static const std::string& tools::wroot::file::s_class ( )

inlinestatic

Definition at line 39 of file file.

                                    {
    static const std::string s_v("tools::wroot::file");
    return s_v;
  }

s_cls()

virtual const std::string& tools::wroot::file::s_cls ( ) const

inlinevirtual

Definition at line 43 of file file.

{return s_class();}

set_compression()

void tools::wroot::file::set_compression ( uint32  a_level )

inline

Definition at line 358 of file file.

                                       {
    // level = 0 objects written to this file will not be compressed.
    // level = 1 minimal compression level but fast.
    // ....
    // level = 9 maximal compression level but slow.
    m_compress = a_level;
    if(m_compress>9) m_compress = 9;
  }

set_END()

virtual void tools::wroot::file::set_END ( seek  a_end )

inlinevirtual

Implements tools::wroot::ifile.

Definition at line 80 of file file.

                                  {
    m_END = a_end;
 
    if(m_free_segs.empty()) {
      m_out << "tools::wroot::file::set_END :"
            << " free_seg list should not be empty here."
            << std::endl;
    } else {
      free_seg* end_seg = m_free_segs.back();
      if(end_seg->last()!=START_BIG_FILE()) {
        m_out << "tools::wroot::file::set_END :"
              << " last free_seg is not the ending of file one."
              << " free_seg list looks corrupted."
              << std::endl;
      } else {
        m_free_segs.back()->set_first(m_END);
      }
    }
  }

set_pos()

virtual bool tools::wroot::file::set_pos ( seek  a_offset = 0, from  a_from = begin  )

inlinevirtual

Implements tools::wroot::ifile.

Definition at line 49 of file file.

                                                             {
    int whence = 0;
    switch(a_from) {
    case begin:
      whence = SEEK_SET;
      break;
    case current:
      whence = SEEK_CUR;
      break;
    case end:
      whence = SEEK_END;
      break;
    }
 
#if defined(__linux__) && (__GLIBC__ == 2) && (__GLIBC_MINOR__ >= 2)
    if (::lseek64(m_file, a_offset, whence) < 0) {
#elif defined(_MSC_VER)
    if (::_lseeki64(m_file, a_offset, whence) < 0) {
#else
    if (::lseek(m_file, a_offset, whence) < 0) {
#endif
      m_out << "tools::wroot::file::set_pos :"
            << " cannot set position " << a_offset
            << " in file " << sout(m_path) << "."
            << std::endl;
      return false;
    }
    return true;
  }

synchronize()

virtual bool tools::wroot::file::synchronize ( )

inlinevirtual

Implements tools::wroot::ifile.

Definition at line 137 of file file.

                            {
    // Synchornize a file's in-core and on-disk states.
#ifdef _MSC_VER
    if(::_commit(m_file)) {
      m_out << "tools::wroot::file::synchronize :"
            << " in _commit() for file " << sout(m_path) << "."
            << std::endl;
      return false;
    }
#elif defined(__MINGW32__) || defined(__MINGW64__)
    return true;
#else
    if (::fsync(m_file) < 0) {
      m_out << "tools::wroot::file::synchronize :"
            << " error in fsync() for file " << sout(m_path) << "."
            << std::endl;
      return false;
    }
#endif
    return true;
  }

unlink()

static bool tools::wroot::file::unlink ( const std::string &  a_path )

inlinestaticprotected

Definition at line 473 of file file.

                                             {
    // Unlink, i.e. remove, a file or directory. Returns true when succesfull,
    // false in case of failure.
    struct stat finfo;
    if (::stat(a_path.c_str(),&finfo) < 0) return false;
#ifdef _MSC_VER
    if (finfo.st_mode & S_IFDIR)
      return (::_rmdir(a_path.c_str())==-1 ? false : true);
    else
      return (::unlink(a_path.c_str())==-1 ? false : true);
#else
    if (S_ISDIR(finfo.st_mode))
      return (::rmdir(a_path.c_str())==-1 ? false : true);
    else
      return (::unlink(a_path.c_str())==-1 ? false : true);
#endif
  }

verbose()

virtual bool tools::wroot::file::verbose ( ) const

inlinevirtual

Implements tools::wroot::ifile.

Definition at line 45 of file file.

{return m_verbose;}

version()

virtual uint32 tools::wroot::file::version ( ) const

inlinevirtual

Implements tools::wroot::ifile.

Definition at line 126 of file file.

                                 {
    // Return version id as an integer, i.e. "2.22/04" -> 22204.
    static const uint32 ROOT_MAJOR_VERSION = 4;
    static const uint32 ROOT_MINOR_VERSION = 0;
    static const uint32 ROOT_PATCH_VERSION = 0;
    return
      10000 * ROOT_MAJOR_VERSION +
      100 * ROOT_MINOR_VERSION +
      ROOT_PATCH_VERSION;
  }

write()

bool tools::wroot::file::write ( uint32 &  a_nbytes )

inline

Definition at line 400 of file file.

                              {
    // Write memory objects to this file :
    //  Loop on all objects in m_root_directory (including subdirectories).
    //  A new key is created in the directories m_keys linked list
    //  for each object.
    //  The list of keys is then saved on the file (via write_keys)
    //  as a single data record.
    //  The directory header info is rewritten on the directory header record.
    //  //The linked list of FREE segments is written.
    //  The file header is written (bytes 1->m_BEGIN).
    a_nbytes = 0;
 
    if(m_verbose) {
      m_out << "tools::wroot::file::write :"
            << " writing Name=" << sout(m_path)
            << " Title=" << sout(m_title) << "."
            << std::endl;
    }
 
    uint32 nbytes;
    if(!m_root_directory.write(nbytes)) return false; // Write directory tree
 
    if(!write_streamer_infos()) {
      m_out << "tools::wroot::file::write :"
            << " write_streamer_infos failed."
            << std::endl;
      return false;
    }
 
    if(!write_free_segments()) {
      m_out << "tools::wroot::file::write :"
            << " can't write free segments."
            << std::endl;
      return false;
    }
 
    if(!write_header()) { //write 45 bytes at BOF.
      m_out << "tools::wroot::file::write :"
            << " can't write file header."
            << std::endl;
      return false;
    }
 
    a_nbytes = nbytes;
    return true;
  }

write_buffer()

virtual bool tools::wroot::file::write_buffer ( const char *  a_buffer, uint32  a_length  )

inlinevirtual

Implements tools::wroot::ifile.

Definition at line 100 of file file.

                                                                  {
    // Write a buffer to the file. This is the basic low level write operation.
#ifdef _MSC_VER
    typedef int ssize_t;
#endif
    ssize_t siz;
    while ((siz = ::write(m_file,a_buffer,a_length)) < 0 &&
            error_number() == EINTR) reset_error_number();
 
    if(siz < 0) {
      m_out << "tools::wroot::file::write_buffer :"
            << " error writing to file " << sout(m_path) << "."
            << std::endl;
      return false;
    }
    if(siz!=(ssize_t)a_length) {
      m_out << "tools::wroot::file::write_buffer :"
           << "error writing all requested bytes to file " << sout(m_path)
           << ", wrote " << long_out(siz) << " of " << a_length
           << std::endl;
      return false;
    }
    //m_bytes_write  += siz;
    return true;
  }

write_free_segments()

bool tools::wroot::file::write_free_segments ( )

inlineprotected

Definition at line 637 of file file.

                            {
    //  The linked list of FREE segments (fFree) is written as a single data record.
 
    // Delete old record if it exists :
    if(m_seek_free){
      if(!make_free_seg(m_seek_free, m_seek_free + m_nbytes_free -1)) {
        m_out << "tools::wroot::file::write_free_segments :"
              << " key.write_self() failed."
              << std::endl;
        return false;
      }
    }
 
    //::printf("debug : write_free_segments : seg list :\n");
 
    uint32 nbytes = 0;
   {tools_lforcit(free_seg*,m_free_segs,it) {
      nbytes += (*it)->record_size();
      //::printf("debug : write_free_segments : %lu %lu\n",
      //         (*it)->first(),(*it)->last());
    }}
    if(!nbytes) return true;
 
    wroot::key key(m_out,*this,
                   m_root_directory.seek_directory(),
                   m_path,m_title,"TFile",
                   nbytes); // It does a (*this).set_END().
    if(!key.seek_key()) return false;
 
   {char* pos = key.data_buffer();
    wbuf wb(m_out,byte_swap(),key.eob(),pos);
    tools_lforcit(free_seg*,m_free_segs,it) {
      if(!(*it)->fill_buffer(wb)) return false;
    }}
 
    //key.set_cycle(1);
    if(!key.write_self(*this)) {
      m_out << "tools::wroot::file::write_free_segments :"
            << " key.write_self() failed."
            << std::endl;
      return false;
    }
 
    m_seek_free = key.seek_key();
    m_nbytes_free = key.number_of_bytes();
    if(m_verbose) {
      m_out << "tools::wroot::file::write_free_segments :"
            << " write key." << std::endl;
    }
 
    uint32 n;
    if(!key.write_file(*this,n)) return false;
    if(!n) return false;
 
    return true;
  }

write_header()

bool tools::wroot::file::write_header ( )

inlineprotected

Definition at line 498 of file file.

                      {
    const char root[] = "root";
    //char psave[kBegin()];
    char psave[128];
    const char* eob = psave + kBegin();
    char* pos = psave;
    ::memcpy(pos,root,4); pos += 4;
    uint32 vers = m_version;
    if((m_END>START_BIG_FILE())        ||
       (m_seek_free>START_BIG_FILE())  ||
       (m_seek_info>START_BIG_FILE())  ){
      vers += 1000000;
      m_units = 8;
    }
    wbuf wb(m_out,byte_swap(),eob,pos);
    if(!wb.write(vers)) return false;
    if(!wb.write((seek32)m_BEGIN)) return false;
    if(vers>1000000) {
      if(!wb.write(m_END)) return false;
      if(!wb.write(m_seek_free)) return false;
    } else {
      if(!wb.write((seek32)m_END)) return false;
      if(!wb.write((seek32)m_seek_free)) return false;
    }
    if(!wb.write(m_nbytes_free)) return false;
    //int nfree  = fFreeSegments.size();
    uint32 nfree  = 0; //FIXME
    if(!wb.write(nfree)) return false;
    if(!wb.write(m_nbytes_name)) return false;
    if(!wb.write(m_units)) return false;
    if(!wb.write(m_compress)) return false;
    if(vers>1000000) {
      if(!wb.write(m_seek_info)) return false;
    } else {
      if(!wb.write((seek32)m_seek_info)) return false;
    }
    if(!wb.write(m_nbytes_info)) return false;
    if(!set_pos()) return false; //BOF
    uint32 nbytes = uint32(pos - psave);
    //::printf("debug : write_header : %d\n",nbytes);
    if(!write_buffer(psave,nbytes)) return false;
    if(!synchronize()) return false;
    return true;
  }

write_streamer_infos()

bool tools::wroot::file::write_streamer_infos ( )

inlineprotected

Definition at line 543 of file file.

                              {
    obj_list<streamer_info> sinfos;
    fill_infos(sinfos,m_out);
 
    if(sinfos.empty()) return false;
 
    buffer bref(m_out,byte_swap(),256);
 
    if(!sinfos.stream(bref)) {
      m_out << "tools::wroot::file::write_streamer_infos :"
            << " cannot stream obj_list<streamer_info>."
            << std::endl;
      return false;
    }
    uint32 nbytes = bref.length();
 
    wroot::key key(m_out,*this,
                   m_root_directory.seek_directory(),
                   "StreamerInfo","",
                   sinfos.store_cls(),
                   nbytes); // It does a (*this).set_END().
    if(!key.seek_key()) return false;
 
    if(!bref.displace_mapped(key.key_length())) return false;
 
    ::memcpy(key.data_buffer(),bref.buf(),nbytes);
 
    //key.set_cycle(1);
    if(!key.write_self(*this)) {
      m_out << "tools::wroot::file::write_streamer_infos :"
            << " key.write_self() failed."
            << std::endl;
      return false;
    }
 
    m_seek_info = key.seek_key();
    m_nbytes_info = key.number_of_bytes();
    //FIXME sumBuffer(key.objectSize());
 
    uint32 n;
    if(!key.write_file(*this,n)) return false;
    if(!n) return false;
 
    return true;
  }

zip()

static bool tools::wroot::file::zip ( std::ostream &  a_out, compress_func  a_func, int  a_level, uint32  a_srcsize, char *  a_src, uint32  a_tgtsize, char *  a_tgt, uint32 &  a_irep  )

inlinestaticprotected

Definition at line 694 of file file.

                                 {
 
    // from Rio/Bits/R__zip using zlib.
 
    const uint32 HDRSIZE = 9;
 
    if(a_tgtsize<HDRSIZE) {
      a_out << "tools::wroot::directory::zip :"
            << " target buffer too small."
            << std::endl;
      a_irep = 0;
      return false;
    }
    if(a_srcsize>0xffffff) {
      a_out << "tools::wroot::directory::zip :"
            << " source buffer too big."
            << std::endl;
      a_irep = 0;
      return false;
    }
 
    uint32 out_size;
    if(!a_func(a_out,a_level,
               a_srcsize,a_src,
               a_tgtsize,a_tgt+HDRSIZE,
               out_size)) {
      a_out << "tools::wroot::directory::zip :"
            << " zipper failed."
            << std::endl;
      a_irep = 0;
      return false;
    }
    if((HDRSIZE+out_size)>a_tgtsize) {
      a_out << "tools::wroot::directory::zip :"
            << " target buffer overflow."
            << std::endl;
      a_irep = 0;
      return false;
    }
 
    // HEADER :
    a_tgt[0] = 'Z'; // Signature ZLib
    a_tgt[1] = 'L';
    a_tgt[2] = 8; //DEFLATE
 
    a_tgt[3] = (char)(out_size & 0xff);
    a_tgt[4] = (char)((out_size >> 8) & 0xff);
    a_tgt[5] = (char)((out_size >> 16) & 0xff);
 
    a_tgt[6] = (char)(a_srcsize & 0xff);
    a_tgt[7] = (char)((a_srcsize >> 8) & 0xff);
    a_tgt[8] = (char)((a_srcsize >> 16) & 0xff);
 
    a_irep = HDRSIZE+out_size;
 
    return true;
  }

ziper()

virtual bool tools::wroot::file::ziper ( char  a_key, compress_func &  a_func  ) const

inlinevirtual

Implements tools::wroot::ifile.

Definition at line 159 of file file.

                                                             {
    std::map<char,compress_func>::const_iterator it = m_zipers.find(a_key);
    if(it==m_zipers.end()) {
      a_func = 0;
      return false;
    }
    a_func = (*it).second;
    return true;
  }

Member Data Documentation

m_BEGIN

seek tools::wroot::file::m_BEGIN

protected

Definition at line 778 of file file.

m_compress

uint32 tools::wroot::file::m_compress

protected

Definition at line 785 of file file.

m_END

seek tools::wroot::file::m_END

protected

Definition at line 779 of file file.

m_file

int tools::wroot::file::m_file

protected

Definition at line 769 of file file.

m_free_segs

std::list<free_seg*> tools::wroot::file::m_free_segs

protected

Definition at line 774 of file file.

m_nbytes_free

uint32 tools::wroot::file::m_nbytes_free

protected

Definition at line 781 of file file.

m_nbytes_info

uint32 tools::wroot::file::m_nbytes_info

protected

Definition at line 787 of file file.

m_nbytes_name

uint32 tools::wroot::file::m_nbytes_name

protected

Definition at line 783 of file file.

m_out

std::ostream& tools::wroot::file::m_out

protected

Definition at line 766 of file file.

m_path

std::string tools::wroot::file::m_path

protected

Definition at line 767 of file file.

m_root_directory

directory tools::wroot::file::m_root_directory

protected

Definition at line 772 of file file.

m_seek_free

seek tools::wroot::file::m_seek_free

protected

Definition at line 780 of file file.

m_seek_info

seek tools::wroot::file::m_seek_info

protected

Definition at line 786 of file file.

m_title

std::string tools::wroot::file::m_title

protected

Definition at line 771 of file file.

m_units

char tools::wroot::file::m_units

protected

Definition at line 784 of file file.

m_verbose

bool tools::wroot::file::m_verbose

protected

Definition at line 768 of file file.

m_version

uint32 tools::wroot::file::m_version

protected

Definition at line 777 of file file.

m_zipers

std::map<char,compress_func> tools::wroot::file::m_zipers

protected

Definition at line 773 of file file.

---

The documentation for this class was generated from the following file:

• /Users/barrand/private/dev/softinex/g4tools/g4tools/tools/wroot/file