Skip to content

Commit

Permalink
Fix comments
Browse files Browse the repository at this point in the history
  • Loading branch information
Alexandr Samylkin committed Feb 23, 2017
1 parent 5415a12 commit 3cab60b
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions modules/rpc/yarpc.go
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -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
Expand Down Expand Up @@ -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")
Expand Down

0 comments on commit 3cab60b

Please sign in to comment.