Skip to content

Commit

Permalink
Ignore socket parsing error from dispatcher (#1198)
Browse files Browse the repository at this point in the history
  • Loading branch information
ian-shim authored Feb 1, 2025
1 parent a1fceb9 commit a13af02
Showing 1 changed file with 9 additions and 1 deletion.
10 changes: 9 additions & 1 deletion disperser/controller/dispatcher.go
Original file line number Diff line number Diff line change
Expand Up @@ -150,7 +150,15 @@ func (d *Dispatcher) HandleBatch(ctx context.Context) (chan core.SigningMessage,
op := op
host, _, _, v2DispersalPort, _, err := core.ParseOperatorSocket(op.Socket)
if err != nil {
return nil, nil, fmt.Errorf("failed to parse operator socket (%s): %w", op.Socket, err)
d.logger.Warn("failed to parse operator socket, check if the socket format is correct", "operator", opID.Hex(), "socket", op.Socket, "err", err)
sigChan <- core.SigningMessage{
Signature: nil,
Operator: opID,
BatchHeaderHash: batchData.BatchHeaderHash,
AttestationLatencyMs: 0,
Err: fmt.Errorf("failed to parse operator socket (%s): %w", op.Socket, err),
}
continue
}

client, err := d.nodeClientManager.GetClient(host, v2DispersalPort)
Expand Down

0 comments on commit a13af02

Please sign in to comment.