We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent e05897d commit 062da84Copy full SHA for 062da84
src/future.cpp
@@ -189,18 +189,14 @@ bool Future::set_callback(Future::Callback callback, void* data) {
189
}
190
191
void Future::internal_set(ScopedMutex& lock) {
192
+ is_set_ = true;
193
if (callback_) {
194
Callback callback = callback_;
195
void* data = data_;
196
lock.unlock();
197
callback(CassFuture::to(this), data);
198
lock.lock();
199
-
200
- // CPP-987 Set this after the callbacks run to avoid unexpected exits
201
- // from wait ops due to spurious wakeups
202
- is_set_ = true;
203
204
// Broadcast after we've run the callback so that threads waiting
205
// on this future see the side effects of the callback.
206
uv_cond_broadcast(&cond_);
0 commit comments