diff --git a/node/consensus/provers/proposer.go b/node/consensus/provers/proposer.go index 7bec431..e402c09 100644 --- a/node/consensus/provers/proposer.go +++ b/node/consensus/provers/proposer.go @@ -162,9 +162,11 @@ func (m *Manager) PlanAndAllocate( ) continue } + if s.Shards == 0 { s.Shards = 1 } + var score *big.Int switch m.Strategy { case DataGreedy: @@ -191,6 +193,7 @@ func (m *Manager) PlanAndAllocate( if err != nil { return nil, errors.Wrap(err, "plan and allocate") } + if shardsSqrt.IsZero() { return nil, errors.New("plan and allocate") } diff --git a/node/consensus/time/global_time_reel.go b/node/consensus/time/global_time_reel.go index 44b69c8..0057291 100644 --- a/node/consensus/time/global_time_reel.go +++ b/node/consensus/time/global_time_reel.go @@ -1612,7 +1612,8 @@ func (g *GlobalTimeReel) bootstrapFromStore() error { } // persistCanonicalFrames writes a contiguous set of canonical frames to the -// store in one txn. In non-archive mode, it also prunes old frames from the store. +// store in one txn. In non-archive mode, it also prunes old frames from the +// store. func (g *GlobalTimeReel) persistCanonicalFrames( frames []*protobufs.GlobalFrame, ) error { diff --git a/node/datarpc/data_worker_ipc_server.go b/node/datarpc/data_worker_ipc_server.go index a6fe313..6090784 100644 --- a/node/datarpc/data_worker_ipc_server.go +++ b/node/datarpc/data_worker_ipc_server.go @@ -188,6 +188,7 @@ func (r *DataWorkerIPCServer) RespawnServer(filter []byte) error { r.logger.Info( "data worker listening", zap.String("address", r.listenAddrGRPC), + zap.String("resolved", lis.Addr().String()), ) if len(filter) != 0 { globalTimeReel, err := r.appConsensusEngineFactory.CreateGlobalTimeReel() @@ -217,6 +218,7 @@ func (r *DataWorkerIPCServer) CreateJoinProof( ctx context.Context, req *protobufs.CreateJoinProofRequest, ) (*protobufs.CreateJoinProofResponse, error) { + r.logger.Debug("received request to create join proof") proof := r.frameProver.CalculateMultiProof( [32]byte(req.Challenge), req.Difficulty,