H0llyW00dzZ/fiber
H0llyW00dzZ/fiber
1
0
Fork 0
mirror of https://github.com/gofiber/fiber.git synced 2025-02-12 02:20:57 +00:00
Code Releases Activity

🐛fix: rename handlerCount to handlersCount (#1674)

Browse Source
This commit is contained in:
vecpeng 2021-12-29 17:26:50 +08:00 committed by GitHub
parent fbee8fb274
commit ef3a689600
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
4 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
app.go
View File

@ -98,7 +98,7 @@ type App struct {
// Amount of registered routes
routesCount uint32
// Amount of registered handlers
handlerCount uint32
handlersCount uint32
// Ctx pool
pool sync.Pool
// Fasthttp server
@ -540,7 +540,7 @@ func (app *App) Mount(prefix string, fiber *App) Router {
app.errorHandlers[prefix+mountedPrefixes] = errHandler
}
atomic.AddUint32(&app.handlerCount, fiber.handlerCount)
atomic.AddUint32(&app.handlersCount, fiber.handlersCount)
return app
}
@ -800,7 +800,7 @@ func (app *App) Stack() [][]*Route {
// HandlersCount returns the amount of registered handlers.
func (app *App) HandlersCount() uint32 {
return app.handlerCount
return app.handlersCount
}
// Shutdown gracefully shuts down the server without interrupting any active connections.
@ -1104,7 +1104,7 @@ func (app *App) startupMessage(addr string, tls bool, pids string) {
" │ Prefork .%s PID ....%s │\n"+
" └───────────────────────────────────────────────────┘"+
cReset,
value(strconv.Itoa(int(app.handlerCount)), 14), value(procs, 12),
value(strconv.Itoa(int(app.handlersCount)), 14), value(procs, 12),
value(isPrefork, 14), value(strconv.Itoa(os.Getpid()), 14),
)

4
app_test.go
View File

@ -300,7 +300,7 @@ func Test_App_Mount(t *testing.T) {
resp, err := app.Test(httptest.NewRequest(MethodGet, "/john/doe", nil))
utils.AssertEqual(t, nil, err, "app.Test(req)")
utils.AssertEqual(t, 200, resp.StatusCode, "Status code")
utils.AssertEqual(t, uint32(2), app.handlerCount)
utils.AssertEqual(t, uint32(2), app.handlersCount)
}
func Test_App_Use_Params(t *testing.T) {
@ -931,7 +931,7 @@ func Test_App_Group_Mount(t *testing.T) {
resp, err := app.Test(httptest.NewRequest(MethodGet, "/v1/john/doe", nil))
utils.AssertEqual(t, nil, err, "app.Test(req)")
utils.AssertEqual(t, 200, resp.StatusCode, "Status code")
utils.AssertEqual(t, uint32(2), app.handlerCount)
utils.AssertEqual(t, uint32(2), app.handlersCount)
}
func Test_App_Group(t *testing.T) {

2
group.go
View File

@ -41,7 +41,7 @@ func (grp *Group) Mount(prefix string, fiber *App) Router {
grp.app.errorHandlers[groupPath+mountedPrefixes] = errHandler
}
atomic.AddUint32(&grp.app.handlerCount, fiber.handlerCount)
atomic.AddUint32(&grp.app.handlersCount, fiber.handlersCount)
return grp
}

4
router.go
View File

@ -266,7 +266,7 @@ func (app *App) register(method, pathRaw string, handlers ...Handler) Router {
Handlers: handlers,
}
// Increment global handler count
atomic.AddUint32(&app.handlerCount, uint32(len(handlers)))
atomic.AddUint32(&app.handlersCount, uint32(len(handlers)))
// Middleware route matches all HTTP methods
if isUse {
@ -403,7 +403,7 @@ func (app *App) registerStatic(prefix, root string, config ...Static) Router {
Handlers: []Handler{handler},
}
// Increment global handler count
atomic.AddUint32(&app.handlerCount, 1)
atomic.AddUint32(&app.handlersCount, 1)
// Add route to stack
app.addRoute(MethodGet, &route)
// Add HEAD route