neww ndb automake

ndb/test/tools/hugoCalculator.cpp:
  Rename: ndb/test/tools/hugoCalculator/hugoCalculator.cpp -> ndb/test/tools/hugoCalculator.cpp
ndb/test/tools/hugoLoad.cpp:
  Rename: ndb/test/tools/hugoLoad/hugoLoad.cpp -> ndb/test/tools/hugoLoad.cpp
ndb/test/tools/hugoFill.cpp:
  Rename: ndb/test/tools/hugoFill/hugoFill.cpp -> ndb/test/tools/hugoFill.cpp
ndb/test/tools/hugoLockRecords.cpp:
  Rename: ndb/test/tools/hugoLockRecords/hugoLockRecords.cpp -> ndb/test/tools/hugoLockRecords.cpp
ndb/test/tools/hugoPkRead.cpp:
  Rename: ndb/test/tools/hugoPkRead/hugoPkRead.cpp -> ndb/test/tools/hugoPkRead.cpp
ndb/test/tools/hugoPkReadRecord.cpp:
  Rename: ndb/test/tools/hugoPkReadRecord/hugoPkReadRecord.cpp -> ndb/test/tools/hugoPkReadRecord.cpp
ndb/test/tools/hugoScanRead.cpp:
  Rename: ndb/test/tools/hugoScanRead/hugoScanRead.cpp -> ndb/test/tools/hugoScanRead.cpp
ndb/test/tools/restart.cpp:
  Rename: ndb/test/tools/restart/restart.cpp -> ndb/test/tools/restart.cpp
ndb/test/ndbapi/TraceNdbApi.cpp:
  Rename: ndb/test/ndbapi/acid2/TraceNdbApi.cpp -> ndb/test/ndbapi/TraceNdbApi.cpp
ndb/test/ndbapi/VerifyNdbApi.cpp:
  Rename: ndb/test/ndbapi/acid2/VerifyNdbApi.cpp -> ndb/test/ndbapi/VerifyNdbApi.cpp
ndb/test/ndbapi/acid.cpp:
  Rename: ndb/test/ndbapi/acid/acid.cpp -> ndb/test/ndbapi/acid.cpp
ndb/test/ndbapi/acid2.cpp:
  Rename: ndb/test/ndbapi/acid2/acid2.cpp -> ndb/test/ndbapi/acid2.cpp
ndb/test/ndbapi/bulk_copy.cpp:
  Rename: ndb/test/ndbapi/bulk_copy/bulk_copy.cpp -> ndb/test/ndbapi/bulk_copy.cpp
ndb/test/ndbapi/celloDb.cpp:
  Rename: ndb/test/ndbapi/cello-sessionDb/celloDb.cpp -> ndb/test/ndbapi/celloDb.cpp
ndb/test/ndbapi/create_all_tabs.cpp:
  Rename: ndb/test/ndbapi/create_all_tabs/create_all_tabs.cpp -> ndb/test/ndbapi/create_all_tabs.cpp
ndb/test/ndbapi/create_tab.cpp:
  Rename: ndb/test/ndbapi/create_tab/create_tab.cpp -> ndb/test/ndbapi/create_tab.cpp
ndb/test/ndbapi/drop_all_tabs.cpp:
  Rename: ndb/test/ndbapi/drop_all_tabs/drop_all_tabs.cpp -> ndb/test/ndbapi/drop_all_tabs.cpp
ndb/test/ndbapi/flexAsynch.cpp:
  Rename: ndb/test/ndbapi/flexAsynch/flexAsynch.cpp -> ndb/test/ndbapi/flexAsynch.cpp
ndb/test/ndbapi/flexBench.cpp:
  Rename: ndb/test/ndbapi/flexBench/flexBench.cpp -> ndb/test/ndbapi/flexBench.cpp
ndb/test/ndbapi/flexHammer.cpp:
  Rename: ndb/test/ndbapi/flexHammer/flexHammer.cpp -> ndb/test/ndbapi/flexHammer.cpp
ndb/test/ndbapi/flexScan.cpp:
  Rename: ndb/test/ndbapi/flexScan/flexScan.cpp -> ndb/test/ndbapi/flexScan.cpp
ndb/test/ndbapi/flexTT.cpp:
  Rename: ndb/test/ndbapi/flexTT/flexTT.cpp -> ndb/test/ndbapi/flexTT.cpp
ndb/test/ndbapi/flexTimedAsynch.cpp:
  Rename: ndb/test/ndbapi/flexTimedAsynch/flexTimedAsynch.cpp -> ndb/test/ndbapi/flexTimedAsynch.cpp
ndb/test/ndbapi/flex_bench_mysql.cpp:
  Rename: ndb/test/ndbapi/flex_bench_mysql/flex_bench_mysql.cpp -> ndb/test/ndbapi/flex_bench_mysql.cpp
ndb/test/ndbapi/index.cpp:
  Rename: ndb/test/ndbapi/indexTest/index.cpp -> ndb/test/ndbapi/index.cpp
ndb/test/ndbapi/asyncGenerator.cpp:
  Rename: ndb/test/ndbapi/lmc-bench/async-src/generator/asyncGenerator.cpp -> ndb/test/ndbapi/asyncGenerator.cpp
ndb/test/ndbapi/index2.cpp:
  Rename: ndb/test/ndbapi/indexTest2/index2.cpp -> ndb/test/ndbapi/index2.cpp
ndb/test/ndbapi/interpreterInTup.cpp:
  Rename: ndb/test/ndbapi/interpreterInTup/interpreterInTup.cpp -> ndb/test/ndbapi/interpreterInTup.cpp
ndb/test/ndbapi/mainAsyncGenerator.cpp:
  Rename: ndb/test/ndbapi/lmc-bench/async-src/generator/mainAsyncGenerator.cpp -> ndb/test/ndbapi/mainAsyncGenerator.cpp
ndb/test/ndbapi/ndb_async1.cpp:
  Rename: ndb/test/ndbapi/lmc-bench/async-src/user/ndb_async1.cpp -> ndb/test/ndbapi/ndb_async1.cpp
ndb/test/ndbapi/ndb_async2.cpp:
  Rename: ndb/test/ndbapi/lmc-bench/async-src/user/ndb_async2.cpp -> ndb/test/ndbapi/ndb_async2.cpp
ndb/test/ndbapi/ndb_user_populate.cpp:
  Rename: ndb/test/ndbapi/lmc-bench/src/user/ndb_user_populate.cpp -> ndb/test/ndbapi/ndb_user_populate.cpp
ndb/test/ndbapi/ndb_user_transaction.cpp:
  Rename: ndb/test/ndbapi/lmc-bench/src/user/ndb_user_transaction.cpp -> ndb/test/ndbapi/ndb_user_transaction.cpp
ndb/test/ndbapi/ndb_user_transaction2.cpp:
  Rename: ndb/test/ndbapi/lmc-bench/src/user/ndb_user_transaction2.cpp -> ndb/test/ndbapi/ndb_user_transaction2.cpp
ndb/test/ndbapi/ndb_user_transaction3.cpp:
  Rename: ndb/test/ndbapi/lmc-bench/src/user/ndb_user_transaction3.cpp -> ndb/test/ndbapi/ndb_user_transaction3.cpp
