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

Method send

flow/include/flow/IThreadPool.h:126–132  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

124 }
125
126 void send(T const& t) { // Can be called safely from another thread.
127 Promise<Void> signal;
128 tagAndForward(&promiseStream, t, signal.getFuture());
129 g_network->onMainThread(std::move(signal),
130 g_network->isOnMainThread() ? incrementPriorityIfEven(g_network->getCurrentTask())
131 : TaskPriority::DefaultOnMainThread);
132 }
133
134 void sendError(Error const& e) { // Can be called safely from another thread.
135 Promise<Void> signal;

Callers

nothing calls this directly

Calls 7

tagAndForwardFunction · 0.85
moveFunction · 0.85
incrementPriorityIfEvenFunction · 0.85
getFutureMethod · 0.45
onMainThreadMethod · 0.45
isOnMainThreadMethod · 0.45
getCurrentTaskMethod · 0.45

Tested by

no test coverage detected