Skip to content

Commit 0daae8e

Browse files
committed
Update error responses
1 parent bca25ad commit 0daae8e

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

disperser/dataapi/operator_handler.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -48,14 +48,14 @@ func (oh *OperatorHandler) ProbeOperatorHosts(ctx context.Context, operatorId st
4848
operatorSocket := core.OperatorSocket(operatorInfo.Socket)
4949
retrievalSocket := operatorSocket.GetRetrievalSocket()
5050
retrievalPortOpen := checkIsOperatorPortOpen(retrievalSocket, 3, oh.logger)
51-
retrievalOnline, retrievalStatus := false, "port closed"
51+
retrievalOnline, retrievalStatus := false, fmt.Sprintf("port closed or unreachable for %s", retrievalSocket)
5252
if retrievalPortOpen {
5353
retrievalOnline, retrievalStatus = checkServiceOnline(ctx, "node.Retrieval", retrievalSocket, 3*time.Second)
5454
}
5555

5656
dispersalSocket := operatorSocket.GetDispersalSocket()
5757
dispersalPortOpen := checkIsOperatorPortOpen(dispersalSocket, 3, oh.logger)
58-
dispersalOnline, dispersalStatus := false, "port closed"
58+
dispersalOnline, dispersalStatus := false, fmt.Sprintf("port closed or unreachable for %s", dispersalSocket)
5959
if dispersalPortOpen {
6060
dispersalOnline, dispersalStatus = checkServiceOnline(ctx, "node.Dispersal", dispersalSocket, 3*time.Second)
6161
}
@@ -115,11 +115,11 @@ func checkServiceOnline(ctx context.Context, serviceName string, socket string,
115115
if list := r.GetListServicesResponse(); list != nil {
116116
for _, service := range list.GetService() {
117117
if service.GetName() == serviceName {
118-
return true, "available"
118+
return true, fmt.Sprintf("%s is available", serviceName)
119119
}
120120
}
121121
}
122-
return false, "unavailable"
122+
return false, fmt.Sprintf("grpc available but %s service not found at %s", serviceName, socket)
123123
}
124124

125125
func (oh *OperatorHandler) GetOperatorsStake(ctx context.Context, operatorId string) (*OperatorsStakeResponse, error) {

0 commit comments

Comments
 (0)