ndb/test/ndbapi/userInterface.cpp:
  Rename: ndb/test/ndbapi/lmc-bench/async-src/user/userInterface.cpp -> ndb/test/ndbapi/userInterface.cpp
ndb/test/ndbapi/benchronja.cpp:
  Rename: ndb/test/ndbapi/ronja/benchronja/benchronja.cpp -> ndb/test/ndbapi/benchronja.cpp
ndb/test/ndbapi/ndb_user_transaction4.cpp:
  Rename: ndb/test/ndbapi/lmc-bench/src/user/ndb_user_transaction4.cpp -> ndb/test/ndbapi/ndb_user_transaction4.cpp
ndb/test/ndbapi/ndb_user_transaction5.cpp:
  Rename: ndb/test/ndbapi/lmc-bench/src/user/ndb_user_transaction5.cpp -> ndb/test/ndbapi/ndb_user_transaction5.cpp
ndb/test/ndbapi/ndb_user_transaction6.cpp:
  Rename: ndb/test/ndbapi/lmc-bench/src/user/ndb_user_transaction6.cpp -> ndb/test/ndbapi/ndb_user_transaction6.cpp
ndb/test/ndbapi/restarter.cpp:
  Rename: ndb/test/ndbapi/restarter/restarter.cpp -> ndb/test/ndbapi/restarter.cpp
ndb/test/ndbapi/restarter2.cpp:
  Rename: ndb/test/ndbapi/restarter2/restarter2.cpp -> ndb/test/ndbapi/restarter2.cpp
ndb/test/ndbapi/restarts.cpp:
  Rename: ndb/test/ndbapi/restarts/restarts.cpp -> ndb/test/ndbapi/restarts.cpp
ndb/test/ndbapi/InsertRecs.cpp:
  Rename: ndb/test/ndbapi/telco/InsertRecs.cpp -> ndb/test/ndbapi/InsertRecs.cpp
ndb/test/ndbapi/adoInsertRecs.cpp:
  Rename: ndb/test/ndbapi/telco/adoInsertRecs.cpp -> ndb/test/ndbapi/adoInsertRecs.cpp
ndb/test/ndbapi/initronja.cpp:
  Rename: ndb/test/ndbapi/ronja/initronja/initronja.cpp -> ndb/test/ndbapi/initronja.cpp
ndb/test/ndbapi/msa.cpp:
  Rename: ndb/test/ndbapi/telco/msa.cpp -> ndb/test/ndbapi/msa.cpp
ndb/test/ndbapi/testBasic.cpp:
  Rename: ndb/test/ndbapi/testBasic/testBasic.cpp -> ndb/test/ndbapi/testBasic.cpp
ndb/test/ndbapi/testDataBuffers.cpp:
  Rename: ndb/test/ndbapi/testDataBuffers/testDataBuffers.cpp -> ndb/test/ndbapi/testDataBuffers.cpp
ndb/test/ndbapi/testDict.cpp:
  Rename: ndb/test/ndbapi/testDict/testDict.cpp -> ndb/test/ndbapi/testDict.cpp
ndb/test/ndbapi/testGrep.cpp:
  Rename: ndb/test/ndbapi/testGrep/testGrep.cpp -> ndb/test/ndbapi/testGrep.cpp
ndb/test/ndbapi/testGrepVerify.cpp:
  Rename: ndb/test/ndbapi/testGrep/verify/testGrepVerify.cpp -> ndb/test/ndbapi/testGrepVerify.cpp
ndb/test/ndbapi/testIndex.cpp:
  Rename: ndb/test/ndbapi/testIndex/testIndex.cpp -> ndb/test/ndbapi/testIndex.cpp
ndb/test/ndbapi/testInterpreter.cpp:
  Rename: ndb/test/ndbapi/testInterpreter/testInterpreter.cpp -> ndb/test/ndbapi/testInterpreter.cpp
ndb/test/ndbapi/testMgm.cpp:
  Rename: ndb/test/ndbapi/testMgm/testMgm.cpp -> ndb/test/ndbapi/testMgm.cpp
ndb/test/ndbapi/testNdbApi.cpp:
  Rename: ndb/test/ndbapi/testNdbApi/testNdbApi.cpp -> ndb/test/ndbapi/testNdbApi.cpp
ndb/test/ndbapi/testNodeRestart.cpp:
  Rename: ndb/test/ndbapi/testNodeRestart/testNodeRestart.cpp -> ndb/test/ndbapi/testNodeRestart.cpp
ndb/test/ndbapi/testOIBasic.cpp:
  Rename: ndb/test/ndbapi/testOIBasic/testOIBasic.cpp -> ndb/test/ndbapi/testOIBasic.cpp
ndb/test/ndbapi/testOperations.cpp:
  Rename: ndb/test/ndbapi/testOperations/testOperations.cpp -> ndb/test/ndbapi/testOperations.cpp
ndb/test/ndbapi/testOrderedIndex.cpp:
  Rename: ndb/test/ndbapi/testOrderedIndex/testOrderedIndex.cpp -> ndb/test/ndbapi/testOrderedIndex.cpp
ndb/test/ndbapi/testRestartGci.cpp:
  Rename: ndb/test/ndbapi/testRestartGci/testRestartGci.cpp -> ndb/test/ndbapi/testRestartGci.cpp
ndb/test/ndbapi/testScan.cpp:
  Rename: ndb/test/ndbapi/testScan/testScan.cpp -> ndb/test/ndbapi/testScan.cpp
ndb/test/ndbapi/testScanInterpreter.cpp:
  Rename: ndb/test/ndbapi/testScanInterpreter/testScanInterpreter.cpp -> ndb/test/ndbapi/testScanInterpreter.cpp
ndb/test/ndbapi/testSystemRestart.cpp:
  Rename: ndb/test/ndbapi/testSystemRestart/testSystemRestart.cpp -> ndb/test/ndbapi/testSystemRestart.cpp
ndb/test/ndbapi/testTimeout.cpp:
  Rename: ndb/test/ndbapi/testTimeout/testTimeout.cpp -> ndb/test/ndbapi/testTimeout.cpp
ndb/test/ndbapi/cdrserver.cpp:
  Rename: ndb/test/ndbapi/vw_test/cdrserver.cpp -> ndb/test/ndbapi/cdrserver.cpp
ndb/test/ndbapi/size.cpp:
  Rename: ndb/test/ndbapi/vw_test/size.cpp -> ndb/test/ndbapi/size.cpp
ndb/test/ndbapi/testTransactions.cpp:
  Rename: ndb/test/ndbapi/testTransactions/testTransactions.cpp -> ndb/test/ndbapi/testTransactions.cpp
ndb/test/ndbapi/test_event.cpp:
  Rename: ndb/test/ndbapi/test_event/test_event.cpp -> ndb/test/ndbapi/test_event.cpp
ndb/tools/delete_all.cpp:
  Rename: ndb/tools/delete_all/delete_all.cpp -> ndb/tools/delete_all.cpp
ndb/tools/desc.cpp:
  Rename: ndb/tools/desc/desc.cpp -> ndb/tools/desc.cpp
ndb/tools/drop_index.cpp:
  Rename: ndb/tools/drop_index/drop_index.cpp -> ndb/tools/drop_index.cpp
