fix (libzkp): check tx num when CCC ErrUnknown error occurred

miner/worker.go

@@ -1145,6 +1145,17 @@ loop:
  // However, after `ErrUnknown`, ccc might remain in an
  // inconsistent state, so we cannot pack more transactions.
  circuitCapacityReached = true
+ txNumInCcc, err := w.circuitCapacityChecker.GetTxNum()
+ if err == nil {
+ txNumInMiner := uint64(w.current.tcount)
+ if txNumInMiner == txNumInCcc {
+ log.Info("tx count in miner is same with CCC", "txNum", txNumInMiner)
+ } else {
+ log.Error("tx count in miner is different with CCC", "txNumInMiner", txNumInMiner, "txNumInCcc", txNumInCcc)
+ }
+ } else {
+ log.Error("failed to get_tx_num", "err", err)
+ }
  break loop
 
  case (errors.Is(err, circuitcapacitychecker.ErrUnknown) && !tx.IsL1MessageTx()):
@@ -1164,6 +1175,17 @@ loop:
  // inconsistent state, so we cannot pack more transactions.
  w.eth.TxPool().RemoveTx(tx.Hash(), true)
  circuitCapacityReached = true
+ txNumInCcc, err := w.circuitCapacityChecker.GetTxNum()
+ if err == nil {
+ txNumInMiner := uint64(w.current.tcount)
+ if txNumInMiner == txNumInCcc {
+ log.Info("tx count in miner is same with CCC", "txNum", txNumInMiner)
+ } else {
+ log.Error("tx count in miner is different with CCC", "txNumInMiner", txNumInMiner, "txNumInCcc", txNumInCcc)
+ }
+ } else {
+ log.Error("failed to get_tx_num", "err", err)
+ }
  break loop
 
  default:

params/version.go

@@ -24,7 +24,7 @@ import (
 const (
  VersionMajor = 4 // Major version component of the current release
  VersionMinor = 4 // Minor version component of the current release
- VersionPatch = 2 // Patch version component of the current release
+ VersionPatch = 3 // Patch version component of the current release
  VersionMeta = "sepolia" // Version metadata to append to the version string
 )
 

rollup/circuitcapacitychecker/impl.go

@@ -141,3 +141,31 @@ func (ccc *CircuitCapacityChecker) ApplyBlock(traces *types.BlockTrace) (*types.
  }
  return (*types.RowConsumption)(&result.AccRowUsage.RowUsageDetails), nil
 }
+
+func (ccc *CircuitCapacityChecker) GetTxNum() (uint64, error) {
+ ccc.Lock()
+ defer ccc.Unlock()
+
+ log.Debug("ccc get_tx_num start", "id", ccc.ID)
+ rawResult := C.get_tx_num(C.uint64_t(ccc.ID))
+ defer func() {
+ C.free(unsafe.Pointer(rawResult))
+ }()
+ log.Debug("ccc get_tx_num end", "id", ccc.ID)
+
+ result := &WrappedTxNum{}
+ if err = json.Unmarshal([]byte(C.GoString(rawResult)), result); err != nil {
+ log.Error("fail to json unmarshal get_tx_num result", "id", ccc.ID, "err", err)
+ return nil, ErrUnknown
+ }
+ if result.Error != "" {
+ log.Error("fail to get_tx_num in CircuitCapacityChecker", "id", ccc.ID, "err", result.Error)
+ return nil, ErrUnknown
+ }
+ if result.TxNum == nil {
+ log.Error("fail to get_tx_num in CircuitCapacityChecker", "id", ccc.ID, "err", "TxNum is empty unexpectedly")
+ return nil, ErrUnknown
+ }
+
+ return result.TxNum, nil
+}

rollup/circuitcapacitychecker/libzkp/libzkp.h

@@ -4,3 +4,4 @@ uint64_t new_circuit_capacity_checker();
 void reset_circuit_capacity_checker(uint64_t id);
 char* apply_tx(uint64_t id, char *tx_traces);
 char* apply_block(uint64_t id, char *block_trace);
+char* get_tx_num(uint64_t id);

rollup/circuitcapacitychecker/libzkp/src/lib.rs

@@ -20,6 +20,12 @@ pub mod checker {
  pub error: Option<String>,
  }
 
+ #[derive(Debug, Clone, Deserialize, Serialize)]
+ pub struct TxNumResult {
+ pub tx_num: Option<u64>,
+ pub error: Option<String>,
+ }
+
  static mut CHECKERS: OnceCell<HashMap<u64, CircuitCapacityChecker>> = OnceCell::new();
 
  /// # Safety
@@ -176,6 +182,50 @@ pub mod checker {
  }
  }
  }
+
+ /// # Safety
+ #[no_mangle]
+ pub unsafe extern "C" fn get_tx_num(id: u64) -> *const c_char {
+ let result = get_tx_num_inner(id);
+ let r = match result {
+ Ok(tx_num) => {
+ log::debug!("id: {id}, tx_num: {tx_num}");
+ TxNumResult {
+ tx_num: Some(tx_num),
+ error: None,
+ }
+ }
+ Err(e) => TxNumResult {
+ tx_num: None,
+ error: Some(format!("{e:?}")),
+ },
+ };
+ serde_json::to_vec(&r).map_or(null(), vec_to_c_char)
+ }
+
+ unsafe fn get_tx_num_inner(id: u64) -> Result<u64, Error> {
+ log::debug!("ccc get_tx_num raw input, id: {id}");
+ panic::catch_unwind(|| {
+ Ok(CHECKERS
+ .get_mut()
+ .ok_or(anyhow!(
+ "fail to get circuit capacity checkers map in get_tx_num"
+ ))?
+ .get_mut(&id)
+ .ok_or(anyhow!(
+ "fail to get circuit capacity checker (id: {id}) in get_tx_num"
+ ))?
+ .get_tx_num() as u64)
+ })
+ .map_or_else(
+ |e| {
+ Err(anyhow!(
+ "circuit capacity checker (id: {id}) error in get_tx_num: {e:?}"
+ ))
+ },
+ |result| result,
+ )
+ }
 }
 
 pub(crate) mod utils {

rollup/circuitcapacitychecker/mock.go

@@ -43,6 +43,10 @@ func (ccc *CircuitCapacityChecker) ApplyBlock(traces *types.BlockTrace) (*types.
  }}, nil
 }
 
+func (ccc *CircuitCapacityChecker) GetTxNum() (uint64, error) {
+ return 0, nil
+}
+
 func (ccc *CircuitCapacityChecker) ScheduleError(cnt int, err error) {
  ccc.countdown = cnt
  ccc.nextError = &err

rollup/circuitcapacitychecker/types.go

@@ -15,3 +15,8 @@ type WrappedRowUsage struct {
  AccRowUsage *types.RowUsage `json:"acc_row_usage,omitempty"`
  Error string `json:"error,omitempty"`
 }
+
+type WrappedTxNum struct {
+ TxNum uint64 `json:"tx_num,omitempty"`
+ Error string `json:"error,omitempty"`
+}