MCPcopy Create free account
hub / github.com/apple/foundationdb / cancel

Function cancel

fdbclient/MultiVersionTransaction.actor.cpp:3112–3122  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

3110}
3111
3112THREAD_FUNC cancel(void* arg) {
3113 threadSleep(0.1 * deterministicRandom()->random01());
3114 try {
3115 ((ThreadSingleAssignmentVar<int>*)arg)->addref();
3116 destroy(arg);
3117 } catch (Error& e) {
3118 printf("Caught error in cancel: %s\n", e.name());
3119 ASSERT(false);
3120 }
3121 THREAD_RETURN;
3122}
3123
3124ACTOR Future<Void> checkUndestroyedFutures(std::vector<ThreadSingleAssignmentVar<int>*> undestroyed) {
3125 state int fNum;

Callers 7

cleanupUnsafeMethod · 0.85
delFutureRefMethod · 0.85
delFutureRefMethod · 0.85
cancelMethod · 0.85
cancelMethod · 0.85
cancelMethod · 0.85
cancelMethod · 0.85

Calls 7

threadSleepFunction · 0.85
deterministicRandomFunction · 0.85
printfFunction · 0.85
random01Method · 0.80
destroyFunction · 0.70
nameMethod · 0.65
addrefMethod · 0.45

Tested by

no test coverage detected