diff --git a/src/client/src/tscBulkWrite.c b/src/client/src/tscBulkWrite.c index ad03072cc578f84003c9278bd28f897ff6ecf635..b723891500d4904702e539eb60651a3e1b5a813d 100644 --- a/src/client/src/tscBulkWrite.c +++ b/src/client/src/tscBulkWrite.c @@ -290,11 +290,8 @@ inline static void dispatcherSleepUntil(SAsyncBulkWriteDispatcher* dispatcher, s if (durationMillis(current, timeout) <= 0) { return; } - - if (pthread_mutex_timedlock(&dispatcher->mutex, &timeout)) { - return; - } + pthread_mutex_lock(&dispatcher->mutex); while (true) { // notified by dispatcherShutdown(...). if (atomic_load_8(&dispatcher->shutdown)) {