Method buffer_write

nodedb/src/control/server/pgwire/session/transaction.rs:135–145

Buffer a write task during a transaction block. Returns `true` if buffered (in transaction), `false` if not (dispatch immediately).

(&self, addr: &SocketAddr, task: PhysicalTask)

    ///
    /// Returns `true` if buffered (in transaction), `false` if not (dispatch immediately).
    pub fn buffer_write(&self, addr: &SocketAddr, task: PhysicalTask) -> bool {
        self.write_session(addr, |session| {
            if session.tx_state == TransactionState::InBlock {
                session.tx_buffer.push(task);
                true
            } else {
                false
            }
        })
        .unwrap_or(false)
    }

    /// ROLLBACK — discard the write buffer and return to idle.
    /// Returns any pending GAP_FREE reservations that need to be rolled back.