database/mariadb
1
0
Fork 0
mirror of https://github.com/MariaDB/server.git synced 2025-08-29 00:08:14 +03:00
Code Activity

changed some NdbConnection to NdbTransaction

Browse Source
This commit is contained in:
tomas@poseidon.ndb.mysql.com
2005-01-04 13:47:16 +01:00
parent abb926c3c9
commit 53acd15667
2 changed files with 33 additions and 34 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
ndb/examples/ndbapi_async_example/ndbapi_async.cpp
View File

@@ -30,7 +30,6 @@
*
* Ndb
* init()
* getDictionary()
* startTransaction()
* closeTransaction()
* sendPollNdb()
@@ -97,10 +96,10 @@ typedef struct {
} async_callback_t;
/**
* Structure used in "free list" to a NdbConnection
* Structure used in "free list" to a NdbTransaction
*/
typedef struct {
NdbConnection* conn;
NdbTransaction* conn;
int used;
} transaction_t;
@@ -123,7 +122,7 @@ int populate(Ndb * myNdb, int data, async_callback_t * cbData);
/**
* Error handler.
*/
bool asynchErrorHandler(NdbConnection * trans, Ndb* ndb);
bool asynchErrorHandler(NdbTransaction * trans, Ndb* ndb);
/**
* Exit function
@@ -162,7 +161,7 @@ closeTransaction(Ndb * ndb , async_callback_t * cb)
* Callback executed when transaction has return from NDB
*/
static void
callback(int result, NdbConnection* trans, void* aObject)
callback(int result, NdbTransaction* trans, void* aObject)
{
async_callback_t * cbData = (async_callback_t *)aObject;
if (result<0)
@@ -232,7 +231,7 @@ void asynchExitHandler(Ndb * m_ndb)
/* returns true if is recoverable (temporary),
* false if it is an error that is permanent.
*/
bool asynchErrorHandler(NdbConnection * trans, Ndb* ndb)
bool asynchErrorHandler(NdbTransaction * trans, Ndb* ndb)
{
NdbError error = trans->getNdbError();
switch(error.status)