Commit faff1935 authored by joreland@mysql.com's avatar joreland@mysql.com

Merge mysql.com:/home/jonas/src/mysql-5.0

into  mysql.com:/home/jonas/src/mysql-5.0-push
parents 74823892 a5c6ab3c
...@@ -103,7 +103,7 @@ public: ...@@ -103,7 +103,7 @@ public:
NDBT_ResultRow& get_row(Uint32 idx) { return *rows[idx];} 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); int wait_async(Ndb*, int timeout = -1);
protected: protected:
...@@ -121,8 +121,8 @@ protected: ...@@ -121,8 +121,8 @@ protected:
int m_async_reply; int m_async_reply;
int m_async_return; int m_async_return;
friend void HugoOperations_async_callback(int, NdbConnection*, void*); friend void HugoOperations_async_callback(int, NdbTransaction*, void*);
void callback(int res, NdbConnection*); void callback(int res, NdbTransaction*);
}; };
#endif #endif
...@@ -1099,7 +1099,7 @@ int runBug_11133(NDBT_Context* ctx, NDBT_Step* step){ ...@@ -1099,7 +1099,7 @@ int runBug_11133(NDBT_Context* ctx, NDBT_Step* step){
C2(hugoOps.execute_NoCommit(pNdb) == 0); C2(hugoOps.execute_NoCommit(pNdb) == 0);
C2(hugoOps2.startTransaction(&ndb2) == 0); C2(hugoOps2.startTransaction(&ndb2) == 0);
C2(hugoOps2.pkWriteRecord(&ndb2, 0, 1) == 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(hugoOps.execute_Commit(pNdb) == 0);
C2(hugoOps2.wait_async(&ndb2) == 0); C2(hugoOps2.wait_async(&ndb2) == 0);
C2(hugoOps.closeTransaction(pNdb) == 0); C2(hugoOps.closeTransaction(pNdb) == 0);
...@@ -1110,7 +1110,7 @@ int runBug_11133(NDBT_Context* ctx, NDBT_Step* step){ ...@@ -1110,7 +1110,7 @@ int runBug_11133(NDBT_Context* ctx, NDBT_Step* step){
C2(hugoOps.execute_NoCommit(pNdb) == 0); C2(hugoOps.execute_NoCommit(pNdb) == 0);
C2(hugoOps2.startTransaction(&ndb2) == 0); C2(hugoOps2.startTransaction(&ndb2) == 0);
C2(hugoOps2.pkWriteRecord(&ndb2, 0, 1) == 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(hugoOps.execute_Commit(pNdb) == 0);
C2(hugoOps2.wait_async(&ndb2) == 0); C2(hugoOps2.wait_async(&ndb2) == 0);
C2(hugoOps.closeTransaction(pNdb) == 0); C2(hugoOps.closeTransaction(pNdb) == 0);
......
...@@ -409,13 +409,13 @@ int HugoOperations::execute_Rollback(Ndb* pNdb){ ...@@ -409,13 +409,13 @@ int HugoOperations::execute_Rollback(Ndb* pNdb){
} }
void void
HugoOperations_async_callback(int res, NdbConnection* pCon, void* ho) HugoOperations_async_callback(int res, NdbTransaction* pCon, void* ho)
{ {
((HugoOperations*)ho)->callback(res, pCon); ((HugoOperations*)ho)->callback(res, pCon);
} }
void void
HugoOperations::callback(int res, NdbConnection* pCon) HugoOperations::callback(int res, NdbTransaction* pCon)
{ {
assert(pCon == pTrans); assert(pCon == pTrans);
m_async_reply= 1; m_async_reply= 1;
...@@ -423,7 +423,8 @@ HugoOperations::callback(int res, NdbConnection* pCon) ...@@ -423,7 +423,8 @@ HugoOperations::callback(int res, NdbConnection* pCon)
} }
int 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; m_async_reply= 0;
pTrans->executeAsynchPrepare(et, pTrans->executeAsynchPrepare(et,
...@@ -591,7 +592,7 @@ int HugoOperations::compareRecordToCopy(int numRecords ){ ...@@ -591,7 +592,7 @@ int HugoOperations::compareRecordToCopy(int numRecords ){
void void
HugoOperations::refresh() { HugoOperations::refresh() {
NdbConnection* t = getTransaction(); NdbTransaction * t = getTransaction();
if(t) if(t)
t->refresh(); t->refresh();
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment