| 243 | } |
| 244 | |
| 245 | void Replicator::startSavepoint(CheckStatusWrapper* status, Transaction* transaction) |
| 246 | { |
| 247 | try |
| 248 | { |
| 249 | auto& txnData = transaction->getData(); |
| 250 | |
| 251 | txnData.putTag(opStartSavepoint); |
| 252 | |
| 253 | if (txnData.getSize() > m_config->bufferSize) |
| 254 | flush(txnData, FLUSH_OVERFLOW); |
| 255 | } |
| 256 | catch (const Exception& ex) |
| 257 | { |
| 258 | ex.stuffException(status); |
| 259 | } |
| 260 | } |
| 261 | |
| 262 | void Replicator::releaseSavepoint(CheckStatusWrapper* status, Transaction* transaction) |
| 263 | { |
nothing calls this directly
no test coverage detected