From 3cab60ba09806e648f83a978cfcf1858206caa6f Mon Sep 17 00:00:00 2001 From: Alexandr Samylkin Date: Wed, 22 Feb 2017 18:42:58 -0800 Subject: [PATCH] Fix comments --- modules/rpc/yarpc.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/modules/rpc/yarpc.go b/modules/rpc/yarpc.go index 74b89b5e0..fe6a1ade2 100644 --- a/modules/rpc/yarpc.go +++ b/modules/rpc/yarpc.go @@ -114,8 +114,8 @@ type Address struct { type handlerWithDispatcher func(dispatcher *yarpc.Dispatcher) error -// Stores a collection of all modules configs with a shared dispatcher and user handles to -// append procedures to the dispatcher +// Stores a collection of all module configs with a shared dispatcher +// and user handles to work with the dispatcher. type dispatcherController struct { // sync configs sync.RWMutex @@ -177,7 +177,7 @@ func (c *dispatcherController) addDefaultMiddleware(host service.Host) { } // Starts the dispatcher: -// 1. Merge all existing configs +// 1. Add default middleware and merge all existing configs // 2. Create a dispatcher // 3. Call user handles to e.g. register transport.Procedures on the dispatcher // 4. Start the dispatcher @@ -285,7 +285,7 @@ func newYARPCModule( return nil, errs.Wrap(err, "can't read inbounds") } - // iterate over inbounds + // Iterate over inbounds. transportsIn, err := prepareInbounds(module.config.Inbounds, mi.Host.Name()) if err != nil { return nil, errs.Wrap(err, "can't process inbounds")