diff --git a/single/listener.go b/single/listener.go index 3f3efbf7545ad0764fc32c15955d5c2def2ff51e..0ee3165a041e67fd30851aca5d9fa760a63b9c39 100644 --- a/single/listener.go +++ b/single/listener.go @@ -13,6 +13,8 @@ import ( "gitlab.com/xx_network/primitives/id" ) +const listenerProcessorName = "listenerProcessorName" + type Receiver interface { Callback(*Request, receptionID.EphemeralIdentity, []rounds.Round) } @@ -145,6 +147,11 @@ func (l *listener) Process(ecrMsg format.Message, } } +func (l *listener) String() string { + return listenerProcessorName + +} + func (l *listener) Stop() { svc := cmixMsg.Service{ Identifier: l.myId[:], diff --git a/single/requestPartProcessor.go b/single/requestPartProcessor.go index bf473d9487ffe57c9712ecd6430e77aafd283143..b6564d1e8712741b01a6ff675372455c6c5307a0 100644 --- a/single/requestPartProcessor.go +++ b/single/requestPartProcessor.go @@ -16,6 +16,8 @@ import ( "gitlab.com/xx_network/primitives/id" ) +const requestPartProcessorName = "requestPartProcessor" + // requestPartProcessor handles the decryption and collation of request parts. type requestPartProcessor struct { myId *id.ID @@ -56,3 +58,7 @@ func (rpp *requestPartProcessor) Process(msg format.Message, rpp.cb(payload, rpp.roundIDs.getList()) } } + +func (rpp *requestPartProcessor) String() string { + return requestPartProcessorName +} diff --git a/single/responseProcessor.go b/single/responseProcessor.go index 0339427dd7f1033719d104c169170aa79fe60051..5f1e89163c309b0f0fa9b4a2ea7f20a48d782509 100644 --- a/single/responseProcessor.go +++ b/single/responseProcessor.go @@ -9,6 +9,8 @@ import ( "gitlab.com/elixxir/primitives/format" ) +const responseProcessorName = "responseProcessorName" + type callbackWrapper func(payload []byte, receptionID receptionID.EphemeralIdentity, rounds []rounds.Round, err error) @@ -58,3 +60,8 @@ func (rsp *responseProcessor) Process(ecrMsg format.Message, rsp.callback(payload, receptionID, rsp.roundIDs.getList(), nil) } } + +func (rsp *responseProcessor) String() string { + return responseProcessorName + +} diff --git a/ud/utils_test.go b/ud/utils_test.go index 0cfc90dd02d3e701b4cb3ad1e9309c23e775a9d1..675acc924c0ee015c8c25ad1bfe0af3f244d77f7 100644 --- a/ud/utils_test.go +++ b/ud/utils_test.go @@ -313,6 +313,10 @@ func (tnm *testNetworkManager) Process(ecrMsg format.Message, } +func (tnm *testNetworkManager) String() string { + return "mockPRocessor" +} + func (tnm *testNetworkManager) DeleteService(clientID *id.ID, toDelete message.Service, processor message.Processor) { return }