ndb/tools/drop_tab.cpp:
  Rename: ndb/tools/drop_tab/drop_tab.cpp -> ndb/tools/drop_tab.cpp
ndb/tools/listTables.cpp:
  Rename: ndb/tools/list_tables/listTables.cpp -> ndb/tools/listTables.cpp
ndb/tools/ndbsql.cpp:
  Rename: ndb/tools/ndbsql/ndbsql.cpp -> ndb/tools/ndbsql.cpp
ndb/tools/select_all.cpp:
  Rename: ndb/tools/select_all/select_all.cpp -> ndb/tools/select_all.cpp
ndb/tools/select_count.cpp:
  Rename: ndb/tools/select_count/select_count.cpp -> ndb/tools/select_count.cpp
ndb/test/tools/hugoScanUpdate.cpp:
  Rename: ndb/test/tools/hugoScanUpd.cpp -> ndb/test/tools/hugoScanUpdate.cpp
ndb/test/tools/hugoPkUpdate.cpp:
  Rename: ndb/test/tools/hugoPkUpd.cpp -> ndb/test/tools/hugoPkUpdate.cpp
ndb/test/tools/hugoPkDelete.cpp:
  Rename: ndb/test/tools/hugoPkDel.cpp -> ndb/test/tools/hugoPkDelete.cpp
ndb/tools/Makefile_old:
  Rename: ndb/tools/Makefile -> ndb/tools/Makefile_old
ndb/test/tools/transproxy.cpp:
  Rename: ndb/tools/transproxy.cpp -> ndb/test/tools/transproxy.cpp
ndb/test/tools/verify_index.cpp:
  Rename: ndb/tools/verify_index.cpp -> ndb/test/tools/verify_index.cpp
ndb/test/tools/copy_tab.cpp:
  Rename: ndb/tools/copy_tab.cpp -> ndb/test/tools/copy_tab.cpp
ndb/test/tools/cpcc.cpp:
  Rename: ndb/tools/cpcc.cpp -> ndb/test/tools/cpcc.cpp
ndb/test/tools/create_index.cpp:
  Rename: ndb/tools/create_index.cpp -> ndb/test/tools/create_index.cpp
ndb/test/tools/old_dirs/waiter/Makefile_old:
  mvdir
ndb/test/tools/old_dirs/waiter/waiter.cpp:
  mvdir
ndb/test/tools/old_dirs/restart/Makefile:
  mvdir
ndb/test/tools/old_dirs/hugoScanUpdate/Makefile:
  mvdir
ndb/test/tools/old_dirs/hugoScanRead/Makefile:
  mvdir
ndb/test/tools/old_dirs/hugoPkUpdate/Makefile:
  mvdir
ndb/test/tools/old_dirs/hugoPkReadRecord/Makefile:
  mvdir
ndb/test/tools/old_dirs/hugoPkRead/Makefile:
  mvdir
ndb/test/tools/old_dirs/hugoPkDelete/Makefile:
  mvdir
ndb/test/tools/old_dirs/hugoLockRecords/Makefile:
  mvdir
ndb/test/tools/old_dirs/hugoLoad/Makefile:
  mvdir
ndb/test/tools/old_dirs/hugoFill/Makefile:
  mvdir
ndb/test/tools/old_dirs/hugoCalculator/Makefile:
  mvdir
ndb/tools/old_dirs/copy_tab/Makefile:
  mvdir
ndb/tools/old_dirs/cpcc/Makefile:
  mvdir
ndb/tools/old_dirs/create_index/Makefile:
  mvdir
ndb/tools/old_dirs/delete_all/Makefile:
  mvdir
ndb/tools/old_dirs/desc/Makefile:
  mvdir
ndb/tools/old_dirs/drop_index/Makefile:
  mvdir
ndb/tools/old_dirs/drop_tab/Makefile:
  mvdir
ndb/tools/old_dirs/list_tables/Makefile:
  mvdir
ndb/tools/old_dirs/select_all/Makefile:
  mvdir
ndb/tools/old_dirs/select_count/Makefile:
  mvdir
ndb/test/tools/old_dirs/transproxy/Makefile:
  mvdir
ndb/test/tools/old_dirs/verify_index/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/flexTT/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/flexTimedAsynch/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/flexHammer/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/flexHammer/README:
  mvdir
ndb/test/ndbapi/old_dirs/flexBench/Makefile.am:
  mvdir
ndb/test/ndbapi/old_dirs/flexBench/Makefile_old:
  mvdir
ndb/test/ndbapi/old_dirs/flexBench/ndbplot.pl:
  mvdir
ndb/test/ndbapi/old_dirs/flexAsynch/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/drop_all_tabs/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/create_tab/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testOIBasic/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testOIBasic/times.txt:
  mvdir
ndb/test/ndbapi/old_dirs/testNodeRestart/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testOperations/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testBlobs/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testBackup/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testDict/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/test_event/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testTransactions/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testTimeout/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testSystemRestart/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testScanInterpreter/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testDataBuffers/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testIndex/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testMgm/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/restarter/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/flexScan/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/flexScan/README:
  mvdir
ndb/test/ndbapi/old_dirs/testRestartGci/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/flex_bench_mysql/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/indexTest/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/indexTest2/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testBasic/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/basicAsynch/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/create_all_tabs/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testNdbApi/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testOrderedIndex/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/restarter2/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/telco/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/telco/readme:
  mvdir
ndb/test/ndbapi/old_dirs/acid/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/acid2/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/acid2/TraceNdbApi.hpp:
  mvdir
ndb/test/ndbapi/old_dirs/acid2/VerifyNdbApi.hpp:
  mvdir
ndb/test/ndbapi/old_dirs/interpreterInTup/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/ronja/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/ronja/benchronja/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/ronja/initronja/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testScan/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/vw_test/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/vw_test/bcd.h:
  mvdir
ndb/test/ndbapi/old_dirs/vw_test/utv.h:
  mvdir
ndb/test/ndbapi/old_dirs/vw_test/vcdrfunc.h:
  mvdir
ndb/test/ndbapi/old_dirs/vw_test/script/client_start:
  mvdir
ndb/test/ndbapi/old_dirs/testGrep/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testGrep/verify/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/testInterpreter/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/restarts/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/bulk_copy/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/async-src/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/async-src/generator/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/async-src/include/dbGenerator.h:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/async-src/include/testData.h:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/async-src/include/userInterface.h:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/async-src/user/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/async-src/user/macros.h:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/async-src/user/ndb_error.hpp:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/bin/.empty:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/include/ndb_schema.hpp:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/include/testDefinitions.h:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/lib/.empty:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/script/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/script/async-lmc-bench-l-p10.sh:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/script/async-lmc-bench-l.sh:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/script/async-lmc-bench-p10.sh:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/script/async-lmc-bench.sh:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/README:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/generator/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/generator/dbGenerator.c:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/makevars.linux:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/makevars.sparc:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/generator/dbGenerator.h:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/generator/mainGenerator.c:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/include/testData.h:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/include/userInterface.h:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/populator/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/populator/dbPopulate.c:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/populator/dbPopulate.h:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/populator/mainPopulate.c:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/user/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/user/localDbPrepare.c:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/user/macros.h:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/user/ndb_error.hpp:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/user/old/Makefile:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/user/old/userHandle.h:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/user/old/userInterface.c:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/user/old/userTransaction.c:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/user/userHandle.h:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/user/userInterface.cpp:
  mvdir
