(ctx context.Context, data wshrpc.CommandJobInputData)
| 122 | } |
| 123 | |
| 124 | func (msc *MainServerConn) JobInputCommand(ctx context.Context, data wshrpc.CommandJobInputData) error { |
| 125 | if !msc.PeerAuthenticated.Load() { |
| 126 | return fmt.Errorf("not authenticated") |
| 127 | } |
| 128 | if !WshCmdJobManager.IsJobStarted() { |
| 129 | return fmt.Errorf("job not started") |
| 130 | } |
| 131 | |
| 132 | WshCmdJobManager.InputQueue.QueueItem(data.InputSessionId, data.SeqNum, data) |
| 133 | return nil |
| 134 | } |
nothing calls this directly
no test coverage detected