test/logdb
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

default get pid

Browse Source
This commit is contained in:
eson 2018-12-19 00:47:37 +08:00
parent f30ecc41a2
commit 4e6b70cb94
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
logdb.go
View File

@ -5,6 +5,7 @@ import (
"fmt" "fmt"
"io/ioutil" "io/ioutil"
"log" "log"
"os"
"time" "time"
yaml "gopkg.in/yaml.v2" yaml "gopkg.in/yaml.v2"
@ -19,6 +20,7 @@ type LogDB struct {
Port string `yaml:"port"` Port string `yaml:"port"`
User string `yaml:"user"` User string `yaml:"user"`
pid int
hostid int hostid int
nextCheck int64 nextCheck int64
checkLimit int64 checkLimit int64
@ -29,6 +31,7 @@ type LogDB struct {
func New(filename string) *LogDB { func New(filename string) *LogDB {
logdb := LogDB{} logdb := LogDB{}
logdb.checkLimit = 300 logdb.checkLimit = 300
logdb.pid = os.Getpid()
data, err := ioutil.ReadFile(filename) data, err := ioutil.ReadFile(filename)
if err != nil { if err != nil {
@ -108,10 +111,9 @@ type ADResonse struct {
Response string Response string
} }
func (logdb *LogDB) ADParserSelect(pid, spider_id int) []ADResonse { func (logdb *LogDB) ADParserSelect(spider_id int) []ADResonse {
// pid := os.Getpid() + 2000 pid := logdb.pid + 2000
// spiderid := 73 + 1000000
logdb.ADCheckError(spider_id) logdb.ADCheckError(spider_id)
_, err := logdb.driver.Exec("update log_spider set status = ? where spider_id = ? and status = 0 limit 100", pid, spider_id) _, err := logdb.driver.Exec("update log_spider set status = ? where spider_id = ? and status = 0 limit 100", pid, spider_id)