/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/ |
H A D | SnapshotReferenceUtil.java | 89 final Path snapshotDir, final SnapshotVisitor visitor) in visitReferencedFiles() argument 92 visitReferencedFiles(conf, fs, snapshotDir, desc, visitor); in visitReferencedFiles() 108 visitTableStoreFiles(conf, fs, snapshotDir, desc, visitor); in visitReferencedFiles() 109 visitLogFiles(fs, snapshotDir, visitor); in visitReferencedFiles() 128 LOG.debug("No manifest files present: " + snapshotDir); in visitTableStoreFiles() 165 FSVisitor.visitLogFiles(fs, snapshotDir, visitor); in visitLogFiles() 196 final Path snapshotDir = manifest.getSnapshotDir(); in verifySnapshot() local 209 final Path snapshotDir = manifest.getSnapshotDir(); in concurrentVisitReferencedFiles() local 213 LOG.debug("No manifest files present: " + snapshotDir); in concurrentVisitReferencedFiles() 327 final Path snapshotDir) throws IOException { in getHFileNames() argument [all …]
|
H A D | SnapshotManifestV2.java | 66 private final Path snapshotDir; field in SnapshotManifestV2.ManifestBuilder 69 public ManifestBuilder(final Configuration conf, final FileSystem fs, final Path snapshotDir) { in ManifestBuilder() argument 70 this.snapshotDir = snapshotDir; in ManifestBuilder() 83 FSDataOutputStream stream = fs.create(getRegionManifestPath(snapshotDir, manifest)); in regionClose() 119 final Executor executor,final FileSystem fs, final Path snapshotDir, in loadRegionManifests() argument 121 FileStatus[] manifestFiles = FSUtils.listStatus(fs, snapshotDir, new PathFilter() { in loadRegionManifests() 162 static void deleteRegionManifest(final FileSystem fs, final Path snapshotDir, in deleteRegionManifest() argument 164 fs.delete(getRegionManifestPath(snapshotDir, manifest), true); in deleteRegionManifest() 167 private static Path getRegionManifestPath(final Path snapshotDir, in getRegionManifestPath() argument 170 return new Path(snapshotDir, SNAPSHOT_MANIFEST_PREFIX + regionName); in getRegionManifestPath()
|
H A D | SnapshotManifestV1.java | 68 private final Path snapshotDir; field in SnapshotManifestV1.ManifestBuilder 71 public ManifestBuilder(final Configuration conf, final FileSystem fs, final Path snapshotDir) { in ManifestBuilder() argument 72 this.snapshotDir = snapshotDir; in ManifestBuilder() 79 fs, snapshotDir, regionInfo); in regionOpen() 115 final Executor executor,final FileSystem fs, final Path snapshotDir, in loadRegionManifests() argument 117 FileStatus[] regions = FSUtils.listStatus(fs, snapshotDir, new FSUtils.RegionDirFilter(fs)); in loadRegionManifests() 119 LOG.info("No regions under directory:" + snapshotDir); in loadRegionManifests() 130 return buildManifestFromDisk(conf, fs, snapshotDir, hri); in loadRegionManifests() 151 static void deleteRegionManifest(final FileSystem fs, final Path snapshotDir, in deleteRegionManifest() argument 154 fs.delete(new Path(snapshotDir, regionName), true); in deleteRegionManifest()
|
H A D | SnapshotInfo.java | 351 Path snapshotDir = SnapshotDescriptionUtils.getCompletedSnapshotDir(snapshotName, rootDir); in loadSnapshotInfo() local 352 if (!fs.exists(snapshotDir)) { in loadSnapshotInfo() 353 LOG.warn("Snapshot '" + snapshotName + "' not found in: " + snapshotDir); in loadSnapshotInfo() 357 SnapshotDescription snapshotDesc = SnapshotDescriptionUtils.readSnapshotInfo(fs, snapshotDir); in loadSnapshotInfo() 358 snapshotManifest = SnapshotManifest.open(getConf(), fs, snapshotDir, snapshotDesc); in loadSnapshotInfo() 490 Path snapshotDir = SnapshotDescriptionUtils.getCompletedSnapshotDir(snapshot, rootDir); in getSnapshotStats() local 491 SnapshotManifest manifest = SnapshotManifest.open(conf, fs, snapshotDir, snapshot); in getSnapshotStats() 520 Path snapshotDir = SnapshotDescriptionUtils.getSnapshotsDir(rootDir); in getSnapshotList() local 521 FileStatus[] snapshots = fs.listStatus(snapshotDir, in getSnapshotList()
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/master/snapshot/ |
H A D | SnapshotFileCache.java | 83 Collection<String> filesUnderSnapshot(final Path snapshotDir) throws IOException; in filesUnderSnapshot() argument 90 private final Path snapshotDir; field in SnapshotFileCache 134 this.snapshotDir = SnapshotDescriptionUtils.getSnapshotsDir(rootDir); in SnapshotFileCache() 210 FileStatus dirStatus = fs.getFileStatus(snapshotDir); in refreshCache() 215 LOG.error("Snapshot directory: " + snapshotDir + " doesn't exist"); in refreshCache() 223 Path snapshotTmpDir = new Path(snapshotDir, SnapshotDescriptionUtils.SNAPSHOT_TMP_DIR_NAME); in refreshCache() 228 FileStatus[] tmpSnapshots = FSUtils.listStatus(fs, snapshotDir); in refreshCache() 258 FileStatus[] snapshots = FSUtils.listStatus(fs, snapshotDir); in refreshCache() 298 Path snapshotTmpDir = new Path(snapshotDir, SnapshotDescriptionUtils.SNAPSHOT_TMP_DIR_NAME); in getSnapshotsInProgress()
|
H A D | SnapshotManager.java | 198 if (snapshotDir == null) snapshotDir = SnapshotDescriptionUtils.getSnapshotsDir(rootDir); in getCompletedSnapshots() 201 if (!fs.exists(snapshotDir)) { in getCompletedSnapshots() 206 FileStatus[] snapshots = fs.listStatus(snapshotDir, in getCompletedSnapshots() 282 snapshot = SnapshotDescriptionUtils.readSnapshotInfo(fs, snapshotDir); in deleteSnapshot() 292 if (!fs.delete(snapshotDir, true)) { in deleteSnapshot() 643 return fs.exists(snapshotDir); in isSnapshotCompleted() 694 if (!fs.exists(snapshotDir)) { in restoreSnapshot() 704 snapshotDir, snapshot); in restoreSnapshot() 1089 Path snapshotDir = SnapshotDescriptionUtils.getSnapshotsDir(mfs.getRootDir()); in checkSnapshotSupport() local 1090 if (fs.exists(snapshotDir)) { in checkSnapshotSupport() [all …]
|
H A D | MasterSnapshotVerifier.java | 106 public void verifySnapshot(Path snapshotDir, Set<String> snapshotServers) in verifySnapshot() argument 109 snapshotDir, snapshot); in verifySnapshot() 111 verifySnapshotDescription(snapshotDir); in verifySnapshot() 124 private void verifySnapshotDescription(Path snapshotDir) throws CorruptedSnapshotException { in verifySnapshotDescription() argument 125 SnapshotDescription found = SnapshotDescriptionUtils.readSnapshotInfo(fs, snapshotDir); in verifySnapshotDescription()
|
H A D | TakeSnapshotHandler.java | 81 private final Path snapshotDir; field in TakeSnapshotHandler 108 this.snapshotDir = SnapshotDescriptionUtils.getCompletedSnapshotDir(snapshot, rootDir); in TakeSnapshotHandler() 205 completeSnapshot(this.snapshotDir, this.workingDir, this.fs); in process() 254 public void completeSnapshot(Path snapshotDir, Path workingDir, FileSystem fs) in completeSnapshot() argument 257 + snapshotDir); in completeSnapshot() 258 if (!fs.rename(workingDir, snapshotDir)) { in completeSnapshot() 260 + ") to completed directory(" + snapshotDir + ")."); in completeSnapshot()
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/snapshot/ |
H A D | TestRestoreSnapshotHelper.java | 98 Path snapshotDir = builder.commit(); in restoreAndVerify() local 104 testRestore(snapshotDir, desc, htdClone); in restoreAndVerify() 142 public void testRestore(final Path snapshotDir, final SnapshotDescription sd, in testRestore() argument 144 LOG.debug("pre-restore table=" + htdClone.getTableName() + " snapshot=" + snapshotDir); in testRestore() 148 RestoreSnapshotHelper helper = getRestoreHelper(rootDir, snapshotDir, sd, htdClone); in testRestore() 151 LOG.debug("post-restore table=" + htdClone.getTableName() + " snapshot=" + snapshotDir); in testRestore() 158 private RestoreSnapshotHelper getRestoreHelper(final Path rootDir, final Path snapshotDir, in getRestoreHelper() argument 163 SnapshotManifest manifest = SnapshotManifest.open(conf, fs, snapshotDir, sd); in getRestoreHelper()
|
H A D | TestSnapshotManifest.java | 59 private Path snapshotDir; field in TestSnapshotManifest 74 snapshotDir = builder.commit(); in setup() 121 SnapshotManifest.open(conf, fs, snapshotDir, snapshotDesc); in testReadSnapshotManifest() 126 SnapshotManifest.open(conf, fs, snapshotDir, snapshotDesc); in testReadSnapshotManifest() 136 … FSDataOutputStream stream = fs.create(new Path(snapshotDir, SnapshotManifest.DATA_MANIFEST_NAME)); in writeDataManifest()
|
H A D | SnapshotTestingUtils.java | 199 Path snapshotDir = SnapshotDescriptionUtils.getCompletedSnapshotDir( in confirmSnapshotValid() local 201 assertTrue(fs.exists(snapshotDir)); in confirmSnapshotValid() 208 SnapshotManifest manifest = SnapshotManifest.open(conf, fs, snapshotDir, desc); in confirmSnapshotValid() 409 Path snapshotDir = SnapshotDescriptionUtils.getCompletedSnapshotDir(snapshotName, in corruptSnapshot() local 416 SnapshotReferenceUtil.visitTableStoreFiles(conf, fs, snapshotDir, snapshotDesc, in corruptSnapshot() 465 private Path snapshotDir; field in SnapshotTestingUtils.SnapshotMock.SnapshotBuilder 480 .createTableDescriptorForTableDirectory(snapshotDir, htd, false); in SnapshotBuilder() 492 return this.snapshotDir; in getSnapshotsDir() 528 SnapshotDescriptionUtils.completeSnapshot(desc, rootDir, snapshotDir, fs); in commit() 529 snapshotDir = SnapshotDescriptionUtils.getCompletedSnapshotDir(desc, rootDir); in commit() [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/test/java/org/apache/hadoop/hdfs/server/namenode/snapshot/ |
H A D | TestSnapshotDiffReport.java | 77 private String genSnapshotName(Path snapshotDir) { in genSnapshotName() argument 79 if (snapshotNumberMap.containsKey(snapshotDir)) { in genSnapshotName() 80 sNum = snapshotNumberMap.get(snapshotDir); in genSnapshotName() 82 snapshotNumberMap.put(snapshotDir, ++sNum); in genSnapshotName() 106 for (Path snapshotDir : snapshotDirs) { in modifyAndCreateSnapshot() 107 hdfs.allowSnapshot(snapshotDir); in modifyAndCreateSnapshot() 108 hdfs.createSnapshot(snapshotDir, genSnapshotName(snapshotDir)); in modifyAndCreateSnapshot() 125 for (Path snapshotDir : snapshotDirs) { in modifyAndCreateSnapshot() 126 hdfs.createSnapshot(snapshotDir, genSnapshotName(snapshotDir)); in modifyAndCreateSnapshot() 143 for (Path snapshotDir : snapshotDirs) { in modifyAndCreateSnapshot() [all …]
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/master/snapshot/ |
H A D | TestSnapshotFileCache.java | 79 Path snapshotDir = SnapshotDescriptionUtils.getSnapshotsDir(rootDir); in cleanupFiles() local 80 fs.delete(snapshotDir, true); in cleanupFiles() 101 Path snapshotDir = SnapshotDescriptionUtils.getSnapshotsDir(rootDir); in testJustFindLogsDirectory() local 104 public Collection<String> filesUnderSnapshot(final Path snapshotDir) in testJustFindLogsDirectory() 106 return SnapshotReferenceUtil.getWALNames(fs, snapshotDir); in testJustFindLogsDirectory() 239 public Collection<String> filesUnderSnapshot(final Path snapshotDir) throws IOException { in filesUnderSnapshot() argument 241 files.addAll(SnapshotReferenceUtil.getWALNames(fs, snapshotDir)); in filesUnderSnapshot() 242 files.addAll(SnapshotReferenceUtil.getHFileNames(UTIL.getConfiguration(), fs, snapshotDir)); in filesUnderSnapshot() local
|
/dports/devel/gitlab-runner/gitlab-runner-8925d9a06fd8e452e2161a768462652a2a13111f/vendor/github.com/containerd/containerd/containerd-1.4.3/snapshots/overlay/ |
H A D | overlay.go | 336 snapshotDir := filepath.Join(o.root, "snapshots") 337 fd, err := os.Open(snapshotDir) 354 cleanup = append(cleanup, filepath.Join(snapshotDir, d)) 383 snapshotDir := filepath.Join(o.root, "snapshots") 384 td, err = o.prepareDirectory(ctx, snapshotDir, kind) 421 path = filepath.Join(snapshotDir, s.ID) 435 func (o *snapshotter) prepareDirectory(ctx context.Context, snapshotDir string, kind snapshots.Kind… 436 td, err := ioutil.TempDir(snapshotDir, "new-")
|
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/containerd/containerd/snapshots/overlay/ |
H A D | overlay.go | 329 snapshotDir := filepath.Join(o.root, "snapshots") 330 fd, err := os.Open(snapshotDir) 347 cleanup = append(cleanup, filepath.Join(snapshotDir, d)) 376 snapshotDir := filepath.Join(o.root, "snapshots") 377 td, err = o.prepareDirectory(ctx, snapshotDir, kind) 414 path = filepath.Join(snapshotDir, s.ID) 428 func (o *snapshotter) prepareDirectory(ctx context.Context, snapshotDir string, kind snapshots.Kind… 429 td, err := ioutil.TempDir(snapshotDir, "new-")
|
/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/containerd/containerd/snapshots/overlay/ |
H A D | overlay.go | 332 snapshotDir := filepath.Join(o.root, "snapshots") 333 fd, err := os.Open(snapshotDir) 350 cleanup = append(cleanup, filepath.Join(snapshotDir, d)) 379 snapshotDir := filepath.Join(o.root, "snapshots") 380 td, err = o.prepareDirectory(ctx, snapshotDir, kind) 417 path = filepath.Join(snapshotDir, s.ID) 431 func (o *snapshotter) prepareDirectory(ctx context.Context, snapshotDir string, kind snapshots.Kind… 432 td, err := ioutil.TempDir(snapshotDir, "new-")
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/containerd/containerd/snapshots/overlay/ |
H A D | overlay.go | 322 snapshotDir := filepath.Join(o.root, "snapshots") 323 fd, err := os.Open(snapshotDir) 340 cleanup = append(cleanup, filepath.Join(snapshotDir, d)) 369 snapshotDir := filepath.Join(o.root, "snapshots") 370 td, err = o.prepareDirectory(ctx, snapshotDir, kind) 407 path = filepath.Join(snapshotDir, s.ID) 421 func (o *snapshotter) prepareDirectory(ctx context.Context, snapshotDir string, kind snapshots.Kind… 422 td, err := ioutil.TempDir(snapshotDir, "new-")
|
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/containerd/containerd/snapshots/overlay/ |
H A D | overlay.go | 332 snapshotDir := filepath.Join(o.root, "snapshots") 333 fd, err := os.Open(snapshotDir) 350 cleanup = append(cleanup, filepath.Join(snapshotDir, d)) 379 snapshotDir := filepath.Join(o.root, "snapshots") 380 td, err = o.prepareDirectory(ctx, snapshotDir, kind) 417 path = filepath.Join(snapshotDir, s.ID) 431 func (o *snapshotter) prepareDirectory(ctx context.Context, snapshotDir string, kind snapshots.Kind… 432 td, err := ioutil.TempDir(snapshotDir, "new-")
|
/dports/sysutils/helm/helm-3.5.2/vendor/github.com/containerd/containerd/snapshots/overlay/ |
H A D | overlay.go | 336 snapshotDir := filepath.Join(o.root, "snapshots") 337 fd, err := os.Open(snapshotDir) 354 cleanup = append(cleanup, filepath.Join(snapshotDir, d)) 383 snapshotDir := filepath.Join(o.root, "snapshots") 384 td, err = o.prepareDirectory(ctx, snapshotDir, kind) 421 path = filepath.Join(snapshotDir, s.ID) 435 func (o *snapshotter) prepareDirectory(ctx context.Context, snapshotDir string, kind snapshots.Kind… 436 td, err := ioutil.TempDir(snapshotDir, "new-")
|
/dports/security/vault/vault-1.8.2/vendor/github.com/containerd/containerd/snapshots/overlay/ |
H A D | overlay.go | 336 snapshotDir := filepath.Join(o.root, "snapshots") 337 fd, err := os.Open(snapshotDir) 354 cleanup = append(cleanup, filepath.Join(snapshotDir, d)) 383 snapshotDir := filepath.Join(o.root, "snapshots") 384 td, err = o.prepareDirectory(ctx, snapshotDir, kind) 421 path = filepath.Join(snapshotDir, s.ID) 435 func (o *snapshotter) prepareDirectory(ctx context.Context, snapshotDir string, kind snapshots.Kind… 436 td, err := ioutil.TempDir(snapshotDir, "new-")
|
/dports/misc/concourse/concourse-6.7.2/vendor/github.com/containerd/containerd/snapshots/overlay/ |
H A D | overlay.go | 329 snapshotDir := filepath.Join(o.root, "snapshots") 330 fd, err := os.Open(snapshotDir) 347 cleanup = append(cleanup, filepath.Join(snapshotDir, d)) 376 snapshotDir := filepath.Join(o.root, "snapshots") 377 td, err = o.prepareDirectory(ctx, snapshotDir, kind) 414 path = filepath.Join(snapshotDir, s.ID) 428 func (o *snapshotter) prepareDirectory(ctx context.Context, snapshotDir string, kind snapshots.Kind… 429 td, err := ioutil.TempDir(snapshotDir, "new-")
|
/dports/databases/hbase/hbase-1.2.1/hbase-server/src/test/java/org/apache/hadoop/hbase/master/cleaner/ |
H A D | TestSnapshotFromMaster.java | 204 Path snapshotDir = SnapshotDescriptionUtils.getCompletedSnapshotDir(snapshotName, rootDir); in testIsDoneContract() local 206 SnapshotDescriptionUtils.writeSnapshotInfo(desc, snapshotDir, fs); in testIsDoneContract() 223 Path snapshotDir = SnapshotDescriptionUtils.getCompletedSnapshotDir(snapshotName, rootDir); in testGetCompletedSnapshots() local 225 SnapshotDescriptionUtils.writeSnapshotInfo(snapshot, snapshotDir, fs); in testGetCompletedSnapshots() 236 snapshotDir = SnapshotDescriptionUtils.getCompletedSnapshotDir(snapshotName, rootDir); in testGetCompletedSnapshots() 238 SnapshotDescriptionUtils.writeSnapshotInfo(snapshot, snapshotDir, fs); in testGetCompletedSnapshots() 264 Path snapshotDir = SnapshotDescriptionUtils.getCompletedSnapshotDir(snapshotName, rootDir); in testDeleteSnapshot() local 265 SnapshotDescriptionUtils.writeSnapshotInfo(snapshot, snapshotDir, fs); in testDeleteSnapshot()
|
/dports/sysutils/terraform-provider-gridscale/terraform-provider-gridscale-1.6.2/vendor/github.com/hashicorp/terraform-plugin-sdk/internal/configs/configload/ |
H A D | loader_snapshot.go | 261 return snapshotDir{ 313 _, isDir := f.(snapshotDir) 374 type snapshotDir struct { struct 380 var _ afero.File = snapshotDir{} 382 func (f snapshotDir) Readdir(count int) ([]os.FileInfo, error) { argument 397 func (f snapshotDir) Readdirnames(count int) ([]string, error) { argument
|
/dports/sysutils/terraform-provider-vultr/terraform-provider-vultr-0.1.10/vendor/github.com/hashicorp/terraform/configs/configload/ |
H A D | loader_snapshot.go | 261 return snapshotDir{ 313 _, isDir := f.(snapshotDir) 374 type snapshotDir struct { struct 380 var _ afero.File = snapshotDir{} 382 func (f snapshotDir) Readdir(count int) ([]os.FileInfo, error) { argument 397 func (f snapshotDir) Readdirnames(count int) ([]string, error) { argument
|
/dports/sysutils/terraform/terraform-1.0.11/internal/configs/configload/ |
H A D | loader_snapshot.go | 261 return snapshotDir{ 313 _, isDir := f.(snapshotDir) 374 type snapshotDir struct { struct 380 var _ afero.File = snapshotDir{} 382 func (f snapshotDir) Readdir(count int) ([]os.FileInfo, error) { argument 397 func (f snapshotDir) Readdirnames(count int) ([]string, error) { argument
|