import java.util.Deque;
import java.util.Iterator;
import java.util.Optional;
+import java.util.OptionalLong;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.atomic.AtomicIntegerFieldUpdater;
import java.util.concurrent.atomic.AtomicReferenceFieldUpdater;
final boolean success = markSealed();
checkState(success, "Proxy %s was already sealed", getIdentifier());
- if (!sealAndSend(Optional.empty())) {
+ if (!sealAndSend(OptionalLong.empty())) {
sealSuccessor();
}
}
}
private void predecessorSealed() {
- if (markSealed() && !sealAndSend(Optional.empty())) {
+ if (markSealed() && !sealAndSend(OptionalLong.empty())) {
sealSuccessor();
}
}
* @param enqueuedTicks Enqueue ticks when this is invoked from replay path.
* @return True if seal operation was successful, false if this proxy has a successor.
*/
- boolean sealAndSend(final Optional<Long> enqueuedTicks) {
+ boolean sealAndSend(final OptionalLong enqueuedTicks) {
return sealState();
}
successor.handleReplayedRemoteRequest(optState.get(), null, enqueuedTicks);
}
if (successor.markSealed()) {
- successor.sealAndSend(Optional.of(enqueuedTicks));
+ successor.sealAndSend(OptionalLong.of(enqueuedTicks));
}
}
}
abstract void handleReplayedRemoteRequest(TransactionRequest<?> request,
@Nullable Consumer<Response<?, ?>> callback, long enqueuedTicks);
- private static IllegalStateException unhandledResponseException(Response<?, ?> resp) {
+ private static IllegalStateException unhandledResponseException(final Response<?, ?> resp) {
return new IllegalStateException("Unhandled response " + resp.getClass());
}