Method Close

internal/utils/dbs/db.go:195–243

Close the database

()

// Close the database
func (this *DB) Close() error {
	// check database status
	this.statusLocker.Lock()
	if this.isClosing {
		this.statusLocker.Unlock()
		return nil
	}
	this.isClosing = true
	this.statusLocker.Unlock()

	// waiting for updating operations to finish
	var maxLoops = 5_000
	for {
		this.statusLocker.Lock()
		var countUpdating = this.countUpdating
		this.statusLocker.Unlock()
		if countUpdating <= 0 {
			break
		}
		time.Sleep(1 * time.Millisecond)

		maxLoops--
		if maxLoops <= 0 {
			break
		}
	}

	for _, batch := range this.batches {
		batch.close()
	}

	events.Remove(fmt.Sprintf("db_%p", this))

	defer func() {
		if this.locker != nil {
			_ = this.locker.Release()
		}
	}()

	// print log
	/**if len(this.dsn) > 0 {
		u, _ := url.Parse(this.dsn)
		if u != nil && len(u.Path) > 0 {
			remotelogs.Debug("DB", "close '"+u.Path)
		}
	}**/

	return this.rawDB.Close()
}

func (this *DB) BeginUpdating() bool {
	this.statusLocker.Lock()