odb_lock_test.cxx File Reference

#include <assert.h>
#include "midas.h"
#include "msystem.h"

Include dependency graph for odb_lock_test.cxx:

Go to the source code of this file.

Functions
void	test1 (HNDLE hDB)
int	thread1 (void *)
void	test2 (HNDLE hDB)
int	main (int argc, char *argv[])

Variables
HNDLE	xhDB = -1
BOOL	xThread1done = false

Function Documentation

main()

int main	(	int	argc,
		char *	argv[]
	)

Definition at line 85 of file odb_lock_test.cxx.

{
   setbuf(stdout, NULL);
   setbuf(stderr, NULL);
   int status = 0;
   char host_name[256];
   char expt_name[256];
   host_name[0] = 0;
   expt_name[0] = 0;
 
   cm_get_environment(host_name, sizeof(host_name), expt_name, sizeof(expt_name));
 
   status = cm_connect_experiment1(host_name, expt_name, "odb_lock_test", 0, DEFAULT_ODB_SIZE, 0);
   assert(status == CM_SUCCESS);
   
   HNDLE hDB;
   status = cm_get_experiment_database(&hDB, NULL);
   assert(status == CM_SUCCESS);
 
   cm_set_watchdog_params(0, 0);
 
   test1(hDB);
   test2(hDB);
 
   status = cm_disconnect_experiment();
   assert(status == CM_SUCCESS);
 
   return 0;
}   

Here is the call graph for this function:

test1()

void test1

(

HNDLE

hDB

)

Definition at line 14 of file odb_lock_test.cxx.

{
   printf("test1: test recursive ODB lock\n");
   printf("lock1\n");
   db_lock_database(hDB);
   printf("lock2\n");
   db_lock_database(hDB);
   printf("lock3\n");
   db_lock_database(hDB);
   printf("sleep\n");
   sleep(5);
   printf("unlock3\n");
   db_unlock_database(hDB);
   printf("unlock2\n");
   db_unlock_database(hDB);
   printf("sleep\n");
   sleep(5);
   printf("unlock1\n");
   db_unlock_database(hDB);
   printf("done.\n");
}

Here is the call graph for this function:

Here is the caller graph for this function:

test2()

void test2

(

HNDLE

hDB

)

Definition at line 56 of file odb_lock_test.cxx.

{
   //int timeout = db_set_lock_timeout(hDB, 0);
   //db_set_lock_timeout(hDB, 10000);
   printf("test2: test multithread locking\n");
   printf("t0: lock1\n");
   db_lock_database(hDB);
   printf("t0: lock1 done\n");
   xhDB = hDB;
   ss_thread_create(thread1, NULL);
   printf("t0: sleep\n");
   sleep(5);
   printf("t0: unlock1\n");
   db_unlock_database(hDB);
   printf("t0: lock2\n");
   db_lock_database(hDB);
   printf("t0: lock2 done\n");
   printf("t0: unlock2\n");
   db_unlock_database(hDB);
   printf("t0: unlock2 done\n");
   printf("t0: waiting for thread1...\n");
   while (!xThread1done) {
      printf("t0: waiting\n");
      sleep(1);
   }
   printf("t0: done.\n");
   //db_set_lock_timeout(hDB, timeout);
}

Here is the call graph for this function:

Here is the caller graph for this function:

thread1()

int thread1

(

void *

)

Definition at line 39 of file odb_lock_test.cxx.

{
   HNDLE hDB = xhDB;
   printf("t1: thread started\n");
   printf("t1: lock1\n");
   db_lock_database(hDB);
   printf("t1: lock1 done\n");
   printf("t1: sleep\n");
   sleep(5);
   printf("t1: unlock1\n");
   db_unlock_database(hDB);
   printf("t1: unlock1 done\n");
   printf("t1: thread done\n");
   xThread1done = TRUE;
   return 0;
}

Here is the call graph for this function:

Here is the caller graph for this function:

Variable Documentation

xhDB

HNDLE xhDB = -1

Definition at line 36 of file odb_lock_test.cxx.

xThread1done

BOOL xThread1done = false

Definition at line 37 of file odb_lock_test.cxx.