inteligr8/alfresco-community-repo
1
0
Fork 0
mirror of https://github.com/Alfresco/alfresco-community-repo.git synced 2025-08-07 17:49:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

ContentDiskDriverTest needs to initialise new JLAN stuff introduced by merge of JLAN_CLUSTER.

Browse Source 
git-svn-id: https://svn.alfresco.com/repos/alfresco-enterprise/alfresco/HEAD/root@28851 c4b6b30b-aa2e-2d43-bbcb-ca4b014f7261
This commit is contained in:
Mark Rogers
2011-07-07 14:20:05 +00:00
parent a13c8cbf7e
commit 86f3c8cd8c
1 changed files with 61 additions and 96 deletions
Download Patch File Download Diff File Expand all files Collapse all files

157
source/java/org/alfresco/filesys/repo/ContentDiskDriverTest.java
View File

@@ -47,10 +47,14 @@ import org.alfresco.jlan.server.filesys.FileAttribute;
import org.alfresco.jlan.server.filesys.FileExistsException; import org.alfresco.jlan.server.filesys.FileExistsException;
import org.alfresco.jlan.server.filesys.FileInfo; import org.alfresco.jlan.server.filesys.FileInfo;
import org.alfresco.jlan.server.filesys.FileOpenParams; import org.alfresco.jlan.server.filesys.FileOpenParams;
import org.alfresco.jlan.server.filesys.FilesystemsConfigSection;
import org.alfresco.jlan.server.filesys.NetworkFile; import org.alfresco.jlan.server.filesys.NetworkFile;
import org.alfresco.jlan.server.filesys.NetworkFileServer; import org.alfresco.jlan.server.filesys.NetworkFileServer;
import org.alfresco.jlan.server.filesys.SearchContext; import org.alfresco.jlan.server.filesys.SearchContext;
import org.alfresco.jlan.server.filesys.TreeConnection; import org.alfresco.jlan.server.filesys.TreeConnection;
import org.alfresco.filesys.config.ServerConfigurationBean;
import org.alfresco.model.ContentModel; import org.alfresco.model.ContentModel;
import org.alfresco.model.ForumModel; import org.alfresco.model.ForumModel;
import org.alfresco.repo.action.evaluator.NoConditionEvaluator; import org.alfresco.repo.action.evaluator.NoConditionEvaluator;
@@ -190,91 +194,41 @@ public class ContentDiskDriverTest extends TestCase
// txn.getStatus(); // txn.getStatus();
// txn.rollback(); // txn.rollback();
} }
/**
* Test create context.
*
* Must have "store" and "rootPath"
*/
public void testCreateContext() throws Exception
{
logger.debug("testCreateContext");
GenericConfigElement cfg1 = new GenericConfigElement("filesystem");
GenericConfigElement store = new GenericConfigElement("store");
store.setValue(STORE_NAME);
cfg1.addChild(store);
GenericConfigElement rootPath = new GenericConfigElement("rootPath");
rootPath.setValue(ROOT_PATH);
cfg1.addChild(rootPath);
/**
* Step 1: Call create context and expect it to succeed
*/
DeviceContext context = driver.createContext(SHARE_NAME, cfg1);
assertTrue (context instanceof ContentContext);
assertNotNull (context);
ContentContext ctx = (ContentContext)context;
assertEquals("Device name wrong", SHARE_NAME, ctx.getDeviceName());
assertEquals("Root Path wrong", ROOT_PATH, ctx.getRootPath());
context.CloseContext();
/**
* Step 2: Negative test - missing store property
*/
try
{
GenericConfigElement cfg2 = new GenericConfigElement("filesystem");
cfg2.addChild(rootPath);
driver.createContext(SHARE_NAME, cfg2);
fail("missing store not detected");
}
catch (DeviceContextException de)
{
// expect to go here
}
/**
* Step 3: Negative test - missing rootPath property
*/
try
{
GenericConfigElement cfg2 = new GenericConfigElement("filesystem");
cfg2.addChild(store);
driver.createContext(SHARE_NAME, cfg2);
fail("missing store not detected");
}
catch (DeviceContextException de)
{
// expect to go here
}
}
private DiskSharedDevice getDiskSharedDevice() throws DeviceContextException private DiskSharedDevice getDiskSharedDevice() throws DeviceContextException
{ {
ServerConfiguration scfg = new ServerConfiguration("testServer"); ServerConfiguration scfg = new ServerConfiguration("testServer");
TestServer testServer = new TestServer("testServer", scfg);
SrvSession testSession = new TestSrvSession(666, testServer, "test", "remoteName"); FilesystemsConfigSection fcfg = new FilesystemsConfigSection(scfg);
GenericConfigElement cfg1 = new GenericConfigElement("filesystem"); // TestServer testServer = new TestServer("testServer", scfg);
// SrvSession testSession = new TestSrvSession(666, testServer, "test", "remoteName");
GenericConfigElement store = new GenericConfigElement("store"); //
store.setValue(STORE_NAME); // GenericConfigElement cfg1 = new GenericConfigElement("filesystem");
cfg1.addChild(store); //
// GenericConfigElement store = new GenericConfigElement("store");
GenericConfigElement rootPath = new GenericConfigElement("rootPath"); // store.setValue(STORE_NAME);
rootPath.setValue(ROOT_PATH); // cfg1.addChild(store);
cfg1.addChild(rootPath); //
// GenericConfigElement rootPath = new GenericConfigElement("rootPath");
ContentContext filesysContext = (ContentContext) driver.createContext(STORE_NAME, cfg1); // rootPath.setValue(ROOT_PATH);
// cfg1.addChild(rootPath);
DiskSharedDevice share = new DiskSharedDevice("test", driver, filesysContext); //
// ContentContext filesysContext = (ContentContext) driver.createContext(STORE_NAME, cfg1);
//
// DiskSharedDevice share = new DiskSharedDevice("test", driver, filesysContext);
ContentContext ctx = new ContentContext( "testContext", STORE_NAME, ROOT_PATH, repositoryHelper.getCompanyHome());
ServerConfigurationBean scb = new ServerConfigurationBean("testServer");
scb.addConfigSection(fcfg);
ctx.setServerConfigurationBean(scb);
ctx.enableStateCache(true);
DiskSharedDevice share = new DiskSharedDevice("test", driver, ctx);
return share; return share;
} }
@@ -289,7 +243,9 @@ public class ContentDiskDriverTest extends TestCase
TestServer testServer = new TestServer("testServer", scfg); TestServer testServer = new TestServer("testServer", scfg);
SrvSession testSession = new TestSrvSession(666, testServer, "test", "remoteName"); SrvSession testSession = new TestSrvSession(666, testServer, "test", "remoteName");
DiskSharedDevice share = getDiskSharedDevice(); DiskSharedDevice share = getDiskSharedDevice();
TreeConnection testConnection = testServer.getTreeConnection(share); TreeConnection testConnection = testServer.getTreeConnection(share);
final RetryingTransactionHelper tran = transactionService.getRetryingTransactionHelper(); final RetryingTransactionHelper tran = transactionService.getRetryingTransactionHelper();
class TestContext class TestContext
@@ -304,7 +260,7 @@ public class ContentDiskDriverTest extends TestCase
*/ */
int openAction = FileAction.CreateNotExist; int openAction = FileAction.CreateNotExist;
final String FILE_NAME="testCreateFile.new"; final String FILE_NAME="testCreateFile2.new";
final String FILE_PATH="\\"+FILE_NAME; final String FILE_PATH="\\"+FILE_NAME;
FileOpenParams params = new FileOpenParams(FILE_PATH, openAction, AccessMode.ReadWrite, FileAttribute.NTNormal, 0); FileOpenParams params = new FileOpenParams(FILE_PATH, openAction, AccessMode.ReadWrite, FileAttribute.NTNormal, 0);
@@ -390,20 +346,26 @@ public class ContentDiskDriverTest extends TestCase
ServerConfiguration scfg = new ServerConfiguration("testServer"); ServerConfiguration scfg = new ServerConfiguration("testServer");
TestServer testServer = new TestServer("testServer", scfg); TestServer testServer = new TestServer("testServer", scfg);
SrvSession testSession = new TestSrvSession(666, testServer, "test", "remoteName"); SrvSession testSession = new TestSrvSession(666, testServer, "test", "remoteName");
DiskSharedDevice share = getDiskSharedDevice();
GenericConfigElement cfg1 = new GenericConfigElement("filesystem"); // ServerConfiguration scfg = new ServerConfiguration("testServer");
// TestServer testServer = new TestServer("testServer", scfg);
GenericConfigElement store = new GenericConfigElement("store"); // SrvSession testSession = new TestSrvSession(666, testServer, "test", "remoteName");
store.setValue(STORE_NAME); //
cfg1.addChild(store); // GenericConfigElement cfg1 = new GenericConfigElement("filesystem");
//
GenericConfigElement rootPath = new GenericConfigElement("rootPath"); // GenericConfigElement store = new GenericConfigElement("store");
rootPath.setValue(ROOT_PATH); // store.setValue(STORE_NAME);
cfg1.addChild(rootPath); // cfg1.addChild(store);
//
ContentContext filesysContext = (ContentContext) driver.createContext(STORE_NAME, cfg1); // GenericConfigElement rootPath = new GenericConfigElement("rootPath");
// rootPath.setValue(ROOT_PATH);
DiskSharedDevice share = new DiskSharedDevice("test", driver, filesysContext); // cfg1.addChild(rootPath);
//
// ContentContext filesysContext = (ContentContext) driver.createContext(STORE_NAME, cfg1);
//
// DiskSharedDevice share = new DiskSharedDevice("test", driver, filesysContext);
TreeConnection testConnection = testServer.getTreeConnection(share); TreeConnection testConnection = testServer.getTreeConnection(share);
final RetryingTransactionHelper tran = transactionService.getRetryingTransactionHelper(); final RetryingTransactionHelper tran = transactionService.getRetryingTransactionHelper();
@@ -788,6 +750,7 @@ public class ContentDiskDriverTest extends TestCase
SrvSession testSession = new TestSrvSession(666, testServer, "test", "remoteName"); SrvSession testSession = new TestSrvSession(666, testServer, "test", "remoteName");
DiskSharedDevice share = getDiskSharedDevice(); DiskSharedDevice share = getDiskSharedDevice();
final TreeConnection testConnection = testServer.getTreeConnection(share); final TreeConnection testConnection = testServer.getTreeConnection(share);
final RetryingTransactionHelper tran = transactionService.getRetryingTransactionHelper(); final RetryingTransactionHelper tran = transactionService.getRetryingTransactionHelper();
final String FILE_PATH1=TEST_ROOT_DOS_PATH + "\\SourceFile1.new"; final String FILE_PATH1=TEST_ROOT_DOS_PATH + "\\SourceFile1.new";
@@ -926,6 +889,7 @@ public class ContentDiskDriverTest extends TestCase
SrvSession testSession = new TestSrvSession(666, testServer, "test", "remoteName"); SrvSession testSession = new TestSrvSession(666, testServer, "test", "remoteName");
DiskSharedDevice share = getDiskSharedDevice(); DiskSharedDevice share = getDiskSharedDevice();
final TreeConnection testConnection = testServer.getTreeConnection(share); final TreeConnection testConnection = testServer.getTreeConnection(share);
final RetryingTransactionHelper tran = transactionService.getRetryingTransactionHelper(); final RetryingTransactionHelper tran = transactionService.getRetryingTransactionHelper();
final String FILE_PATH1=TEST_ROOT_DOS_PATH + "\\SourceFile1.new"; final String FILE_PATH1=TEST_ROOT_DOS_PATH + "\\SourceFile1.new";
@@ -1037,6 +1001,7 @@ public class ContentDiskDriverTest extends TestCase
final SrvSession testSession = new TestSrvSession(666, testServer, "test", "remoteName"); final SrvSession testSession = new TestSrvSession(666, testServer, "test", "remoteName");
DiskSharedDevice share = getDiskSharedDevice(); DiskSharedDevice share = getDiskSharedDevice();
final TreeConnection testConnection = testServer.getTreeConnection(share); final TreeConnection testConnection = testServer.getTreeConnection(share);
final RetryingTransactionHelper tran = transactionService.getRetryingTransactionHelper(); final RetryingTransactionHelper tran = transactionService.getRetryingTransactionHelper();
/** /**
@@ -2067,7 +2032,7 @@ public class ContentDiskDriverTest extends TestCase
final RetryingTransactionHelper tran = transactionService.getRetryingTransactionHelper(); final RetryingTransactionHelper tran = transactionService.getRetryingTransactionHelper();
int openAction = FileAction.CreateNotExist; int openAction = FileAction.CreateNotExist;
String FILE_PATH="\\testCreateFile.new"; String FILE_PATH="\\testDeleteFile.new";
FileOpenParams params = new FileOpenParams(FILE_PATH, openAction, AccessMode.ReadWrite, FileAttribute.NTNormal, 0); FileOpenParams params = new FileOpenParams(FILE_PATH, openAction, AccessMode.ReadWrite, FileAttribute.NTNormal, 0);