diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/Log/LogRecordStore.cpp')
-rw-r--r-- | TAO/orbsvcs/orbsvcs/Log/LogRecordStore.cpp | 184 |
1 files changed, 0 insertions, 184 deletions
diff --git a/TAO/orbsvcs/orbsvcs/Log/LogRecordStore.cpp b/TAO/orbsvcs/orbsvcs/Log/LogRecordStore.cpp deleted file mode 100644 index 1d1b824065b..00000000000 --- a/TAO/orbsvcs/orbsvcs/Log/LogRecordStore.cpp +++ /dev/null @@ -1,184 +0,0 @@ -// $Id$ - - -#include "orbsvcs/Time_Utilities.h" -#include "orbsvcs/Log/LogRecordStore.h" -#include "orbsvcs/Log/Log_Constraint_Interpreter.h" -#include "orbsvcs/Log/Log_Constraint_Visitors.h" - - -LogRecordStore::LogRecordStore (CORBA::ULongLong max_size, - CORBA::ULong max_rec_list_len) - : maxid_ (0), - max_size_ (max_size), - current_size_ (0), - num_records_ (0), - max_rec_list_len_ (max_rec_list_len) -{ - //No-Op. -} - -LogRecordStore::~LogRecordStore (void) -{ - // No-Op. -} - -int -LogRecordStore::open (void) -{ - return rec_hash_.open (); -} - -int -LogRecordStore::close (void) -{ - // Close the hash - return rec_hash_.close (); -} - -// TODO: make these inline .. -CORBA::ULongLong -LogRecordStore::get_max_size (void) -{ - return max_size_; -} - -void -LogRecordStore::set_max_size (CORBA::ULongLong size) -{ - this->max_size_ = size; -} - -CORBA::ULongLong -LogRecordStore::get_current_size (void) -{ - return this->current_size_; -} - -CORBA::ULongLong -LogRecordStore::get_n_records (void) -{ - return this->num_records_; -} - -// inline ... - -int -LogRecordStore::log (DsLogAdmin::LogRecord &rec) -{ - // Check if we are allowed to write... - if (max_size_ !=0 && current_size_ >= max_size_) - return 1; // return code for log rec. full - - // Initialize a couple of fields first... - // ACE emulation of U Long Long (for platforms that don't have one) - // does not define postfix operators - rec.id = ++maxid_; - // TODO: Reuse ids by keeping a list. - - ORBSVCS_Time::Time_Value_to_TimeT(rec.time,ACE_OS::gettimeofday()); - - - // First, bind the id to the LogRecord in the hash_map - if (this->rec_hash_.bind (rec.id, rec) != 0) - { - #if defined (ACE_LACKS_LONGLONG_T) - ACE_ERROR_RETURN ((LM_ERROR, - "LogRecordStore (%P|%t):Failed to bind %Q in the hash map\n", - ACE_U64_TO_U32(rec.id)), - -1); - #else - ACE_ERROR_RETURN ((LM_ERROR, - "LogRecordStore (%P|%t):Failed to bind %Q in the hash map\n", - rec.id), - -1); - #endif - } - - // Increment the number of records in the log - ++(this->num_records_); - this->current_size_ = - this->current_size_ + sizeof (rec); - - return 0; -} - -int -LogRecordStore::retrieve (DsLogAdmin::RecordId id, DsLogAdmin::LogRecord &rec) -{ - int retval = rec_hash_.find (id, rec); - return retval; -} - -int -LogRecordStore::update (DsLogAdmin::LogRecord &rec) -{ - if (rec_hash_.unbind (rec.id, rec) != 0) - { - return -1; - } - - return rec_hash_.bind (rec.id, rec); -} - -int -LogRecordStore::remove (DsLogAdmin::RecordId id) -{ - DsLogAdmin::LogRecord rec; - if (rec_hash_.unbind (id, rec) != 0) - { - return -1; - } - - --(this->num_records_); - this->current_size_ = - this->current_size_ - sizeof (rec); - // TODO: return ids to a reuse list. - return 0; -} - -int -LogRecordStore::purge_old_records (void) -{ - // TBD: - // Delete 5% of the old records. - return -1; -} - -LogRecordStore::LOG_RECORD_STORE& -LogRecordStore::get_storage (void) -{ - return rec_hash_; -} - -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) - -template class ACE_Hash_Map_Entry<DsLogAdmin::RecordId,DsLogAdmin::LogRecord>; -template class ACE_Hash_Map_Manager<DsLogAdmin::RecordId,DsLogAdmin::LogRecord,ACE_Null_Mutex>; -template class ACE_Hash_Map_Manager_Ex<DsLogAdmin::RecordId, DsLogAdmin::LogRecord, - ACE_Hash<DsLogAdmin::RecordId>, ACE_Equal_To<DsLogAdmin::RecordId>, ACE_Null_Mutex>; -template class ACE_Hash_Map_Iterator<DsLogAdmin::RecordId,DsLogAdmin::LogRecord,ACE_Null_Mutex>; -template class ACE_Hash_Map_Iterator_Ex<DsLogAdmin::RecordId, DsLogAdmin::LogRecord, ACE_Hash<DsLogAdmin::RecordId>, - ACE_Equal_To<DsLogAdmin::RecordId>, ACE_Null_Mutex>; -template class ACE_Hash_Map_Iterator_Base_Ex<DsLogAdmin::RecordId, DsLogAdmin::LogRecord, ACE_Hash<DsLogAdmin::RecordId>, - ACE_Equal_To<DsLogAdmin::RecordId>, ACE_Null_Mutex>; -template class ACE_Hash_Map_Reverse_Iterator<DsLogAdmin::RecordId,DsLogAdmin::LogRecord,ACE_Null_Mutex>; -template class ACE_Hash_Map_Reverse_Iterator_Ex<DsLogAdmin::RecordId, DsLogAdmin::LogRecord, ACE_Hash<DsLogAdmin::RecordId>, - ACE_Equal_To<DsLogAdmin::RecordId>, ACE_Null_Mutex>; - -#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) - -#pragma instantiate ACE_Hash_Map_Entry<DsLogAdmin::RecordId,DsLogAdmin::LogRecord> -#pragma instantiate ACE_Hash_Map_Manager<DsLogAdmin::RecordId,DsLogAdmin::LogRecord,ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Manager_Ex<DsLogAdmin::RecordId, DsLogAdmin::LogRecord, ACE_Hash<DsLogAdmin::RecordId>, -ACE_Equal_To<DsLogAdmin::RecordId>, ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Iterator<DsLogAdmin::RecordId,DsLogAdmin::LogRecord,ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Iterator_Ex<DsLogAdmin::RecordId, DsLogAdmin::LogRecord, ACE_Hash<DsLogAdmin::RecordId>, -ACE_Equal_To<DsLogAdmin::RecordId>, ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Iterator_Base_Ex<DsLogAdmin::RecordId, DsLogAdmin::LogRecord, ACE_Hash<DsLogAdmin::RecordId>, -ACE_Equal_To<DsLogAdmin::RecordId>, ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Reverse_Iterator<DsLogAdmin::RecordId,DsLogAdmin::LogRecord,ACE_Null_Mutex> -#pragma instantiate ACE_Hash_Map_Reverse_Iterator_Ex<DsLogAdmin::RecordId, DsLogAdmin::LogRecord, ACE_Hash<DsLogAdmin::RecordId>, -ACE_Equal_To<DsLogAdmin::RecordId>, ACE_Null_Mutex> - -#endif /* ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA */ |