@@ -81,6 +81,7 @@ func (self *Agent) AddJob(job models.JobForInsert) (int64, error) {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return 0, err
|
return 0, err
|
||||||
}
|
}
|
||||||
|
self.jobs[jid] = newJob()
|
||||||
self.in <- &proto.Command{
|
self.in <- &proto.Command{
|
||||||
Id: jid,
|
Id: jid,
|
||||||
Command: job.Command,
|
Command: job.Command,
|
||||||
@@ -155,7 +156,6 @@ func (self *Agent) recv() error {
|
|||||||
|
|
||||||
func (self *Agent) send() error {
|
func (self *Agent) send() error {
|
||||||
for job := range self.in {
|
for job := range self.in {
|
||||||
self.jobs[job.Id] = newJob()
|
|
||||||
if err := self.bidi.Send(job); err != nil {
|
if err := self.bidi.Send(job); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user