diff --git a/src/api/auth/user_register.go b/src/api/auth/user_register.go index a66858160..9fcca6dbc 100644 --- a/src/api/auth/user_register.go +++ b/src/api/auth/user_register.go @@ -42,6 +42,7 @@ func UserRegister(c *gin.Context) { log.Info("", "", "api user_register init ....") etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.RpcGetTokenName) client := pbAuth.NewAuthClient(etcdConn) + defer etcdConn.Close() params := paramsUserRegister{} if err := c.BindJSON(¶ms); err != nil { diff --git a/src/api/auth/user_token.go b/src/api/auth/user_token.go index 2e18145f7..f4bcfb6ac 100644 --- a/src/api/auth/user_token.go +++ b/src/api/auth/user_token.go @@ -29,6 +29,7 @@ func UserToken(c *gin.Context) { log.Info("", "", "api user_token init ....") etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.RpcGetTokenName) client := pbAuth.NewAuthClient(etcdConn) + defer etcdConn.Close() params := paramsUserToken{} if err := c.BindJSON(¶ms); err != nil { diff --git a/src/api/friend/add_blacklist.go b/src/api/friend/add_blacklist.go index 710174a42..cde3179ba 100644 --- a/src/api/friend/add_blacklist.go +++ b/src/api/friend/add_blacklist.go @@ -21,6 +21,7 @@ func AddBlacklist(c *gin.Context) { etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImFriendName) client := pbFriend.NewFriendClient(etcdConn) + defer etcdConn.Close() params := paramsSearchFriend{} if err := c.BindJSON(¶ms); err != nil { diff --git a/src/api/friend/add_friend.go b/src/api/friend/add_friend.go index 16b5577c1..23f2406a9 100644 --- a/src/api/friend/add_friend.go +++ b/src/api/friend/add_friend.go @@ -22,6 +22,7 @@ func AddFriend(c *gin.Context) { etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImFriendName) client := pbFriend.NewFriendClient(etcdConn) + defer etcdConn.Close() params := paramsAddFriend{} if err := c.BindJSON(¶ms); err != nil { diff --git a/src/api/friend/add_friend_response.go b/src/api/friend/add_friend_response.go index 045811016..92c77f51f 100644 --- a/src/api/friend/add_friend_response.go +++ b/src/api/friend/add_friend_response.go @@ -23,6 +23,7 @@ func AddFriendResponse(c *gin.Context) { etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImFriendName) client := pbFriend.NewFriendClient(etcdConn) + defer etcdConn.Close() params := paramsAddFriendResponse{} if err := c.BindJSON(¶ms); err != nil { diff --git a/src/api/friend/delete_friend.go b/src/api/friend/delete_friend.go index ad0451c72..5912aed59 100644 --- a/src/api/friend/delete_friend.go +++ b/src/api/friend/delete_friend.go @@ -22,6 +22,7 @@ func DeleteFriend(c *gin.Context) { etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImFriendName) client := pbFriend.NewFriendClient(etcdConn) + defer etcdConn.Close() params := paramsDeleteFriend{} if err := c.BindJSON(¶ms); err != nil { diff --git a/src/api/friend/get_blcaklist.go b/src/api/friend/get_blcaklist.go index 1cea8981d..417c1a1b3 100644 --- a/src/api/friend/get_blcaklist.go +++ b/src/api/friend/get_blcaklist.go @@ -32,6 +32,7 @@ func GetBlacklist(c *gin.Context) { etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImFriendName) client := pbFriend.NewFriendClient(etcdConn) + defer etcdConn.Close() params := paramsGetBlackList{} if err := c.BindJSON(¶ms); err != nil { diff --git a/src/api/friend/get_friend_apply_list.go b/src/api/friend/get_friend_apply_list.go index 63ac7bd23..d51d20c62 100644 --- a/src/api/friend/get_friend_apply_list.go +++ b/src/api/friend/get_friend_apply_list.go @@ -33,6 +33,7 @@ func GetFriendApplyList(c *gin.Context) { etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImFriendName) client := pbFriend.NewFriendClient(etcdConn) + defer etcdConn.Close() params := paramsGetFriendApplyList{} if err := c.BindJSON(¶ms); err != nil { diff --git a/src/api/friend/get_friend_list.go b/src/api/friend/get_friend_list.go index ed3c67218..2af10a39f 100644 --- a/src/api/friend/get_friend_list.go +++ b/src/api/friend/get_friend_list.go @@ -34,6 +34,7 @@ func GetFriendList(c *gin.Context) { etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImFriendName) client := pbFriend.NewFriendClient(etcdConn) + defer etcdConn.Close() params := paramsGetFriendLIst{} if err := c.BindJSON(¶ms); err != nil { diff --git a/src/api/friend/remove_blacklist.go b/src/api/friend/remove_blacklist.go index 4b76724c3..8b5b423ea 100644 --- a/src/api/friend/remove_blacklist.go +++ b/src/api/friend/remove_blacklist.go @@ -21,6 +21,7 @@ func RemoveBlacklist(c *gin.Context) { etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImFriendName) client := pbFriend.NewFriendClient(etcdConn) + defer etcdConn.Close() params := paramsRemoveBlackList{} if err := c.BindJSON(¶ms); err != nil { diff --git a/src/api/friend/search_friend.go b/src/api/friend/search_friend.go index 3bddcc582..80e1c561c 100644 --- a/src/api/friend/search_friend.go +++ b/src/api/friend/search_friend.go @@ -21,6 +21,7 @@ func SearchFriend(c *gin.Context) { log.Info("", "", fmt.Sprintf("api search friend init ....")) etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImFriendName) client := pbFriend.NewFriendClient(etcdConn) + defer etcdConn.Close() params := paramsSearchFriend{} if err := c.BindJSON(¶ms); err != nil { diff --git a/src/api/friend/set_friend_comment.go b/src/api/friend/set_friend_comment.go index 55928ee58..6323e2662 100644 --- a/src/api/friend/set_friend_comment.go +++ b/src/api/friend/set_friend_comment.go @@ -22,6 +22,7 @@ func SetFriendComment(c *gin.Context) { etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImFriendName) client := pbFriend.NewFriendClient(etcdConn) + defer etcdConn.Close() params := paramsSetFriendComment{} if err := c.BindJSON(¶ms); err != nil { diff --git a/src/api/user/get_user_info.go b/src/api/user/get_user_info.go index e1c79ac33..bce511d14 100644 --- a/src/api/user/get_user_info.go +++ b/src/api/user/get_user_info.go @@ -27,6 +27,7 @@ func GetUserInfo(c *gin.Context) { etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImUserName) client := pbUser.NewUserClient(etcdConn) + defer etcdConn.Close() params := paramsStruct{} if err := c.BindJSON(¶ms); err != nil { diff --git a/src/api/user/update_user_info.go b/src/api/user/update_user_info.go index d3e2e5d6b..6cf633850 100644 --- a/src/api/user/update_user_info.go +++ b/src/api/user/update_user_info.go @@ -29,6 +29,7 @@ func UpdateUserInfo(c *gin.Context) { etcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImUserName) client := pbUser.NewUserClient(etcdConn) + defer etcdConn.Close() params := paramsStruct{} if err := c.BindJSON(¶ms); err != nil {