@@ -58,13 +58,13 @@ ScanInterpretTest::addRowToInsert(Ndb* pNdb,
58
58
NdbOperation* pOp =
59
59
pInsTrans->getNdbOperation (restab.getName ());
60
60
if (pOp == NULL ) {
61
- ERR (pInsTrans->getNdbError ());
61
+ NDB_ERR (pInsTrans->getNdbError ());
62
62
pNdb->closeTransaction (pInsTrans);
63
63
return NDBT_FAILED;
64
64
}
65
65
66
66
if ( pOp->insertTuple () == -1 ) {
67
- ERR (pInsTrans->getNdbError ());
67
+ NDB_ERR (pInsTrans->getNdbError ());
68
68
pNdb->closeTransaction (pInsTrans);
69
69
return NDBT_FAILED;
70
70
}
@@ -113,7 +113,7 @@ ScanInterpretTest::addRowToInsert(Ndb* pNdb,
113
113
break ;
114
114
}
115
115
if (check != 0 ){
116
- ERR (pInsTrans->getNdbError ());
116
+ NDB_ERR (pInsTrans->getNdbError ());
117
117
pNdb->closeTransaction (pInsTrans);
118
118
return NDBT_FAILED;
119
119
}
@@ -130,12 +130,12 @@ ScanInterpretTest::addRowToCheckTrans(Ndb* pNdb,
130
130
NdbOperation* pOp =
131
131
pCheckTrans->getNdbOperation (restab.getName ());
132
132
if (pOp == NULL ) {
133
- ERR (pNdb->getNdbError ());
133
+ NDB_ERR (pNdb->getNdbError ());
134
134
return NDBT_FAILED;
135
135
}
136
136
137
137
if (pOp->readTuple () != 0 ) {
138
- ERR (pNdb->getNdbError ());
138
+ NDB_ERR (pNdb->getNdbError ());
139
139
return NDBT_FAILED;
140
140
}
141
141
@@ -179,7 +179,7 @@ ScanInterpretTest::addRowToCheckTrans(Ndb* pNdb,
179
179
break ;
180
180
}
181
181
if (check != 0 ){
182
- ERR (pNdb->getNdbError ());
182
+ NDB_ERR (pNdb->getNdbError ());
183
183
return NDBT_FAILED;
184
184
}
185
185
}
@@ -212,30 +212,30 @@ ScanInterpretTest::scanRead(Ndb* pNdb,
212
212
if (pTrans == NULL ) {
213
213
const NdbError err = pNdb->getNdbError ();
214
214
if (err.status == NdbError::TemporaryError){
215
- ERR (err);
215
+ NDB_ERR (err);
216
216
NdbSleep_MilliSleep (50 );
217
217
retryAttempt++;
218
218
continue ;
219
219
}
220
- ERR (err);
220
+ NDB_ERR (err);
221
221
return NDBT_FAILED;
222
222
}
223
223
224
224
pOp = pTrans->getNdbScanOperation (tab.getName ());
225
225
if (pOp == NULL ) {
226
- ERR (pTrans->getNdbError ());
226
+ NDB_ERR (pTrans->getNdbError ());
227
227
pNdb->closeTransaction (pTrans);
228
228
return NDBT_FAILED;
229
229
}
230
230
231
231
if ( pOp->readTuples (NdbScanOperation::LM_Read, 0 , parallelism) ) {
232
- ERR (pTrans->getNdbError ());
232
+ NDB_ERR (pTrans->getNdbError ());
233
233
pNdb->closeTransaction (pTrans);
234
234
return NDBT_FAILED;
235
235
}
236
236
237
237
if (filter.filterOp (pOp) != 0 ){
238
- ERR (pTrans->getNdbError ());
238
+ NDB_ERR (pTrans->getNdbError ());
239
239
pNdb->closeTransaction (pTrans);
240
240
return NDBT_FAILED;
241
241
}
@@ -244,14 +244,14 @@ ScanInterpretTest::scanRead(Ndb* pNdb,
244
244
for (int a = 0 ; a<tab.getNoOfColumns (); a++){
245
245
if ((row.attributeStore (a) =
246
246
pOp->getValue (tab.getColumn (a)->getName ())) == 0 ) {
247
- ERR (pTrans->getNdbError ());
247
+ NDB_ERR (pTrans->getNdbError ());
248
248
pNdb->closeTransaction (pTrans);
249
249
return NDBT_FAILED;
250
250
}
251
251
}
252
252
check = pTrans->execute (NoCommit);
253
253
if ( check == -1 ) {
254
- ERR (pTrans->getNdbError ());
254
+ NDB_ERR (pTrans->getNdbError ());
255
255
pNdb->closeTransaction (pTrans);
256
256
return NDBT_FAILED;
257
257
}
@@ -271,7 +271,7 @@ ScanInterpretTest::scanRead(Ndb* pNdb,
271
271
check = pTrans->execute (Commit);
272
272
if ( check == -1 ) {
273
273
const NdbError err = pTrans->getNdbError ();
274
- ERR (err);
274
+ NDB_ERR (err);
275
275
pNdb->closeTransaction (pTrans);
276
276
return NDBT_FAILED;
277
277
}
@@ -280,13 +280,13 @@ ScanInterpretTest::scanRead(Ndb* pNdb,
280
280
const NdbError err = pTrans->getNdbError ();
281
281
282
282
if (err.status == NdbError::TemporaryError){
283
- ERR (err);
283
+ NDB_ERR (err);
284
284
pNdb->closeTransaction (pTrans);
285
285
NdbSleep_MilliSleep (50 );
286
286
retryAttempt++;
287
287
continue ;
288
288
}
289
- ERR (err);
289
+ NDB_ERR (err);
290
290
pNdb->closeTransaction (pTrans);
291
291
return NDBT_FAILED;
292
292
}
@@ -324,30 +324,30 @@ ScanInterpretTest::scanReadVerify(Ndb* pNdb,
324
324
if (pTrans == NULL ) {
325
325
const NdbError err = pNdb->getNdbError ();
326
326
if (err.status == NdbError::TemporaryError){
327
- ERR (err);
327
+ NDB_ERR (err);
328
328
NdbSleep_MilliSleep (50 );
329
329
retryAttempt++;
330
330
continue ;
331
331
}
332
- ERR (err);
332
+ NDB_ERR (err);
333
333
return NDBT_FAILED;
334
334
}
335
335
336
336
337
337
pOp = pTrans->getNdbScanOperation (tab.getName ());
338
338
if (pOp == NULL ) { if (pOp->getValue (" KOL2" ) == 0 ){
339
- ERR (pNdb->getNdbError ());
339
+ NDB_ERR (pNdb->getNdbError ());
340
340
return NDBT_FAILED;
341
341
}
342
342
343
343
344
- ERR (pTrans->getNdbError ());
344
+ NDB_ERR (pTrans->getNdbError ());
345
345
pNdb->closeTransaction (pTrans);
346
346
return NDBT_FAILED;
347
347
}
348
348
349
349
if ( pOp->readTuples (NdbScanOperation::LM_Read, 0 , parallelism) ) {
350
- ERR (pTrans->getNdbError ());
350
+ NDB_ERR (pTrans->getNdbError ());
351
351
pNdb->closeTransaction (pTrans);
352
352
return NDBT_FAILED;
353
353
}
@@ -356,14 +356,14 @@ ScanInterpretTest::scanReadVerify(Ndb* pNdb,
356
356
for (int a = 0 ; a<tab.getNoOfColumns (); a++){
357
357
if ((row.attributeStore (a) =
358
358
pOp->getValue (tab.getColumn (a)->getName ())) == 0 ) {
359
- ERR (pTrans->getNdbError ());
359
+ NDB_ERR (pTrans->getNdbError ());
360
360
pNdb->closeTransaction (pTrans);
361
361
return NDBT_FAILED;
362
362
}
363
363
}
364
364
check = pTrans->execute (NoCommit);
365
365
if ( check == -1 ) {
366
- ERR (pTrans->getNdbError ());
366
+ NDB_ERR (pTrans->getNdbError ());
367
367
pNdb->closeTransaction (pTrans);
368
368
return NDBT_FAILED;
369
369
}
@@ -383,13 +383,13 @@ ScanInterpretTest::scanReadVerify(Ndb* pNdb,
383
383
pExistTrans = pNdb->startTransaction ();
384
384
if (pExistTrans == NULL ) {
385
385
const NdbError err = pNdb->getNdbError ();
386
- ERR (err);
386
+ NDB_ERR (err);
387
387
return NDBT_FAILED;
388
388
}
389
389
pNoExistTrans = pNdb->startTransaction ();
390
390
if (pNoExistTrans == NULL ) {
391
391
const NdbError err = pNdb->getNdbError ();
392
- ERR (err);
392
+ NDB_ERR (err);
393
393
return NDBT_FAILED;
394
394
}
395
395
do {
@@ -419,7 +419,7 @@ ScanInterpretTest::scanReadVerify(Ndb* pNdb,
419
419
check = pExistTrans->execute (Commit);
420
420
if ( check == -1 ) {
421
421
const NdbError err = pExistTrans->getNdbError ();
422
- ERR (err);
422
+ NDB_ERR (err);
423
423
if (err.code != 626 ){
424
424
pNdb->closeTransaction (pExistTrans);
425
425
pNdb->closeTransaction (pNoExistTrans);
@@ -440,7 +440,7 @@ ScanInterpretTest::scanReadVerify(Ndb* pNdb,
440
440
const NdbError err = pNoExistTrans->getNdbError ();
441
441
// The transactions error code should be zero
442
442
if (err.code != 626 ){
443
- ERR (err);
443
+ NDB_ERR (err);
444
444
pNdb->closeTransaction (pNoExistTrans);
445
445
pNdb->closeTransaction (pTrans);
446
446
return NDBT_FAILED;
@@ -465,13 +465,13 @@ ScanInterpretTest::scanReadVerify(Ndb* pNdb,
465
465
const NdbError err = pTrans->getNdbError ();
466
466
467
467
if (err.status == NdbError::TemporaryError){
468
- ERR (err);
468
+ NDB_ERR (err);
469
469
pNdb->closeTransaction (pTrans);
470
470
NdbSleep_MilliSleep (50 );
471
471
retryAttempt++;
472
472
continue ;
473
473
}
474
- ERR (err);
474
+ NDB_ERR (err);
475
475
pNdb->closeTransaction (pTrans);
476
476
return NDBT_FAILED;
477
477
}
0 commit comments