| 384 | } |
| 385 | |
| 386 | int recom_commit(struct sqlclntstate *clnt, struct sql_thread *thd, |
| 387 | char *tzname, int is_distributed_tran) |
| 388 | { |
| 389 | int rc = 0; |
| 390 | |
| 391 | /* temp hook for sql transactions */ |
| 392 | if (clnt->dbtran.dtran) { |
| 393 | rc = fdb_trans_commit(clnt, TRANS_CLNTCOMM_NORMAL); |
| 394 | if (rc) { |
| 395 | logmsg(LOGMSG_ERROR, "%s distributed failure rc=%d\n", __func__, rc); |
| 396 | return rc; |
| 397 | } |
| 398 | } |
| 399 | |
| 400 | return rese_commit(clnt, thd, tzname, OSQL_RECOM_REQ, is_distributed_tran); |
| 401 | } |
| 402 | |
| 403 | int recom_abort(struct sqlclntstate *clnt) |
| 404 | { |
no test coverage detected