diff options
author | unknown <joreland@mysql.com> | 2005-07-21 09:10:44 +0200 |
---|---|---|
committer | unknown <joreland@mysql.com> | 2005-07-21 09:10:44 +0200 |
commit | de5af58d8deecd980b66e7d082d1b52b5ba0b8d9 (patch) | |
tree | fc7bae798580e4d7fe0f1f653e298761ec932802 /ndb | |
parent | fa22e3898225716b02c538d03e4c043d2df3e377 (diff) | |
download | mariadb-git-de5af58d8deecd980b66e7d082d1b52b5ba0b8d9.tar.gz |
merge
Diffstat (limited to 'ndb')
-rw-r--r-- | ndb/test/include/HugoOperations.hpp | 6 | ||||
-rw-r--r-- | ndb/test/ndbapi/testNdbApi.cpp | 4 | ||||
-rw-r--r-- | ndb/test/src/HugoOperations.cpp | 9 |
3 files changed, 10 insertions, 9 deletions
diff --git a/ndb/test/include/HugoOperations.hpp b/ndb/test/include/HugoOperations.hpp index dde60c1300d..dbb2ff8d430 100644 --- a/ndb/test/include/HugoOperations.hpp +++ b/ndb/test/include/HugoOperations.hpp @@ -103,7 +103,7 @@ public: NDBT_ResultRow& get_row(Uint32 idx) { return *rows[idx];} - int execute_async(Ndb*, ExecType, AbortOption = AbortOnError); + int execute_async(Ndb*, NdbTransaction::ExecType, NdbTransaction::AbortOption = NdbTransaction::AbortOnError); int wait_async(Ndb*, int timeout = -1); protected: @@ -121,8 +121,8 @@ protected: int m_async_reply; int m_async_return; - friend void HugoOperations_async_callback(int, NdbConnection*, void*); - void callback(int res, NdbConnection*); + friend void HugoOperations_async_callback(int, NdbTransaction*, void*); + void callback(int res, NdbTransaction*); }; #endif diff --git a/ndb/test/ndbapi/testNdbApi.cpp b/ndb/test/ndbapi/testNdbApi.cpp index 7ed86a56ad1..67932780d8f 100644 --- a/ndb/test/ndbapi/testNdbApi.cpp +++ b/ndb/test/ndbapi/testNdbApi.cpp @@ -1099,7 +1099,7 @@ int runBug_11133(NDBT_Context* ctx, NDBT_Step* step){ C2(hugoOps.execute_NoCommit(pNdb) == 0); C2(hugoOps2.startTransaction(&ndb2) == 0); C2(hugoOps2.pkWriteRecord(&ndb2, 0, 1) == 0); - C2(hugoOps2.execute_async(&ndb2, NoCommit) == 0); + C2(hugoOps2.execute_async(&ndb2, NdbTransaction::NoCommit) == 0); C2(hugoOps.execute_Commit(pNdb) == 0); C2(hugoOps2.wait_async(&ndb2) == 0); C2(hugoOps.closeTransaction(pNdb) == 0); @@ -1110,7 +1110,7 @@ int runBug_11133(NDBT_Context* ctx, NDBT_Step* step){ C2(hugoOps.execute_NoCommit(pNdb) == 0); C2(hugoOps2.startTransaction(&ndb2) == 0); C2(hugoOps2.pkWriteRecord(&ndb2, 0, 1) == 0); - C2(hugoOps2.execute_async(&ndb2, NoCommit) == 0); + C2(hugoOps2.execute_async(&ndb2, NdbTransaction::NoCommit) == 0); C2(hugoOps.execute_Commit(pNdb) == 0); C2(hugoOps2.wait_async(&ndb2) == 0); C2(hugoOps.closeTransaction(pNdb) == 0); diff --git a/ndb/test/src/HugoOperations.cpp b/ndb/test/src/HugoOperations.cpp index 6b988497e94..91902c56d76 100644 --- a/ndb/test/src/HugoOperations.cpp +++ b/ndb/test/src/HugoOperations.cpp @@ -409,13 +409,13 @@ int HugoOperations::execute_Rollback(Ndb* pNdb){ } void -HugoOperations_async_callback(int res, NdbConnection* pCon, void* ho) +HugoOperations_async_callback(int res, NdbTransaction* pCon, void* ho) { ((HugoOperations*)ho)->callback(res, pCon); } void -HugoOperations::callback(int res, NdbConnection* pCon) +HugoOperations::callback(int res, NdbTransaction* pCon) { assert(pCon == pTrans); m_async_reply= 1; @@ -423,7 +423,8 @@ HugoOperations::callback(int res, NdbConnection* pCon) } int -HugoOperations::execute_async(Ndb* pNdb, ExecType et, AbortOption eao){ +HugoOperations::execute_async(Ndb* pNdb, NdbTransaction::ExecType et, + NdbTransaction::AbortOption eao){ m_async_reply= 0; pTrans->executeAsynchPrepare(et, @@ -591,7 +592,7 @@ int HugoOperations::compareRecordToCopy(int numRecords ){ void HugoOperations::refresh() { - NdbConnection* t = getTransaction(); + NdbTransaction * t = getTransaction(); if(t) t->refresh(); } |