1 files changed, 443 insertions, 0 deletions
diff --git a/mddmgr/test/test_transmddobj.cc b/mddmgr/test/test_transmddobj.cc
new file mode 100644
index 0000000..28c50d2
--- /dev/null
+++ b/mddmgr/test/test_transmddobj.cc
@@ -0,0 +1,443 @@
+/*
+* This file is part of rasdaman community.
+*
+* Rasdaman community is free software: you can redistribute it and/or modify
+* it under the terms of the GNU General Public License as published by
+* the Free Software Foundation, either version 3 of the License, or
+* (at your option) any later version.
+*
+* Rasdaman community is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+* GNU General Public License for more details.
+*
+* You should have received a copy of the GNU General Public License
+* along with rasdaman community.  If not, see <http://www.gnu.org/licenses/>.
+*
+* Copyright 2003, 2004, 2005, 2006, 2007, 2008, 2009 Peter Baumann /
+rasdaman GmbH.
+*
+* For more information please see <http://www.rasdaman.org>
+* or contact Peter Baumann via <baumann@rasdaman.com>.
+/
+/**
+ * SOURCE: test_transmddcoll.cc
+ *
+ * MODULE: test for transmddobj of cachetamgr
+ *
+ * COMMENTS:
+ *   none
+ *
+*/
+
+#include "rt_odb_Database.hxx"  
+
+#define TEST_PRIVATE
+
+#include <stdlib.h>
+#include <iostream>
+#include <vector.h>                  // STL
+#include "mddmgr/transtile.hh"
+#include "mddmgr/transmddobj.hh"
+
+#include "typefactory.hh"
+#include "ulongtype.hh"              // from catalogif
+#include "mddbasetype.hh"            //  from catalogif
+
+#include "raslib/minterval.hh"
+#include "mddmgr/transmddcoll.hh"
+#include "mddmgr/mddcolliter.hh"
+#include "adminif.hh"
+#include "databaseif.hh"
+#include "transactionif.hh"
+
+#include "raslib/rminit.hh"
+RMINITGLOBALS('C')
+
+#include <malloc.h>
+
+// Needed by Adminif. Adminif has to be instantiated because
+// of cell base types. 
+extern char* myExecArgv0 = "";
+
+void testConstruction( );
+void testRemovetile( );
+void testIntersection( );
+void printMemInfo( );
+
+
+/*************************************************************
+ * Function name.: int main( int argc, char** argv)
+ *
+ * Arguments.....: 
+ *   argc: number of arguments given to program
+ *   argv: array of char* with arguments
+ * Return value..: exit status
+ * Description...: none
+ ************************************************************/
+
+int
+main( int argc, char** argv)
+{
+  myExecArgv0 = argv[0];
+  AdminIf* myAdmin = AdminIf::instance();
+  TransactionIf ta;
+  char O2DBName[] = "BaseTestTransMDDObj"; 
+  
+  // variables representing O2 database, ta and session
+  DatabaseIf database;
+  // connect to the database
+  cout << "Connecting to database " << O2DBName 
+       << "..." << endl;
+  int errorDBOpen;
+  try{
+    errorDBOpen =  database.open( O2DBName );
+  }
+  catch( ...) 
+  {
+     cout << "Caught Exception " << endl;
+     errorDBOpen = -6;
+  }
+  if ( errorDBOpen < 0 )
+  {
+    cout << "Database doesn't exist. Create it new ... " << endl;
+    cout << "Creating new database " << O2DBName
+       << "..." << endl;
+    database.create( O2DBName, "TestSMSchema" );
+    cout << "Connecting to database " << O2DBName 
+       << "..." << endl;
+    try{
+      errorDBOpen =  database.open( O2DBName );
+    }
+    catch(...)
+    {
+       errorDBOpen = -6;
+    }
+  }    
+  if ( errorDBOpen < 0 )
+  {
+    cout << "Failed at opening newly created database " << errorDBOpen << endl;
+    cout << "Exiting " << endl;
+    return errorDBOpen;
+  }
+  
+  ta.begin( &database, 1 );
+  
+  cout << " Main - begin " << endl;
+  printMemInfo( );
+  
+  /*
+  cout << "---------- ";
+  cout << "Testing constructor and insertTile for TransMDDObj: " << endl;
+  testConstruction( );
+  cout << "Testing constructor - end " << endl;
+  printMemInfo( );
+  */
+  
+  cout << "Testing intersection for TransMDDObj: " << endl;
+  testIntersection( );
+  cout << "Testing intersection - end " << endl;
+  printMemInfo( );
+ 
+  
+  /*
+  cout << "---------- ";
+  cout << "Testing removeTile from TransMDDObj: " << endl;
+  testRemovetile( );
+  cout << "Main - end " << endl;
+  printMemInfo( );
+  */
+  
+  ta.abort( );
+  database.close( );
+  
+  delete myAdmin;
+
+}
+
+void testConstruction( )
+{
+  const int numTilesObj = 20;
+  r_Sinterval domSinterval;
+  cout <<"here 1" << endl;
+  ULongType ult;
+  BaseType* anyType = new( (d_Database*)(d_Database::transient_memory) ) ULongType; //  anyType;
+  
+  cout << "here 2"<< endl;
+  const MDDBaseType* anyBaseType = 
+     new( (d_Database*)(d_Database::transient_memory) ) MDDBaseType( "AnyType", &ult/* anyType */ );
+  
+  // const MDDBaseType anyBaseType( "AnyType", &ult );
+  
+  char anyCell[4];
+  int j;
+  MDDObj* testMDDObj;
+  
+  
+  cout << "Creating transient tiles for the MDD object ... " << endl;
+  vector<TransTile*> tilesVect(numTilesObj);
+  
+  
+  // initialize array of tiles
+  for (j=0; j<numTilesObj ; j++)
+  {
+    r_Minterval dom(2);
+    TransTile* tt;
+    
+    domSinterval.set_interval( r_Range(j* 10), r_Range((j+1)*10-1) );
+    dom <<  domSinterval << domSinterval;  
+    cout << "Newly created tile domain : " << dom << "  " << endl;
+    // printMemInfo();
+    tt = new TransTile( dom, anyType, anyCell );
+    cout << "Tile created " << endl;
+    // printMemInfo();
+    tilesVect[j] = tt ;
+  }
+ 
+  // Test trans tiles part - BEGIN
+  // works fine 
+  /*
+  for ( int h=0; h < tilesVect.size(); h++)
+     delete tilesVect[h];
+  */
+  // release (tilesVect.begin( ), tilesVect.end( ) );
+  
+  // Test trans tiles part - END
+  
+  
+  cout << "Creating the transient MDD object ... " << endl;
+  
+  r_Minterval dom(2);
+  domSinterval.set_interval( r_Range( 0 ), r_Range( 100 ) );
+    domSinterval.set_low( '*' );
+  dom << domSinterval << domSinterval;
+  // testMDDObj = new TransMDDObj( dom, "ULong" );
+  testMDDObj = new TransMDDObj( anyBaseType, dom );
+  for(j=0; j < numTilesObj; j++)
+  { 
+    testMDDObj->insertTile(  tilesVect[j] );
+  }
+  // printMemInfo();
+  
+  cout << "Printing contents of the created object ... " << endl;
+  testMDDObj->printStatus( );
+  
+  cout << "Deleting the created object ... " << endl;
+  delete testMDDObj;
+  // printMemInfo();
+  
+  
+}
+
+
+void testIntersection( )
+{
+  const int numTilesObj = 20;
+  r_Sinterval domSinterval;
+
+  const BaseType* ulongTypeObj = TypeFactory::mapType("ULong");
+   
+  char uLongCell[] = {0,1,2,3};
+  
+  const MDDBaseType* anyBaseType = 
+     new MDDBaseType( "AnyType1", (BaseType*) ulongTypeObj );
+   
+  TypeFactory::addTempType( (Type*) anyBaseType );
+  
+  BaseType* bt = ( (MDDBaseType* ) anyBaseType )->getBaseType( ); 
+  cout << "Base type size " <<  bt->getSize( )<< endl;
+  
+  
+  int j;
+  MDDObj* testMDDObj;
+
+  
+  cout << "Creating transient tiles for the MDD object ... " << endl;
+  vector<TransTile*> tilesVect(numTilesObj);
+  
+  
+  // initialize array of tiles
+  for (j=0; j<numTilesObj ; j++)
+  {
+    r_Minterval dom(2);
+    TransTile* tt;
+    
+    domSinterval.set_interval( r_Range(j* 10), r_Range((j+1)*10-1) );
+    dom <<  domSinterval << domSinterval;  
+    cout << "Newly created tile domain : " << dom << "  " << endl;
+    // printMemInfo();
+    tt = new TransTile( dom,  (BaseType*) ulongTypeObj, uLongCell );
+    cout << "Tile created " << endl;
+    if (!j)
+      tt->printStatus( );
+    // printMemInfo();
+    tilesVect[j] = tt ;
+  }
+ 
+  // Test trans tiles part - BEGIN
+  // works fine 
+  /*
+  for ( int h=0; h < tilesVect.size(); h++)
+     delete tilesVect[h];
+  */
+  // release (tilesVect.begin( ), tilesVect.end( ) );
+  
+  // Test trans tiles part - END
+  
+  
+  cout << "Creating the transient MDD object ... " << endl;
+  
+  r_Minterval dom(2);
+  domSinterval.set_interval( r_Range( 0 ), r_Range( 100 ) );
+    domSinterval.set_low( '*' );
+  dom << domSinterval << domSinterval;
+  testMDDObj = new  TransMDDObj( anyBaseType, dom );
+  for(j=0; j < numTilesObj; j++)
+  { 
+    testMDDObj->insertTile(  tilesVect[j] );
+  }
+  // printMemInfo();
+  
+  cout << "Printing contents of the created object ... " << endl;
+  testMDDObj->printStatus( );
+  
+  r_Minterval searchInterval(2);
+  domSinterval.set_interval( r_Range( 4 ), r_Range( 96 ) );
+  searchInterval<< domSinterval ; 
+  domSinterval.set_interval( r_Range( 22 ), r_Range( 84 ) );
+  searchInterval<< domSinterval ; 
+  cout << "Intersection with "<< searchInterval << " :" << endl ;
+  
+  vector<Tile*>* intersectResult = 
+     ( testMDDObj )->intersect( searchInterval );
+  cout << "Result of intersection:" << endl;
+  cout << "Intersect result size " << intersectResult->size( ) << endl;
+  for (int tilesIter = 0; tilesIter < intersectResult->size( ) ; tilesIter++)
+  {
+     Tile* currTile;
+     currTile = (*intersectResult)[tilesIter];
+     cout << "Tile " << tilesIter << " domain : " ;
+     cout << currTile->getDomain( ) << endl;
+  }
+  
+  // printMemInfo();
+  cout << "Deleting intersection result " << endl;
+  // Individual tiles in the intersectResult shouldn't be deleted, since 
+  // they are part of the TransMDDObj. They are deleted whenever the object
+  // is deleted. 
+  delete intersectResult;
+  // printMemInfo();
+  
+  cout << "Testing point query " << endl;
+  r_Point pnt1( r_Range(2) , r_Range(3) );
+  unsigned long* c1 = (unsigned long*) testMDDObj->pointQuery( pnt1 );
+     // char* c1 = testMDDObj->pointQuery( pnt1 );
+  cout << "1. Result "<< pnt1 << ": "<< *c1 << endl;
+  
+  r_Point pnt2( r_Range(20) , r_Range(30) );
+  unsigned long* c2 = (unsigned long*) testMDDObj->pointQuery( pnt2 );
+    // char* c2 = testMDDObj->pointQuery( pnt2 );
+  cout << "2. Result "<< pnt2 << ": "<<  c2 << endl;
+  
+  cout << "Deleting the created object ... " << endl;
+  delete testMDDObj;
+  printMemInfo(); 
+}
+
+
+void testRemovetile( )
+{
+  const int numTilesObj = 20;
+  r_Sinterval domSinterval;
+  BaseType* anyType = new( (d_Database*)(d_Database::transient_memory) )  ULongType; //  ULongType anyType;
+  char anyCell[4]= {'a','b','c','\0'};
+  int j,i;
+  TransMDDObj* testMDDObj;
+  vector<Tile*>* allTilesObj;
+  vector<Tile*> tilesToDelete;
+  const MDDBaseType* anyBaseType = 
+     new( (d_Database*)(d_Database::transient_memory) )  MDDBaseType( "AnyType", anyType );
+   
+  cout << "Creating transient tiles for the MDD object ... " << endl;
+  vector<TransTile*> tilesVect;
+  
+  // initialize array of tiles
+  for ( j=0; j<numTilesObj ; j++)
+  {
+    r_Minterval dom(2);
+    domSinterval.set_interval( r_Range(j* 10), r_Range((j+1)*10-1) );
+    dom <<  domSinterval << domSinterval; 
+    cout << "New TransTile " << endl;
+    tilesVect.push_back( new TransTile( dom, anyType, anyCell ) );
+    // printMemInfo( );
+  }
+  
+  cout << "Creating the transient MDD object ... " << endl;
+  
+  r_Minterval dom(2);
+  domSinterval.set_interval( r_Range( 0 ), r_Range( 100 ) );
+  domSinterval.set_low( '*' );
+  dom << domSinterval << domSinterval;
+  testMDDObj = new TransMDDObj( anyBaseType, dom );
+  for( j=0; j < numTilesObj; j++)
+  { 
+    cout << "InsertTile " << endl ;
+    testMDDObj->insertTile( ( Tile*) tilesVect[j] );
+    // printMemInfo( );
+  }
+  
+  cout << "Printing contents of the created object ... " << endl;
+  testMDDObj->printStatus( );
+  
+  cout << "Getting all tiles from the object... " << endl;
+  allTilesObj = testMDDObj->getTiles( );
+  // printMemInfo( );
+    
+  cout << "Removing tile 2, 4, 6, and 12 from the object... " << endl;
+  for ( i = 0; i < allTilesObj->size( ); i++)
+  {
+    if ( i==2 || i == 4 || i == 6 || i == 12 )
+    {
+      tilesToDelete.push_back( (*allTilesObj)[i]);
+    }    
+  }
+   for ( i = 0; i < tilesToDelete.size( ); i++)
+  {
+    cout << " Tile is going to be removed " << endl;
+    testMDDObj->removeTile(tilesToDelete[i] );
+    cout << endl << " Value of  pointer to tile : " << tilesToDelete[i] << endl<< endl;
+    // printMemInfo();
+  }
+  testMDDObj->printStatus( );
+  
+  cout << "Deleting the created object ... " << endl;
+  // printMemInfo( );
+  delete testMDDObj;
+  cout << "Already deleted " << endl;
+  // printMemInfo( );
+  
+  delete  allTilesObj;
+}
+
+
+void printMemInfo( )
+{
+  
+  
+  // allows to store values in the program
+  struct mallinfo meminfo = mallinfo();
+     
+  cout << "   Memory Usage Information :  " ;
+  cout << endl;
+
+  cout << "      space in arena                 : " << meminfo.arena << endl;
+  cout << "      number of small blocks         : " << meminfo.smblks << endl;
+  cout << "      number of ordinary blocks      : " << meminfo.ordblks << endl;
+  cout << "      space in free ordinary blocks  : " << meminfo.fordblks << endl;
+  cout << "      space in used ordinary blocks  : " << meminfo.uordblks << endl;
+
+  // cout << "additional space from last call: " << meminfo.uordblks - memUsed << endl;
+
+}
+
+