add error handling for sentinel cid lookups

filecoin-saturn · Jul 5, 2023 · c20f01c · c20f01c
1 parent 44d5802
commit c20f01c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/pool.go b/pool.go
@@ -247,7 +247,7 @@ func (p *pool) fetchSentinelCid(node string) error {
 	}
 	trialTimeout, cancel := context.WithTimeout(context.Background(), 30*time.Second)
 	reqUrl := fmt.Sprintf(sentinelCidReqTemplate, sc)
-	goLogger.Debugw("Fetching Sentinel CID: ", sc, " from: ", node)
+	goLogger.Debugw("fetching sentinel cid: ", reqUrl, " from: ", node)
 	err = p.fetchResourceAndUpdate(trialTimeout, node, reqUrl, 0, p.mirrorValidator)
 	cancel()
 	return err

diff --git a/tieredhashing/tiered_hashing.go b/tieredhashing/tiered_hashing.go
@@ -255,7 +255,11 @@ func (t *TieredHashing) GetPerf() map[string]*NodePerf {
 
 func (t *TieredHashing) GetSentinelCid(ip string) (string, error) {
 	if node, ok := t.nodes[ip]; ok {
+		if len(node.SentinelCid) > 0 {
 		return node.SentinelCid, nil
+		} else {
+			return "", fmt.Errorf("sentinel cid doesn't exist for node: %s ", ip)
+		}
 
 	} else {
 		return "", fmt.Errorf("node with IP: %s is not in Caboose pool ", ip)