Method setTimeout

fdbclient/MultiVersionTransaction.actor.cpp:1499–1525

Configure a timeout based on the options set for this transaction. This timeout only applies if we don't have an underlying database object to connect with.

// Configure a timeout based on the options set for this transaction. This timeout only applies
// if we don't have an underlying database object to connect with.
void MultiVersionTransaction::setTimeout(Optional<StringRef> value) {
	double timeoutDuration = extractIntOption(value, 0, std::numeric_limits<int>::max()) / 1000.0;

	ThreadFuture<Void> prevTimeout;
	double transactionStartTime = startTime;

	{ // lock scope
		ThreadSpinLockHolder holder(timeoutLock);
		prevTimeout = currentTimeout;

		if (timeoutDuration > 0) {
			Reference<ThreadSingleAssignmentVar<Void>> tsav = timeoutTsav;
			ThreadFuture<Void> newTimeout = onMainThread([transactionStartTime, tsav, timeoutDuration]() {
				return timeoutImpl(tsav, timeoutDuration - std::max(0.0, now() - transactionStartTime));
			});
			currentTimeout = newTimeout;
		} else {
			currentTimeout = ThreadFuture<Void>();
		}
	}

	// Cancel the previous timeout now that we have a new one. This means that changing the timeout
	// affects in-flight operations, which is consistent with the behavior in RYW.
	if (prevTimeout.isValid()) {
		prevTimeout.cancel();
	}
}

// Creates a ThreadFuture<T> that will signal an error if the transaction times out.
template <class T>