diff options
| author | jonas@eel.(none) <> | 2005-09-09 13:14:35 +0200 |
|---|---|---|
| committer | jonas@eel.(none) <> | 2005-09-09 13:14:35 +0200 |
| commit | d70f092aec4fac9663980f300a95456d6fed4b52 (patch) | |
| tree | 7ffe9693169b51427e0f36cc92d52932c7cbefe6 /ndb | |
| parent | 2bd9c2d6f600100af0bca4b28fa3a7d0b9c53743 (diff) | |
| download | mariadb-git-d70f092aec4fac9663980f300a95456d6fed4b52.tar.gz | |
merge fixes
Diffstat (limited to 'ndb')
| -rw-r--r-- | ndb/test/ndbapi/testSRBank.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/ndb/test/ndbapi/testSRBank.cpp b/ndb/test/ndbapi/testSRBank.cpp index 5677f551da6..6d57724f4c6 100644 --- a/ndb/test/ndbapi/testSRBank.cpp +++ b/ndb/test/ndbapi/testSRBank.cpp @@ -23,7 +23,7 @@ #include "bank/Bank.hpp" int runCreateBank(NDBT_Context* ctx, NDBT_Step* step){ - Bank bank; + Bank bank(ctx->m_cluster_connection); int overWriteExisting = true; if (bank.createAndLoadBank(overWriteExisting, 10) != NDBT_OK) return NDBT_FAILED; @@ -43,7 +43,7 @@ int runBankTimer(NDBT_Context* ctx, NDBT_Step* step){ ctx->incProperty("ThreadCount"); while (!ctx->isTestStopped()) { - Bank bank; + Bank bank(ctx->m_cluster_connection); while(!ctx->isTestStopped() && ctx->getProperty("SR") <= 1) if(bank.performIncreaseTime(wait, yield) == NDBT_FAILED) break; @@ -63,7 +63,7 @@ int runBankTransactions(NDBT_Context* ctx, NDBT_Step* step){ ctx->incProperty("ThreadCount"); while (!ctx->isTestStopped()) { - Bank bank; + Bank bank(ctx->m_cluster_connection); while(!ctx->isTestStopped() && ctx->getProperty("SR") <= 1) if(bank.performTransactions(0, 1) == NDBT_FAILED) break; @@ -83,7 +83,7 @@ int runBankGL(NDBT_Context* ctx, NDBT_Step* step){ ctx->incProperty("ThreadCount"); while (ctx->isTestStopped() == false) { - Bank bank; + Bank bank(ctx->m_cluster_connection); while(!ctx->isTestStopped() && ctx->getProperty("SR") <= 1) if (bank.performMakeGLs(yield) != NDBT_OK) { @@ -102,7 +102,7 @@ int runBankGL(NDBT_Context* ctx, NDBT_Step* step){ } int runBankSum(NDBT_Context* ctx, NDBT_Step* step){ - Bank bank; + Bank bank(ctx->m_cluster_connection); int wait = 2000; // Max ms between each sum of accounts int yield = 1; // Loops before bank returns int result = NDBT_OK; @@ -160,7 +160,7 @@ int runSR(NDBT_Context* ctx, NDBT_Step* step) { int wait = 0; int yield = 1; - Bank bank; + Bank bank(ctx->m_cluster_connection); if (bank.performSumAccounts(wait, yield) != 0) { ndbout << "bank.performSumAccounts FAILED" << endl; @@ -183,7 +183,7 @@ int runSR(NDBT_Context* ctx, NDBT_Step* step) } int runDropBank(NDBT_Context* ctx, NDBT_Step* step){ - Bank bank; + Bank bank(ctx->m_cluster_connection); if (bank.dropBank() != NDBT_OK) return NDBT_FAILED; return NDBT_OK; |