diff --git a/remotecache/flashgroupmanager/config.go b/remotecache/flashgroupmanager/config.go index 92a4cdd3a..18cea78dc 100644 --- a/remotecache/flashgroupmanager/config.go +++ b/remotecache/flashgroupmanager/config.go @@ -48,7 +48,7 @@ var AddrDatabase = make(map[uint64]string) type clusterConfig struct { cfsProto.RemoteCacheConfig - httpProxyPoolSize uint64 + httpProxyPoolSize int heartbeatPort int64 replicaPort int64 peerAddrs []string diff --git a/remotecache/flashgroupmanager/http_server.go b/remotecache/flashgroupmanager/http_server.go index 0f23d9c09..174802eb5 100644 --- a/remotecache/flashgroupmanager/http_server.go +++ b/remotecache/flashgroupmanager/http_server.go @@ -2,7 +2,6 @@ package flashgroupmanager import ( "fmt" - "math" "net/http" "net/http/httputil" "time" @@ -163,14 +162,8 @@ func (m *FlashGroupManager) registerAPIMiddleware(route *mux.Router) { func (m *FlashGroupManager) newReverseProxy() *httputil.ReverseProxy { tr := &http.Transport{} if m.config != nil { - ps := m.config.httpProxyPoolSize // uint64 - if ps > uint64(math.MaxInt) { - log.LogErrorf("newReverseProxy httpProxyPoolSize[%d] invalid", ps) - return nil - } - poolSize := int(ps) tr = proto.GetHttpTransporter(&proto.HttpCfg{ - PoolSize: poolSize, + PoolSize: m.config.httpProxyPoolSize, }) } diff --git a/remotecache/flashgroupmanager/server.go b/remotecache/flashgroupmanager/server.go index f35a402aa..54daf41d8 100644 --- a/remotecache/flashgroupmanager/server.go +++ b/remotecache/flashgroupmanager/server.go @@ -200,8 +200,7 @@ func (m *FlashGroupManager) checkConfig(cfg *config.Config) (err error) { if m.id, err = strconv.ParseUint(cfg.GetString(ID), 10, 64); err != nil { return fmt.Errorf("%v,err:%v", proto.ErrInvalidCfg, err.Error()) } - - m.config.httpProxyPoolSize = uint64(cfg.GetInt64(HttpReversePoolSize)) + m.config.httpProxyPoolSize = cfg.GetInt(HttpReversePoolSize) if m.config.httpProxyPoolSize < defaultHttpReversePoolSize { m.config.httpProxyPoolSize = defaultHttpReversePoolSize }