objstrm.cpp

Go to the documentation of this file.

//----------------------------------------------------------------------------
// ObjectWindows
// Copyright (c) 1992, 1996 by Borland International, All Rights Reserved
//
//----------------------------------------------------------------------------
#include <owl/pch.h>
#include <owl/defs.h>
#include <owl/streambl.h>
#include <owl/objstrm.h>
#include <owl/private/memory.h>
#include <owl/template.h>
#include <owl/pointer.h>
 
#include <streambuf>
#if defined(BI_MULTI_THREAD_RTL)
#include <owl/thread.h>
#endif
 
#include <owl/except.h>
#include <set>
 
#if defined(__BORLANDC__)
# pragma option -w-ccc // Disable "Condition is always true/false"
#endif
 
using namespace std;
 
namespace owl {
 
DIAG_DEFINE_GROUP_INIT(OWL_INI, Objstrm, 1, 0);
 
namespace
{
  const uint32 streamVersion = 0x0101;
  const tchar versionIndicator = _T(':');
  const tchar EOS = _T('\0');
 
  const uint8  oldNullStringLen = UCHAR_MAX;
  const uint32 nullStringLen = ULONG_MAX;
 
  TStreamableTypes& GetTypes_()
  {
    static TStreamableTypes types; // Synchronised in C++11.
    return types;
  }
 
  //
  // Support for multi-threading
  // NOTE: This support is incomplete, untested and probably unreliable.
  //
 
#if defined(BI_MULTI_THREAD_RTL)
 
  TMRSWSection& GetLock_()
  {
    static TMRSWSection lock; // Synchronised in C++11.
    return lock;
  }
 
#define LOCK_TYPES_(s) TMRSWSection::TLock lock__(GetLock_(), s, false)
 
#else
 
#define LOCK_TYPES_(s)
 
#endif
 
} // namespace
 
class TStreamableBaseArray: public TPtrArray<TStreamableBase*>{
  public:
    TStreamableBaseArray(int a, int b=0, int c=0): TPtrArray<TStreamableBase*>(a,b,c){}
    TStreamableBaseArray(){}
};
//
class TStreamableClassArray: public TISortedPtrArray<TStreamableClass*>{
  public:
    TStreamableClassArray(int a, int b=0, int c=0): TISortedPtrArray<TStreamableClass*>(a,b,c){}
    TStreamableClassArray(){}
 
    int Add(TStreamableClass* t);
    bool DetachItem(TStreamableClass* t)
      {
        const auto index = Find(t);
        if (index != NPOS)
        {
          Remove(index);
          return true;
        }
        return false;
      }
    int Find(TStreamableClass* t) const;
  private:
    int    Add(const TStreamableClass* t);
    bool  DetachItem(const TStreamableClass* t);
    int    Find(const TStreamableClass* t) const;
};
int TStreamableClassArray::Add(TStreamableClass* t)
{
  if(ItemCnt>=Reserved)
     Resize(ItemCnt+1); // on error -> throw xalloc
  unsigned loc = ItemCnt++;
  while( loc > 0 && *t < *(Data[loc-1])) {
    Data[loc] = Data[loc-1];
    loc--;
   }
  Data[loc] = (TStreamableClass*)t;
  return loc;
}
int TStreamableClassArray::Find(TStreamableClass* t) const
{
  auto lower = 0;
  auto upper = static_cast<int>(Size()) - 1;
  while (lower <= upper)
  {
    const auto middle = (lower + upper) / 2;
    if (*(Data[middle]) == *t)
      return middle;
    if (*(Data[middle]) < *t)
      lower = middle + 1;
    else
      upper = middle - 1;
  }
  return NPOS;
}
 
//
// Uses a std::set for faster insertion and lookup. The Borland sorted arrays
// have very poor performance for large numbers of items (O(n^2)).
//
class TSortedTPWObjObjectArray
{
public:
 
   TSortedTPWObjObjectArray(int = 0) {}
 
   void Flush() { m_Items.clear(); }
   void Add(TPWrittenObjects::TPWObj obj) { m_Items.insert(obj); }
   P_id_type Find(TPWrittenObjects::TPWObj obj) const
   {
     std::set<TPWrittenObjects::TPWObj>::const_iterator i = m_Items.find(obj);
     return (i != m_Items.end()) ? i->Ident : 0;
   }
 
private:
 
