Home
last modified time | relevance | path

Searched refs:snapshotDir (Results 1 – 25 of 75) sorted by relevance

123

/dports/databases/hbase/hbase-1.2.1/hbase-server/src/main/java/org/apache/hadoop/hbase/snapshot/
H A DSnapshotReferenceUtil.java89 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 DSnapshotManifestV2.java66 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 DSnapshotManifestV1.java68 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 DSnapshotInfo.java351 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 DSnapshotFileCache.java83 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 DSnapshotManager.java198 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 DMasterSnapshotVerifier.java106 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 DTakeSnapshotHandler.java81 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 DTestRestoreSnapshotHelper.java98 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 DTestSnapshotManifest.java59 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 DSnapshotTestingUtils.java199 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 DTestSnapshotDiffReport.java77 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 DTestSnapshotFileCache.java79 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 Doverlay.go336 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 Doverlay.go329 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 Doverlay.go332 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 Doverlay.go322 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 Doverlay.go332 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 Doverlay.go336 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 Doverlay.go336 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 Doverlay.go329 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 DTestSnapshotFromMaster.java204 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 Dloader_snapshot.go261 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 Dloader_snapshot.go261 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 Dloader_snapshot.go261 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

123