(depth int)
| 68 | } |
| 69 | |
| 70 | func (m *TaskParallel) Setup(depth int) error { |
| 71 | m.setup = true |
| 72 | if m.in != nil { |
| 73 | for _, task := range m.runners { |
| 74 | task.MessageInSet(m.in.MessageOut()) |
| 75 | //u.Infof("parallel task in: #%d task p:%p %T %p", i, task, task, task.MessageIn()) |
| 76 | } |
| 77 | } |
| 78 | for _, task := range m.runners { |
| 79 | task.MessageOutSet(m.msgOutCh) |
| 80 | } |
| 81 | for i := 0; i < len(m.runners); i++ { |
| 82 | //u.Debugf("%d Setup: %T", depth, m.runners[i]) |
| 83 | if err := m.runners[i].Setup(depth + 1); err != nil { |
| 84 | return err |
| 85 | } |
| 86 | } |
| 87 | return nil |
| 88 | } |
| 89 | |
| 90 | func (m *TaskParallel) Add(task Task) error { |
| 91 | if m.setup { |
nothing calls this directly
no test coverage detected