natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Removed the dependencies for JDK7. 

git-svn-id: https://svn.apache.org/repos/asf/incubator/cassandra/trunk@756731 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Avinash Lakshman 2009-03-20 19:49:11 +00:00
parent 5bea7e1772
commit ff2cf35aff
1 changed files with 0 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/org/apache/cassandra/db/CommitLog.java
View File

@ -19,7 +19,6 @@
package org.apache.cassandra.db; package org.apache.cassandra.db;
import java.io.*; import java.io.*;
import java.nio.file.Path;
import java.util.*; import java.util.*;
import org.apache.cassandra.config.CFMetaData; import org.apache.cassandra.config.CFMetaData;
@ -628,28 +627,6 @@ class CommitLog
forcedRollOver_ = true; forcedRollOver_ = true;
} }
synchronized public void snapshot( String snapshotDirectory ) throws IOException
{
Map<String, List<File>> tableToCommitLogs = RecoveryManager.getListOFCommitLogsPerTable();
List<File> clogs = tableToCommitLogs.get(table_);
if( clogs != null )
{
File snapshotDir = new File(snapshotDirectory);
if( !snapshotDir.exists() )
snapshotDir.mkdir();
File commitLogSnapshotDir = new File(snapshotDirectory + System.getProperty("file.separator") + "CommitLogs");
if( !commitLogSnapshotDir.exists() )
commitLogSnapshotDir.mkdir();
for (File file : clogs)
{
Path existingLink = file.toPath();
File hardLinkFile = new File(commitLogSnapshotDir.getAbsolutePath() + System.getProperty("file.separator") + file.getName());
Path hardLink = hardLinkFile.toPath();
hardLink.createLink(existingLink);
}
}
}
public static void main(String[] args) throws Throwable public static void main(String[] args) throws Throwable
{ {
LogUtil.init(); LogUtil.init();