ndb/test/ndbapi/old_dirs/lmc-bench/src/user/userTransaction.c:
  mvdir
ndb/test/ndbapi/testBasicAsynch.cpp:
  Change mode to -rw-rw-r--
ndb/tools/old_dirs/ndbnet/Makefile.PL:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Net.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Base.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Client.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Command.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Config.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Run.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Util.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/ndbnet.pl:
  mvdir
ndb/tools/old_dirs/ndbnet/ndbnetd.pl:
  mvdir
ndb/tools/old_dirs/ndbnet/ndbrun:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Database.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Env.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Node.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Net/NodeApi.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Net/NodeDb.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Net/NodeMgmt.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Net/Server.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Net/ServerINET.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Net/ServerUNIX.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Run/Base.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Run/Database.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Run/Env.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Run/Node.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Util/Base.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Util/Dir.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Util/Event.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Util/File.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Util/IO.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Util/Lock.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Util/Log.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Util/Socket.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Util/SocketINET.pm:
  mvdir
ndb/tools/old_dirs/ndbnet/lib/NDB/Util/SocketUNIX.pm:
  mvdir
ndb/tools/old_dirs/ndbsql/Makefile:
  mvdir
ndb/tools/old_dirs/src/counterviewer/CounterViewer.java:
  mvdir
ndb/test/ndbapi/bank/Bank.hpp:
  mvdir
ndb/test/ndbapi/bank/Makefile_old:
  Rename: ndb/test/ndbapi/bank/Makefile -> ndb/test/ndbapi/bank/Makefile_old
ndb/test/ndbapi/bank/old_dirs/bankCreator/Makefile:
  mvdir
ndb/test/ndbapi/bank/old_dirs/bankSumAccounts/Makefile:
  mvdir
ndb/test/ndbapi/bank/old_dirs/bankMakeGL/Makefile:
  mvdir
ndb/test/ndbapi/bank/old_dirs/bankTimer/Makefile:
  mvdir
ndb/test/ndbapi/bank/old_dirs/bankValidateAllGLs/Makefile:
  mvdir
ndb/test/ndbapi/bank/old_dirs/bankTransactionMaker/Makefile:
  mvdir
ndb/test/ndbapi/bank/old_dirs/src/Makefile:
  mvdir
ndb/test/ndbapi/bank/old_dirs/testBank/Makefile:
  mvdir
ndb/test/ndbapi/ScanFilter.hpp:
  Rename: ndb/test/ndbapi/old_dirs/testScanInterpreter/ScanFilter.hpp -> ndb/test/ndbapi/ScanFilter.hpp
ndb/test/ndbapi/ScanInterpretTest.hpp:
  Rename: ndb/test/ndbapi/old_dirs/testScanInterpreter/ScanInterpretTest.hpp -> ndb/test/ndbapi/ScanInterpretTest.hpp
ndb/test/ndbapi/ScanFunctions.hpp:
  Rename: ndb/test/ndbapi/old_dirs/testScan/ScanFunctions.hpp -> ndb/test/ndbapi/ScanFunctions.hpp

1 files changed, 1503 insertions, 0 deletions

