Refactor session close as xorm already does everything needed internally (#2020)

diff --git a/models/attachment.go b/models/attachment.go
index d800a47109da7b627d3c195f1d137186143d4794..3b3521bf60364e6191fe3c6fe06cedceb7b2cf57 100644 (file)
--- a/models/attachment.go
+++ b/models/attachment.go
@@ -48,7 +48,7 @@ func (a *Attachment) AfterSet(colName string, _ xorm.Cell) {
 // IncreaseDownloadCount is update download count + 1
 func (a *Attachment) IncreaseDownloadCount() error {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
 
        // Update download count.
        if _, err := sess.Exec("UPDATE `attachment` SET download_count=download_count+1 WHERE id=?", a.ID); err != nil {

diff --git a/models/branches.go b/models/branches.go
index a71c0e96222705e8d5161ac9e3d3e55d0082ab0e..6115f9c687f74ffdf5553d3537f37b7846348f80 100644 (file)
--- a/models/branches.go
+++ b/models/branches.go
@@ -95,7 +95,7 @@ func (repo *Repository) AddProtectedBranch(branchName string, canPush bool) erro
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -126,7 +126,7 @@ func (repo *Repository) ChangeProtectedBranch(id int64, canPush bool) error {
        ProtectedBranch.CanPush = canPush
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -146,7 +146,7 @@ func (repo *Repository) DeleteProtectedBranch(id int64) (err error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/gpg_key.go b/models/gpg_key.go
index 5763ef840383f4b79ae2909a21c267a0baf4ee5b..d39cc54ce607b3bfb258498be6a50ca4da548807 100644 (file)
--- a/models/gpg_key.go
+++ b/models/gpg_key.go
@@ -127,7 +127,7 @@ func AddGPGKey(ownerID int64, content string) (*GPGKey, error) {
 
        //Get DB session
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return nil, err
        }
@@ -267,7 +267,7 @@ func DeleteGPGKey(doer *User, id int64) (err error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/issue.go b/models/issue.go
index d4d0a5a2ffef26a9930053d2122d0064bcfb4a59..b5553b7c82dc350493f5255808aa64ad3a5ca49a 100644 (file)
--- a/models/issue.go
+++ b/models/issue.go
@@ -406,7 +406,7 @@ func (issue *Issue) clearLabels(e *xorm.Session, doer *User) (err error) {
 // Triggers appropriate WebHooks, if any.
 func (issue *Issue) ClearLabels(doer *User) (err error) {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -470,7 +470,7 @@ func (ts labelSorter) Swap(i, j int) {
 // Triggers appropriate WebHooks, if any.
 func (issue *Issue) ReplaceLabels(labels []*Label, doer *User) (err error) {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -598,7 +598,7 @@ func (issue *Issue) changeStatus(e *xorm.Session, doer *User, repo *Repository,
 // ChangeStatus changes issue status to open or closed.
 func (issue *Issue) ChangeStatus(doer *User, repo *Repository, isClosed bool) (err error) {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -899,7 +899,7 @@ func newIssue(e *xorm.Session, doer *User, opts NewIssueOptions) (err error) {
 // NewIssue creates new issue with labels for repository.
 func NewIssue(repo *Repository, issue *Issue, labelIDs []int64, uuids []string) (err error) {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/issue_comment.go b/models/issue_comment.go
index ead3f1bed35c99951141d63ce5624b812e47207f..2da70decffdb63ecbe006ae25a6100e42b81b666 100644 (file)
--- a/models/issue_comment.go
+++ b/models/issue_comment.go
@@ -502,7 +502,7 @@ type CreateCommentOptions struct {
 // CreateComment creates comment of issue or commit.
 func CreateComment(opts *CreateCommentOptions) (comment *Comment, err error) {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return nil, err
        }
@@ -620,7 +620,7 @@ func UpdateComment(c *Comment) error {
 // DeleteComment deletes the comment
 func DeleteComment(comment *Comment) error {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err := sess.Begin(); err != nil {
                return err
        }

diff --git a/models/issue_label.go b/models/issue_label.go
index 67e0ac77b5497347294ca8ac5cc9cfc55b3af070..19bf01c6c774e3807da4423d95034a5fd5ef24d5 100644 (file)
--- a/models/issue_label.go
+++ b/models/issue_label.go
@@ -223,7 +223,7 @@ func DeleteLabel(repoID, labelID int64) error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -298,7 +298,7 @@ func NewIssueLabel(issue *Issue, label *Label, doer *User) (err error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -327,7 +327,7 @@ func newIssueLabels(e *xorm.Session, issue *Issue, labels []*Label, doer *User)
 // NewIssueLabels creates a list of issue-label relations.
 func NewIssueLabels(issue *Issue, labels []*Label, doer *User) (err error) {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -375,7 +375,7 @@ func deleteIssueLabel(e *xorm.Session, issue *Issue, label *Label, doer *User) (
 // DeleteIssueLabel deletes issue-label relation.
 func DeleteIssueLabel(issue *Issue, label *Label, doer *User) (err error) {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/issue_milestone.go b/models/issue_milestone.go
index cfd2ce17076b1cc27bd04903675c5f81a1d9a095..d12c309b8777b1d09b32b43b63be6e59ea2bee4d 100644 (file)
--- a/models/issue_milestone.go
+++ b/models/issue_milestone.go
@@ -104,7 +104,7 @@ func (m *Milestone) APIFormat() *api.Milestone {
 // NewMilestone creates new milestone of repository.
 func NewMilestone(m *Milestone) (err error) {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -215,7 +215,7 @@ func ChangeMilestoneStatus(m *Milestone, isClosed bool) (err error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -330,7 +330,7 @@ func DeleteMilestoneByRepoID(repoID, id int64) error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/issue_user.go b/models/issue_user.go
index 024a3cccd92302c32a864c49a161a34eb01b909f..11d47dd0a666093ffe14383d24c0023a094b5121 100644 (file)
--- a/models/issue_user.go
+++ b/models/issue_user.go
@@ -69,7 +69,7 @@ func updateIssueUserByAssignee(e Engine, issue *Issue) (err error) {
 // UpdateIssueUserByAssignee updates issue-user relation for assignee.
 func UpdateIssueUserByAssignee(issue *Issue) (err error) {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/lfs.go b/models/lfs.go
index 99b8138ab75860eccd0a3f384aa629c369eef686..f908cae1f2e5981e11771abf215efcaba0a1446c 100644 (file)
--- a/models/lfs.go
+++ b/models/lfs.go
@@ -56,7 +56,7 @@ func NewLFSMetaObject(m *LFSMetaObject) (*LFSMetaObject, error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return nil, err
        }
@@ -94,7 +94,7 @@ func RemoveLFSMetaObjectByOid(oid string) error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err := sess.Begin(); err != nil {
                return err
        }

diff --git a/models/migrations/migrations.go b/models/migrations/migrations.go
index 2a54c497c1f69c15296b89ebd35cf340071603ff..99fd0124800a362a85a56675ba9b3d0810612b71 100644 (file)
--- a/models/migrations/migrations.go
+++ b/models/migrations/migrations.go
@@ -167,13 +167,6 @@ Please try to upgrade to a lower version (>= v0.6.0) first, then upgrade to curr
        return nil
 }
 
-func sessionRelease(sess *xorm.Session) {
-       if !sess.IsCommitedOrRollbacked {
-               sess.Rollback()
-       }
-       sess.Close()
-}
-
 func fixLocaleFileLoadPanic(_ *xorm.Engine) error {
        cfg, err := ini.Load(setting.CustomConf)
        if err != nil {
@@ -214,7 +207,7 @@ func trimCommitActionAppURLPrefix(x *xorm.Engine) error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -287,7 +280,7 @@ func issueToIssueLabel(x *xorm.Engine) error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -330,7 +323,7 @@ func attachmentRefactor(x *xorm.Engine) error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -408,7 +401,7 @@ func renamePullRequestFields(x *xorm.Engine) (err error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -492,7 +485,7 @@ func generateOrgRandsAndSalt(x *xorm.Engine) (err error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/migrations/v13.go b/models/migrations/v13.go
index c9a50a992e0fd034f69b5ad1b50f430daeb99e35..f81271f981230dae6ff8befe01e620e007c4fda6 100644 (file)
--- a/models/migrations/v13.go
+++ b/models/migrations/v13.go
@@ -23,7 +23,7 @@ func ldapUseSSLToSecurityProtocol(x *xorm.Engine) error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/models.go b/models/models.go
index 02a782cde323124c6a50378d668a96cc52e0f010..6a8fbfe624cdcb72e0cdf9fcbf5285b8b12c8313 100644 (file)
--- a/models/models.go
+++ b/models/models.go
@@ -49,13 +49,6 @@ type Engine interface {
        Where(interface{}, ...interface{}) *xorm.Session
 }
 
-func sessionRelease(sess *xorm.Session) {
-       if !sess.IsCommitedOrRollbacked {
-               sess.Rollback()
-       }
-       sess.Close()
-}
-
 var (
        x      *xorm.Engine
        tables []interface{}

diff --git a/models/org.go b/models/org.go
index 5c2d89a78dbc3c4ca04af0cbd8b211293caf664a..b4cbabcb53cdf05fcade3aba95e4a6bcb947cea9 100644 (file)
--- a/models/org.go
+++ b/models/org.go
@@ -127,7 +127,7 @@ func CreateOrganization(org, owner *User) (err error) {
        org.Type = UserTypeOrganization
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -481,7 +481,7 @@ func RemoveOrgUser(orgID, userID int64) error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err := sess.Begin(); err != nil {
                return err
        }

diff --git a/models/org_team.go b/models/org_team.go
index 5c97a7032e94d6f109939c0f8cdb228ea3c4861e..a7a1ba85d6a427cda82f78e3d6883581dc878046 100644 (file)
--- a/models/org_team.go
+++ b/models/org_team.go
@@ -119,7 +119,7 @@ func (t *Team) AddRepository(repo *Repository) (err error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -180,7 +180,7 @@ func (t *Team) RemoveRepository(repoID int64) error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -309,7 +309,7 @@ func UpdateTeam(t *Team, authChanged bool) (err error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -354,7 +354,7 @@ func DeleteTeam(t *Team) error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err := sess.Begin(); err != nil {
                return err
        }
@@ -482,7 +482,7 @@ func AddTeamMember(team *Team, userID int64) error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err := sess.Begin(); err != nil {
                return err
        }
@@ -584,7 +584,7 @@ func removeTeamMember(e Engine, team *Team, userID int64) error {
 // RemoveTeamMember removes member from given team of given organization.
 func RemoveTeamMember(team *Team, userID int64) error {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err := sess.Begin(); err != nil {
                return err
        }

diff --git a/models/pull.go b/models/pull.go
index b5b63bebf11365b5f5df226b2274d137c663a95b..882ee1b2208ed66c3570c27f666c9e6816f3443d 100644 (file)
--- a/models/pull.go
+++ b/models/pull.go
@@ -406,7 +406,7 @@ func (pr *PullRequest) setMerged() (err error) {
        pr.HasMerged = true
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -602,7 +602,7 @@ func (pr *PullRequest) testPatch() (err error) {
 // NewPullRequest creates new pull request with labels for repository.
 func NewPullRequest(repo *Repository, pull *Issue, labelIDs []int64, uuids []string, pr *PullRequest, patch []byte) (err error) {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/repo.go b/models/repo.go
index f8fef47ebee3292ab9f00d36daf848239331c95a..8d9713842012d4bbb2c4092bfb5c4ec8837b8562 100644 (file)
--- a/models/repo.go
+++ b/models/repo.go
@@ -1271,7 +1271,7 @@ func CreateRepository(u *User, opts CreateRepoOptions) (_ *Repository, err error
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return nil, err
        }
@@ -1355,7 +1355,7 @@ func TransferOwnership(doer *User, newOwnerName string, repo *Repository) error
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return fmt.Errorf("sess.Begin: %v", err)
        }
@@ -1580,7 +1580,7 @@ func updateRepository(e Engine, repo *Repository, visibilityChanged bool) (err e
 // UpdateRepository updates a repository
 func UpdateRepository(repo *Repository, visibilityChanged bool) (err error) {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -1625,7 +1625,7 @@ func DeleteRepository(uid, repoID int64) error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -2240,7 +2240,7 @@ func ForkRepository(u *User, oldRepo *Repository, name, desc string) (_ *Reposit
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return nil, err
        }
@@ -2284,7 +2284,7 @@ func ForkRepository(u *User, oldRepo *Repository, name, desc string) (_ *Reposit
 
        // Copy LFS meta objects in new session
        sess2 := x.NewSession()
-       defer sessionRelease(sess2)
+       defer sess2.Close()
        if err = sess2.Begin(); err != nil {
                return nil, err
        }

diff --git a/models/repo_collaboration.go b/models/repo_collaboration.go
index 39df5b9efa2b5264358facd8c85f3d3119183f74..791f022a3f50444e1a2e3c52fa8667342c8144e1 100644 (file)
--- a/models/repo_collaboration.go
+++ b/models/repo_collaboration.go
@@ -46,7 +46,7 @@ func (repo *Repository) AddCollaborator(u *User) error {
        collaboration.Mode = AccessModeWrite
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -136,7 +136,7 @@ func (repo *Repository) ChangeCollaborationAccessMode(uid int64, mode AccessMode
        collaboration.Mode = mode
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -161,7 +161,7 @@ func (repo *Repository) DeleteCollaboration(uid int64) (err error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/repo_editor.go b/models/repo_editor.go
index 40898dd4c26fb11a9726ff9c3ce8bda184d68720..720e07162589577197c238f16bc8e84b11b885fd 100644 (file)
--- a/models/repo_editor.go
+++ b/models/repo_editor.go
@@ -401,7 +401,7 @@ func DeleteUploads(uploads ...*Upload) (err error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/ssh_key.go b/models/ssh_key.go
index 38b172d2ed4981747a0f6a582469c1707fb4ddcf..947b2dabfd0cd8a2b76705162414e44bd8585249 100644 (file)
--- a/models/ssh_key.go
+++ b/models/ssh_key.go
@@ -430,7 +430,7 @@ func AddPublicKey(ownerID int64, name, content string) (*PublicKey, error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return nil, err
        }
@@ -535,7 +535,7 @@ func DeletePublicKey(doer *User, id int64) (err error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -732,7 +732,7 @@ func AddDeployKey(repoID int64, name, content string) (*DeployKey, error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return nil, err
        }
@@ -812,7 +812,7 @@ func DeleteDeployKey(doer *User, id int64) error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/user.go b/models/user.go
index 8d8afdfdb802c76f8d5e1a52ce997bf1981e77d6..6484c8cf696f872da0e2725b779a858bc2d6c8fe 100644 (file)
--- a/models/user.go
+++ b/models/user.go
@@ -436,7 +436,7 @@ func (u *User) UploadAvatar(data []byte) error {
        m := resize.Resize(avatar.AvatarSize, avatar.AvatarSize, img, resize.NearestNeighbor)
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -715,7 +715,7 @@ func CreateUser(u *User) (err error) {
        u.MaxRepoCreation = -1
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -1033,7 +1033,7 @@ func deleteUser(e *xorm.Session, u *User) error {
 // but issues/comments/pulls will be kept and shown as someone has been deleted.
 func DeleteUser(u *User) (err error) {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/user_follow.go b/models/user_follow.go
index 2d64d05473adac04d470563f6c5545d3474fd01d..4bde71cb91c6026979a4e467932a32b21a4deac7 100644 (file)
--- a/models/user_follow.go
+++ b/models/user_follow.go
@@ -24,7 +24,7 @@ func FollowUser(userID, followID int64) (err error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -50,7 +50,7 @@ func UnfollowUser(userID, followID int64) (err error) {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/user_mail.go b/models/user_mail.go
index 4ccf08e9d9dc7c0bc5a896f2405dea4398ff4391..285ba74f61b2f1968eb4a0c2a7dcdde68cb6a347 100644 (file)
--- a/models/user_mail.go
+++ b/models/user_mail.go
@@ -127,7 +127,7 @@ func (email *EmailAddress) Activate() error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }
@@ -208,7 +208,7 @@ func MakeEmailPrimary(email *EmailAddress) error {
        }
 
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }

diff --git a/models/webhook.go b/models/webhook.go
index 5cb2e13a6d558cb5a13c700ad5736dce1201d394..b7e687a4616f002464c8c3cdbbae68a1e519588e 100644 (file)
--- a/models/webhook.go
+++ b/models/webhook.go
@@ -267,7 +267,7 @@ func UpdateWebhook(w *Webhook) error {
 // ID must be specified and do not assign unnecessary fields.
 func deleteWebhook(bean *Webhook) (err error) {
        sess := x.NewSession()
-       defer sessionRelease(sess)
+       defer sess.Close()
        if err = sess.Begin(); err != nil {
                return err
        }