yuxh/gearman-go
1
0
Fork 1
Code Issues Pull Requests Releases Wiki Activity

move the auto-inc into the global

Browse Source
This commit is contained in:
Xing Xing 2013-02-03 21:34:13 +08:00
parent 962846c2f7
commit 6619b9a10e
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
client/client.go
View File

@ -16,6 +16,14 @@ import (
"github.com/mikespook/gearman-go/common" "github.com/mikespook/gearman-go/common"
) )
var (
ai *autoinc.AutoInc
)
func init() {
ai = autoinc.New(0, 1)
}
// Status handler // Status handler
// handle, known, running, numerator, denominator // handle, known, running, numerator, denominator
type StatusHandler func(string, bool, bool, uint64, uint64) type StatusHandler func(string, bool, bool, uint64, uint64)
@ -43,7 +51,6 @@ type Client struct {
conn net.Conn conn net.Conn
addr string addr string
ai *autoinc.AutoInc
mutex sync.RWMutex mutex sync.RWMutex
} }
@ -62,7 +69,6 @@ func New(addr string) (client *Client, err error) {
in: make(chan []byte, common.QUEUE_SIZE), in: make(chan []byte, common.QUEUE_SIZE),
out: make(chan *Job, common.QUEUE_SIZE), out: make(chan *Job, common.QUEUE_SIZE),
addr: addr, addr: addr,
ai: autoinc.New(0, 1),
TimeOut: time.Second, TimeOut: time.Second,
} }
if err = client.connect(); err != nil { if err = client.connect(); err != nil {
@ -278,7 +284,7 @@ func (client *Client) writeJob(job *Job) {
// Internal do // Internal do
func (client *Client) do(funcname string, data []byte, func (client *Client) do(funcname string, data []byte,
flag uint32) (id string, handle string) { flag uint32) (id string, handle string) {
id = strconv.Itoa(int(client.ai.Id())) id = strconv.Itoa(int(ai.Id()))
l := len(funcname) + len(id) + len(data) + 2 l := len(funcname) + len(id) + len(data) + 2
rel := make([]byte, 0, l) rel := make([]byte, 0, l)
rel = append(rel, []byte(funcname)...) // len(funcname) rel = append(rel, []byte(funcname)...) // len(funcname)