ros2/hailort
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

v4.16.0 (#11)

Browse Source 
* v4.16.0
This commit is contained in:
HailoRT-Automation
2023-12-28 16:14:01 +02:00
committed by GitHub
parent 459eaf0234
commit 35d9282f36
276 changed files with 14513 additions and 8725 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
hailort/hailortcli/run_command.cpp
View File

@@ -445,28 +445,6 @@ hailo_status recv_loop(const inference_runner_params &params, RecvObject &recv_o
return HAILO_SUCCESS;
}
template<typename SendObject, typename RecvObject>
hailo_status abort_streams(std::vector<std::reference_wrapper<SendObject>> &send_objects,
std::vector<std::reference_wrapper<RecvObject>> &recv_objects)
{
auto status = HAILO_SUCCESS; // Best effort
for (auto &output_stream : recv_objects) {
auto abort_status = output_stream.get().abort();
if (HAILO_SUCCESS != abort_status) {
LOGGER__ERROR("Failed to abort output stream {}", output_stream.get().name());
status = abort_status;
}
}
for (auto &input_stream : send_objects) {
auto abort_status = input_stream.get().abort();
if (HAILO_SUCCESS != abort_status) {
LOGGER__ERROR("Failed to abort input stream {}", input_stream.get().name());
status = abort_status;
}
}
return status;
}
Expected<std::map<std::string, std::vector<InputVStream>>> create_input_vstreams(ConfiguredNetworkGroup &configured_net_group,
const inference_runner_params &params)
{
@@ -705,7 +683,7 @@ static hailo_status run_streaming_impl(std::shared_ptr<ConfiguredNetworkGroup> c
auto status = wait_for_exit_with_timeout(std::chrono::seconds(params.time_to_run));
CHECK_SUCCESS(status);
status = abort_streams(send_objects, recv_objects);
status = configured_net_group->shutdown();
barrier.terminate();
CHECK_SUCCESS(status);
}