Lines Matching refs:g_con
217 static NdbConnection* g_con = 0; variable
294 if (g_con != 0 && g_con->getNdbError().code != 0) { in printerror()
295 ndbout << "con: " << g_con->getNdbError() << endl; in printerror()
308 NdbOperation* ope = g_con->getNdbErrorOperation(); in printerror()
882 Uint32 code= g_con->getNdbError().code; in conHasTimeoutError()
901 return g_con->getNdbError().code; in conError()
972 g_con->setMaxPendingBlobReadBytes(byteSize); in setBatchSizes()
983 g_con->setMaxPendingBlobWriteBytes(byteSize); in setBatchSizes()
1221 CHK(g_con->execute(NoCommit) == 0); in readBlobData()
1383 CHK((g_con = g_ndb->startTransaction()) != 0); in verifyHeadInline()
1384 CHK((g_opr = g_con->getNdbOperation(g_opt.m_tname)) != 0); in verifyHeadInline()
1400 CHK(g_con->execute(Commit, AbortOnError) == 0); in verifyHeadInline()
1410 CHK(g_con->execute(Commit, AbortOnError) == -1 && in verifyHeadInline()
1411 g_con->getNdbError().code == 626); in verifyHeadInline()
1413 g_ndb->closeTransaction(g_con); in verifyHeadInline()
1415 g_con = 0; in verifyHeadInline()
1444 CHK((g_con = g_ndb->startTransaction()) != 0); in verifyBlobTable()
1445 CHK((g_ops = g_con->getNdbScanOperation(b.m_btname)) != 0); in verifyBlobTable()
1469 CHK(g_con->execute(NoCommit) == 0); in verifyBlobTable()
1563 g_ndb->closeTransaction(g_con); in verifyBlobTable()
1567 g_con = 0; in verifyBlobTable()
1635 CHK((g_con = g_ndb->startTransaction()) != 0); in insertPk()
1641 CHK((g_opr = g_con->getNdbOperation(g_opt.m_tname)) != 0); in insertPk()
1663 CHK((g_const_opr = g_con->insertTuple(g_full_record, in insertPk()
1678 CHK(g_con->execute(NoCommit) == 0); in insertPk()
1685 if (g_con->execute(Commit) == 0) in insertPk()
1687 g_ndb->closeTransaction(g_con); in insertPk()
1688 CHK((g_con = g_ndb->startTransaction()) != 0); in insertPk()
1722 CHK(g_con->execute(Commit) == 0); in insertPk()
1726 g_ndb->closeTransaction(g_con); in insertPk()
1728 g_con = 0; in insertPk()
1745 CHK((g_con = g_ndb->startTransaction()) != 0); in readPk()
1760 CHK((g_opr = g_con->getNdbOperation(g_opt.m_tname)) != 0); in readPk()
1782 CHK((g_const_opr = g_con->readTuple(g_key_record, tup.m_key_row, in readPk()
1797 CHK(g_con->execute(NoCommit) == 0); in readPk()
1805 if (g_con->execute(NoCommit) == 0) in readPk()
1811 CHK(g_con->execute(Commit) == 0); in readPk()
1820 if (g_con->execute(Commit) != 0) in readPk()
1844 g_ndb->closeTransaction(g_con); in readPk()
1848 g_con = 0; in readPk()
1866 CHK((g_con = g_ndb->startTransaction()) != 0); in readLockPk()
1887 CHK((g_opr = g_con->getNdbOperation(g_opt.m_tname)) != 0); in readLockPk()
1918 CHK((g_const_opr = g_con->readTuple(g_key_record, tup.m_key_row, in readLockPk()
1932 CHK(g_con->execute(NoCommit) == 0); in readLockPk()
1938 if (g_con->execute(NoCommit) == 0) in readLockPk()
1992 const NdbOperation* unlockOp = g_con->unlock(lh); in readLockPk()
2000 CHK(g_con->execute(NoCommit) == 0); in readLockPk()
2003 if (g_con->execute(Commit) != 0) in readLockPk()
2023 g_ndb->closeTransaction(g_con); in readLockPk()
2027 g_con = 0; in readLockPk()
2047 CHK((g_con = g_ndb->startTransaction()) != 0); in updatePk()
2050 CHK((g_opr = g_con->getNdbOperation(g_opt.m_tname)) != 0); in updatePk()
2083 CHK((g_const_opr= g_con->updateTuple(g_key_record, tup.m_key_row, in updatePk()
2088 CHK((g_const_opr= g_con->readTuple(g_key_record, tup.m_key_row, in updatePk()
2094 CHK((g_const_opr= g_con->readTuple(g_key_record, tup.m_key_row, in updatePk()
2108 CHK(g_con->execute(NoCommit) == 0); in updatePk()
2115 if (g_con->execute(Commit) != 0) in updatePk()
2119 g_ndb->closeTransaction(g_con); in updatePk()
2136 g_ndb->closeTransaction(g_con); in updatePk()
2140 g_con = 0; in updatePk()
2159 CHK((g_con = g_ndb->startTransaction()) != 0); in writePk()
2162 CHK((g_opr = g_con->getNdbOperation(g_opt.m_tname)) != 0); in writePk()
2187 CHK((g_const_opr= g_con->writeTuple(g_key_record, tup.m_key_row, in writePk()
2200 CHK(g_con->execute(NoCommit) == 0); in writePk()
2207 if (g_con->execute(Commit) != 0) in writePk()
2220 g_ndb->closeTransaction(g_con); in writePk()
2225 g_con = 0; in writePk()
2243 CHK((g_con = g_ndb->startTransaction()) != 0); in deletePk()
2249 CHK((g_opr = g_con->getNdbOperation(g_opt.m_tname)) != 0); in deletePk()
2274 CHK((g_const_opr= g_con->deleteTuple(g_key_record, tup.m_key_row, in deletePk()
2279 if (g_con->execute(Commit) != 0) in deletePk()
2294 g_ndb->closeTransaction(g_con); in deletePk()
2295 CHK((g_con = g_ndb->startTransaction()) != 0); in deletePk()
2305 if (g_con->execute(Commit) != 0) in deletePk()
2319 g_ndb->closeTransaction(g_con); in deletePk()
2320 g_con = 0; in deletePk()
2349 CHK((g_con = g_ndb->startTransaction()) != 0); in deleteNoPk()
2352 CHK((g_opr = g_con->getNdbOperation(g_opt.m_tname)) != 0); in deleteNoPk()
2360 CHK(g_con->execute(Commit) == -1); // fail in deleteNoPk()
2362 DBG("con: " << g_con->getNdbError()); in deleteNoPk()
2364 CHK(g_con->getNdbError().code == 626 || g_opr->getNdbError().code == 626); in deleteNoPk()
2365 g_ndb->closeTransaction(g_con); in deleteNoPk()
2367 g_con = 0; in deleteNoPk()
2386 CHK((g_con = g_ndb->startTransaction()) != 0); in readIdx()
2401 CHK((g_opx = g_con->getNdbIndexOperation(g_opt.m_x1name, g_opt.m_tname)) != 0); in readIdx()
2413 CHK((g_const_opr= g_con->readTuple(g_idx_record, tup.m_key_row, in readIdx()
2425 if(g_con->execute(NoCommit) || in readIdx()
2431 if (g_con->execute(Commit) != 0) in readIdx()
2454 g_ndb->closeTransaction(g_con); in readIdx()
2458 g_con = 0; in readIdx()
2477 CHK((g_con = g_ndb->startTransaction()) != 0); in updateIdx()
2480 CHK((g_opx = g_con->getNdbIndexOperation(g_opt.m_x1name, g_opt.m_tname)) != 0); in updateIdx()
2492 CHK((g_const_opr= g_con->updateTuple(g_idx_record, tup.m_key_row, in updateIdx()
2502 if (g_con->execute(NoCommit) || in updateIdx()
2508 if (g_con->execute(Commit) != 0) in updateIdx()
2520 g_ndb->closeTransaction(g_con); in updateIdx()
2524 g_con = 0; in updateIdx()
2543 CHK((g_con = g_ndb->startTransaction()) != 0); in writeIdx()
2546 CHK((g_opx = g_con->getNdbIndexOperation(g_opt.m_x1name, g_opt.m_tname)) != 0); in writeIdx()
2561 CHK((g_const_opr= g_con->writeTuple(g_idx_record, tup.m_key_row, in writeIdx()
2575 if (g_con->execute(NoCommit) || in writeIdx()
2581 if (g_con->execute(Commit)) in writeIdx()
2593 g_ndb->closeTransaction(g_con); in writeIdx()
2597 g_con = 0; in writeIdx()
2615 CHK((g_con = g_ndb->startTransaction()) != 0); in deleteIdx()
2621 CHK((g_opx = g_con->getNdbIndexOperation(g_opt.m_x1name, g_opt.m_tname)) != 0); in deleteIdx()
2632 CHK((g_const_opr= g_con->deleteTuple(g_idx_record, tup.m_key_row, in deleteIdx()
2636 if (g_con->execute(Commit)) in deleteIdx()
2650 g_ndb->closeTransaction(g_con); in deleteIdx()
2651 CHK((g_con = g_ndb->startTransaction()) != 0); in deleteIdx()
2661 if(g_con->execute(Commit)) in deleteIdx()
2674 g_ndb->closeTransaction(g_con); in deleteIdx()
2676 g_con= 0; in deleteIdx()
2697 CHK((g_con = g_ndb->startTransaction()) != 0); in readScan()
2713 CHK((g_ops = g_con->getNdbScanOperation(g_opt.m_tname)) != 0); in readScan()
2715 CHK((g_ops = g_con->getNdbIndexScanOperation(g_opt.m_x2name, g_opt.m_tname)) != 0); in readScan()
2734 CHK((g_ops= g_con->scanTable(g_full_record, in readScan()
2737 CHK((g_ops= g_con->scanIndex(g_ord_record, g_full_record, in readScan()
2747 if (g_con->execute(NoCommit)) in readScan()
2756 g_ndb->closeTransaction(g_con); in readScan()
2836 g_ndb->closeTransaction(g_con); in readScan()
2843 g_con = 0; in readScan()
2861 CHK((g_con = g_ndb->startTransaction()) != 0); in updateScan()
2865 CHK((g_ops = g_con->getNdbScanOperation(g_opt.m_tname)) != 0); in updateScan()
2867 CHK((g_ops = g_con->getNdbIndexScanOperation(g_opt.m_x2name, g_opt.m_tname)) != 0); in updateScan()
2885 CHK((g_ops= g_con->scanTable(g_key_record, in updateScan()
2888 CHK((g_ops= g_con->scanIndex(g_ord_record, g_key_record, in updateScan()
2891 CHK(g_con->execute(NoCommit) == 0); in updateScan()
2954 CHK((g_const_opr = g_ops->updateCurrentTuple(g_con, g_blob_record, tup.m_row)) != 0); in updateScan()
2963 CHK(g_con->execute(NoCommit) == 0); in updateScan()
2968 (g_con->execute(NoCommit))) in updateScan()
2989 CHK(g_con->execute(Commit) == 0); in updateScan()
2992 g_ndb->closeTransaction(g_con); in updateScan()
2994 g_con = 0; in updateScan()
3012 CHK((g_con = g_ndb->startTransaction()) != 0); in lockUnlockScan()
3022 CHK((g_ops = g_con->getNdbScanOperation(g_opt.m_tname)) != 0); in lockUnlockScan()
3024 CHK((g_ops = g_con->getNdbIndexScanOperation(g_opt.m_x2name, g_opt.m_tname)) != 0); in lockUnlockScan()
3046 CHK((g_ops= g_con->scanTable(g_key_record, in lockUnlockScan()
3049 CHK((g_ops= g_con->scanIndex(g_ord_record, g_key_record, in lockUnlockScan()
3052 CHK(g_con->execute(NoCommit) == 0); in lockUnlockScan()
3117 CHK((g_const_opr = g_ops->lockCurrentTuple(g_con, g_blob_record, tup.m_row, in lockUnlockScan()
3127 CHK(g_con->execute(NoCommit) == 0); in lockUnlockScan()
3133 if (g_con->execute(NoCommit) == 0) in lockUnlockScan()
3167 const NdbOperation* unlockOp = g_con->unlock(lh); in lockUnlockScan()
3174 CHK(g_con->execute(NoCommit) == 0); in lockUnlockScan()
3208 CHK(g_con->execute(Commit) == 0); in lockUnlockScan()
3211 g_ndb->closeTransaction(g_con); in lockUnlockScan()
3213 g_con = 0; in lockUnlockScan()
3231 CHK((g_con = g_ndb->startTransaction()) != 0); in deleteScan()
3236 CHK((g_ops = g_con->getNdbScanOperation(g_opt.m_tname)) != 0); in deleteScan()
3238 CHK((g_ops = g_con->getNdbIndexScanOperation(g_opt.m_x2name, g_opt.m_tname)) != 0); in deleteScan()
3256 CHK((g_ops= g_con->scanTable(g_key_record, in deleteScan()
3259 CHK((g_ops= g_con->scanIndex(g_ord_record, g_key_record, in deleteScan()
3262 CHK(g_con->execute(NoCommit) == 0); in deleteScan()
3320 CHK(g_ops->deleteCurrentTuple(g_con, g_key_record) != NULL); in deleteScan()
3365 CHK(g_con->execute(NoCommit) == 0); in deleteScan()
3367 CHK(g_con->execute(Commit) == 0); in deleteScan()
3368 CHK(g_con->restart() == 0); in deleteScan()
3382 CHK(g_con->execute(Commit) == 0); in deleteScan()
3385 g_ndb->closeTransaction(g_con); in deleteScan()
3388 g_con = 0; in deleteScan()
3454 CHK((op= g_con->getNdbOperation(g_opt.m_tname)) != 0); in setupOperation()
3456 CHK((op = g_con->getNdbIndexOperation(g_opt.m_x1name, g_opt.m_tname)) != 0); in setupOperation()
3617 CHK((g_con= g_ndb->startTransaction()) != 0); in bugtest_36756()
3618 CHK((g_opr= g_con->getNdbOperation(g_opt.m_tname)) != 0); in bugtest_36756()
3631 CHK(g_con->execute(Commit) == 0); in bugtest_36756()
3632 g_con->close(); in bugtest_36756()
3661 CHK((g_con= g_ndb->startTransaction()) != 0); in bugtest_36756()
3671 int rc = g_con->execute(NdbTransaction::NoCommit, ao); in bugtest_36756()
3674 " Trans err " << g_con->getNdbError().code << in bugtest_36756()
3677 " CommitStatus " << g_con->commitStatus()); in bugtest_36756()
3680 CHK(g_con->getNdbError().code == eo.transactionErrorCode); in bugtest_36756()
3683 CHK(g_con->commitStatus() == eo.commitStatus); in bugtest_36756()
3685 g_con->close(); in bugtest_36756()
3690 CHK((g_con= g_ndb->startTransaction()) != 0); in bugtest_36756()
3691 CHK((g_opr= g_con->getNdbOperation(g_opt.m_tname)) != 0); in bugtest_36756()
3701 CHK(g_con->execute(Commit) == 0); in bugtest_36756()
3702 g_con->close(); in bugtest_36756()
3706 g_con= 0; in bugtest_36756()
3741 CHK((g_con= g_ndb->startTransaction()) != 0); in bugtest_45768()
3742 CHK((g_opr= g_con->getNdbOperation(g_opt.m_tname)) != 0); in bugtest_45768()
3755 CHK(g_con->execute(Commit) == 0); in bugtest_45768()
3756 g_con->close(); in bugtest_45768()
3768 CHK((g_con = g_ndb->startTransaction()) != 0); in bugtest_45768()
3773 CHK((g_opr = g_con->getNdbOperation(g_opt.m_tname)) != 0); in bugtest_45768()
3788 int rc = g_con->execute(NdbTransaction::NoCommit); in bugtest_45768()
3792 if (g_con->getNdbError().code == 630) in bugtest_45768()
3795 CHK(g_con->getNdbError().code == 1218); // Send buffers overloaded in bugtest_45768()
3799 g_con->close(); in bugtest_45768()
3802 CHK(g_con->getNdbError().code == 630); in bugtest_45768()
3805 rc = g_con->execute(NdbTransaction::Commit); in bugtest_45768()
3809 CHK(g_con->getNdbError().code == 4350); in bugtest_45768()
3811 g_con->close(); in bugtest_45768()
3814 CHK((g_con= g_ndb->startTransaction()) != 0); in bugtest_45768()
3815 CHK((g_opr= g_con->getNdbOperation(g_opt.m_tname)) != 0); in bugtest_45768()
3825 CHK(g_con->execute(Commit) == 0); in bugtest_45768()
3826 g_con->close(); in bugtest_45768()
3830 g_con= 0; in bugtest_45768()
3898 CHK((g_con= g_ndb->startTransaction()) != 0); in bugtest_62321()
3899 CHK((g_opr= g_con->getNdbOperation(g_opt.m_tname)) != 0); in bugtest_62321()
3912 CHK(g_con->execute(Commit) == 0); in bugtest_62321()
3913 g_con->close(); in bugtest_62321()
3919 CHK((g_con= g_ndb->startTransaction()) != 0); in bugtest_62321()
3925 failOp= g_con->getNdbOperation(g_opt.m_tname); in bugtest_62321()
3940 CHK((g_opr= g_con->getNdbOperation(g_opt.m_tname)) != 0); in bugtest_62321()
3958 failOp= g_con->getNdbOperation(g_opt.m_tname); in bugtest_62321()
3979 int rc = g_con->execute(NdbTransaction::NoCommit); in bugtest_62321()
3982 CHK(g_con->getNdbError().code == 626); in bugtest_62321()
3987 g_con->close(); in bugtest_62321()
4320 CHK((g_con = g_ndb->startTransaction()) != 0); in testperf()
4322 CHK((g_opr = g_con->getNdbOperation(tab.getName())) != 0); in testperf()
4328 CHK(g_con->execute(NoCommit) == 0); in testperf()
4331 CHK(g_con->execute(Rollback) == 0); in testperf()
4334 g_con = 0; in testperf()
4340 CHK((g_con = g_ndb->startTransaction()) != 0); in testperf()
4342 CHK((g_opr = g_con->getNdbOperation(tab.getName())) != 0); in testperf()
4347 CHK(g_con->execute(NoCommit) == 0); in testperf()
4350 CHK(g_con->execute(Rollback) == 0); in testperf()
4354 g_con = 0; in testperf()
4365 CHK((g_con = g_ndb->startTransaction()) != 0); in testperf()
4367 CHK((g_opr = g_con->getNdbOperation(tab.getName())) != 0); in testperf()
4376 CHK(g_con->execute(Commit) == 0); in testperf()
4377 g_ndb->closeTransaction(g_con); in testperf()
4378 CHK((g_con = g_ndb->startTransaction()) != 0); in testperf()
4383 CHK(g_con->execute(Commit) == 0); in testperf()
4384 g_ndb->closeTransaction(g_con); g_con = 0; in testperf()
4393 CHK((g_con = g_ndb->startTransaction()) != 0); in testperf()
4398 CHK((g_opr = g_con->getNdbOperation(tab.getName())) != 0); in testperf()
4405 CHK(g_con->execute(NoCommit) == 0); in testperf()
4408 CHK(g_con->execute(Commit) == 0); in testperf()
4412 g_ndb->closeTransaction(g_con); g_con = 0; in testperf()
4417 CHK((g_con = g_ndb->startTransaction()) != 0); in testperf()
4422 CHK((g_opr = g_con->getNdbOperation(tab.getName())) != 0); in testperf()
4429 CHK(g_con->execute(NoCommit) == 0); in testperf()
4434 CHK(g_con->execute(Commit) == 0); in testperf()
4437 g_ndb->closeTransaction(g_con); g_opr = 0; in testperf()
4438 g_con = 0; in testperf()
4452 CHK((g_con = g_ndb->startTransaction()) != 0); in testperf()
4453 CHK((g_ops = g_con->getNdbScanOperation(tab.getName())) != 0); in testperf()
4457 CHK(g_con->execute(NoCommit) == 0); in testperf()
4472 g_ndb->closeTransaction(g_con); g_ops = 0; in testperf()
4473 g_con = 0; in testperf()
4484 CHK((g_con = g_ndb->startTransaction()) != 0); in testperf()
4485 CHK((g_ops = g_con->getNdbScanOperation(tab.getName())) != 0); in testperf()
4489 CHK(g_con->execute(NoCommit) == 0); in testperf()
4508 g_ndb->closeTransaction(g_con); g_con = 0; in testperf()
4535 CHK((g_con = g_ndb->startTransaction()) != 0); in bugtest_4088()
4545 CHK((g_opr = g_con->getNdbOperation(name)) != 0); in bugtest_4088()
4552 CHK((g_opx = g_con->getNdbIndexOperation(g_opt.m_x1name, g_opt.m_tname)) != 0); in bugtest_4088()
4559 CHK(g_con->execute(Commit) == 0); in bugtest_4088()
4591 CHK((g_con= g_ndb->startTransaction()) != 0); in bugtest_27018()
4601 CHK((g_const_opr= g_con->updateTuple(g_key_record, tup.m_key_row, in bugtest_27018()
4607 CHK(g_con->execute(NoCommit) == 0); in bugtest_27018()
4612 CHK(g_con->execute(Commit) == 0); in bugtest_27018()
4613 g_ndb->closeTransaction(g_con); in bugtest_27018()
4615 CHK((g_con= g_ndb->startTransaction()) != 0); in bugtest_27018()
4616 CHK((g_const_opr= g_con->readTuple(g_key_record, tup.m_key_row, in bugtest_27018()
4625 CHK(g_con->execute(Commit) == 0); in bugtest_27018()
4637 g_ndb->closeTransaction(g_con); in bugtest_27018()
4638 g_con=0; in bugtest_27018()
4748 CHK((g_con= g_ndb->startTransaction()) != 0); in bugtest_27370()
4750 CHK((g_const_opr= g_con->writeTuple(g_key_record, data.m_key_row, in bugtest_27370()
4757 CHK(g_con->execute(Commit) == 0); in bugtest_27370()
4758 g_ndb->closeTransaction(g_con); in bugtest_27370()
4759 g_con= NULL; in bugtest_27370()
4768 CHK((g_con= g_ndb->startTransaction()) != 0); in bugtest_27370()
4769 CHK((g_const_opr= g_con->readTuple(g_key_record, data.m_key_row, in bugtest_27370()
4776 CHK(g_con->execute(NoCommit, AbortOnError, 1) == 0); in bugtest_27370()
4810 CHK(g_con->execute(commitType, AbortOnError, 1) == 0); in bugtest_27370()
4812 g_ndb->closeTransaction(g_con); in bugtest_27370()
4813 g_con= NULL; in bugtest_27370()
4820 CHK((g_con= g_ndb->startTransaction()) != 0); in bugtest_27370()
4821 CHK((g_ops= g_con->scanTable(g_full_record, in bugtest_27370()
4824 CHK(g_con->execute(NoCommit, AbortOnError, 1) == 0); in bugtest_27370()
4859 CHK(g_con->execute(NoCommit, AbortOnError, 1) == 0); in bugtest_27370()
4863 g_ndb->closeTransaction(g_con); in bugtest_27370()
4864 g_con= NULL; in bugtest_27370()
4875 g_con= NULL; in bugtest_27370()
4896 CHK((g_con = g_ndb->startTransaction()) != 0); in bugtest_28116()
4897 CHK((g_opr = g_con->getNdbOperation(g_opt.m_tname)) != 0); in bugtest_28116()
4954 CHK(g_con->getNdbError().code == 4264); in bugtest_28116()
4957 g_ndb->closeTransaction(g_con); in bugtest_28116()
4959 g_con = 0; in bugtest_28116()