flat_file_persistence.h

这是广泛使用的通信开源项目,对于大容量,高并发的通讯要求完全能够胜任,他广泛可用于网络游戏医学图像网关的高qos要求.更详细的内容可阅读相应的材料

/* -*- C++ -*- */
//=============================================================================
/**
 *  @file   Flat_File_Persistence.h
 *
 *  Flat_File_Persistence.h,v 1.5 2003/11/01 11:15:09 dhinton Exp
 *
 *  @author Marina Spivak <[e-mail]>
 */
//=============================================================================

#ifndef TAO_FLAT_FILE_PERSISTENCE_H
#define TAO_FLAT_FILE_PERSISTENCE_H

#include "Storable.h"
#include "ace/OS_NS_stdio.h"

//------------------------------------------------------------------------
// The Flat File concrete classes
//------------------------------------------------------------------------
class TAO_NS_FlatFileStream : public TAO_Storable_Base
{
public:

  TAO_NS_FlatFileStream(const ACE_CString & file, const char * mode);
  virtual ~TAO_NS_FlatFileStream();

  /// Remove a file by name (file is not open)
  virtual void remove();

  /// Check if a file exists on disk (file is not open)
  virtual int exists();

  /// Open a file (the remaining methods below all require an open file)
  virtual int open();

  /// Close an open file
  virtual int close();

  /// Acquire a file lock
  virtual int flock (int whence, int start, int len);

  /// Release a file lock
  virtual int funlock (int whence, int start, int len);

  /// Returns the last time an open file was changed
  virtual time_t last_changed(void);

  /// Write a header to disk
  virtual TAO_Storable_Base& operator << (
              const TAO_NS_Persistence_Header& header);

  /// Read a header from disk
  virtual TAO_Storable_Base& operator >> (
              TAO_NS_Persistence_Header& header);

  /// Write a record to disk
  virtual TAO_Storable_Base& operator << (
              const TAO_NS_Persistence_Record& record);

  /// Read a record from disk
  virtual TAO_Storable_Base& operator >> (
              TAO_NS_Persistence_Record& record);

  /// Write the global data to disk
  virtual TAO_Storable_Base& operator << (
              const TAO_NS_Persistence_Global& global);

  /// Read the global data from disk
  virtual TAO_Storable_Base& operator >> (
              TAO_NS_Persistence_Global& global);

private:
  ACE_OS::ace_flock_t filelock_;
  FILE* fl_;
  ACE_CString file_;
  ACE_CString mode_;
};

class TAO_NS_FlatFileFactory : public TAO_Naming_Service_Persistence_Factory
{
public:
  // Factory Methods

  /// Create the stream that can operate on a disk file
  virtual TAO_Storable_Base *create_stream(const ACE_CString & file, 
                                           const ACE_TCHAR * mode);
};


#endif