| 552 | } |
| 553 | |
| 554 | void flush(Buffer* buf) { |
| 555 | ssize_t result = write(_in_memory ? _memfd : _fd, buf->data(), buf->offset()); |
| 556 | if (result > 0) { |
| 557 | atomicInc(_bytes_written, (u64)result); |
| 558 | } |
| 559 | buf->reset(); |
| 560 | } |
| 561 | |
| 562 | void flushIfNeeded(Buffer* buf, int limit = RECORDING_BUFFER_LIMIT) { |
| 563 | if (buf->offset() >= limit) { |