diff --git a/ndb/test/ndbapi/celloDb.cpp b/ndb/test/ndbapi/celloDb.cpp
new file mode 100644
index 00000000000..ec61e783585
--- /dev/null
+++ b/ndb/test/ndbapi/celloDb.cpp
@@ -0,0 +1,1503 @@
+/* Copyright (C) 2003 MySQL AB
+
+   This program 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 2 of the License, or
+   (at your option) any later version.
+
+   This program 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 this program; if not, write to the Free Software
+   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
+
+
+/* ***************************************************
+       BASIC TEST 1
+       Test basic functions and status of NDB
+
+       Arguments:
+        none 
+
+       Returns:
+        0 - Test passed
+       -1 - Test failed
+        1 - Invalid arguments
+flexBench
+ * *************************************************** */
+
+#include <NdbApi.hpp>
+#include <NdbMain.h>
+
+#define MAXATTR 4
+#define MAXTABLES 4
+#define PAGESIZE 8192
+#define OVERHEAD 0.02
+#define NUMBEROFRECORDS 10
+#define PKSIZE 1
+#define ATTRNAMELEN 16
+
+
+static void  createTable_IPACCT(Ndb*);
+static void  createTable_RPACCT(Ndb*);
+static void  createTable_SBMCALL(Ndb*);
+static void  createTable_TODACCT(Ndb*);
+
+static void  error_handler(const char*);
+static bool  error_handler2(const char*, int) ;
+
+static void  setAttrNames(void);
+static void  setTableNames(void);
+static void  create_table(Ndb*);
+static void  insert_rows(Ndb*);
+static void  update_rows(Ndb*);
+static void  delete_rows(Ndb*);
+static void  verify_deleted(Ndb*);
+static void  read_and_verify_rows(Ndb*);
+
+static void  insert_IPACCT(Ndb*, Uint32, Uint32, Uint32, Uint32, Uint32); //3 for Pk, and two data. just to test;
+
+static void read_IPACCT(Ndb* , Uint32 , Uint32  , Uint32 );
+
+static  int		        tAttributeSize;
+static  int             bTestPassed;
+
+static  char    		tableName[MAXTABLES][ATTRNAMELEN];static  char		    attrName[MAXATTR][ATTRNAMELEN];
+static  int    		    attrValue[NUMBEROFRECORDS];
+static  int                 pkValue[NUMBEROFRECORDS];
+static int		    failed = 0 ;
+#include <NdbOut.hpp>
+
+NDB_COMMAND(celloDb, "celloDb", "celloDb", "celloDb", 65535)
+{
+
+  int                   tTableId;
+  int                   i;
+  Ndb	      		MyNdb( "CELLO-SESSION-DB" );
+
+  MyNdb.init();
+
+  // Assume test passed
+  bTestPassed = 0;
+  /*
+  // Initialize global variables
+  for (i = 0; i < NUMBEROFRECORDS; i ++)
+     pkValue[i] = i; 
+  
+  for (i = 0; i < NUMBEROFRECORDS; i ++)
+     attrValue[i] = i;
+  */
+  tAttributeSize = 1;
+
+  // Wait for Ndb to become ready
+  if (MyNdb.waitUntilReady() == 0) {
+    ndbout << endl << "Cello session db - Starting " << endl;
+    ndbout << "Test basic functions and status of NDB" << endl;
+    
+
+      
+    createTable_SBMCALL (&MyNdb );
+    createTable_RPACCT (&MyNdb );
+    createTable_TODACCT (&MyNdb );
+    createTable_IPACCT (&MyNdb );
+    
+    insert_IPACCT(&MyNdb, 1,2,1,2,2);
+    read_IPACCT(&MyNdb, 1, 2 , 1);
+    /*
+      insert_rows(&MyNdb);
+
+      read_and_verify_rows(&MyNdb);
+
+
+      // Create some new values to use for update
+      for (i = 0; i < NUMBEROFRECORDS; i++)
+		  attrValue[i] = NUMBEROFRECORDS-i;
+
+      update_rows(&MyNdb);
+
+      read_and_verify_rows(&MyNdb);
+
+      delete_rows(&MyNdb);
+
+      verify_deleted(&MyNdb);
+      */
+    }
+    else {
+	bTestPassed = -1;
+      }
+
+
+  if (bTestPassed == 0)
+    {
+      // Test passed
+      ndbout << "OK - Test passed" << endl;
+    }
+  else
+    {
+      // Test failed
+      ndbout << "FAIL - Test failed" << endl;
+      exit(-1);
+    }
+  return NULL;
+}
+
+static void 
+error_handler(const char* errorText)
+{
+  // Test failed 
+  ndbout << endl << "ErrorMessage: " << errorText << endl;
+  bTestPassed = -1;
+}
+
+static void
+createTable_SBMCALL ( Ndb* pMyNdb )
+{
+  /****************************************************************
+   *	Create table and attributes. 	
+   *
+   *    create table SBMCALL(
+   *      for attribs, see the REQ SPEC for cello session DB
+   *     )
+   *  
+   ***************************************************************/ 
+
+  const char* tname = "SBMCALL";
+  Uint32 recordsize = 244; //including 12 byte overhead
+  Uint32 pksize = 8; //size of total prim. key. in bytes. sum of entire composite PK.
+  Uint32 tTableId = pMyNdb->getTable()->openTable(tname);
+  
+  if (tTableId == -1) {    
+    Uint32              check; 
+    Uint32              i;
+    NdbSchemaCon      	*MySchemaTransaction;
+    NdbSchemaOp	       	*MySchemaOp;
+    
+    ndbout << "Creating " << tname << "..." << endl;
+    
+    MySchemaTransaction = pMyNdb->startSchemaTransaction();
+    if( ( MySchemaTransaction == NULL ) && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+    MySchemaOp = MySchemaTransaction->getNdbSchemaOp();	
+    if( ( MySchemaOp == NULL ) && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+        
+    // Createtable
+
+    Uint32 tablesize=(recordsize*NUMBEROFRECORDS + OVERHEAD * NUMBEROFRECORDS)/1024;
+    Uint32 noPages=(pksize*NUMBEROFRECORDS)/PAGESIZE;
+    
+    ndbout << "table size " << tablesize << "for table name " << tname << endl;
+    
+    check = MySchemaOp->createTable( tname,
+        		             tablesize,		// Table Size
+				     TupleKey,	// Key Type
+				     noPages,		// Nr of Pages
+				     All,
+				     6,
+				     78,
+				     80,
+				     1,
+				     true
+				     );
+    
+    if( check == -1 ) {
+      error_handler(MySchemaTransaction->getNdbErrorString());
+      exit(-1);
+    }
+    
+
+    
+    // Create first column, primary key 
+    check = MySchemaOp->createAttribute( "SPBBOARDID",
+					 TupleKey,
+					 32,
+					 PKSIZE,
+					 UnSigned,
+					 MMBased,
+					 NotNullAttribute );
+
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+
+    // Create second column, primary key 
+    check = MySchemaOp->createAttribute( "CALLID",
+					 TupleKey,
+					 32,
+					 PKSIZE,
+					 UnSigned,
+					 MMBased,
+					 NotNullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+
+    // Creat thrid column, RP Session info, byte[16] represented as (String, 16)
+    check = MySchemaOp->createAttribute( "RPSESS",
+					 NoKey,
+					 32,
+					 16,
+					 String,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+// Creat fourth column, GRE Tunnel info, byte[16] represented as (String, 16)
+    check = MySchemaOp->createAttribute( "GRETUNNEL",
+					 NoKey,
+					 32,
+					 16,
+					 String,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+// Creat fifth column, PPP Session info, byte[24] represented as (String, 24)
+    check = MySchemaOp->createAttribute( "PPPSESS",
+					 NoKey,
+					 32,
+					 24,
+					 String,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+    
+    if( (MySchemaTransaction->execute() == -1) && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+    pMyNdb->closeSchemaTransaction(MySchemaTransaction);
+    ndbout << "done" << endl;
+    
+    
+  } //if 
+  
+  //else table already created , proceed
+}
+
+
+
+static void
+createTable_RPACCT(Ndb*pMyNdb)
+{
+  
+  /****************************************************************
+   *	Create table and attributes. 	
+   *
+   *    create table RPACCT(
+   *      for attribs, see the REQ SPEC for cello session DB
+   *     )
+   *  
+   ***************************************************************/ 
+ 
+ const char* tname = "RPACCT";
+ Uint32 recordsize = 380; //including 12 byte overhead
+ Uint32 pksize = 8; //size of total prim. key. in bytes.
+ Uint32 tTableId = pMyNdb->getTable()->openTable(tname);
+ 
+ if (tTableId == -1) {    
+   Uint32              check; 
+   Uint32              i;
+   NdbSchemaCon      	*MySchemaTransaction;
+   NdbSchemaOp	       	*MySchemaOp;
+   
+   ndbout << "Creating " << tname << "..." << endl;
+   
+   MySchemaTransaction = pMyNdb->startSchemaTransaction();
+   if( MySchemaTransaction == NULL )
+     error_handler(MySchemaTransaction->getNdbErrorString());
+   
+   MySchemaOp = MySchemaTransaction->getNdbSchemaOp();	
+   if( MySchemaOp == NULL ) 
+      error_handler(MySchemaTransaction->getNdbErrorString());
+   
+   // Createtable
+   
+   Uint32 tablesize=(recordsize*NUMBEROFRECORDS + OVERHEAD * NUMBEROFRECORDS)/1024;
+   Uint32 noPages=(pksize*NUMBEROFRECORDS)/PAGESIZE;
+   
+   ndbout << "table size " << tablesize << "for table name " << tname << endl;
+   
+   check = MySchemaOp->createTable( tname,
+				    tablesize,		// Table Size
+				    TupleKey,	// Key Type
+				     noPages		// Nr of Pages
+				    );
+   
+   if( check == -1 ) 
+     error_handler(MySchemaTransaction->getNdbErrorString());
+   
+   
+   
+   // Create first column, primary key 
+   check = MySchemaOp->createAttribute( "SPBBOARDID",
+					TupleKey,
+					32,
+					PKSIZE,
+					 UnSigned,
+					MMBased,
+					NotNullAttribute );
+   
+   if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+     exit (-1) ;
+   
+   
+   // Create second column, primary key 
+   check = MySchemaOp->createAttribute( "CALLID",
+					TupleKey,
+					32,
+					PKSIZE,
+					 UnSigned,
+					 MMBased,
+					 NotNullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+
+    // Creat thrid column MS ID, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "MSID",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+
+    // Create PDSN FA Address, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "PDSN",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+
+    // Create Serving PCF, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "SPCF",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+
+
+    // Create BS ID, 12 byte char, represented as String,12
+    check = MySchemaOp->createAttribute( "BSID",
+					 NoKey,
+					 32,
+					 12,
+					 String,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+
+
+
+
+    // Create User Zone, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "UZ",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+
+    // Create Forward Multiplex, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "FMO",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+
+    // Create Reverse Multiplex, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "RMO",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+    // Create Forward Fund rate, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "FFR",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+    
+ // Create Reverse Fund rate, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "RFR",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+    
+ // Create Service Option, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "SO",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+
+
+ // Create Forward Traffic Type, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "FTT",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+
+// Create Reverse Traffic Type, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "RTT",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+
+// Create Fund Frame Size, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "FFS",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+
+// Create Forware Fund RC, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "FFRC",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+
+    // Create Reverse Fund RC, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "RFRC",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+
+    // Create DCCH Frame Format, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "DCCH",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+    
+    // Create Airlink QOS, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "AQOS",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+
+// Create Bad PPP Frame Count , 4 byte unsigned
+    check = MySchemaOp->createAttribute( "BPPPFC",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+
+
+// Create Active Time , 4 byte unsigned
+    check = MySchemaOp->createAttribute( "AT",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+
+// Create Nb Active Transitions , 4 byte unsigned
+    check = MySchemaOp->createAttribute( "NBAT",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+// Create SDB Octet Count In , 4 byte unsigned
+    check = MySchemaOp->createAttribute( "SDBOCI",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+    
+
+// Create Nb SDB In, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "NBSDBI",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+
+
+// Create Nb SDB Out, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "NBSDBO",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+
+
+// Create HDLC Bytes received, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "HDLC",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+
+    
+    if( (MySchemaTransaction->execute() == -1) && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+    pMyNdb->closeSchemaTransaction(MySchemaTransaction);
+    ndbout << "done" << endl;
+    
+ } //if 
+  
+ //else table already created , proceed
+  }
+ 
+
+static void
+createTable_IPACCT(Ndb* pMyNdb)
+{
+
+
+  /****************************************************************
+   *	Create table and attributes. 	
+   *
+   *    create table IPACCT(
+   *      for attribs, see the REQ SPEC for cello session DB
+   *     )
+   *  
+   ***************************************************************/ 
+
+  const char* tname = "IPACCT";
+  Uint32 recordsize = 70; //including 12 byte overhead
+  Uint32 pksize = 12; //size of total prim. key. in bytes.
+  Uint32 tTableId = pMyNdb->getTable()->openTable(tname);
+  
+  if (tTableId == -1) {    
+    Uint32              check; 
+    Uint32              i;
+    NdbSchemaCon      	*MySchemaTransaction;
+    NdbSchemaOp	       	*MySchemaOp;
+    
+    ndbout << "Creating " << tname << "..." << endl;
+    
+    MySchemaTransaction = pMyNdb->startSchemaTransaction();
+    if( MySchemaTransaction == NULL )
+      error_handler(MySchemaTransaction->getNdbErrorString());
+    
+    MySchemaOp = MySchemaTransaction->getNdbSchemaOp();	
+    if( MySchemaOp == NULL ) 
+      error_handler(MySchemaTransaction->getNdbErrorString());
+    
+    // Createtable
+
+    Uint32 tablesize=(recordsize*NUMBEROFRECORDS + OVERHEAD * NUMBEROFRECORDS)/1024;
+    Uint32 noPages=(pksize*NUMBEROFRECORDS)/PAGESIZE;
+    
+    ndbout << "table size " << tablesize << "for table name " << tname << endl;
+    
+    check = MySchemaOp->createTable( tname,
+        		             tablesize,		// Table Size
+				     TupleKey,	// Key Type
+				     noPages		// Nr of Pages
+				     );
+    
+    if( check == -1 ) 
+      error_handler(MySchemaTransaction->getNdbErrorString());
+    
+
+
+    // Create first column, primary key 
+    check = MySchemaOp->createAttribute( "SPBBOARDID",
+					 TupleKey,
+					 32,
+					 PKSIZE,
+					 UnSigned,
+					 MMBased,
+					 NotNullAttribute );
+
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+
+    // Create second column, primary key 
+    check = MySchemaOp->createAttribute( "CALLID",
+					 TupleKey,
+					 32,
+					 PKSIZE,
+					 UnSigned,
+					 MMBased,
+					 NotNullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+   // Create third column, primary key 
+    check = MySchemaOp->createAttribute( "IPADDR",
+					 TupleKey,
+					 32,
+					 PKSIZE,
+					 String,
+					 MMBased,
+					 NotNullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+     
+
+// Create Acct session id  4 byte unsigned
+    check = MySchemaOp->createAttribute( "ASID",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+// Create Correlation ID, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "CID",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+// Create MIP HA Address, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "MIPHA",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+    
+
+    
+// Create IP technology, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "IPT",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+
+// Create Compuls Tunnel ID, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "CTID",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+// Create IP QOS, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "IPQOS",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+    
+    // Create Data octet count in, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "DOCI",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+    // Create Data octet count out, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "DOCO",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+    // Create Event time, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "ET",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+     // Create In mip sig count, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "IMSC",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+// Create Out mip sig count, 4 byte unsigned
+    check = MySchemaOp->createAttribute( "OMSC",
+					 NoKey,
+					 32,
+					 1,
+					 UnSigned,
+					 MMBased,
+					 NullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+    
+    if( (MySchemaTransaction->execute() == -1) && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+    pMyNdb->closeSchemaTransaction(MySchemaTransaction);
+    ndbout << "done" << endl;
+    
+
+
+  } //if 
+
+  //else table already created , proceed
+}
+
+
+static void
+createTable_TODACCT(Ndb* pMyNdb)
+{
+
+
+  /****************************************************************
+   *	Create table and attributes. 	
+   *
+   *    create table TODACCT(
+   *      for attribs, see the REQ SPEC for cello session DB
+   *     )
+   *  
+   ***************************************************************/ 
+  
+  const char* tname = "TODACCT";
+  Uint32 recordsize = 92; //including 12 byte overhead
+  Uint32 pksize = 12; //size of total prim. key. in bytes.
+  Uint32 tTableId = pMyNdb->getTable()->openTable(tname);
+  
+  if (tTableId == -1) {    
+    Uint32              check; 
+    Uint32              i;
+    NdbSchemaCon      	*MySchemaTransaction;
+    NdbSchemaOp	       	*MySchemaOp;
+    
+    ndbout << "Creating " << tname << "..." << endl;
+    
+    MySchemaTransaction = pMyNdb->startSchemaTransaction();
+    if( MySchemaTransaction == NULL )
+      error_handler(MySchemaTransaction->getNdbErrorString());
+    
+    MySchemaOp = MySchemaTransaction->getNdbSchemaOp();	
+    if( MySchemaOp == NULL ) 
+      error_handler(MySchemaTransaction->getNdbErrorString());
+    
+    // Createtable
+    
+    Uint32 tablesize=(recordsize*NUMBEROFRECORDS + OVERHEAD * NUMBEROFRECORDS)/1024;
+    Uint32 noPages=(pksize*NUMBEROFRECORDS)/PAGESIZE;
+    
+    ndbout << "table size " << tablesize << "for table name " << tname << endl;
+    
+    check = MySchemaOp->createTable( tname,
+        		             tablesize,		// Table Size
+				     TupleKey,	// Key Type
+				     noPages		// Nr of Pages
+				     );
+    
+    if( check == -1 ) 
+      error_handler(MySchemaTransaction->getNdbErrorString());
+    
+
+
+    // Create first column, primary key 
+    check = MySchemaOp->createAttribute( "SPBBOARDID",
+					 TupleKey,
+					 32,
+					 PKSIZE,
+					 UnSigned,
+					 MMBased,
+					 NotNullAttribute );
+
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+    
+
+    // Create second column, primary key 
+    check = MySchemaOp->createAttribute( "CALLID",
+					 TupleKey,
+					 32,
+					 PKSIZE,
+					 UnSigned,
+					 MMBased,
+					 NotNullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+   // Create third column, primary key 
+    check = MySchemaOp->createAttribute( "IPADDR",
+					 TupleKey,
+					 32,
+					 PKSIZE,
+					 String,
+					 MMBased,
+					 NotNullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+
+   // Create third column, primary key 
+    check = MySchemaOp->createAttribute( "INDEX",
+					 TupleKey,
+					 32,
+					 PKSIZE,
+					 UnSigned,
+					 MMBased,
+					 NotNullAttribute );
+    
+    if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+     
+
+// Create Acct session id  4 byte unsigned
+    check = MySchemaOp->createAttribute( "TOD",
+					 NoKey,
+					 32,
+					 16,
+					 String,
+					 MMBased,
+					 NullAttribute );
+
+
+   if( (check == -1)  && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+      exit (-1) ;
+
+
+     
+   if( (MySchemaTransaction->execute() == -1) && (!error_handler2((const char*)MySchemaTransaction->getNdbErrorString(),  MySchemaTransaction->getNdbError())) )
+     exit (-1) ;
+   
+   pMyNdb->closeSchemaTransaction(MySchemaTransaction);
+   ndbout << "done" << endl;
+   
+  } //if 
+  
+ //else table already created , proceed
+}
+
+
+
+
+
+
+static void  read_IPACCT(Ndb* pMyNdb, Uint32 CALLID, Uint32 SPBBOARDID , Uint32 IPADDR)
+{
+
+
+  int                   check;
+  int                   loop_count_ops;
+  int					count;
+  int                   count_attributes;
+  char* value;
+  NdbConnection			*MyTransaction;
+  NdbOperation			*MyOperation;
+  NdbRecAttr*           tTmp;
+  
+  
+  
+  MyTransaction = pMyNdb->startTransaction();
+  if (MyTransaction == NULL)
+    error_handler(pMyNdb->getNdbErrorString());
+  
+  MyOperation = MyTransaction->getNdbOperation("IPACCT");	
+  if (MyOperation == NULL) 
+    error_handler( MyTransaction->getNdbErrorString());
+  
+  check = MyOperation->readTuple();
+  if( check == -1 ) 
+    error_handler( MyTransaction->getNdbErrorString());
+  
+  check = MyOperation->equal( "SPBBOARDID",SPBBOARDID );
+  if( check == -1 ) 
+    error_handler( MyTransaction->getNdbErrorString());
+  
+
+  check = MyOperation->equal( "IPADDR","IPADDR" );
+  if( check == -1 ) 
+    error_handler( MyTransaction->getNdbErrorString());
+  
+
+  check = MyOperation->equal( "CALLID",CALLID );
+  if( check == -1 ) 
+    error_handler( MyTransaction->getNdbErrorString());
+
+
+
+
+  tTmp = MyOperation->getValue("IPQOS", NULL );
+  if( tTmp == NULL ) 
+    error_handler( MyTransaction->getNdbErrorString());
+  ndbout << " tTmp " << tTmp->isNULL() << endl;
+  MyTransaction->execute(Commit);
+  
+  ndbout << " value read " << tTmp->int32_value() << endl;
+  
+}
+
+
+
+static void  insert_IPACCT(Ndb* pMyNdb, Uint32 CALLID, Uint32 SPBBOARDID , Uint32 IPADDR, Uint32 ASID, Uint32 IPQOS)
+{
+  /****************************************************************
+   *	Insert rows 	
+   *
+   ***************************************************************/
+
+  int                   check;
+  int                   loop_count_ops;
+  int					count;
+  int                   i;
+  NdbConnection			*MyTransaction;
+  NdbOperation			*MyOperation;
+ 
+  ndbout << "Inserting records..."  << flush;
+   
+  MyTransaction = pMyNdb->startTransaction();
+  if (MyTransaction == NULL)	  
+    error_handler(pMyNdb->getNdbErrorString());
+  
+  MyOperation = MyTransaction->getNdbOperation("IPACCT");	
+  if (MyOperation == NULL) 
+    error_handler(MyTransaction->getNdbErrorString());
+ 
+
+ 
+  check = MyOperation->insertTuple();
+  if( check == -1 ) 
+    error_handler(MyTransaction->getNdbErrorString());
+  
+  ndbout << "insertTuple"  << endl;  
+  
+  check = MyOperation->equal("CALLID",CALLID );
+  if( check == -1 ) 
+    error_handler(MyTransaction->getNdbErrorString());
+  ndbout << "equal"  << endl;  
+  
+
+  check = MyOperation->equal("SPBBOARDID",SPBBOARDID );
+  if( check == -1 ) 
+    error_handler(MyTransaction->getNdbErrorString());
+  ndbout << "equal"  << endl;  
+
+
+  check = MyOperation->equal("IPADDR","IPADDR" );
+  if( check == -1 ) 
+    error_handler(MyTransaction->getNdbErrorString());
+  ndbout << "equal"  << endl;  
+
+
+  check = MyOperation->setValue( "IPQOS", IPQOS);
+  if( check == -1 ) 
+    error_handler(MyTransaction->getNdbErrorString());
+  ndbout << "Set Value"  << endl;
+  
+
+
+  check = MyOperation->setValue( "ASID", ASID);
+  if( check == -1 ) 
+    error_handler(MyTransaction->getNdbErrorString());
+  ndbout << "Set Value"  << endl;
+  
+
+  check = MyTransaction->execute( Commit ); 
+  if(check == -1 ) {
+    ndbout << "error at commit"  << endl;
+    error_handler(MyTransaction->getNdbErrorString());
+  }
+  else
+    ;//ndbout << ".";
+  
+  pMyNdb->closeTransaction(MyTransaction);
+  
+  
+      
+  ndbout << "OK" << endl;
+  
+  return;
+}
+
+static void  
+update_rows(Ndb* pMyNdb){
+ /****************************************************************
+   *	Update rows in SimpleTable 	
+   *
+   ***************************************************************/
+
+  int                   check;
+  int                   loop_count_ops;
+  int					count;
+  int                   i;
+  NdbConnection			*MyTransaction;
+  NdbOperation			*MyOperation;
+
+   ndbout << "Updating records..." << flush;
+   
+   loop_count_ops = NUMBEROFRECORDS;
+
+   for (count=0 ; count < loop_count_ops ; count++)    {
+
+      MyTransaction = pMyNdb->startTransaction();
+      if (MyTransaction == NULL)
+		  error_handler( pMyNdb->getNdbErrorString() );
+
+      MyOperation = MyTransaction->getNdbOperation(tableName[0]);	
+      if (MyOperation == NULL) 
+        error_handler(MyTransaction->getNdbErrorString());
+
+      check = MyOperation->updateTuple();
+      if( check == -1 ) 
+        error_handler(MyTransaction->getNdbErrorString());
+	 
+      check = MyOperation->equal( attrName[0], (char*)&pkValue[count] );
+      if( check == -1 ) 
+         error_handler(MyTransaction->getNdbErrorString());
+
+      for (i = 1; i < MAXATTR; i++)
+	{
+          check = MyOperation->setValue( attrName[i], (char*)&attrValue[count]);
+          if( check == -1 ) 
+             error_handler(MyTransaction->getNdbErrorString());
+	}
+
+      if( MyTransaction->execute( Commit ) == -1 )
+         error_handler(MyTransaction->getNdbErrorString());
+      else
+	;//ndbout << ".";
+        
+      pMyNdb->closeTransaction(MyTransaction);
+
+    }
+
+   ndbout << "OK" << endl;
+  return;
+
+};
+
+static void  
+delete_rows(Ndb* pMyNdb){
+
+  /****************************************************************
+   *	Delete rows from SimpleTable 	
+   *
+   ***************************************************************/
+
+  int                   check;
+  int                   loop_count_ops;
+  int					count;
+  NdbConnection			*MyTransaction;
+  NdbOperation			*MyOperation;
+
+   ndbout << "Deleting records..."<< flush;
+   
+   loop_count_ops = NUMBEROFRECORDS;
+
+   for (count=0 ; count < loop_count_ops ; count++)    {
+
+      MyTransaction = pMyNdb->startTransaction();
+      if (MyTransaction == NULL)
+		  error_handler( pMyNdb->getNdbErrorString() );
+
+      MyOperation = MyTransaction->getNdbOperation(tableName[0]);	
+      if (MyOperation == NULL) 
+        error_handler(MyTransaction->getNdbErrorString());
+
+
+      check = MyOperation->deleteTuple();
+      if( check == -1 ) 
+        error_handler(MyTransaction->getNdbErrorString());
+	 
+      check = MyOperation->equal( attrName[0], (char*)&pkValue[count] );
+      if( check == -1 ) 
+         error_handler(MyTransaction->getNdbErrorString());
+
+
+      if( MyTransaction->execute( Commit ) == -1 )
+         error_handler(MyTransaction->getNdbErrorString());
+      else
+	;// ndbout << ".";
+        
+      pMyNdb->closeTransaction(MyTransaction);
+
+    }
+
+   ndbout << "OK" << endl;
+  return;
+
+};
+
+static void 
+verify_deleted(Ndb* pMyNdb){
+  int                   check;
+  int                   loop_count_ops;
+  int					count;
+  NdbConnection			*MyTransaction;
+  NdbOperation			*MyOperation;
+
+  ndbout << "Verifying deleted records..."<< flush;
+    
+  loop_count_ops = NUMBEROFRECORDS;
+
+  for (count=0 ; count < loop_count_ops ; count++)
+  {
+     MyTransaction = pMyNdb->startTransaction();
+     if (MyTransaction == NULL)
+        error_handler(pMyNdb->getNdbErrorString());
+
+     MyOperation = MyTransaction->getNdbOperation(tableName[0]);	
+     if (MyOperation == NULL) 
+        error_handler( MyTransaction->getNdbErrorString());
+       
+     check = MyOperation->readTuple();
+     if( check == -1 ) 
+       error_handler( MyTransaction->getNdbErrorString());
+
+     check = MyOperation->equal( attrName[0],(char*)&pkValue[count] );
+     if( check == -1 ) 
+        error_handler( MyTransaction->getNdbErrorString());
+
+     // Exepect to receive an error
+      if( MyTransaction->execute( Commit ) != -1 ) 
+         error_handler(MyTransaction->getNdbErrorString());
+      else
+      {
+        ;//ndbout << ".";
+      }
+     
+      pMyNdb->closeTransaction(MyTransaction);
+
+    }
+
+   ndbout << "OK" << endl;
+  return;
+};
+
+static void 
+read_and_verify_rows(Ndb* pMyNdb)
+{
+
+  int                   check;
+  int                   loop_count_ops;
+  int					count;
+  int                   count_attributes;
+
+  NdbConnection			*MyTransaction;
+  NdbOperation			*MyOperation;
+  NdbRecAttr*           tTmp;
+
+  int					readValue[MAXATTR];
+
+  ndbout << "Verifying records..."<< flush;
+    
+  loop_count_ops = NUMBEROFRECORDS;
+
+  for (count=0 ; count < loop_count_ops ; count++)
+  {
+     MyTransaction = pMyNdb->startTransaction();
+     if (MyTransaction == NULL)
+        error_handler(pMyNdb->getNdbErrorString());
+
+     MyOperation = MyTransaction->getNdbOperation(tableName[0]);	
+     if (MyOperation == NULL) 
+        error_handler( MyTransaction->getNdbErrorString());
+       
+     check = MyOperation->readTuple();
+     if( check == -1 ) 
+        error_handler( MyTransaction->getNdbErrorString());
+
+     check = MyOperation->equal( attrName[0],(char*)&pkValue[count] );
+     if( check == -1 ) 
+        error_handler( MyTransaction->getNdbErrorString());
+
+     for (count_attributes = 1; count_attributes < MAXATTR; count_attributes++)
+     {
+        tTmp = MyOperation->getValue( (char*)attrName[count_attributes], (char*)&readValue[count_attributes] );
+        if( tTmp == NULL ) 
+           error_handler( MyTransaction->getNdbErrorString());
+      }
+
+      if( MyTransaction->execute( Commit ) == -1 ) 
+         error_handler(MyTransaction->getNdbErrorString());
+      else
+      {
+	// Check value in db against value in mem     
+
+	//ndbout << readValue[1] << " == " << attrValue[count] << endl;
+           
+	   if ( readValue[1]!=attrValue[count] )
+             error_handler("Verification error!");
+           else
+	   if ( readValue[2]!=attrValue[count] )
+             error_handler("Verification error!");
+           else
+	   if ( readValue[3]!=attrValue[count] )
+             error_handler("Verification error!");
+           else
+	   {
+	     ;//ndbout << ".";
+	   }
+	}
+        pMyNdb->closeTransaction(MyTransaction);
+
+    }
+
+   ndbout << "OK" << endl;
+  return;
+
+ 
+
+};
+
+
+static void
+setAttrNames()
+{
+  int i;
+
+  for (i = 0; i < MAXATTR ; i++)
+  {
+    sprintf(&attrName[i][0], "Col%d", i);
+  }
+}
+
+static void
+setTableNames()
+{
+  int i;
+
+  sprintf(&tableName[0][0], "SBMCALL", 0);
+  sprintf(&tableName[1][0], "RPACCT", 0);
+  sprintf(&tableName[2][0], "IPACCT", 0);
+  sprintf(&tableName[3][0], "TODACCT", 0);
+
+}
+
+
+bool error_handler2(const char* error_string, int error_int) {
+  failed++ ;
+  ndbout << error_string << endl ;
+  if ( 4008==error_int || 721==error_int || 266==error_int ){
+    ndbout << endl << "Attempting to recover and continue now..." << endl ;
+    return true ; // return true to retry
+  }
+  return false ; // return false to abort
+}