lsm/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2025-11-09 03:44:56 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

serialize sqlite operations

Browse Source 
fix https://github.com/seaweedfs/seaweedfs/issues/3827
This commit is contained in:
chrislu
2022-10-12 00:03:27 -07:00
parent dff85e9c71
commit cea73ac008
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
weed/filer/sqlite/sqlite_store.go
View File

@@ -74,6 +74,8 @@ func (store *SqliteStore) initialize(dbFile, createTable, upsertQuery string) (e
return fmt.Errorf("connect to %s error:%v", dbFile, err) return fmt.Errorf("connect to %s error:%v", dbFile, err)
} }
store.DB.SetMaxOpenConns(1)
if err = store.CreateTable(context.Background(), abstract_sql.DEFAULT_TABLE); err != nil { if err = store.CreateTable(context.Background(), abstract_sql.DEFAULT_TABLE); err != nil {
return fmt.Errorf("init table %s: %v", abstract_sql.DEFAULT_TABLE, err) return fmt.Errorf("init table %s: %v", abstract_sql.DEFAULT_TABLE, err)
} }