import org.apache.hadoop.net.unix.DomainSocketWatcher; //导入依赖的package包/类
public ShortCircuitCache(int maxTotalSize, long maxNonMmappedEvictableLifespanMs,
    int maxEvictableMmapedSize, long maxEvictableMmapedLifespanMs,
    long mmapRetryTimeoutMs, long staleThresholdMs, int shmInterruptCheckMs) {
  Preconditions.checkArgument(maxTotalSize >= 0);
  this.maxTotalSize = maxTotalSize;
  Preconditions.checkArgument(maxNonMmappedEvictableLifespanMs >= 0);
  this.maxNonMmappedEvictableLifespanMs = maxNonMmappedEvictableLifespanMs;
  Preconditions.checkArgument(maxEvictableMmapedSize >= 0);
  this.maxEvictableMmapedSize = maxEvictableMmapedSize;
  Preconditions.checkArgument(maxEvictableMmapedLifespanMs >= 0);
  this.maxEvictableMmapedLifespanMs = maxEvictableMmapedLifespanMs;
  this.mmapRetryTimeoutMs = mmapRetryTimeoutMs;
  this.staleThresholdMs = staleThresholdMs;
  DfsClientShmManager shmManager = null;
  if ((shmInterruptCheckMs > 0) &&
      (DomainSocketWatcher.getLoadingFailureReason() == null)) {
    try {
      shmManager = new DfsClientShmManager(shmInterruptCheckMs);
    } catch (IOException e) {
      LOG.error("failed to create ShortCircuitShmManager", e);
    }
  }
  this.shmManager = shmManager;
}
 

import org.apache.hadoop.net.unix.DomainSocketWatcher; //导入依赖的package包/类
DfsClientShmManager(int interruptCheckPeriodMs) throws IOException {
  this.domainSocketWatcher = new DomainSocketWatcher(interruptCheckPeriodMs,
      "client");
}
 

import org.apache.hadoop.net.unix.DomainSocketWatcher; //导入依赖的package包/类
@VisibleForTesting
public DomainSocketWatcher getDomainSocketWatcher() {
  return domainSocketWatcher;
}
 

import org.apache.hadoop.net.unix.DomainSocketWatcher; //导入依赖的package包/类
DfsClientShmManager(int interruptCheckPeriodMs) throws IOException {
  this.domainSocketWatcher = new DomainSocketWatcher(interruptCheckPeriodMs);
}