本文整理了Java中com.palantir.lock.v2.WaitForLocksRequest类的一些代码示例，展示了WaitForLocksRequest类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。WaitForLocksRequest类的具体详情如下：
包路径：com.palantir.lock.v2.WaitForLocksRequest
类名称：WaitForLocksRequest

WaitForLocksRequest介绍

暂无

代码示例

代码示例来源：origin: palantir/atlasdb

static RequestInfo of(WaitForLocksRequest request) {
    return ImmutableRequestInfo.of(
        request.getRequestId(),
        request.getClientDescription().orElse(EMPTY_DESCRIPTION),
        request.getLockDescriptors());
  }
}

代码示例来源：origin: palantir/atlasdb

@Override
public AsyncResult<Void> waitForLocks(WaitForLocksRequest request) {
  return lockService.waitForLocks(
      request.getRequestId(),
      request.getLockDescriptors(),
      TimeLimit.of(request.getAcquireTimeoutMs()));
}

代码示例来源：origin: palantir/atlasdb

private void waitFor(Set<LockDescriptor> lockDescriptors) {
  WaitForLocksRequest request = WaitForLocksRequest.of(lockDescriptors,
      transactionConfig.get().getLockAcquireTimeoutMillis());
  WaitForLocksResponse response = timelockService.waitForLocks(request);
  if (!response.wasSuccessful()) {
    log.error("Timed out waiting for commits to complete. Timeout was {} ms. First ten locks were {}.",
        SafeArg.of("requestId", request.getRequestId()),
        SafeArg.of("acquireTimeoutMs", transactionConfig.get().getLockAcquireTimeoutMillis()),
        UnsafeArg.of("firstTenLockDescriptors", Iterables.limit(lockDescriptors, 10)));
    throw new TransactionLockAcquisitionTimeoutException("Timed out waiting for commits to complete.");
  }
}

代码示例来源：origin: palantir/atlasdb

@Test
public void waitForLocksDelegates() {
  WaitForLocksRequest request = WaitForLocksRequest.of(LOCKS, TIMEOUT);
  timelock.waitForLocks(request);
  verify(delegate).waitForLocks(request);
  verifyNoMoreInteractions(refresher);
}

代码示例来源：origin: palantir/atlasdb

@Override
public WaitForLocksResponse waitForLocks(WaitForLocksRequest request) {
  com.palantir.lock.LockRequest legacyRequest = toLegacyWaitForLocksRequest(request.getLockDescriptors());
  // this blocks indefinitely, and can only fail if the connection fails (and throws an exception)
  lockAnonymous(legacyRequest);
  return WaitForLocksResponse.successful();
}

代码示例来源：origin: com.palantir.atlasdb/atlasdb-impl-shared

private void waitFor(Set<LockDescriptor> lockDescriptors) {
  WaitForLocksRequest request = WaitForLocksRequest.of(lockDescriptors,
      transactionConfig.get().getLockAcquireTimeoutMillis());
  WaitForLocksResponse response = timelockService.waitForLocks(request);
  if (!response.wasSuccessful()) {
    log.error("Timed out waiting for commits to complete. Timeout was {} ms. First ten locks were {}.",
        SafeArg.of("requestId", request.getRequestId()),
        SafeArg.of("acquireTimeoutMs", transactionConfig.get().getLockAcquireTimeoutMillis()),
        UnsafeArg.of("firstTenLockDescriptors", Iterables.limit(lockDescriptors, 10)));
    throw new TransactionLockAcquisitionTimeoutException("Timed out waiting for commits to complete.");
  }
}

代码示例来源：origin: palantir/atlasdb

@Test
public void waitForLocksDelegatesToLockService() throws InterruptedException {
  com.palantir.lock.LockRequest legacyRequest = com.palantir.lock.LockRequest.builder(buildLockMap(LockMode.READ)).lockAndRelease().build();
  when(lockService.lock(LockClient.ANONYMOUS.getClientId(), legacyRequest)).thenReturn(LOCK_REFRESH_TOKEN);
  timelock.waitForLocks(WaitForLocksRequest.of(ImmutableSet.of(LOCK_A, LOCK_B), TIMEOUT));
  verify(lockService).lock(LockClient.ANONYMOUS.getClientId(), legacyRequest);
}

代码示例来源：origin: com.palantir.atlasdb/timelock-impl

static RequestInfo of(WaitForLocksRequest request) {
    return ImmutableRequestInfo.of(
        request.getRequestId(),
        request.getClientDescription().orElse(EMPTY_DESCRIPTION),
        request.getLockDescriptors());
  }
}

代码示例来源：origin: com.palantir.atlasdb/timelock-impl

@Override
public AsyncResult<Void> waitForLocks(WaitForLocksRequest request) {
  return lockService.waitForLocks(
      request.getRequestId(),
      request.getLockDescriptors(),
      TimeLimit.of(request.getAcquireTimeoutMs()));
}