Skip to content

Commit

Permalink
refactor gin context
Browse files Browse the repository at this point in the history
Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com>
  • Loading branch information
appleboy committed May 8, 2020
1 parent 736d448 commit f11ccce
Show file tree
Hide file tree
Showing 4 changed files with 32 additions and 31 deletions.
2 changes: 2 additions & 0 deletions context.go
Original file line number Diff line number Diff line change
Expand Up @@ -54,6 +54,7 @@ type Context struct {
fullPath string

engine *Engine
params *Params

// This mutex protect Keys map
mu sync.RWMutex
Expand Down Expand Up @@ -95,6 +96,7 @@ func (c *Context) reset() {
c.Accepted = nil
c.queryCache = nil
c.formCache = nil
*c.params = (*c.params)[0:0]
}

// Copy returns a copy of the current context that can be safely used outside the request's scope.
Expand Down
53 changes: 26 additions & 27 deletions gin.go
Original file line number Diff line number Diff line change
Expand Up @@ -113,8 +113,8 @@ type Engine struct {
noMethod HandlersChain
pool sync.Pool
trees methodTrees
paramsPool sync.Pool
maxParams uint16
// paramsPool sync.Pool
maxParams uint16
}

var _ IRouter = &Engine{}
Expand Down Expand Up @@ -165,7 +165,8 @@ func Default() *Engine {
}

func (engine *Engine) allocateContext() *Context {
return &Context{engine: engine}
v := make(Params, 0, engine.maxParams)
return &Context{engine: engine, params: &v}
}

// Delims sets template left and right delims and returns a Engine instance.
Expand Down Expand Up @@ -276,13 +277,13 @@ func (engine *Engine) addRoute(method, path string, handlers HandlersChain) {
}

// Lazy-init paramsPool alloc func
if engine.paramsPool.New == nil && engine.maxParams > 0 {
engine.paramsPool.New = func() interface{} {
// log.Println("engine.maxParams:", engine.maxParams)
ps := make(Params, 0, engine.maxParams)
return &ps
}
}
// if engine.paramsPool.New == nil && engine.maxParams > 0 {
// engine.paramsPool.New = func() interface{} {
// // log.Println("engine.maxParams:", engine.maxParams)
// ps := make(Params, 0, engine.maxParams)
// return &ps
// }
// }
}

// Routes returns a slice of registered routes, including some useful information, such as:
Expand Down Expand Up @@ -401,22 +402,20 @@ func (engine *Engine) HandleContext(c *Context) {
c.index = oldIndexValue
}

func (engine *Engine) getParams() *Params {
// c := engine.pool.Get().(*Context)
// c.Params = c.Params[0:0]
ps := engine.paramsPool.Get().(*Params)
*ps = (*ps)[0:0] // reset slice
return ps
}
// func (engine *Engine) getParams() *Params {
// ps := engine.paramsPool.Get().(*Params)
// *ps = (*ps)[0:0] // reset slice
// return ps
// }

func (engine *Engine) putParams(ps *Params) {
// c := engine.pool.Get().(*Context)
// c.Params = *ps
// engine.pool.Put(c)
if ps != nil {
engine.paramsPool.Put(ps)
}
}
// func (engine *Engine) putParams(ps *Params) {
// c := engine.pool.Get().(*Context)
// c.Params = *ps
// engine.pool.Put(c)
// if ps != nil {
// engine.paramsPool.Put(ps)
// }
// }

func (engine *Engine) handleHTTPRequest(c *Context) {
httpMethod := c.Request.Method
Expand All @@ -439,9 +438,9 @@ func (engine *Engine) handleHTTPRequest(c *Context) {
}
root := t[i].root
// Find route in tree
value := root.getValue(rPath, engine.getParams, unescape)
value := root.getValue(rPath, c.params, unescape)
if value.params != nil {
engine.putParams(value.params)
// engine.putParams(value.params)
c.Params = *value.params
}
if value.handlers != nil {
Expand Down
6 changes: 3 additions & 3 deletions tree.go
Original file line number Diff line number Diff line change
Expand Up @@ -419,7 +419,7 @@ type nodeValue struct {
// If no handle can be found, a TSR (trailing slash redirect) recommendation is
// made if a handle exists with an extra (without the) trailing slash for the
// given path.
func (n *node) getValue(path string, params func() *Params, unescape bool) (value nodeValue) {
func (n *node) getValue(path string, params *Params, unescape bool) (value nodeValue) {
value = nodeValue{}
walk: // Outer loop for walking the tree
for {
Expand Down Expand Up @@ -474,7 +474,7 @@ walk: // Outer loop for walking the tree
// }
if params != nil {
if value.params == nil {
value.params = params()
value.params = params
}
// Expand slice within preallocated capacity
i := len(*value.params)
Expand Down Expand Up @@ -536,7 +536,7 @@ walk: // Outer loop for walking the tree
// Save param value
if params != nil {
if value.params == nil {
value.params = params()
value.params = params
}
// Expand slice within preallocated capacity
i := len(*value.params)
Expand Down
2 changes: 1 addition & 1 deletion tree_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -40,7 +40,7 @@ func checkRequests(t *testing.T, tree *node, requests testRequests, unescapes ..
}

for _, request := range requests {
value := tree.getValue(request.path, getParams, unescape)
value := tree.getValue(request.path, getParams(), unescape)

if value.handlers == nil {
if !request.nilHandler {
Expand Down

0 comments on commit f11ccce

Please sign in to comment.