Gabriel Cristian Alecu
e005ea4442
Fixed WORK_FAIL needing 2 arguments
According to http://gearman.org/protocol/ , WORK_FAIL only has 1 argument: the handle
9 yıl önce
Graham Barr
7bcc4de76f
Do not ignore write errors
9 yıl önce
Graham Barr
d82da8fd71
Avoid read channel corruption when response size > bufferSize
When receiving a response, what was happening
1. Read bufferSize and it gets assigned to leftdata
2. Read another bufferSize
3. 2 buffers get appended, but leftdata still points to first buffer
4. Process data buffer which contains only complete responses
5. Back to ReadLoop, but leftdata still points to first incomplete buffer
causing corrupt data to be processed
Solution is to make leftdata nil once we have merged it with the second buffer
10 yıl önce
Graham Barr
49ea8c0ec1
Increase buffer size to 8K
10 yıl önce
Graham Barr
3e556edb2d
When a job completes, remove its handler
10 yıl önce
Randall McPherson
0591572d8e
Make pool clients safe for concurrent access with mutex.
10 yıl önce
Xing Xing
5334b50533
fixed #34
10 yıl önce
Damian Gryski
7229235a4f
Use %v instead of %V, which is not a valid Printf verb
10 yıl önce
Damian Gryski
ad0d49dcb2
Use fmt.Errorf() instead of errors.New(fmt.Sprintf())
10 yıl önce
Xing Xing
f880354a61
type assertion with *net.OpError
10 yıl önce
Xing Xing
45a9d7c3e5
fixed #31
10 yıl önce
Xing Xing
98a935207b
fixed issue #27
10 yıl önce
Xing Xing
87631cc2e5
go fmt & better examples
10 yıl önce
Xing Xing
76196899f8
fxied issue #20
10 yıl önce
Xing Xing
bf25cc1728
a better documents for the client package
10 yıl önce
Xing Xing
02e6bfebcb
prepared for documentation
10 yıl önce
Xing Xing
e9c29799fb
refactoring worker side data package
10 yıl önce
Xing Xing
c8f2f5085c
race is bad, how should we do?
10 yıl önce
Xing Xing
e3f789bc86
fixed nil pointer
10 yıl önce
Xing Xing
e5179e3b5b
started refactoring worker
10 yıl önce
Xing Xing
124e686699
go fmt
10 yıl önce
Xing Xing
2a27eca7b7
fixed building package issue
10 yıl önce
Xing Xing
358c8c4af0
processed ERROR package
10 yıl önce
Xing Xing
4997e30a77
runabled 0.2
10 yıl önce
Xing Xing
e5c30068cd
0.2 refactoring begining
10 yıl önce
Paul Mach
5e215b9257
Remove depenance on external libs for unique id
10 yıl önce
Xing Xing
2002bb1804
fixed bson/ObjectId
11 yıl önce
mikespook
e7d32edee0
fixed for travis-ci
11 yıl önce
mikespook
8e009be940
#14 fixed
11 yıl önce
Paul Mach
f3b4013e2b
Update and Receive status correctly
11 yıl önce
Xing Xing
011c3253f7
issue 'use of closed network connection' of client fixed
11 yıl önce
mikespook
568c70b083
#12 fixed
11 yıl önce
mikespook
7a8a5d4a6a
for issue #10 ; an IdGenerator interface, use bson.ObjectId as default
11 yıl önce
Ingo Oeser
af4035284d
do not generate unique id on background submission
11 yıl önce
Xing Xing
6619b9a10e
move the auto-inc into the global
11 yıl önce
mikespook
962846c2f7
pooling finished
11 yıl önce
mikespook
af05460727
fixed the infinite loop of client
11 yıl önce
mikespook
16a965f52d
An infinite loop ... :(
11 yıl önce
mikespook
f7a84a6587
pool's syntax error fixed
11 yıl önce
mikespook
c00234ba9a
Refactoring the client api
11 yıl önce
mikespook
dbc06bf540
start refactoring...
11 yıl önce
mikespook
ab0fc4a6a5
What a mess! -_-!
11 yıl önce
mikespook
d66157f79e
a dirty implementing of pooling, refactoring needed
11 yıl önce
mikespook
4de3ae3f49
init commit for issue #3
11 yıl önce
mikespook
d6c6bfe9f0
moved to github
11 yıl önce
mikespook
624c61519f
using time.After instead of a separate goroutine
12 yıl önce
mikespook
a8f7c8ab9d
Read a empty data means connection error
12 yıl önce
mikespook
f14964bc81
add timeout to client.Do
12 yıl önce
mikespook
2960cb9953
refacotring worker's code
--HG--
branch : 0.1
rename : worker/jobagent.go => worker/agent.go
rename : worker/workerjob.go => worker/job.go
12 yıl önce
mikespook
563af037cb
fixed client:Job.Encode
--HG--
branch : 0.1
12 yıl önce