Skip to content

Commit c2e0849

Browse files
committed
Fixing sleep for Windows
1 parent 9b011ca commit c2e0849

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

src/confluent_kafka/src/confluent_kafka.c

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,9 @@
2929

3030
#include <stdarg.h>
3131

32+
#ifdef _WIN32
33+
#include <windows.h>
34+
#endif
3235

3336
/**
3437
* @brief KNOWN ISSUES
@@ -2057,7 +2060,11 @@ int wait_for_oauth_token_set(Handle *h) {
20572060
while (!h->oauth_token_set && elapsed_sec < max_wait_sec) {
20582061
CallState cs;
20592062
CallState_begin(h, &cs);
2063+
#ifdef _WIN32
2064+
Sleep(retry_interval_sec * 1000);
2065+
#else
20602066
sleep(retry_interval_sec);
2067+
#endif
20612068
CallState_end(h, &cs);
20622069
elapsed_sec += retry_interval_sec;
20632070
}

0 commit comments

Comments
 (0)