diff options
author | unknown <tomas@poseidon.(none)> | 2004-05-26 15:36:55 +0000 |
---|---|---|
committer | unknown <tomas@poseidon.(none)> | 2004-05-26 15:36:55 +0000 |
commit | abee640f44e4475a6b5448f30dcec9bca5455bda (patch) | |
tree | d3d9058cf001e85ae696c10f65a429f2115fab0b /ndb/test/ndbapi/mainAsyncGenerator.cpp | |
parent | 5e53268b6979066630b76af1e88899014e613be3 (diff) | |
download | mariadb-git-abee640f44e4475a6b5448f30dcec9bca5455bda.tar.gz |
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
Diffstat (limited to 'ndb/test/ndbapi/mainAsyncGenerator.cpp')
-rw-r--r-- | ndb/test/ndbapi/mainAsyncGenerator.cpp | 392 |
1 files changed, 392 insertions, 0 deletions
diff --git a/ndb/test/ndbapi/mainAsyncGenerator.cpp b/ndb/test/ndbapi/mainAsyncGenerator.cpp new file mode 100644 index 00000000000..f613c66d07b --- /dev/null +++ b/ndb/test/ndbapi/mainAsyncGenerator.cpp @@ -0,0 +1,392 @@ +/* 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 */ + +#include <ndb_global.h> + +#include <NdbHost.h> +#include <NdbSleep.h> +#include <NdbThread.h> +#include <NdbMain.h> +#include <NdbOut.hpp> +#include <NdbEnv.h> +#include <NdbTest.hpp> + +#include "userInterface.h" +#include "dbGenerator.h" + +static int numProcesses; +static int numSeconds; +static int numWarmSeconds; +static int parallellism; +static int millisSendPoll; +static int minEventSendPoll; +static int forceSendPoll; + +static ThreadData *data; + +static void usage(const char *prog) +{ + const char *progname; + + /*--------------------------------------------*/ + /* Get the name of the program (without path) */ + /*--------------------------------------------*/ + progname = strrchr(prog, '/'); + + if (progname == 0) + progname = prog; + else + ++progname; + + ndbout_c( + "Usage: %s [-proc <num>] [-warm <num>] [-time <num>] [ -p <num>] " + "[-t <num> ] [ -e <num> ] [ -f <num>] \n" + " -proc <num> Specifies that <num> is the number of\n" + " threads. The default is 1.\n" + " -time <num> Specifies that the test will run for <num> sec.\n" + " The default is 10 sec\n" + " -warm <num> Specifies the warm-up/cooldown period of <num> " + "sec.\n" + " The default is 10 sec\n" + " -p <num> The no of parallell transactions started by " + "one thread\n" + " -e <num> Minimum no of events before wake up in call to " + "sendPoll\n" + " Default is 1\n" + " -f <num> force parameter to sendPoll\n" + " Default is 0\n", + progname); +} + +static +int +parse_args(int argc, const char **argv) +{ + int i; + + numProcesses = 1; + numSeconds = 10; + numWarmSeconds = 10; + parallellism = 1; + millisSendPoll = 10000; + minEventSendPoll = 1; + forceSendPoll = 0; + + + i = 1; + while (i < argc){ + if (strcmp("-proc",argv[i]) == 0) { + if (i + 1 >= argc) { + return 1; + } + if (sscanf(argv[i+1], "%d", &numProcesses) == -1 || + numProcesses <= 0 || numProcesses > 127) { + ndbout_c("-proc flag requires a positive integer argument [1..127]"); + return 1; + } + i += 2; + } else if (strcmp("-p", argv[i]) == 0){ + if(i + 1 >= argc){ + usage(argv[0]); + return 1; + } + if (sscanf(argv[i+1], "%d", ¶llellism) == -1 || + parallellism <= 0){ + ndbout_c("-p flag requires a positive integer argument"); + return 1; + } + i += 2; + } + else if (strcmp("-time",argv[i]) == 0) { + if (i + 1 >= argc) { + return 1; + } + if (sscanf(argv[i+1], "%d", &numSeconds) == -1 || + numSeconds < 0) { + ndbout_c("-time flag requires a positive integer argument"); + return 1; + } + i += 2; + } + else if (strcmp("-warm",argv[i]) == 0) { + if (i + 1 >= argc) { + return 1; + } + if (sscanf(argv[i+1], "%d", &numWarmSeconds) == -1 || + numWarmSeconds < 0) { + ndbout_c("-warm flag requires a positive integer argument"); + return 1; + } + i += 2; + } + else if (strcmp("-e",argv[i]) == 0) { + if (i + 1 >= argc) { + return 1; + } + if (sscanf(argv[i+1], "%d", &minEventSendPoll) == -1 || + minEventSendPoll < 0) { + ndbout_c("-e flag requires a positive integer argument"); + return 1; + } + i += 2; + } + else if (strcmp("-f",argv[i]) == 0) { + if (i + 1 >= argc) { + usage(argv[0]); + return 1; + } + if (sscanf(argv[i+1], "%d", &forceSendPoll) == -1 || + forceSendPoll < 0) { + ndbout_c("-f flag requires a positive integer argument"); + return 1; + } + i += 2; + } + else { + return 1; + } + } + + if(minEventSendPoll > parallellism){ + ndbout_c("minEventSendPoll(%d) > parallellism(%d)", + minEventSendPoll, parallellism); + ndbout_c("not very good..."); + ndbout_c("very bad..."); + ndbout_c("exiting..."); + return 1; + } + return 0; +} + +static +void +print_transaction(const char *header, + unsigned long totalCount, + TransactionDefinition *trans, + unsigned int printBranch, + unsigned int printRollback) +{ + double f; + + ndbout_c(" %s: %d (%.2f%%) " + "Latency(ms) avg: %d min: %d max: %d std: %d n: %d", + header, + trans->count, + (double)trans->count / (double)totalCount * 100.0, + (int)trans->latency.getMean(), + (int)trans->latency.getMin(), + (int)trans->latency.getMax(), + (int)trans->latency.getStddev(), + (int)trans->latency.getCount() + ); + + if( printBranch ){ + if( trans->count == 0 ) + f = 0.0; + else + f = (double)trans->branchExecuted / (double)trans->count * 100.0; + ndbout_c(" Branches Executed: %d (%.2f%%)", trans->branchExecuted, f); + } + + if( printRollback ){ + if( trans->count == 0 ) + f = 0.0; + else + f = (double)trans->rollbackExecuted / (double)trans->count * 100.0; + ndbout_c(" Rollback Executed: %d (%.2f%%)",trans->rollbackExecuted,f); + } +} + +void +print_stats(const char *title, + unsigned int length, + unsigned int transactionFlag, + GeneratorStatistics *gen, + int numProc, int parallellism) +{ + int i; + char buf[10]; + char name[MAXHOSTNAMELEN]; + + name[0] = 0; + NdbHost_GetHostName(name); + + ndbout_c("\n------ %s ------",title); + ndbout_c("Length : %d %s", + length, + transactionFlag ? "Transactions" : "sec"); + ndbout_c("Processor : %s", name); + ndbout_c("Number of Proc: %d",numProc); + ndbout_c("Parallellism : %d", parallellism); + ndbout_c("\n"); + + if( gen->totalTransactions == 0 ) { + ndbout_c(" No Transactions for this test"); + } + else { + for(i = 0; i < 5; i++) { + sprintf(buf, "T%d",i+1); + print_transaction(buf, + gen->totalTransactions, + &gen->transactions[i], + i >= 2, + i >= 3 ); + } + + ndbout_c("\n"); + ndbout_c(" Overall Statistics:"); + ndbout_c(" Transactions: %d", gen->totalTransactions); + ndbout_c(" Outer : %.0f TPS",gen->outerTps); + ndbout_c("\n"); + } +} + +static +void * +threadRoutine(void *arg) +{ + int i; + ThreadData *data = (ThreadData *)arg; + Ndb * pNDB; + + pNDB = asyncDbConnect(parallellism); + /* NdbSleep_MilliSleep(rand() % 10); */ + + for(i = 0; i<parallellism; i++){ + data[i].pNDB = pNDB; + } + millisSendPoll = 30000; + asyncGenerator(data, parallellism, + millisSendPoll, minEventSendPoll, forceSendPoll); + + asyncDbDisconnect(pNDB); + + NdbThread_Exit(0); + + return NULL; +} + +NDB_COMMAND(DbAsyncGenerator, "DbAsyncGenerator", + "DbAsyncGenerator", "DbAsyncGenerator", 65535) +{ + int i; + int j; + int k; + struct NdbThread* pThread = NULL; + GeneratorStatistics stats; + GeneratorStatistics *p; + char threadName[32]; + int rc = NDBT_OK; + void* tmp = NULL; + if(parse_args(argc,argv) != 0){ + usage(argv[0]); + return NDBT_ProgramExit(NDBT_WRONGARGS); + } + + + ndbout_c("\nStarting Test with %d process(es) for %d %s parallellism %d", + numProcesses, + numSeconds, + "sec", + parallellism); + + ndbout_c(" WarmUp/coolDown = %d sec", numWarmSeconds); + + data = (ThreadData*)malloc((numProcesses*parallellism)*sizeof(ThreadData)); + + for(i = 0; i < numProcesses; i++) { + for(j = 0; j<parallellism; j++){ + data[i*parallellism+j].warmUpSeconds = numWarmSeconds; + data[i*parallellism+j].testSeconds = numSeconds; + data[i*parallellism+j].coolDownSeconds = numWarmSeconds; + data[i*parallellism+j].randomSeed = + NdbTick_CurrentMillisecond()+i+j; + data[i*parallellism+j].changedTime = 0; + data[i*parallellism+j].runState = Runnable; + } + sprintf(threadName, "AsyncThread[%d]", i); + pThread = NdbThread_Create(threadRoutine, + (void**)&data[i*parallellism], + 65535, + threadName, + NDB_THREAD_PRIO_LOW); + if(pThread != 0 && pThread != NULL){ + (&data[i*parallellism])->pThread = pThread; + } else { + perror("Failed to create thread"); + rc = NDBT_FAILED; + } + } + + showTime(); + + /*--------------------------------*/ + /* Wait for all processes to exit */ + /*--------------------------------*/ + for(i = 0; i < numProcesses; i++) { + NdbThread_WaitFor(data[i*parallellism].pThread, &tmp); + NdbThread_Destroy(&data[i*parallellism].pThread); + } + + ndbout_c("All threads have finished"); + + /*-------------------------------------------*/ + /* Clear all structures for total statistics */ + /*-------------------------------------------*/ + stats.totalTransactions = 0; + stats.outerTps = 0.0; + + for(i = 0; i < NUM_TRANSACTION_TYPES; i++ ) { + stats.transactions[i].count = 0; + stats.transactions[i].branchExecuted = 0; + stats.transactions[i].rollbackExecuted = 0; + stats.transactions[i].latency.reset(); + } + + /*--------------------------------*/ + /* Add the values for all Threads */ + /*--------------------------------*/ + for(i = 0; i < numProcesses; i++) { + for(k = 0; k<parallellism; k++){ + p = &data[i*parallellism+k].generator; + + stats.totalTransactions += p->totalTransactions; + stats.outerTps += p->outerTps; + + for(j = 0; j < NUM_TRANSACTION_TYPES; j++ ) { + stats.transactions[j].count += + p->transactions[j].count; + stats.transactions[j].branchExecuted += + p->transactions[j].branchExecuted; + stats.transactions[j].rollbackExecuted += + p->transactions[j].rollbackExecuted; + stats.transactions[j].latency += + p->transactions[j].latency; + } + } + } + + print_stats("Test Results", + numSeconds, + 0, + &stats, + numProcesses, + parallellism); + + free(data); + + NDBT_ProgramExit(rc); +} |