| 260 | } |
| 261 | |
| 262 | void Replicator::releaseSavepoint(CheckStatusWrapper* status, Transaction* transaction) |
| 263 | { |
| 264 | try |
| 265 | { |
| 266 | auto& txnData = transaction->getData(); |
| 267 | |
| 268 | txnData.putTag(opReleaseSavepoint); |
| 269 | |
| 270 | if (txnData.getSize() > m_config->bufferSize) |
| 271 | flush(txnData, FLUSH_OVERFLOW); |
| 272 | } |
| 273 | catch (const Exception& ex) |
| 274 | { |
| 275 | ex.stuffException(status); |
| 276 | } |
| 277 | } |
| 278 | |
| 279 | void Replicator::rollbackSavepoint(CheckStatusWrapper* status, Transaction* transaction) |
| 280 | { |
no test coverage detected