Skip to content
Snippets Groups Projects
Commit bcc014eb authored by william feng's avatar william feng
Browse files

fixed minor grammar issues

parent 8e187475
No related branches found
No related tags found
No related merge requests found
...@@ -32,7 +32,7 @@ func SetAuthenticator(name string, fcn func() filter.Authenticator) { ...@@ -32,7 +32,7 @@ func SetAuthenticator(name string, fcn func() filter.Authenticator) {
} }
// GetAuthenticator finds the Authenticator with @name // GetAuthenticator finds the Authenticator with @name
// panic if not found // Panic if not found
func GetAuthenticator(name string) filter.Authenticator { func GetAuthenticator(name string) filter.Authenticator {
if authenticators[name] == nil { if authenticators[name] == nil {
panic("authenticator for " + name + " is not existing, make sure you have import the package.") panic("authenticator for " + name + " is not existing, make sure you have import the package.")
......
...@@ -53,7 +53,7 @@ type gracefulShutdownFilter struct { ...@@ -53,7 +53,7 @@ type gracefulShutdownFilter struct {
shutdownConfig *config.ShutdownConfig shutdownConfig *config.ShutdownConfig
} }
// Invoke add the requests count and block the new requests if application is closing // Invoke adds the requests count and block the new requests if application is closing
func (gf *gracefulShutdownFilter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result { func (gf *gracefulShutdownFilter) Invoke(ctx context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result {
if gf.rejectNewRequest() { if gf.rejectNewRequest() {
logger.Info("The application is closing, new request will be rejected.") logger.Info("The application is closing, new request will be rejected.")
...@@ -63,7 +63,7 @@ func (gf *gracefulShutdownFilter) Invoke(ctx context.Context, invoker protocol.I ...@@ -63,7 +63,7 @@ func (gf *gracefulShutdownFilter) Invoke(ctx context.Context, invoker protocol.I
return invoker.Invoke(ctx, invocation) return invoker.Invoke(ctx, invocation)
} }
// OnResponse reduce the number of active processes then return the process result // OnResponse reduces the number of active processes then return the process result
func (gf *gracefulShutdownFilter) OnResponse(ctx context.Context, result protocol.Result, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result { func (gf *gracefulShutdownFilter) OnResponse(ctx context.Context, result protocol.Result, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result {
atomic.AddInt32(&gf.activeCount, -1) atomic.AddInt32(&gf.activeCount, -1)
// although this isn't thread safe, it won't be a problem if the gf.rejectNewRequest() is true. // although this isn't thread safe, it won't be a problem if the gf.rejectNewRequest() is true.
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment