Skip to content
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

Merged
merged 6 commits into from
Feb 12, 2025
Merged

Streaming test for windows #3052

merged 6 commits into from
Feb 12, 2025

Conversation

dkalinowski
Copy link
Collaborator

🛠 Summary

Changed wait mechanism from mutex to futures, it turns out there was double lock in the same thread in tests

CVS-157750

🧪 Checklist

  • Change follows security best practices.

@dkalinowski dkalinowski added the WIP Do not merge until resolved label Feb 11, 2025
#ifdef _WIN32
GTEST_SKIP() << "Test disabled on windows";
#endif
// #ifdef _WIN32
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

To remove

#ifdef _WIN32
GTEST_SKIP() << "Test disabled on windows";
#endif
// #ifdef _WIN32
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

to remove

GTEST_SKIP() << "Test disabled on windows";
#endif
// #ifdef _WIN32
// GTEST_SKIP() << "Test disabled on windows";
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

to remove

#ifdef _WIN32
GTEST_SKIP() << "Test disabled on windows";
#endif
// #ifdef _WIN32
Copy link
Collaborator

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

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) {
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why _ suffix was added?

@@ -14,7 +14,8 @@
// limitations under the License.
//*****************************************************************************
#include <chrono>
#include <mutex>
#include <future>
#include <mutex> // ?
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

To remove/

@dkalinowski dkalinowski merged commit 56e256b into main Feb 12, 2025
13 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
WIP Do not merge until resolved
Projects
None yet
Development

Successfully merging this pull request may close these issues.

4 participants