|
@ -311,7 +311,6 @@ func (p *Pipeline) Start(batchNum common.BatchNum, |
|
|
continue |
|
|
continue |
|
|
} |
|
|
} |
|
|
err := p.waitServerProof(p.ctx, batchInfo) |
|
|
err := p.waitServerProof(p.ctx, batchInfo) |
|
|
batchInfo.ServerProof = nil |
|
|
|
|
|
if p.ctx.Err() != nil { |
|
|
if p.ctx.Err() != nil { |
|
|
continue |
|
|
continue |
|
|
} else if err != nil { |
|
|
} else if err != nil { |
|
@ -326,6 +325,7 @@ func (p *Pipeline) Start(batchNum common.BatchNum, |
|
|
} |
|
|
} |
|
|
// We are done with this serverProof, add it back to the pool
|
|
|
// We are done with this serverProof, add it back to the pool
|
|
|
p.proversPool.Add(p.ctx, batchInfo.ServerProof) |
|
|
p.proversPool.Add(p.ctx, batchInfo.ServerProof) |
|
|
|
|
|
// batchInfo.ServerProof = nil
|
|
|
p.txManager.AddBatch(p.ctx, batchInfo) |
|
|
p.txManager.AddBatch(p.ctx, batchInfo) |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|