(client *TCPClient, msg *Message)
| 144 | } |
| 145 | |
| 146 | func (o *BinaryOutput) sendRequest(client *TCPClient, msg *Message) { |
| 147 | if !isRequestPayload(msg.Meta) { |
| 148 | return |
| 149 | } |
| 150 | |
| 151 | uuid := payloadID(msg.Meta) |
| 152 | |
| 153 | start := time.Now() |
| 154 | resp, err := client.Send(msg.Data) |
| 155 | stop := time.Now() |
| 156 | |
| 157 | if err != nil { |
| 158 | Debug(1, "Request error:", err) |
| 159 | } |
| 160 | |
| 161 | if o.config.TrackResponses { |
| 162 | o.responses <- response{resp, uuid, start.UnixNano(), stop.UnixNano() - start.UnixNano()} |
| 163 | } |
| 164 | } |
| 165 | |
| 166 | func (o *BinaryOutput) String() string { |
| 167 | return "Binary output: " + o.address |
no test coverage detected