ACE/apps/JAWS2/JAWS/Filecache.cpp

   1 #include "ace/FILE_Connector.h"
   2 #include "ace/OS_NS_unistd.h"
   3
   4 #include "JAWS/Filecache.h"
   5 #include "JAWS/Cache_List_T.h"
   6
   7 void
   8 JAWS_Referenced_Filecache_Factory::destroy (JAWS_Cache_Object *object)
   9 {
  10   JAWS_FILE *file = (JAWS_FILE *) object->data ();
  11   file->close ();
  12   if (file->map ())
  13     file->map ()->close ();
  14   delete file;
  15   this->JAWS_Referenced_Cache_Object_Factory::destroy (object);
  16 }
  17
  18 void
  19 JAWS_Counted_Filecache_Factory::destroy (JAWS_Cache_Object *object)
  20 {
  21   JAWS_FILE *file = (JAWS_FILE *) object->data ();
  22   file->close ();
  23   if (file->map ())
  24     file->map ()->close ();
  25   delete file;
  26   this->JAWS_Counted_Cache_Object_Factory::destroy (object);
  27 }
  28
  29 JAWS_Cached_FILE::JAWS_Cached_FILE (const char *const &filename,
  30                                     JAWS_Filecache_Proxy::Cache_Manager *cm)
  31   : JAWS_Filecache_Proxy (filename, cm)
  32 {
  33   ACE_HANDLE handle = ACE_INVALID_HANDLE;
  34
  35   if (this->data () != 0)
  36     {
  37       handle = ACE_OS::dup (this->data ()->get_handle ());
  38     }
  39   else
  40     {
  41       JAWS_FILE *file = new JAWS_FILE;
  42       ACE_FILE_Connector file_connector;
  43
  44       int result = file_connector.connect (*file, ACE_FILE_Addr (filename));
  45       if (result == -1 || file->get_handle () == ACE_INVALID_HANDLE)
  46         {
  47           // TODO: do something here!
  48         }
  49
  50       ACE_FILE_Info info;
  51       file->get_info (info);
  52
  53       handle = ACE_OS::dup (file->get_handle ());
  54
  55       {
  56         JAWS_Cached_FILE cf (filename, file, info.size_, cm);
  57         if (cf.data () != 0)
  58           {
  59             new (this) JAWS_Cached_FILE (filename, cm);
  60             return;
  61           }
  62       }
  63     }
  64
  65   this->file_.set_handle (handle);
  66 }
  67
  68 JAWS_Cached_FILE::JAWS_Cached_FILE (const char *const &filename,
  69                                     JAWS_FILE *&file,
  70                                     size_t size,
  71                                     JAWS_Filecache_Proxy::Cache_Manager *cm)
  72   : JAWS_Filecache_Proxy (filename, file, size, cm)
  73 {
  74 }
  75
  76 JAWS_Cached_FILE::~JAWS_Cached_FILE ()
  77 {
  78   this->file_.close ();
  79 }
  80
  81 ACE_FILE_IO *
  82 JAWS_Cached_FILE::file ()
  83 {
  84   return &(this->file_);
  85 }
  86
  87 ACE_Mem_Map *
  88 JAWS_Cached_FILE::mmap ()
  89 {
  90   return (this->data () == 0 ? 0 : this->data ()->mem_map ());
  91 }
  92