-
Notifications
You must be signed in to change notification settings - Fork 216
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Streaming test for windows #3052
Conversation
9a441ff
to
1929ffd
Compare
src/test/streaming_test.cpp
Outdated
#ifdef _WIN32 | ||
GTEST_SKIP() << "Test disabled on windows"; | ||
#endif | ||
// #ifdef _WIN32 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
To remove
src/test/streaming_test.cpp
Outdated
#ifdef _WIN32 | ||
GTEST_SKIP() << "Test disabled on windows"; | ||
#endif | ||
// #ifdef _WIN32 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
to remove
src/test/streaming_test.cpp
Outdated
GTEST_SKIP() << "Test disabled on windows"; | ||
#endif | ||
// #ifdef _WIN32 | ||
// GTEST_SKIP() << "Test disabled on windows"; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
to remove
src/test/streaming_test.cpp
Outdated
#ifdef _WIN32 | ||
GTEST_SKIP() << "Test disabled on windows"; | ||
#endif | ||
// #ifdef _WIN32 |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove in all other places as well
src/test/streaming_test.cpp
Outdated
static auto DisconnectWhenNotified(std::mutex& mtx) { | ||
return [&mtx](::inference::ModelInferRequest* req) { | ||
std::lock_guard<std::mutex> lock(mtx); // waits for lock to be released | ||
static auto DisconnectWhenNotified_(std::future<void>& fut) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Why _ suffix was added?
src/test/streaming_test.cpp
Outdated
@@ -14,7 +14,8 @@ | |||
// limitations under the License. | |||
//***************************************************************************** | |||
#include <chrono> | |||
#include <mutex> | |||
#include <future> | |||
#include <mutex> // ? |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
To remove/
3c14327
to
09b311d
Compare
🛠 Summary
Changed wait mechanism from mutex to futures, it turns out there was double lock in the same thread in tests
CVS-157750
🧪 Checklist