apps/urtrator
Archived
2
0
Fork 0
Code Issues 22 Pull Requests Packages Projects Releases 8 Wiki Activity

Moved runtime.LockOSThread() to urtrator.go.

Browse Source
This commit is contained in:
Stanislav Nikitin 2016-11-21 01:33:04 +05:00
parent 57a5f7cb4c
commit 0392f510f5
4 changed files with 1 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cache/cache_profiles.go vendored
View File

@ -40,9 +40,7 @@ func (c *Cache) deleteProfile(data map[string]string) {
_, ok1 := c.Profiles[data["profile_name"]] _, ok1 := c.Profiles[data["profile_name"]]
if !ok1 { if !ok1 {
fmt.Println("Profile deleted") fmt.Println("Profile deleted")
Database.Unlock()
Database.Db.MustExec(Database.Db.Rebind("DELETE FROM urt_profiles WHERE name=?"), data["profile_name"]) Database.Db.MustExec(Database.Db.Rebind("DELETE FROM urt_profiles WHERE name=?"), data["profile_name"])
Database.Lock()
} else { } else {
fmt.Println("Something goes wrong! Profile is still here!") fmt.Println("Something goes wrong! Profile is still here!")
} }
@ -77,7 +75,6 @@ func (c *Cache) FlushProfiles(data map[string]string) {
} }
} }
Database.Unlock()
tx := Database.Db.MustBegin() tx := Database.Db.MustBegin()
fmt.Println("Adding new profiles...") fmt.Println("Adding new profiles...")
for _, profile := range new_profiles { for _, profile := range new_profiles {
@ -88,7 +85,6 @@ func (c *Cache) FlushProfiles(data map[string]string) {
tx.NamedExec("UPDATE urt_profiles SET name=:name, version=:version, binary=:binary, second_x_session=:second_x_session, additional_parameters=:additional_parameters WHERE name=:name", &profile) tx.NamedExec("UPDATE urt_profiles SET name=:name, version=:version, binary=:binary, second_x_session=:second_x_session, additional_parameters=:additional_parameters WHERE name=:name", &profile)
} }
tx.Commit() tx.Commit()
Database.Lock()
fmt.Println("Done") fmt.Println("Done")
} }

2
cache/cache_servers.go vendored
View File

@ -85,7 +85,6 @@ func (c *Cache) FlushServers(data map[string]string) {
} }
} }
Database.Unlock()
tx := Database.Db.MustBegin() tx := Database.Db.MustBegin()
fmt.Println("Adding new servers...") fmt.Println("Adding new servers...")
if len(new_servers) > 0 { if len(new_servers) > 0 {
@ -102,7 +101,6 @@ func (c *Cache) FlushServers(data map[string]string) {
} }
tx.Commit() tx.Commit()
Database.Lock()
fmt.Println("Done") fmt.Println("Done")
} }

11
database/database_object.go
View File

@ -14,7 +14,6 @@ import (
//"database/sql" //"database/sql"
"fmt" "fmt"
"path" "path"
"runtime"
"strconv" "strconv"
// local // local
@ -49,12 +48,10 @@ func (d *Database) Close() {
tx.Commit() tx.Commit()
d.Db.Close() d.Db.Close()
runtime.UnlockOSThread()
} }
func (d *Database) Initialize(cfg *configuration.Config) { func (d *Database) Initialize(cfg *configuration.Config) {
fmt.Println("Initializing database...") fmt.Println("Initializing database...")
runtime.LockOSThread()
// Connect to database. // Connect to database.
db_path := path.Join(cfg.TEMP["DATA"], "database.sqlite3") db_path := path.Join(cfg.TEMP["DATA"], "database.sqlite3")
@ -75,10 +72,6 @@ func (d *Database) Initialize(cfg *configuration.Config) {
} }
} }
func (d *Database) Lock() {
runtime.LockOSThread()
}
func (d *Database) Migrate() { func (d *Database) Migrate() {
// Getting current database version. // Getting current database version.
dbver := 0 dbver := 0
@ -94,7 +87,3 @@ func (d *Database) Migrate() {
migrate_full(d, dbver) migrate_full(d, dbver)
} }
func (d *Database) Unlock() {
runtime.UnlockOSThread()
}

1
urtrator.go
View File

@ -25,6 +25,7 @@ func main() {
numCPUs := runtime.NumCPU() numCPUs := runtime.NumCPU()
runtime.GOMAXPROCS(numCPUs) runtime.GOMAXPROCS(numCPUs)
runtime.LockOSThread()
ctx := context.New() ctx := context.New()
ctx.Initialize() ctx.Initialize()