<code>optional .alluxio.grpc.file.StopSyncPOptions options = 2;</code>
10897
public alluxio.grpc.StopSyncPOptions getOptions() {
    return options_ == null ? alluxio.grpc.StopSyncPOptions.getDefaultInstance() : options_;
  }
153347
public alluxio.grpc.GetWorkerIdPOptionsOrBuilder getOptionsOrBuilder() {
    return options_ == null ? alluxio.grpc.GetWorkerIdPOptions.getDefaultInstance() : options_;
  }
351894
public static Options buildOptions(int maxBackgroundThreads,
            int levelZeloFileNumCompactionTrigger, long writeBufferSize, long targetFileSizeBase) {
        Options rocksOptions = new Options();
        rocksOptions.setCreateIfMissing(true).getEnv().setBackgroundThreads(1, Env.FLUSH_POOL)
                .setBackgroundThreads(maxBackgroundThreads, Env.COMPACTION_POOL);
        rocksOptions.setMaxBackgroundFlushes(1).setMaxBackgroundCompactions(maxBackgroundThreads);
        rocksOptions.setWriteBufferSize(writeBufferSize).setMinWriteBufferNumberToMerge(2)
                .setLevelZeroFileNumCompactionTrigger(levelZeloFileNumCompactionTrigger)
                .setTargetFileSizeBase(targetFileSizeBase);

        rocksOptions.setMemTableConfig(new SkipListMemTableConfig());
        // rocksOptions.setMemTableConfig(new HashSkipListMemTableConfig());
        // rocksOptions.setMemTableConfig(new HashLinkedListMemTableConfig());

        return rocksOptions;
    }
146220
public void stopSyncInternal(AlluxioURI syncPoint, MountTable.Resolution resolution) {
    try (LockResource r = new LockResource(mSyncManagerLock)) {
      LOG.debug("stop syncPoint {}", syncPoint.getPath());
      RemoveSyncPointEntry removeSyncPoint = File.RemoveSyncPointEntry.newBuilder()
          .setSyncpointPath(syncPoint.toString())
          .setMountId(resolution.getMountId())
          .build();
      apply(removeSyncPoint);
      try {
        stopSyncPostJournal(syncPoint);
      } catch (Throwable e) {
        // revert state;
        AddSyncPointEntry addSyncPoint =
            File.AddSyncPointEntry.newBuilder()
                .setSyncpointPath(syncPoint.toString()).build();
        apply(addSyncPoint);
        recoverFromStopSync(syncPoint, resolution.getMountId());
      }
    }
  }
596604
@OPTIONS
    @Timed
    public void options(@Suspended final AsyncResponse response, @Context final Request request,
            @Context final UriInfo uriInfo, @Context final HttpHeaders headers) {
        final TrellisRequest req = new TrellisRequest(request, uriInfo, headers);
        final String urlBase = getBaseUrl(req);
        final IRI identifier = rdf.createIRI(TRELLIS_DATA_PREFIX + req.getPath());
        final OptionsHandler optionsHandler = new OptionsHandler(req, trellis, req.getVersion() != null, urlBase);

        fetchTrellisResource(identifier, req.getVersion()).thenApply(optionsHandler::initialize)
            .thenApply(optionsHandler::ldpOptions).thenApply(ResponseBuilder::build)
            .exceptionally(this::handleException).thenApply(response::resume);
    }
855523
public alluxio.grpc.FileSystemHeartbeatPOptions getOptions() {
    return options_ == null ? alluxio.grpc.FileSystemHeartbeatPOptions.getDefaultInstance() : options_;
  }
1251986
public alluxio.grpc.ScheduleAsyncPersistencePOptions getOptions() {
    return options_ == null ? alluxio.grpc.ScheduleAsyncPersistencePOptions.getDefaultInstance() : options_;
  }
665664
public alluxio.grpc.RenamePOptionsOrBuilder getOptionsOrBuilder() {
    return options_ == null ? alluxio.grpc.RenamePOptions.getDefaultInstance() : options_;
  }
