|
@@ -997,8 +997,6 @@ func (tx *Transaction) begin() (err error) {
|
|
|
|
|
|
func (tx *Transaction) commit() (err error) {
|
|
func (tx *Transaction) commit() (err error) {
|
|
for _, tree := range tx.trees {
|
|
for _, tree := range tx.trees {
|
|
- go pushTreeStat(tree)
|
|
|
|
-
|
|
|
|
if err = writeJSONQueue(tree); nil != err {
|
|
if err = writeJSONQueue(tree); nil != err {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
@@ -1009,11 +1007,6 @@ func (tx *Transaction) commit() (err error) {
|
|
return
|
|
return
|
|
}
|
|
}
|
|
|
|
|
|
-func pushTreeStat(tree *parse.Tree) {
|
|
|
|
- stat := treenode.StatTree(tree)
|
|
|
|
- util.PushStatusBarCounter(stat)
|
|
|
|
-}
|
|
|
|
-
|
|
|
|
func (tx *Transaction) rollback() {
|
|
func (tx *Transaction) rollback() {
|
|
tx.trees, tx.nodes = nil, nil
|
|
tx.trees, tx.nodes = nil, nil
|
|
return
|
|
return
|