a

554325746@qq.com

2019-12-25 546d23f0ec50be30824d5a58ff5281ff6e21adbb

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
package androidSync
//package main
import (
    sdb "basic.com/Android/syncdb.git"
    "basic.com/valib/logger.git"
    "encoding/json"
    "github.com/hashicorp/memberlist"
    "os"
    "time"
)
 
const (
    syncClusterKeyPrefix = "bjbasic123"
)
const (
    defaultSqliteDBPath = "/sdcard/testdb.db"
 
    dBNameCluster      = "cluster"
    dBNameClusterNode  = "cluster_node"
    dBNameTables       = "dbTables"
    dBNameTablePersons = "dbtablepersons"
)
 
var syncTables = []string{dBNameCluster, dBNameClusterNode, dBNameTables, dBNameTablePersons}
var agent *sdb.Agent
var members *memberlist.Memberlist
var sqliteDBPath string = defaultSqliteDBPath
 
func InitCluster() bool {
    var logFile = "/sdcard/androidSync.log"
    var logSaveDays = 15    
    logger.Config(logFile, logger.DebugLevel)
    logger.SetSaveDays(logSaveDays)
    err := sdb.InitDbConn(sqliteDBPath)
    if err != nil{
        logger.Error("sdb.InitDbConn ERROR: sqliteDBPath:", sqliteDBPath)
        os.Exit(-1)
    }
    return true
}
 
func setDBPath(path string){
    sqliteDBPath = path
}
 
func getDBPath() string {
    return sqliteDBPath
}
 
func clearSearchResult(ml *memberlist.Memberlist) {
    time.Sleep(10 * time.Second)
    sdb.CloseSearchNode(ml)
}
 
func CreateSearchNodeByPwd(pwd string) bool{
 
    pwdFull := syncClusterKeyPrefix + pwd
    var err error
    members, err = sdb.CreateSearchNode(pwdFull)
    if err != nil {
        logger.Error("sdb.CreateSearchNode:", err)
        return false
    }
 
    go clearSearchResult(members)
 
    return true
}
 
 
func createSearchNode(key string) bool {
    var err error
    members, err = sdb.CreateSearchNode(key)
    if err != nil {
        logger.Error("sdb.CreateSearchNode:", err)
        return false
    }
 
    return true
}
 
 
func createSearchNodeWhitClose(key string, delay int) []byte {
    nodes := sdb.CreateSearchNodeWhitClose(key, time.Duration(delay))
    strNodes, err := json.Marshal(nodes)
    if err != nil {
        logger.Error("json.Marshal:", err)
        return nil
    }
    return strNodes
}
 
 
func CloseSearchNode() bool {
    err := sdb.CloseSearchNode(members)
    if err != nil {
        logger.Error("sdb.CloseSearchNode:", err)
        return false
    }
    return true
}
 
func GetSearchNodes() []byte {
    nodes := sdb.GetSearchNodes()
    strNodes, err := json.Marshal(nodes)
    if err != nil {
        logger.Error("json.Marshal:", err)
        return nil
    }
    return strNodes
}