1309074
public alluxio.grpc.GetFileInfoPOptionsOrBuilder getOptionsOrBuilder() {
    return options_ == null ? alluxio.grpc.GetFileInfoPOptions.getDefaultInstance() : options_;
  }
956780
public alluxio.grpc.CompleteFilePOptions getOptions() {
    return options_ == null ? alluxio.grpc.CompleteFilePOptions.getDefaultInstance() : options_;
  }
1129116
@Override
    @Transactional
    public void cancelSnapshot(String snapshotId) throws SnapshotException {
        checkInitialized();
        final Snapshot snapshot = getSnapshot(snapshotId);
        stop(snapshot);
        String snapshotDir = ContentDirUtils.getDestinationPath(snapshotId, this.config.getContentRootDir());
        deleteDirectory(snapshotDir);

        new Thread(new Runnable() {
            @Override
            public void run() {
                final DuracloudEndPointConfig source = snapshot.getSource();
                final String spaceId = source.getSpaceId();
                final ContentStore contentStore =
                    storeClientHelper.create(source,
                                             config.getDuracloudUsername(),
                                             config.getDuracloudPassword());
                try {
                    String result = new Retrier().execute(new Retriable() {
                        /* (non-Javadoc)
                         * @see org.duracloud.common.retry.Retriable#retry()
                         */
                        @Override
                        public Object retry() throws Exception {
                            CompleteCancelSnapshotTaskParameters params =
                                new CompleteCancelSnapshotTaskParameters();
                            params.setSpaceId(spaceId);
                            return contentStore.performTask(SnapshotConstants.COMPLETE_SNAPSHOT_CANCEL_TASK_NAME,
                                                            params.serialize());
                        }
                    });

                    log.info("snapshot cancellation is complete: {}", result);

                    snapshot.setStatus(SnapshotStatus.CANCELLED);
                    snapshot.setStatusText("");
                    eventLog.logSnapshotUpdate(snapshot);
                } catch (Exception ex) {
                    log.error("failed to complete cancellation on the durastore side for space {}:  {}",
                              spaceId,
                              ex.getMessage(),
                              ex);
                }

            }
        }).start();
    }
574588
public alluxio.grpc.RegisterWorkerPOptionsOrBuilder getOptionsOrBuilder() {
    return options_ == null ? alluxio.grpc.RegisterWorkerPOptions.getDefaultInstance() : options_;
  }
1374576
public alluxio.grpc.FileSystemHeartbeatPOptionsOrBuilder getOptionsOrBuilder() {
    return options_ == null ? alluxio.grpc.FileSystemHeartbeatPOptions.getDefaultInstance() : options_;
  }
554317
public void stopSyncForMount(long mountId) throws InvalidPathException, IOException {
    LOG.debug("Stop sync for mount id {}", mountId);
    if (mFilterMap.containsKey(mountId)) {
      List<Pair<AlluxioURI, MountTable.Resolution>> toBeDeleted = new ArrayList<>();
      for (AlluxioURI uri : mFilterMap.get(mountId)) {
        MountTable.Resolution resolution = resolveSyncPoint(uri);
        if (resolution != null) {
          toBeDeleted.add(new Pair<>(uri, resolution));
        }
      }
      // Calling stopSyncInternal outside of the traversal of mFilterMap.get(mountId) to avoid
      // ConcurrentModificationException
      for (Pair<AlluxioURI, MountTable.Resolution> deleteInfo : toBeDeleted) {
        stopSyncInternal(deleteInfo.getFirst(), deleteInfo.getSecond());
      }
    }
  }
1000811
public alluxio.grpc.SetAclPOptionsOrBuilder getOptionsOrBuilder() {
    return options_ == null ? alluxio.grpc.SetAclPOptions.getDefaultInstance() : options_;
  }
936719
public alluxio.grpc.DeletePOptions getOptions() {
    return options_ == null ? alluxio.grpc.DeletePOptions.getDefaultInstance() : options_;
  }
1146638
public alluxio.grpc.CompleteFilePOptionsOrBuilder getOptionsOrBuilder() {
    return options_ == null ? alluxio.grpc.CompleteFilePOptions.getDefaultInstance() : options_;
  }