From ccf3beb5eec365da8946072d904e456fc448ce76 Mon Sep 17 00:00:00 2001 From: Gabriel mermelstein Date: Fri, 25 Apr 2025 11:17:25 +0200 Subject: [PATCH] adding extra context for reliability manager nil errors --- sds/sds.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/sds/sds.go b/sds/sds.go index 4d45aad..fec7caf 100644 --- a/sds/sds.go +++ b/sds/sds.go @@ -320,7 +320,7 @@ func (rm *ReliabilityManager) parseMissingDepsEvent(eventStr string) { func (rm *ReliabilityManager) Cleanup() error { if rm == nil { - err := errors.New("reliability manager is nil") + err := errors.New("reliability manager is nil in Cleanup") Error("Failed to cleanup %v", err) return err } @@ -349,7 +349,7 @@ func (rm *ReliabilityManager) Cleanup() error { func (rm *ReliabilityManager) Reset() error { if rm == nil { - err := errors.New("reliability manager is nil") + err := errors.New("reliability manager is nil in Reset") Error("Failed to reset %v", err) return err } @@ -377,7 +377,7 @@ func (rm *ReliabilityManager) Reset() error { func (rm *ReliabilityManager) WrapOutgoingMessage(message []byte, messageId MessageID) ([]byte, error) { if rm == nil { - err := errors.New("reliability manager is nil") + err := errors.New("reliability manager is nil in WrapOutgoingMessage") Error("Failed to wrap outgoing message %v", err) return nil, err } @@ -434,7 +434,7 @@ func (rm *ReliabilityManager) WrapOutgoingMessage(message []byte, messageId Mess func (rm *ReliabilityManager) UnwrapReceivedMessage(message []byte) (*UnwrappedMessage, error) { if rm == nil { - err := errors.New("reliability manager is nil") + err := errors.New("reliability manager is nil in UnwrapReceivedMessage") Error("Failed to unwrap received message %v", err) return nil, err } @@ -483,7 +483,7 @@ func (rm *ReliabilityManager) UnwrapReceivedMessage(message []byte) (*UnwrappedM // MarkDependenciesMet informs the library that dependencies are met func (rm *ReliabilityManager) MarkDependenciesMet(messageIDs []MessageID) error { if rm == nil { - err := errors.New("reliability manager is nil") + err := errors.New("reliability manager is nil in MarkDependenciesMet") Error("Failed to mark dependencies met %v", err) return err } @@ -529,7 +529,7 @@ func (rm *ReliabilityManager) MarkDependenciesMet(messageIDs []MessageID) error func (rm *ReliabilityManager) StartPeriodicTasks() error { if rm == nil { - err := errors.New("reliability manager is nil") + err := errors.New("reliability manager is nil in StartPeriodicTasks") Error("Failed to start periodic tasks %v", err) return err }