   std::set<TPWrittenObjects::TPWObj> m_Items;
 
};
 
// -----------------------------------------------------------------------------
const char* TStreamer::StreamableName() const
{
    return 0;
}
const char* TStreamer::StreamableName() const {…}
//----------------------------------------------------------------------------------------------
/// Creates a TStreamableClass object with the given name (n) and the given builder
/// function (b), then registers the type.
/// For example, each streamable has a Build member function of type BUILDER. For
/// type-safe object-stream I/O, the stream manager needs to access the names and
/// the type information for each class. To ensure that the appropriate functions
/// are linked into any application using the stream manager, you must provide a
/// reference such as:
/// \code
///   TStreamableClass RegClassName;
/// \endcode
/// where TClassName is the name of the class for which objects need to be streamed.
/// (Note that RegClassName is a single identifier.) This not only registers
/// TClassName (telling the stream manager which Build function to use), it also
/// automatically registers any dependent classes. You can register a class more
/// than once without any harm or overhead.
/// Invoke this function to provide raw memory of the correct size into which an
/// object of the specified class can be read. Because the Build procedure invokes a
/// special constructor for the class, all virtual table pointers are initialized
/// correctly.
/// The distance, in bytes, between the base of the streamable object and the
/// beginning of the TStreamableBase component of the object is d. Calculate d by
/// using the _ _DELTA macro.
/// Example
/// \code
/// TStreamableClass RegTClassName = TStreamableClass("TClassName",
/// TClassName::build, _ _DELTA(TClassName));
/// \endcode
TStreamableClass::TStreamableClass( const char * n,
                                    BUILDER b,
                                    int d,
                                    ModuleId id )
:
  ObjectBuilder( b, d ),
  ModId(id)
{
  ObjectId = strnewdup(n);
  if (id != 0) // id == 0 is used only during lookup. It flags an instance that shouldn't be registered.
    GetTypes_().RegisterType(id, *this);
}
TStreamableClass::TStreamableClass( const char * n, {…}
 
TStreamableClass::~TStreamableClass()
{
  if (ModId != 0)
    GetTypes_().UnRegisterType(ModId, *this);
  delete [] CONST_CAST(char*, ObjectId);
}
TStreamableClass::~TStreamableClass() {…}
 
 
TStreamableTypes::TStreamableTypes()
{
  Types = new TStreamableClassArray(30);
}
TStreamableTypes::TStreamableTypes() {…}
 
 
TStreamableTypes::~TStreamableTypes()
{
  delete Types;
}
TStreamableTypes::~TStreamableTypes() {…}
 
void
TStreamableTypes::RegisterType( ModuleId, TStreamableClass& ts )
{
  PRECONDITION(Types);
  LOCK_TYPES_(false);
  Types->Add(&ts);
}
TStreamableTypes::RegisterType( ModuleId, TStreamableClass& ts ) {…}
 
void TStreamableTypes::UnRegisterType( ModuleId, TStreamableClass& ts )
{
  PRECONDITION(Types);
  LOCK_TYPES_(false);
  Types->DetachItem(&ts);
}
void TStreamableTypes::UnRegisterType( ModuleId, TStreamableClass& ts ) {…}
 
const ObjectBuilder *TStreamableTypes::Lookup( ModuleId, LPCSTR name ) const
{
  PRECONDITION(Types);
  LOCK_TYPES_(true);
  TStreamableClass sc(name, 0, 0, 0);
  const auto loc = Types->Find(&sc);
  if (loc == Types->NPOS)
  {
    _USES_CONVERSION;
    tstring msg;
    msg.reserve(128);
    msg = _T("Attempt to stream unregistered type '");
    msg += _A2W(name);
    msg += _T("'");
    TXBase(msg).Throw();
  }
  return (*Types)[loc];
}
const ObjectBuilder *TStreamableTypes::Lookup( ModuleId, LPCSTR name ) const {…}
 
void TPReadObjects::RemoveAll()
{
  // delete all objects and flush container
  Data->Flush();
}
void TPReadObjects::RemoveAll() {…}
 
void TPReadObjects::RegisterObject( TStreamableBase *adr )
{
  Data->Add( adr );
}
 
TStreamableBase* TPReadObjects::Find( P_id_type id )
{
  if(id < Data->Size())
    return (*Data)[id];
  return 0;
}
 
TPReadObjects::TPReadObjects()
{
  Data = new TStreamableBaseArray;
  Data->Add(0);  // prime it: 0 is not a legal index.
}
TPReadObjects::~TPReadObjects()
{
  RemoveAll();
  delete Data;
}
 
TPWrittenObjects::TPWrittenObjects()
:
  CurId(0)
{
  Data = new TSortedTPWObjObjectArray(10);
}
TPWrittenObjects::~TPWrittenObjects()
{
  delete Data;
}
 
void TPWrittenObjects::RemoveAll()
{
  CurId = 0;
  Data->Flush();
}
void TPWrittenObjects::RemoveAll() {…}
 
void TPWrittenObjects::RegisterObject( TStreamableBase *adr )
{
  Data->Add(TPWObj(((tchar*)(void*)adr)+1, ++CurId));
}
 
void TPWrittenObjects::RegisterVB( const TStreamableBase *adr )
{
  Data->Add(TPWObj(adr,++CurId));
}
 
P_id_type TPWrittenObjects::FindObject( TStreamableBase *d )
{
  return Data->Find(TPWObj(((tchar*)(void*)d)+1,0));
}
 
P_id_type TPWrittenObjects::FindVB( TStreamableBase *d )
{
  return Data->Find(TPWObj(d,0));
}
 
pstream::~pstream()
{
}
pstream::~pstream() {…}
 
/// Returns the (absolute) current stream position.
streampos ipstream::tellg()
{
  streampos res;
  if( !good() )
    res = streampos(EOF);
  else{
    res = bp->pubseekoff(0, ios::cur, ios::in );
    if( res == streampos(EOF) )
      clear( ios::failbit );
  }
  return res;
}
streampos ipstream::tellg() {…}
 
/// Moves the stream position to the absolute position given by pos.
ipstream& ipstream::seekg( streampos pos )
{
  if( good() ){
    objs.RemoveAll();
    streampos p = bp->pubseekoff(pos, ios::beg, ios::in );
    if( p == streampos(EOF) )
      clear( ios::failbit );
  }
  return *this;
}
 
/// Moves to a position relative to the current position by an offset off (+
/// or -) starting at ios::seekdir. You can set ios::seekdir to one of the
/// following:
/// - \c \b    beg (start of stream)
/// - \c \b    cur (current stream position)
/// - \c \b    end (end of stream).
ipstream& ipstream::seekg( streamoff off, ios::seekdir dir )
{
  if( good() ){
    objs.RemoveAll();
#if __GNUC__ >=3
    streampos p = bp->pubseekoff(off, dir, ios::in );
#else
    streampos p = bp->pubseekoff((ios::off_type)off, dir, (ios::openmode)ios::in );
#endif
    if( p == streampos(EOF) )
      clear( ios::failbit );
  }
  return *this;
}
 
/// Returns the byte at the current stream position.
uint8 ipstream::readByte()
{
  int res;
  if( !good() )
      res = uint8(0);
  else{
    res = bp->sbumpc();
    if( res == EOF )
     clear( ios::failbit );
  }
  return uint8(res);
}
uint8 ipstream::readByte() {…}
 
/// Reads sz bytes from current stream position, and writes them to data.
void ipstream::readBytes( void *data, size_t sz )
{
    PRECONDITION( data != 0 );
    if( good() && sz > 0 )
        {
        if( bp->sgetn( (char*)data, sz ) != static_cast<int>(sz) )
            clear( ios::failbit );
        }
}
void ipstream::readBytes( void *data, size_t sz ) {…}
 
/// Reads the number of bytes specified by sz into the supplied buffer (data).
void ipstream::freadBytes( void *data, size_t sz )
{
  PRECONDITION( data != 0 );
 
  if( good() && sz > 0){
    TTmpBuffer<char> buf(static_cast<int>(sz));
 
    if( bp->sgetn( (char*)buf, sz ) != static_cast<int>(sz))
      clear( ios::failbit );
    else
      memcpy( data, (char*)buf, sz);
  }
}
void ipstream::freadBytes( void *data, size_t sz ) {…}
 
/// Returns the word at the current stream position.
uint32 ipstream::readWord()
{
  if( getVersion() > 0 )
    return readWord32();
  else
    return readWord16();
}
uint32 ipstream::readWord() {…}
 
/// Returns the 16-bit word at the current stream position.
uint16 ipstream::readWord16()
{
  if( !good() )
    return 0;
  else{
    uint16 temp;
    if( bp->sgetn( (char*)&temp, sizeof( temp ) ) !=
        static_cast<int>(sizeof( temp )) )
      clear( ios::failbit );
    return temp;
  }
}
uint16 ipstream::readWord16() {…}
 
/// Returns the 32-bit word at the current stream position.
uint32 ipstream::readWord32()
{
  if( !good() )
    return 0;
  else{
    uint32 temp;
    if( bp->sgetn( (char*)&temp, sizeof( temp ) ) !=
        static_cast<int>(sizeof( temp )) )
      clear( ios::failbit );
    return temp;
  }
}
uint32 ipstream::readWord32() {…}
 
uint32 ipstream::readStringLength()
{
  uint32 len;
  if( getVersion() > 0x0100 ){
    len = readWord32();
  }
  else{
    len = readByte();
    if( len == oldNullStringLen )
      len = nullStringLen;
  }
  return len;
}
 
/// Allocates a buffer large enough to contain the string at the current
/// stream position and reads the string into the buffer. The caller must free the
/// buffer.
char* ipstream::readString()
{
  if( !good() )
    return 0;
  else{
    uint32 len = readStringLength();
    if( len == nullStringLen )
      return 0;
 
    char* buf = new char[size_t(len+1)];
    if( buf == 0 )
      return 0;
    readBytes( buf, size_t(len) );
    buf[size_t(len)] = EOS;
    return buf;
  }
}
char* ipstream::readString() {…}
 
/// Reads the string at the current stream position into the buffer
/// specified by buf. If the length of the string is greater than maxLen - 1, it
/// reads nothing. Otherwise, it reads the string into the buffer and appends a
/// null-terminating byte.
LPSTR ipstream::readString( LPSTR buf, unsigned maxLen )
{
  PRECONDITION( buf != 0 );
 
  if( !good() )
    return 0;
  else{
    uint32 len = readStringLength();
    if( len == nullStringLen || len > maxLen-1 )
      return 0;
    readBytes( buf, size_t(len) );
    buf[size_t(len)] = EOS;
    return buf;
  }
}
LPSTR ipstream::readString( LPSTR buf, unsigned maxLen ) {…}
 
/// Reads a string from the stream. It determines the length of the string
/// and allocates a character array of the appropriate length. It reads the
/// string into this array and returns a pointer to the string. The caller is
/// expected to free the allocated memory block.
char *ipstream::freadString()
{
  if( !good() )
    return 0;
  else{
    uint32 len = readStringLength();
    if( len == nullStringLen )
      return 0;
 
    char* buf = new char[size_t(len)+1];
    freadBytes(buf, size_t(len));
    buf[size_t(len)] = EOS;
    return buf;
  }
}
char *ipstream::freadString() {…}
 
/// Reads a string from the stream into the supplied far buffer (buf). If
/// the length of the string is greater than maxLen-1, it reads nothing. Otherwise,
/// it reads the string into the buffer and appends a null-terminating byte.
char* ipstream::freadString( char *buf, unsigned maxLen )
{
  PRECONDITION(buf != 0 );
 
  if( !good() )
    return 0;
  else{
    uint32 len = readStringLength();
    if( len == nullStringLen || len > maxLen-1 )
      return 0;
 
    freadBytes( buf, size_t(len));
    buf[size_t(len)] = EOS;
    return buf;
  }
}
char* ipstream::freadString( char *buf, unsigned maxLen ) {…}
 
/// Reads the version number of the input stream.
void ipstream::readVersion()
{
  if( !good() )
    version = 0;
  else{
    int res = bp->sgetc();
    if( res == EOF ){
      clear( ios::eofbit );
      version = 0;
      return;
    }
    if( res != versionIndicator )
      version = 0;
    else{
      bp->sbumpc();
      version = readWord32();
    }
  }
}
void ipstream::readVersion() {…}
 
TStreamableBase *ipstream::readObject( TStreamableBase *&mem,
                                            ModuleId mid )
{
  if( good() ){
    const ObjectBuilder *pc = readPrefix( mid );
    if( pc == 0 )
      mem = 0;
    else{
      readData( pc, mem );
      readSuffix();
    }
  }
  return mem;
}
TStreamableBase *ipstream::readObject( TStreamableBase *&mem, {…}
 
/// Returns the TStreamableClass object corresponding to the class name stored at
/// the current position in the stream.
const ObjectBuilder *ipstream::readPrefix( ModuleId mid )
{
  char ch = readByte();
  if( ch != '[' ){
    clear( ios::failbit );
    return 0;
  }
 
  char name[128];
  name[0] = EOS;
  readString( name, sizeof name );
  if( name[0] == EOS ){
    clear( ios::failbit );
    return 0;
  }
 
  _USES_CONVERSION;
 
  TRACEX(Objstrm,0,_T("Reading ") << _A2W(name));
  const ObjectBuilder *res = GetTypes_().Lookup(mid, name);
 
  WARNX(Objstrm,res==0,0,_T("Unrecognized class identifier: ") << _A2W(name));
  if( res == 0 ){
    clear( ios::failbit );
    return 0;
  }
 
  return res;
}
const ObjectBuilder *ipstream::readPrefix( ModuleId mid ) {…}
 
/// If mem is 0, it calls the appropriate build function to allocate memory and
/// initialize the virtual table pointer for the object.
/// Finally, it invokes the appropriate read function to read the object from the
/// stream into the memory pointed to by mem.
void ipstream::readData( const ObjectBuilder *c, TStreamableBase *&mem )
{
  TPointer<TStreamer> strmr(c->Builder(mem));
  mem = strmr->GetObject();
 
  // register the address
  registerObject( mem );
 
  uint32 classVer = 0;
  if( getVersion() > 0 )
    classVer = readWord32();
 
  strmr->Read( *this, classVer );
}
void ipstream::readData( const ObjectBuilder *c, TStreamableBase *&mem ) {…}
 
/// Reads and checks the suffix of the object.
void ipstream::readSuffix()
{
  if( !good() )
    return;
  char ch = readByte();
  if( ch != ']' )
    clear( ios::failbit );
}
void ipstream::readSuffix() {…}
 
TStreamableBase *ipstream::readObjectPointer( TStreamableBase *&mem,
                                                   ModuleId mid )
{
  if( !good() )
    return 0;
 
  char ch = readByte();
  switch( ch ){
    case pstream::ptNull:
      mem = 0;
      break;
    case pstream::ptIndexed:{
        P_id_type index = P_id_type(readWord());
        mem = find( index );
        CHECK( mem != 0 );
        break;
      }
    case pstream::ptObject: {
        const ObjectBuilder *pc = readPrefix( mid );
        readData( pc, mem );
        readSuffix();
        break;
      }
    default:
      clear( ios::failbit );
      break;
  }
  return mem;
}
TStreamableBase *ipstream::readObjectPointer( TStreamableBase *&mem, {…}
 
/// Creates a buffered opstream with the given buffer and sets the bp data
/// member to buf. The state is set to 0.
opstream::opstream()
{
  objs = new TPWrittenObjects;
  if( bp != 0 )
    writeVersion();
}
opstream::opstream() {…}
 
/// Creates an opstream object without initializing the buffer pointer, bp.
/// Use pstream::init to set the buffer and state.
opstream::opstream( streambuf * sb )
{
  objs = new TPWrittenObjects;
  pstream::init( sb );
  writeVersion();
}
 
/// Returns the (absolute) current stream position.
streampos opstream::tellp()
{
  streampos res;
  if( !good() )
    res = streampos(EOF);
  else{
    res = bp->pubseekoff(0, ios::cur, ios::out );
    if( res == streampos(EOF) )
      clear( ios::failbit );
  }
  return res;
}
streampos opstream::tellp() {…}
 
/// Moves the current position of the stream to the absolute position given by pos.
opstream& opstream::seekp( streampos pos )
{
  if( good() ){
    objs->RemoveAll();
#if __GNUC__ >=3
    streampos p = bp->pubseekoff(pos, ios::beg, ios::out);
#else
    streampos p = bp->pubseekoff((ios::off_type)pos, (ios::seekdir)ios::beg,
                                 (ios::openmode)ios::out);
#endif
    if( p == streampos(EOF) )
      clear( ios::failbit );
  }
  return *this;
}
 
/// Form 2: Moves to a position relative to the current position by an offset off (+
/// or -) starting at ios::seekdir. You can set ios::seekdir to one if the
/// following:
/// - \c \b  beg (start of stream)
/// - \c \b  cur (current stream position)
/// - \c \b  end (end of stream).
opstream& opstream::seekp( streamoff off, ios::seekdir dir )
{
  if( good() ){
    objs->RemoveAll();
#if __GNUC__ >=3
    streampos p = bp->pubseekoff(off, dir, ios::out );
#else
    streampos p = bp->pubseekoff((ios::off_type)off, dir, (ios::openmode)ios::out );
#endif
    if( p == streampos(EOF) )
      clear( ios::failbit );
  }
  return *this;
}
 
void opstream::writeVersion()
{
  if( good() ){
    writeByte( versionIndicator );
    writeWord32( streamVersion );
  }
}
void opstream::writeVersion() {…}
 
/// Flushes the stream.
opstream& opstream::flush()
{
  if( bp->pubsync() == EOF )
    clear( ios::badbit );
  return *this;
}
opstream& opstream::flush() {…}
 
/// Writes the byte ch to the stream.
void opstream::writeByte( uint8 ch )
{
  if( good() ){
    if( bp->sputc( ch ) == EOF )
      clear( ios::failbit );
  }
}
void opstream::writeByte( uint8 ch ) {…}
 
/// Writes sz bytes from the data buffer to the stream.
void opstream::writeBytes( const void *data, size_t sz )
{
  PRECONDITION( data != 0 );
 
  if( good() && sz > 0 ){
    if( bp->sputn( (char*)data, sz ) != static_cast<int>(sz) )
      clear( ios::failbit );
  }
}
void opstream::writeBytes( const void *data, size_t sz ) {…}
 
/// Writes the 16-bit word us to the stream.
void opstream::writeWord16( uint16 word16 )
{
  if( good() ){
    if( bp->sputn( (char*)&word16, sizeof(word16) ) !=
        static_cast<int>(sizeof(word16)) )
      clear( ios::failbit );
  }
}
void opstream::writeWord16( uint16 word16 ) {…}
 
/// Writes the 32-bit word us to the stream.
void opstream::writeWord32( uint32 word32 )
{
  if( good() ){
    if( bp->sputn( (char*)&word32, sizeof(word32) ) !=
        static_cast<int>(sizeof(word32)) )
      clear( ios::failbit );
  }
}
void opstream::writeWord32( uint32 word32 ) {…}
 
/// Writes the specified number of bytes (sz) from the supplied buffer (data) to the
/// stream.
void opstream::fwriteBytes( const void *data, size_t sz )
{
  PRECONDITION( data != 0 );
 
  if( good() && sz > 0 ){
    char* buf = new char[sz];
 
    memcpy( buf, data, sz );
    if( bp->sputn( (char*)buf, sz ) != static_cast<int>(sz) )
      clear( ios::failbit );
 
    delete[] buf;
  }
}
void opstream::fwriteBytes( const void *data, size_t sz ) {…}
 
/// Writes str to the stream.
void opstream::writeString( const char* str )
{
  if( !good() )
    return;
 
  if( str == 0 ){
    writeWord32( nullStringLen );
    return;
  }
  size_t len = strlen( str );
  writeWord32(static_cast<uint32>(len));
  writeBytes( str, len );
}
void opstream::writeString( const char* str ) {…}
 
/// Writes the specified far character string (str) to the stream.
void opstream::fwriteString( const char * str )
{
  if( !good() )
    return;
 
  if( str == 0 ){
    writeWord32( nullStringLen );
    return;
  }
  size_t len = strlen( str );
  writeWord32(static_cast<uint32>(len));
  fwriteBytes(str, len);
}
void opstream::fwriteString( const char * str ) {…}
 
#if !defined(BI_COMP_GNUC)
#pragma warn -par
#endif
/// Writes the object, pointed to by t, to the output stream. The isPtrargument
/// indicates whether the object was allocated from the heap.
void opstream::writeObject( const TStreamableBase* mem, int IFDIAG(isPtr), ModuleId mid )
{
  _USES_CONVERSION;
  WARNX(Objstrm,
        !isPtr && findObject( CONST_CAST(TStreamableBase *,mem) ),
        0,
        _T("Pointer written before object: ")     \
           << _A2W(_OBJ_FULLTYPENAME(mem)) << _T('(') << (void*)mem << _T(')') );
  if( good() ){
    writePrefix( mem );
    writeData( mem, mid );
    writeSuffix( mem );
  }
}
void opstream::writeObject( const TStreamableBase* mem, int IFDIAG(isPtr), ModuleId mid ) {…}
#if !defined(BI_COMP_GNUC)
#pragma warn .par
#endif
 
/// Writes the object pointer t to the output stream.
void opstream::writeObjectPointer( const TStreamableBase *t, ModuleId mid )
{
  if( good() ){
    P_id_type index;
    if( t == 0 )
      writeByte( pstream::ptNull );
    else if( (index = findObject( CONST_CAST(TStreamableBase *,t) )) != 0 ){
      writeByte( pstream::ptIndexed );
      writeWord( index );
    }
    else{
      writeByte( pstream::ptObject );
      writeObject( t, 1, mid );
    }
  }
}
void opstream::writeObjectPointer( const TStreamableBase *t, ModuleId mid ) {…}
 
/// Writes the class name prefix to the stream. The << operator uses this function
/// to write a prefix and suffix around the data written with writeData. The
/// prefix/suffix is used to ensure type-safe stream I/O.
void opstream::writePrefix( const TStreamableBase *t )
{
  if( good() ){
    writeByte( '[' );
    writeString( _OBJ_TYPENAME(t) );
  }
}
void opstream::writePrefix( const TStreamableBase *t ) {…}
 
/// Writes data to the stream by calling the write member function of the
/// appropriate class for the object being written.
void opstream::writeData( const TStreamableBase *t, ModuleId mid )
{
  _USES_CONVERSION;
  if( good() ){
    registerObject( CONST_CAST(TStreamableBase *,t) );
    const ObjectBuilder *res = GetTypes_().Lookup(mid, _OBJ_TYPENAME(t));
    CHECKX(res, _A2W(_OBJ_FULLTYPENAME(t)));
    TPointer<TStreamer> strmr(res->Builder(CONST_CAST(TStreamableBase *,t)));
    writeWord32( strmr->ClassVersion() );
    strmr->Write( *this );
  }
}
void opstream::writeData( const TStreamableBase *t, ModuleId mid ) {…}
 
/// Opens the named file in the given mode (app, ate, in, out, binary, trunc,
/// nocreate, or noreplace) and protection. The opened file is attached to this
/// stream.
void fpbase::open( LPCSTR b, int m, int)
{
  if (buf.is_open())
    clear(ios::failbit);
  else if (buf.open(b, static_cast<ios::openmode>(m)))
    clear(ios::goodbit);
  else
    clear(ios::badbit);
}
void fpbase::open( LPCSTR b, int m, int) {…}
 
/// Opens the named file in the given mode (app, ate, in, out, binary, trunc,
/// nocreate, or noreplace) and protection. The opened file is attached to this
/// stream.
void fpbase::open(LPCWSTR b, int m, int)
{
  if (buf.is_open())
    clear(ios::failbit);
  else if (buf.open(b, static_cast<ios::openmode>(m)))
    clear(ios::goodbit);
  else
    clear(ios::badbit);
}
void fpbase::open(LPCWSTR b, int m, int) {…}
 
/// Closes the stream and associated file.
void fpbase::close()
{
  if( buf.close() )
    clear(ios::goodbit);
  else
    clear(ios::failbit);
}
void fpbase::close() {…}
 
/// Sets the location of the buffer to buf and the buffer size to len.
void fpbase::setbuf(LPSTR b, int len)
{
  if( buf.pubsetbuf(b, len) )
    clear(ios::goodbit);
  else
    clear(ios::failbit);
}
void fpbase::setbuf(LPSTR b, int len) {…}
 
//
//  These operators are not friends of string, so
//  they must use only the public interface.
//
_OWLCFUNC(opstream& ) operator << ( opstream& os, const tstring& str)
{
  _USES_CONVERSION;
  os.writeString( _W2A(str.c_str()) );
  return os;
}
_OWLCFUNC(opstream& ) operator << ( opstream& os, const tstring& str) {…}
 
/// This operator of ipstream extracts (reads) from the ipstream is, to the string
/// str. It returns a reference to the stream that lets you chain >> operations in
/// the usual way.
_OWLCFUNC(ipstream& ) operator >> ( ipstream& is, tstring& str )
{
  if( is.good() ){
    uint32 len = is.readStringLength();
    if( len == nullStringLen )
      str = _T("");
    else{
      char *temp = new char[size_t(len)+1];
      is.readBytes( temp, size_t(len) );
      temp[size_t(len)] = EOS;
      _USES_CONVERSION;
      str = _A2W(temp);
      delete [] temp;
    }
  }
  return is;
}
_OWLCFUNC(ipstream& ) operator >> ( ipstream& is, tstring& str ) {…};
 
} // OWL namespace
/* ========================================================================== */