From bb43d3a78c7561769e1ba2f8a7208fa3c81ef634 Mon Sep 17 00:00:00 2001 From: youngsterxyf Date: Fri, 8 Jan 2016 13:47:14 +0800 Subject: [PATCH 1/4] fix #1530 --- cache/README.md | 2 +- cache/cache.go | 7 ++++--- cache/cache_test.go | 16 +++++++++------- cache/file.go | 18 +++++++++--------- cache/memcache/memcache.go | 5 +++-- cache/memcache/memcache_test.go | 9 +++++---- cache/memory.go | 12 ++++-------- cache/redis/redis.go | 4 ++-- cache/redis/redis_test.go | 9 +++++---- 9 files changed, 42 insertions(+), 40 deletions(-) diff --git a/cache/README.md b/cache/README.md index 4152c57e..c8cb7454 100644 --- a/cache/README.md +++ b/cache/README.md @@ -26,7 +26,7 @@ Then init a Cache (example with memory adapter) Use it like this: - bm.Put("astaxie", 1, 10) + bm.Put("astaxie", 1, time.Second * 10) bm.Get("astaxie") bm.IsExist("astaxie") bm.Delete("astaxie") diff --git a/cache/cache.go b/cache/cache.go index c9904444..78643aea 100644 --- a/cache/cache.go +++ b/cache/cache.go @@ -23,7 +23,7 @@ // // Use it like this: // -// bm.Put("astaxie", 1, 10) +// bm.Put("astaxie", 1, time.Second * 10) // bm.Get("astaxie") // bm.IsExist("astaxie") // bm.Delete("astaxie") @@ -33,13 +33,14 @@ package cache import ( "fmt" + "time" ) // Cache interface contains all behaviors for cache adapter. // usage: // cache.Register("file",cache.NewFileCache) // this operation is run in init method of file.go. // c,err := cache.NewCache("file","{....}") -// c.Put("key",value,3600) +// c.Put("key",value, time.Second * 3600) // v := c.Get("key") // // c.Incr("counter") // now is 1 @@ -51,7 +52,7 @@ type Cache interface { // GetMulti is a batch version of Get. GetMulti(keys []string) []interface{} // set cached value with key and expire time. - Put(key string, val interface{}, timeout int64) error + Put(key string, val interface{}, timeout time.Duration) error // delete cached value by key. Delete(key string) error // increase cached int value by key, as a counter. diff --git a/cache/cache_test.go b/cache/cache_test.go index 481309fd..73e593e9 100644 --- a/cache/cache_test.go +++ b/cache/cache_test.go @@ -25,7 +25,8 @@ func TestCache(t *testing.T) { if err != nil { t.Error("init err") } - if err = bm.Put("astaxie", 1, 10); err != nil { + timeoutDuration := time.Second * 10 + if err = bm.Put("astaxie", 1, timeoutDuration); err != nil { t.Error("set Error", err) } if !bm.IsExist("astaxie") { @@ -42,7 +43,7 @@ func TestCache(t *testing.T) { t.Error("check err") } - if err = bm.Put("astaxie", 1, 10); err != nil { + if err = bm.Put("astaxie", 1, timeoutDuration); err != nil { t.Error("set Error", err) } @@ -67,7 +68,7 @@ func TestCache(t *testing.T) { } //test GetMulti - if err = bm.Put("astaxie", "author", 10); err != nil { + if err = bm.Put("astaxie", "author", timeoutDuration); err != nil { t.Error("set Error", err) } if !bm.IsExist("astaxie") { @@ -77,7 +78,7 @@ func TestCache(t *testing.T) { t.Error("get err") } - if err = bm.Put("astaxie1", "author1", 10); err != nil { + if err = bm.Put("astaxie1", "author1", timeoutDuration); err != nil { t.Error("set Error", err) } if !bm.IsExist("astaxie1") { @@ -101,7 +102,8 @@ func TestFileCache(t *testing.T) { if err != nil { t.Error("init err") } - if err = bm.Put("astaxie", 1, 10); err != nil { + timeoutDuration := time.Second * 10 + if err = bm.Put("astaxie", 1, timeoutDuration); err != nil { t.Error("set Error", err) } if !bm.IsExist("astaxie") { @@ -133,7 +135,7 @@ func TestFileCache(t *testing.T) { } //test string - if err = bm.Put("astaxie", "author", 10); err != nil { + if err = bm.Put("astaxie", "author", timeoutDuration); err != nil { t.Error("set Error", err) } if !bm.IsExist("astaxie") { @@ -144,7 +146,7 @@ func TestFileCache(t *testing.T) { } //test GetMulti - if err = bm.Put("astaxie1", "author1", 10); err != nil { + if err = bm.Put("astaxie1", "author1", timeoutDuration); err != nil { t.Error("set Error", err) } if !bm.IsExist("astaxie1") { diff --git a/cache/file.go b/cache/file.go index 2d77b567..80f93bce 100644 --- a/cache/file.go +++ b/cache/file.go @@ -33,8 +33,8 @@ import ( // it contains data and expire time. type FileCacheItem struct { Data interface{} - Lastaccess int64 - Expired int64 + Lastaccess time.Time + Expired time.Time } // FileCache Config @@ -42,7 +42,7 @@ var ( FileCachePath = "cache" // cache directory FileCacheFileSuffix = ".bin" // cache file suffix FileCacheDirectoryLevel = 2 // cache file deep level if auto generated cache files. - FileCacheEmbedExpiry int64 // cache expire time, default is no expire forever. + FileCacheEmbedExpiry time.Duration = 0 // cache expire time, default is no expire forever. ) // FileCache is cache adapter for file storage. @@ -76,7 +76,7 @@ func (fc *FileCache) StartAndGC(config string) error { cfg["DirectoryLevel"] = strconv.Itoa(FileCacheDirectoryLevel) } if _, ok := cfg["EmbedExpiry"]; !ok { - cfg["EmbedExpiry"] = strconv.FormatInt(FileCacheEmbedExpiry, 10) + cfg["EmbedExpiry"] = strconv.FormatInt(int64(FileCacheEmbedExpiry.Seconds()), 10) } fc.CachePath = cfg["CachePath"] fc.FileSuffix = cfg["FileSuffix"] @@ -123,7 +123,7 @@ func (fc *FileCache) Get(key string) interface{} { } var to FileCacheItem GobDecode(fileData, &to) - if to.Expired < time.Now().Unix() { + if to.Expired.Before(time.Now()) { return "" } return to.Data @@ -142,16 +142,16 @@ func (fc *FileCache) GetMulti(keys []string) []interface{} { // Put value into file cache. // timeout means how long to keep this file, unit of ms. // if timeout equals FileCacheEmbedExpiry(default is 0), cache this item forever. -func (fc *FileCache) Put(key string, val interface{}, timeout int64) error { +func (fc *FileCache) Put(key string, val interface{}, timeout time.Duration) error { gob.Register(val) item := FileCacheItem{Data: val} if timeout == FileCacheEmbedExpiry { - item.Expired = time.Now().Unix() + (86400 * 365 * 10) // ten years + item.Expired = time.Now().Add(time.Second * (86400 * 365 * 10)) // ten years } else { - item.Expired = time.Now().Unix() + timeout + item.Expired = time.Now().Add(timeout) } - item.Lastaccess = time.Now().Unix() + item.Lastaccess = time.Now() data, err := GobEncode(item) if err != nil { return err diff --git a/cache/memcache/memcache.go b/cache/memcache/memcache.go index 272124da..ea77be38 100644 --- a/cache/memcache/memcache.go +++ b/cache/memcache/memcache.go @@ -37,6 +37,7 @@ import ( "github.com/bradfitz/gomemcache/memcache" "github.com/astaxie/beego/cache" + "time" ) // Cache Memcache adapter. @@ -89,7 +90,7 @@ func (rc *Cache) GetMulti(keys []string) []interface{} { } // Put put value to memcache. only support string. -func (rc *Cache) Put(key string, val interface{}, timeout int64) error { +func (rc *Cache) Put(key string, val interface{}, timeout time.Duration) error { if rc.conn == nil { if err := rc.connectInit(); err != nil { return err @@ -99,7 +100,7 @@ func (rc *Cache) Put(key string, val interface{}, timeout int64) error { if !ok { return errors.New("val must string") } - item := memcache.Item{Key: key, Value: []byte(v), Expiration: int32(timeout)} + item := memcache.Item{Key: key, Value: []byte(v), Expiration: int32(timeout.Seconds())} return rc.conn.Set(&item) } diff --git a/cache/memcache/memcache_test.go b/cache/memcache/memcache_test.go index 27b085e6..93484f6b 100644 --- a/cache/memcache/memcache_test.go +++ b/cache/memcache/memcache_test.go @@ -28,7 +28,8 @@ func TestMemcacheCache(t *testing.T) { if err != nil { t.Error("init err") } - if err = bm.Put("astaxie", "1", 10); err != nil { + timeoutDuration := time.Second * 10 + if err = bm.Put("astaxie", "1", timeoutDuration); err != nil { t.Error("set Error", err) } if !bm.IsExist("astaxie") { @@ -40,7 +41,7 @@ func TestMemcacheCache(t *testing.T) { if bm.IsExist("astaxie") { t.Error("check err") } - if err = bm.Put("astaxie", "1", 10); err != nil { + if err = bm.Put("astaxie", "1", timeoutDuration); err != nil { t.Error("set Error", err) } @@ -69,7 +70,7 @@ func TestMemcacheCache(t *testing.T) { } //test string - if err = bm.Put("astaxie", "author", 10); err != nil { + if err = bm.Put("astaxie", "author", timeoutDuration); err != nil { t.Error("set Error", err) } if !bm.IsExist("astaxie") { @@ -81,7 +82,7 @@ func TestMemcacheCache(t *testing.T) { } //test GetMulti - if err = bm.Put("astaxie1", "author1", 10); err != nil { + if err = bm.Put("astaxie1", "author1", timeoutDuration); err != nil { t.Error("set Error", err) } if !bm.IsExist("astaxie1") { diff --git a/cache/memory.go b/cache/memory.go index f8cccb14..5ba11b3c 100644 --- a/cache/memory.go +++ b/cache/memory.go @@ -17,7 +17,6 @@ package cache import ( "encoding/json" "errors" - "fmt" "sync" "time" ) @@ -31,7 +30,7 @@ var ( type MemoryItem struct { val interface{} createdTime time.Time - lifespan int64 + lifespan time.Duration } func (mi *MemoryItem) isExpire() bool { @@ -39,7 +38,7 @@ func (mi *MemoryItem) isExpire() bool { if mi.lifespan == 0 { return false } - return time.Now().Unix()-mi.createdTime.Unix() > mi.lifespan + return time.Now().Sub(mi.createdTime) > mi.lifespan } // MemoryCache is Memory cache adapter. @@ -83,7 +82,7 @@ func (bc *MemoryCache) GetMulti(names []string) []interface{} { // Put cache to memory. // if lifespan is 0, it will be forever till restart. -func (bc *MemoryCache) Put(name string, value interface{}, lifespan int64) error { +func (bc *MemoryCache) Put(name string, value interface{}, lifespan time.Duration) error { bc.Lock() defer bc.Unlock() bc.items[name] = &MemoryItem{ @@ -201,10 +200,7 @@ func (bc *MemoryCache) StartAndGC(config string) error { cf = make(map[string]int) cf["interval"] = DefaultEvery } - dur, err := time.ParseDuration(fmt.Sprintf("%ds", cf["interval"])) - if err != nil { - return err - } + dur := time.Second * time.Duration(cf["interval"]) bc.Every = cf["interval"] bc.dur = dur go bc.vaccuum() diff --git a/cache/redis/redis.go b/cache/redis/redis.go index 60c1702a..316cb423 100644 --- a/cache/redis/redis.go +++ b/cache/redis/redis.go @@ -109,9 +109,9 @@ ERROR: } // Put put cache to redis. -func (rc *Cache) Put(key string, val interface{}, timeout int64) error { +func (rc *Cache) Put(key string, val interface{}, timeout time.Duration) error { var err error - if _, err = rc.do("SETEX", key, timeout, val); err != nil { + if _, err = rc.do("SETEX", key, int64(timeout.Seconds()), val); err != nil { return err } diff --git a/cache/redis/redis_test.go b/cache/redis/redis_test.go index 1f74fd27..22059508 100644 --- a/cache/redis/redis_test.go +++ b/cache/redis/redis_test.go @@ -28,7 +28,8 @@ func TestRedisCache(t *testing.T) { if err != nil { t.Error("init err") } - if err = bm.Put("astaxie", 1, 10); err != nil { + timeoutDuration := time.Second * 10 + if err = bm.Put("astaxie", 1, timeoutDuration); err != nil { t.Error("set Error", err) } if !bm.IsExist("astaxie") { @@ -40,7 +41,7 @@ func TestRedisCache(t *testing.T) { if bm.IsExist("astaxie") { t.Error("check err") } - if err = bm.Put("astaxie", 1, 10); err != nil { + if err = bm.Put("astaxie", 1, timeoutDuration); err != nil { t.Error("set Error", err) } @@ -69,7 +70,7 @@ func TestRedisCache(t *testing.T) { } //test string - if err = bm.Put("astaxie", "author", 10); err != nil { + if err = bm.Put("astaxie", "author", timeoutDuration); err != nil { t.Error("set Error", err) } if !bm.IsExist("astaxie") { @@ -81,7 +82,7 @@ func TestRedisCache(t *testing.T) { } //test GetMulti - if err = bm.Put("astaxie1", "author1", 10); err != nil { + if err = bm.Put("astaxie1", "author1", timeoutDuration); err != nil { t.Error("set Error", err) } if !bm.IsExist("astaxie1") { From 0b0904db131236e42e38f61aab35960d08bee020 Mon Sep 17 00:00:00 2001 From: youngsterxyf Date: Fri, 8 Jan 2016 20:16:58 +0800 Subject: [PATCH 2/4] for issue #1530, accept @JessonChan's suggestion --- cache/README.md | 2 +- cache/cache.go | 4 ++-- cache/cache_test.go | 4 ++-- cache/file.go | 2 +- cache/memcache/memcache.go | 2 +- cache/memcache/memcache_test.go | 2 +- cache/memory.go | 2 +- cache/redis/redis.go | 2 +- cache/redis/redis_test.go | 2 +- 9 files changed, 11 insertions(+), 11 deletions(-) diff --git a/cache/README.md b/cache/README.md index c8cb7454..957790e7 100644 --- a/cache/README.md +++ b/cache/README.md @@ -26,7 +26,7 @@ Then init a Cache (example with memory adapter) Use it like this: - bm.Put("astaxie", 1, time.Second * 10) + bm.Put("astaxie", 1, 10 * time.Second) bm.Get("astaxie") bm.IsExist("astaxie") bm.Delete("astaxie") diff --git a/cache/cache.go b/cache/cache.go index 78643aea..2008402e 100644 --- a/cache/cache.go +++ b/cache/cache.go @@ -23,7 +23,7 @@ // // Use it like this: // -// bm.Put("astaxie", 1, time.Second * 10) +// bm.Put("astaxie", 1, 10 * time.Second) // bm.Get("astaxie") // bm.IsExist("astaxie") // bm.Delete("astaxie") @@ -40,7 +40,7 @@ import ( // usage: // cache.Register("file",cache.NewFileCache) // this operation is run in init method of file.go. // c,err := cache.NewCache("file","{....}") -// c.Put("key",value, time.Second * 3600) +// c.Put("key",value, 3600 * time.Second) // v := c.Get("key") // // c.Incr("counter") // now is 1 diff --git a/cache/cache_test.go b/cache/cache_test.go index 73e593e9..9ceb606a 100644 --- a/cache/cache_test.go +++ b/cache/cache_test.go @@ -25,7 +25,7 @@ func TestCache(t *testing.T) { if err != nil { t.Error("init err") } - timeoutDuration := time.Second * 10 + timeoutDuration := 10 * time.Second if err = bm.Put("astaxie", 1, timeoutDuration); err != nil { t.Error("set Error", err) } @@ -102,7 +102,7 @@ func TestFileCache(t *testing.T) { if err != nil { t.Error("init err") } - timeoutDuration := time.Second * 10 + timeoutDuration := 10 * time.Second if err = bm.Put("astaxie", 1, timeoutDuration); err != nil { t.Error("set Error", err) } diff --git a/cache/file.go b/cache/file.go index 80f93bce..3a7aa8b0 100644 --- a/cache/file.go +++ b/cache/file.go @@ -147,7 +147,7 @@ func (fc *FileCache) Put(key string, val interface{}, timeout time.Duration) err item := FileCacheItem{Data: val} if timeout == FileCacheEmbedExpiry { - item.Expired = time.Now().Add(time.Second * (86400 * 365 * 10)) // ten years + item.Expired = time.Now().Add((86400 * 365 * 10) * time.Second) // ten years } else { item.Expired = time.Now().Add(timeout) } diff --git a/cache/memcache/memcache.go b/cache/memcache/memcache.go index ea77be38..15ea5d3e 100644 --- a/cache/memcache/memcache.go +++ b/cache/memcache/memcache.go @@ -100,7 +100,7 @@ func (rc *Cache) Put(key string, val interface{}, timeout time.Duration) error { if !ok { return errors.New("val must string") } - item := memcache.Item{Key: key, Value: []byte(v), Expiration: int32(timeout.Seconds())} + item := memcache.Item{Key: key, Value: []byte(v), Expiration: int32(timeout/time.Second)} return rc.conn.Set(&item) } diff --git a/cache/memcache/memcache_test.go b/cache/memcache/memcache_test.go index 93484f6b..19629059 100644 --- a/cache/memcache/memcache_test.go +++ b/cache/memcache/memcache_test.go @@ -28,7 +28,7 @@ func TestMemcacheCache(t *testing.T) { if err != nil { t.Error("init err") } - timeoutDuration := time.Second * 10 + timeoutDuration := 10 * time.Second if err = bm.Put("astaxie", "1", timeoutDuration); err != nil { t.Error("set Error", err) } diff --git a/cache/memory.go b/cache/memory.go index 5ba11b3c..d928afdb 100644 --- a/cache/memory.go +++ b/cache/memory.go @@ -200,7 +200,7 @@ func (bc *MemoryCache) StartAndGC(config string) error { cf = make(map[string]int) cf["interval"] = DefaultEvery } - dur := time.Second * time.Duration(cf["interval"]) + dur := time.Duration(cf["interval"]) * time.Second bc.Every = cf["interval"] bc.dur = dur go bc.vaccuum() diff --git a/cache/redis/redis.go b/cache/redis/redis.go index 316cb423..781e3836 100644 --- a/cache/redis/redis.go +++ b/cache/redis/redis.go @@ -111,7 +111,7 @@ ERROR: // Put put cache to redis. func (rc *Cache) Put(key string, val interface{}, timeout time.Duration) error { var err error - if _, err = rc.do("SETEX", key, int64(timeout.Seconds()), val); err != nil { + if _, err = rc.do("SETEX", key, int64(timeout/time.Second), val); err != nil { return err } diff --git a/cache/redis/redis_test.go b/cache/redis/redis_test.go index 22059508..e51e409b 100644 --- a/cache/redis/redis_test.go +++ b/cache/redis/redis_test.go @@ -28,7 +28,7 @@ func TestRedisCache(t *testing.T) { if err != nil { t.Error("init err") } - timeoutDuration := time.Second * 10 + timeoutDuration := 10 * time.Second if err = bm.Put("astaxie", 1, timeoutDuration); err != nil { t.Error("set Error", err) } From 0c4873884184eac6a135e44b86dd4985df4076c7 Mon Sep 17 00:00:00 2001 From: youngsterxyf Date: Fri, 8 Jan 2016 21:29:12 +0800 Subject: [PATCH 3/4] for issue #1530, fix incompatible bug --- utils/captcha/captcha.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/utils/captcha/captcha.go b/utils/captcha/captcha.go index 76301a03..4ac5c9f9 100644 --- a/utils/captcha/captcha.go +++ b/utils/captcha/captcha.go @@ -64,6 +64,7 @@ import ( "net/http" "path" "strings" + "time" "github.com/astaxie/beego" "github.com/astaxie/beego/cache" @@ -78,7 +79,7 @@ var ( const ( // default captcha attributes challengeNums = 6 - expiration = 600 + expiration = 600 * time.Second fieldIDName = "captcha_id" fieldCaptchaName = "captcha" cachePrefix = "captcha_" @@ -106,7 +107,7 @@ type Captcha struct { ChallengeNums int // captcha expiration seconds - Expiration int64 + Expiration time.Duration // cache key prefix CachePrefix string From 6660720ce6dd1f09a21d58e87a509330f3367edf Mon Sep 17 00:00:00 2001 From: astaxie Date: Tue, 12 Jan 2016 21:55:02 +0800 Subject: [PATCH 4/4] update some config name --- admin.go | 6 +++--- app.go | 8 ++++---- config.go | 30 +++++++++++++++--------------- hooks.go | 4 ++-- router.go | 4 ++-- 5 files changed, 26 insertions(+), 26 deletions(-) diff --git a/admin.go b/admin.go index d143c212..0b45cf8a 100644 --- a/admin.go +++ b/admin.go @@ -104,15 +104,15 @@ func listConf(rw http.ResponseWriter, r *http.Request) { m["BConfig.Listen.Graceful"] = BConfig.Listen.Graceful m["BConfig.Listen.ServerTimeOut"] = BConfig.Listen.ServerTimeOut m["BConfig.Listen.ListenTCP4"] = BConfig.Listen.ListenTCP4 - m["BConfig.Listen.HTTPEnable"] = BConfig.Listen.HTTPEnable + m["BConfig.Listen.EnableHTTP"] = BConfig.Listen.EnableHTTP m["BConfig.Listen.HTTPAddr"] = BConfig.Listen.HTTPAddr m["BConfig.Listen.HTTPPort"] = BConfig.Listen.HTTPPort - m["BConfig.Listen.HTTPSEnable"] = BConfig.Listen.HTTPSEnable + m["BConfig.Listen.EnableHTTPS"] = BConfig.Listen.EnableHTTPS m["BConfig.Listen.HTTPSAddr"] = BConfig.Listen.HTTPSAddr m["BConfig.Listen.HTTPSPort"] = BConfig.Listen.HTTPSPort m["BConfig.Listen.HTTPSCertFile"] = BConfig.Listen.HTTPSCertFile m["BConfig.Listen.HTTPSKeyFile"] = BConfig.Listen.HTTPSKeyFile - m["BConfig.Listen.AdminEnable"] = BConfig.Listen.AdminEnable + m["BConfig.Listen.EnableAdmin"] = BConfig.Listen.EnableAdmin m["BConfig.Listen.AdminAddr"] = BConfig.Listen.AdminAddr m["BConfig.Listen.AdminPort"] = BConfig.Listen.AdminPort m["BConfig.Listen.EnableFcgi"] = BConfig.Listen.EnableFcgi diff --git a/app.go b/app.go index 548bff66..af54ea4b 100644 --- a/app.go +++ b/app.go @@ -100,7 +100,7 @@ func (app *App) Run() { if BConfig.Listen.Graceful { httpsAddr := BConfig.Listen.HTTPSAddr app.Server.Addr = httpsAddr - if BConfig.Listen.HTTPSEnable { + if BConfig.Listen.EnableHTTPS { go func() { time.Sleep(20 * time.Microsecond) if BConfig.Listen.HTTPSPort != 0 { @@ -117,7 +117,7 @@ func (app *App) Run() { } }() } - if BConfig.Listen.HTTPEnable { + if BConfig.Listen.EnableHTTP { go func() { server := grace.NewServer(addr, app.Handlers) server.Server.ReadTimeout = app.Server.ReadTimeout @@ -138,7 +138,7 @@ func (app *App) Run() { // run normal mode app.Server.Addr = addr - if BConfig.Listen.HTTPSEnable { + if BConfig.Listen.EnableHTTPS { go func() { time.Sleep(20 * time.Microsecond) if BConfig.Listen.HTTPSPort != 0 { @@ -152,7 +152,7 @@ func (app *App) Run() { } }() } - if BConfig.Listen.HTTPEnable { + if BConfig.Listen.EnableHTTP { go func() { app.Server.Addr = addr BeeLogger.Info("http server Running on %s", app.Server.Addr) diff --git a/config.go b/config.go index a5229c85..66702872 100644 --- a/config.go +++ b/config.go @@ -44,15 +44,15 @@ type Listen struct { Graceful bool // Graceful means use graceful module to start the server ServerTimeOut int64 ListenTCP4 bool - HTTPEnable bool + EnableHTTP bool HTTPAddr string HTTPPort int - HTTPSEnable bool + EnableHTTPS bool HTTPSAddr string HTTPSPort int HTTPSCertFile string HTTPSKeyFile string - AdminEnable bool + EnableAdmin bool AdminAddr string AdminPort int EnableFcgi bool @@ -123,15 +123,15 @@ func init() { Graceful: false, ServerTimeOut: 0, ListenTCP4: false, - HTTPEnable: true, + EnableHTTP: true, HTTPAddr: "", HTTPPort: 8080, - HTTPSEnable: false, + EnableHTTPS: false, HTTPSAddr: "", HTTPSPort: 10443, HTTPSCertFile: "", HTTPSKeyFile: "", - AdminEnable: false, + EnableAdmin: false, AdminAddr: "", AdminPort: 8088, EnableFcgi: false, @@ -196,7 +196,7 @@ func ParseConfig() (err error) { BConfig.AppName = AppConfig.DefaultString("AppName", BConfig.AppName) BConfig.RecoverPanic = AppConfig.DefaultBool("RecoverPanic", BConfig.RecoverPanic) BConfig.RouterCaseSensitive = AppConfig.DefaultBool("RouterCaseSensitive", BConfig.RouterCaseSensitive) - BConfig.ServerName = AppConfig.DefaultString("BeegoServerName", BConfig.ServerName) + BConfig.ServerName = AppConfig.DefaultString("ServerName", BConfig.ServerName) BConfig.EnableGzip = AppConfig.DefaultBool("EnableGzip", BConfig.EnableGzip) BConfig.EnableErrorsShow = AppConfig.DefaultBool("EnableErrorsShow", BConfig.EnableErrorsShow) BConfig.CopyRequestBody = AppConfig.DefaultBool("CopyRequestBody", BConfig.CopyRequestBody) @@ -205,18 +205,18 @@ func ParseConfig() (err error) { BConfig.Listen.HTTPAddr = AppConfig.String("HTTPAddr") BConfig.Listen.HTTPPort = AppConfig.DefaultInt("HTTPPort", BConfig.Listen.HTTPPort) BConfig.Listen.ListenTCP4 = AppConfig.DefaultBool("ListenTCP4", BConfig.Listen.ListenTCP4) - BConfig.Listen.HTTPEnable = AppConfig.DefaultBool("EnableHTTPListen", BConfig.Listen.HTTPEnable) - BConfig.Listen.HTTPSEnable = AppConfig.DefaultBool("EnableHTTPTLS", BConfig.Listen.HTTPSEnable) + BConfig.Listen.EnableHTTP = AppConfig.DefaultBool("EnableHTTP", BConfig.Listen.EnableHTTP) + BConfig.Listen.EnableHTTPS = AppConfig.DefaultBool("EnableHTTPS", BConfig.Listen.EnableHTTPS) BConfig.Listen.HTTPSAddr = AppConfig.DefaultString("HTTPSAddr", BConfig.Listen.HTTPSAddr) BConfig.Listen.HTTPSPort = AppConfig.DefaultInt("HTTPSPort", BConfig.Listen.HTTPSPort) - BConfig.Listen.HTTPSCertFile = AppConfig.DefaultString("HTTPCertFile", BConfig.Listen.HTTPSCertFile) - BConfig.Listen.HTTPSKeyFile = AppConfig.DefaultString("HTTPKeyFile", BConfig.Listen.HTTPSKeyFile) - BConfig.Listen.AdminEnable = AppConfig.DefaultBool("EnableAdmin", BConfig.Listen.AdminEnable) - BConfig.Listen.AdminAddr = AppConfig.DefaultString("AdminHTTPAddr", BConfig.Listen.AdminAddr) - BConfig.Listen.AdminPort = AppConfig.DefaultInt("AdminHTTPPort", BConfig.Listen.AdminPort) + BConfig.Listen.HTTPSCertFile = AppConfig.DefaultString("HTTPSCertFile", BConfig.Listen.HTTPSCertFile) + BConfig.Listen.HTTPSKeyFile = AppConfig.DefaultString("HTTPSKeyFile", BConfig.Listen.HTTPSKeyFile) + BConfig.Listen.EnableAdmin = AppConfig.DefaultBool("EnableAdmin", BConfig.Listen.EnableAdmin) + BConfig.Listen.AdminAddr = AppConfig.DefaultString("AdminAddr", BConfig.Listen.AdminAddr) + BConfig.Listen.AdminPort = AppConfig.DefaultInt("AdminPort", BConfig.Listen.AdminPort) BConfig.Listen.EnableFcgi = AppConfig.DefaultBool("EnableFcgi", BConfig.Listen.EnableFcgi) BConfig.Listen.EnableStdIo = AppConfig.DefaultBool("EnableStdIo", BConfig.Listen.EnableStdIo) - BConfig.Listen.ServerTimeOut = AppConfig.DefaultInt64("HTTPServerTimeOut", BConfig.Listen.ServerTimeOut) + BConfig.Listen.ServerTimeOut = AppConfig.DefaultInt64("ServerTimeOut", BConfig.Listen.ServerTimeOut) BConfig.WebConfig.AutoRender = AppConfig.DefaultBool("AutoRender", BConfig.WebConfig.AutoRender) BConfig.WebConfig.ViewsPath = AppConfig.DefaultString("ViewsPath", BConfig.WebConfig.ViewsPath) BConfig.WebConfig.DirectoryIndex = AppConfig.DefaultBool("DirectoryIndex", BConfig.WebConfig.DirectoryIndex) diff --git a/hooks.go b/hooks.go index 53b298a0..78abf8ef 100644 --- a/hooks.go +++ b/hooks.go @@ -48,7 +48,7 @@ func registerSession() error { "cookieName": BConfig.WebConfig.Session.SessionName, "gclifetime": BConfig.WebConfig.Session.SessionGCMaxLifetime, "providerConfig": filepath.ToSlash(BConfig.WebConfig.Session.SessionProviderConfig), - "secure": BConfig.Listen.HTTPSEnable, + "secure": BConfig.Listen.EnableHTTPS, "enableSetCookie": BConfig.WebConfig.Session.SessionAutoSetCookie, "domain": BConfig.WebConfig.Session.SessionDomain, "cookieLifeTime": BConfig.WebConfig.Session.SessionCookieLifeTime, @@ -88,7 +88,7 @@ func registerDocs() error { } func registerAdmin() error { - if BConfig.Listen.AdminEnable { + if BConfig.Listen.EnableAdmin { go beeAdminApp.Run() } return nil diff --git a/router.go b/router.go index 671b6151..9d8cd2e6 100644 --- a/router.go +++ b/router.go @@ -609,7 +609,7 @@ func (p *ControllerRegister) ServeHTTP(rw http.ResponseWriter, r *http.Request) defer p.pool.Put(context) defer p.recoverPanic(context) - context.Output.EnableGzip=BConfig.EnableGzip + context.Output.EnableGzip = BConfig.EnableGzip if BConfig.RunMode == DEV { context.Output.Header("Server", BConfig.ServerName) @@ -800,7 +800,7 @@ func (p *ControllerRegister) ServeHTTP(rw http.ResponseWriter, r *http.Request) Admin: timeDur := time.Since(startTime) //admin module record QPS - if BConfig.Listen.AdminEnable { + if BConfig.Listen.EnableAdmin { if FilterMonitorFunc(r.Method, r.URL.Path, timeDur) { if runRouter != nil { go toolbox.StatisticsMap.AddStatistics(r.Method, r.URL.Path, runRouter.Name(), timeDur)