Commits

mikespook committed 35de52f

the Job was out of use.

  • Participants
  • Parent commits c67597e

Comments (0)

Files changed (3)

File src/gearman/gearman.go

     JOB_HIGH = 4
 )
 
-// No use
-type Job interface {
-    Encode() []byte
-}
-
 // Extract the error message
 func getError(data []byte) (eno os.Errno, err os.Error) {
     rel := bytes.SplitN(data, []byte{'\x00'}, 2)

File src/gearman/worker.go

     "os"
     "sync"
     "bytes"
-    //    "log"
 )
 
 // The definition of the callback function.
     defer worker.mutex.Unlock()
 
     if len(worker.clients) == cap(worker.clients) {
-        return os.NewError("There were too many clients.")
+        return os.NewError("To many servers added.")
     }
 
     // Create a new job server's client as a agent of server

File src/gearman/workerjob.go

 import (
     "os"
     "strconv"
-    //    "log"
 )
 
 // Worker side job
     Handle, UniqueId    string
     client              *jobClient
     magicCode, DataType uint32
-    Job
 }
 
 // Create a new job