| | |
| | | msg.setData("Timeout. Device did not response to this command."); |
| | | resultHolder.invokeAllResult(msg); |
| | | }); |
| | | resultHolder.put(key, uuid, result); |
| | | if (resultHolder.exist(key, null)){ |
| | | return result; |
| | | } |
| | | resultHolder.put(key, uuid, result); |
| | | cmder.recordCmd(device, channelId, recordCmdStr, event -> { |
| | | RequestMessage msg = new RequestMessage(); |
| | | msg.setId(uuid); |
| | |
| | | msg.setData("Timeout"); |
| | | resultHolder.invokeAllResult(msg); |
| | | }); |
| | | resultHolder.put(key, uuid, result); |
| | | if(resultHolder.exist(key, null)) { |
| | | return result; |
| | | } |
| | | resultHolder.put(key, uuid, result); |
| | | Device device = storager.queryVideoDevice(deviceId); |
| | | StreamInfo streamInfo = redisCatchStorage.queryPlaybackByDevice(deviceId, channelId); |
| | | if (streamInfo != null) { |