async fn store_pending_block(&mut self) {
        // Create a pending block object to send.
        // Note that failed operations are not included, as per any operation failure
        // the full block is created immediately.
        let pending_block = SendablePendingBlock {
            number: self.state.block_number,
            chunks_left: self.pending_block.chunks_left,
            unprocessed_priority_op_before: self.pending_block.unprocessed_priority_op_before,
            pending_block_iteration: self.pending_block.pending_block_iteration,
            success_operations: self.pending_block.success_operations.clone(),
            failed_txs: self.pending_block.failed_txs.clone(),
        };

        log::trace!(
            "Persisting mini block: {}, operations: {}, failed_txs: {}, chunks_left: {}, miniblock iterations: {}",
            pending_block.number,
            pending_block.success_operations.len(),
            pending_block.failed_txs.len(),
            pending_block.chunks_left,
            pending_block.pending_block_iteration
        );

        let (notification_sender, notification_receiver) = oneshot::channel::<()>();

        let commit_request = CommitRequest::PendingBlock(pending_block, notification_sender);
        self.tx_for_commitments
            .send(commit_request)
            .await
            .expect("committer receiver dropped");

        notification_receiver
            .await
            .expect("committer sender dropped");
    }
/// Stores intermediate representation of a pending block in the database,
/// so the executed transactions are persisted and won't be lost.
Stores intermediate representation of a pending block in the database,
so the executed transactions are persisted and won't be lost.
Stores intermediate representation of a pending block in the database so the executed transactions are persisted and won ' t be lost .
async fn store_pending_block(&mut self) {
        // Create a pending block object to send.
        // Note that failed operations are not included, as per any operation failure
        // the full block is created immediately.
        let pending_block = SendablePendingBlock {
            number: self.state.block_number,
            chunks_left: self.pending_block.chunks_left,
            unprocessed_priority_op_before: self.pending_block.unprocessed_priority_op_before,
            pending_block_iteration: self.pending_block.pending_block_iteration,
            success_operations: self.pending_block.success_operations.clone(),
            failed_txs: self.pending_block.failed_txs.clone(),
        };
        log::trace!(
            "Persisting mini block: {}, operations: {}, failed_txs: {}, chunks_left: {}, miniblock iterations: {}",
            pending_block.number,
            pending_block.success_operations.len(),
            pending_block.failed_txs.len(),
            pending_block.chunks_left,
            pending_block.pending_block_iteration
        );
        let (notification_sender, notification_receiver) = oneshot::channel::<()>();
        let commit_request = CommitRequest::PendingBlock(pending_block, notification_sender);
        self.tx_for_commitments
            .send(commit_request)
            .await
            .expect("committer receiver dropped");
        notification_receiver
            .await
            .expect("committer sender dropped");
    }
async fn store_pending_block ( & mut self ) { // Create a pending block object to send. // Note that failed operations are not included, as per any operation failure // the full block is created immediately. let pending_block = SendablePendingBlock { number : self . state . block_number , chunks_left : self . pending_block . chunks_left , unprocessed_priority_op_before : self . pending_block . unprocessed_priority_op_before , pending_block_iteration : self . pending_block . pending_block_iteration , success_operations : self . pending_block . success_operations . clone ( ) , failed_txs : self . pending_block . failed_txs . clone ( ) , } ; log :: trace ! ( " " pending_block number pending_block success_operations len ( ) pending_block failed_txs len ( ) pending_block chunks_left pending_block pending_block_iteration ) ; let ( notification_sender , notification_receiver ) = oneshot :: channel :: < ( ) > ( ) ; let commit_request = CommitRequest :: PendingBlock ( pending_block , notification_sender ) ; self . tx_for_commitments . send ( commit_request ) . await . expect ( " " ) ; notification_receiver . await . expect ( " " ) ; }
Stores intermediate representation of a pending block in the database,
so the executed transactions are persisted and won't be lost.
Stores intermediate representation of a pending block in the database so the executed transactions are persisted and won ' t be lost .
&mut self