X-Git-Url: https://gerrit.simantics.org/r/gitweb?a=blobdiff_plain;f=bundles%2Forg.simantics.databoard%2Ftestcases%2Forg%2Fsimantics%2Fdataboard%2Ftests%2FTestDirectoryWatch.java;h=fef8bd6d1b6904fc42cbfcb919e14f25f0c3fa36;hb=459ca221e046b0ed539e4eab4486a0a3178a4eba;hp=93ca4bb022d1690584cc5f0d16232c1c5a8c56b8;hpb=969bd23cab98a79ca9101af33334000879fb60c5;p=simantics%2Fplatform.git diff --git a/bundles/org.simantics.databoard/testcases/org/simantics/databoard/tests/TestDirectoryWatch.java b/bundles/org.simantics.databoard/testcases/org/simantics/databoard/tests/TestDirectoryWatch.java index 93ca4bb02..fef8bd6d1 100644 --- a/bundles/org.simantics.databoard/testcases/org/simantics/databoard/tests/TestDirectoryWatch.java +++ b/bundles/org.simantics.databoard/testcases/org/simantics/databoard/tests/TestDirectoryWatch.java @@ -1,110 +1,110 @@ -/******************************************************************************* - * Copyright (c) 2010- Association for Decentralized Information Management in - * Industry THTH ry. - * All rights reserved. This program and the accompanying materials - * are made available under the terms of the Eclipse Public License v1.0 - * which accompanies this distribution, and is available at - * http://www.eclipse.org/legal/epl-v10.html - * - * Contributors: - * VTT Technical Research Centre of Finland - initial API and implementation - *******************************************************************************/ -package org.simantics.databoard.tests; - -import java.io.File; -import java.io.FileFilter; -import java.util.ArrayList; -import java.util.List; -import java.util.Random; - -import junit.framework.TestCase; - -import org.simantics.databoard.accessor.impl.DirectoryWatch; -import org.simantics.databoard.accessor.impl.DirectoryWatch.DirectoryEvent; -import org.simantics.databoard.accessor.impl.DirectoryWatch.DirectoryListener; - -/** - * This test case tests Wathc Servlet. - * - * It creates a random named directory under $TMP$ - * There it - * - * @author Toni Kalajainen - */ -public class TestDirectoryWatch extends TestCase { - - File tmpDir; - - public static File createTmpDir() - { - String tmp = System.getenv("tmp"); - if (tmp==null) tmp = "c:/temp"; - Random r = new Random(); - String randomName = "tmp-"+(r.nextInt(10000)+10000); - File tmpDir = new File(tmp+"/"+randomName); - Boolean ok = tmpDir.mkdirs(); - assertTrue( ok ); - return tmpDir; - } - - public void setUp() throws Exception { - tmpDir = createTmpDir(); - } - - @Override - protected void tearDown() throws Exception { - boolean ok = tmpDir.delete(); - if (!ok) System.err.println(tmpDir+" was not removed."); - } - - public void testAll() - throws Exception { - - FileFilter filter = new FileFilter() { - public boolean accept(File pathname) { - return pathname.getAbsolutePath().toLowerCase().endsWith(".dbb"); - }}; - - DirectoryWatch monitor = new DirectoryWatch(tmpDir, filter); - - final DirectoryEvent result = new DirectoryEvent(); - - // Set listener that collects changes - monitor.addListener(new DirectoryListener() { - @Override - public void onWatchEvent(DirectoryEvent e) { - result.filesAdded.addAll(e.filesAdded); - result.filesRemoved.addAll(e.filesRemoved); - }}); - - // Create file names - List files = new ArrayList(); - for (int i=1; i<10; i++) { - files.add( new File(tmpDir, "file-"+i+".dbb") ); - } - - // Create files - for (File f : files) - { - f.createNewFile(); - } - Thread.sleep( DirectoryWatch.POLL_INTERVAL*2 ); - assertTrue( files.containsAll( result.filesAdded ) ); - assertTrue( result.filesAdded.containsAll( files ) ); - assertTrue( result.filesRemoved.isEmpty() ); - result.filesAdded.clear(); - - // Delete files - for (File f : files) - f.delete(); - Thread.sleep( DirectoryWatch.POLL_INTERVAL*2 ); - assertTrue( files.containsAll( result.filesRemoved ) ); - assertTrue( result.filesRemoved.containsAll( files ) ); - assertTrue( result.filesAdded.isEmpty() ); - result.filesRemoved.clear(); - - monitor.close(); - } - -} - +/******************************************************************************* + * Copyright (c) 2010- Association for Decentralized Information Management in + * Industry THTH ry. + * All rights reserved. This program and the accompanying materials + * are made available under the terms of the Eclipse Public License v1.0 + * which accompanies this distribution, and is available at + * http://www.eclipse.org/legal/epl-v10.html + * + * Contributors: + * VTT Technical Research Centre of Finland - initial API and implementation + *******************************************************************************/ +package org.simantics.databoard.tests; + +import java.io.File; +import java.io.FileFilter; +import java.util.ArrayList; +import java.util.List; +import java.util.Random; + +import junit.framework.TestCase; + +import org.simantics.databoard.accessor.impl.DirectoryWatch; +import org.simantics.databoard.accessor.impl.DirectoryWatch.DirectoryEvent; +import org.simantics.databoard.accessor.impl.DirectoryWatch.DirectoryListener; + +/** + * This test case tests Wathc Servlet. + * + * It creates a random named directory under $TMP$ + * There it + * + * @author Toni Kalajainen + */ +public class TestDirectoryWatch extends TestCase { + + File tmpDir; + + public static File createTmpDir() + { + String tmp = System.getenv("tmp"); + if (tmp==null) tmp = "c:/temp"; + Random r = new Random(); + String randomName = "tmp-"+(r.nextInt(10000)+10000); + File tmpDir = new File(tmp+"/"+randomName); + Boolean ok = tmpDir.mkdirs(); + assertTrue( ok ); + return tmpDir; + } + + public void setUp() throws Exception { + tmpDir = createTmpDir(); + } + + @Override + protected void tearDown() throws Exception { + boolean ok = tmpDir.delete(); + if (!ok) System.err.println(tmpDir+" was not removed."); + } + + public void testAll() + throws Exception { + + FileFilter filter = new FileFilter() { + public boolean accept(File pathname) { + return pathname.getAbsolutePath().toLowerCase().endsWith(".dbb"); + }}; + + DirectoryWatch monitor = new DirectoryWatch(tmpDir, filter); + + final DirectoryEvent result = new DirectoryEvent(); + + // Set listener that collects changes + monitor.addListener(new DirectoryListener() { + @Override + public void onWatchEvent(DirectoryEvent e) { + result.filesAdded.addAll(e.filesAdded); + result.filesRemoved.addAll(e.filesRemoved); + }}); + + // Create file names + List files = new ArrayList(); + for (int i=1; i<10; i++) { + files.add( new File(tmpDir, "file-"+i+".dbb") ); + } + + // Create files + for (File f : files) + { + f.createNewFile(); + } + Thread.sleep( DirectoryWatch.POLL_INTERVAL*2 ); + assertTrue( files.containsAll( result.filesAdded ) ); + assertTrue( result.filesAdded.containsAll( files ) ); + assertTrue( result.filesRemoved.isEmpty() ); + result.filesAdded.clear(); + + // Delete files + for (File f : files) + f.delete(); + Thread.sleep( DirectoryWatch.POLL_INTERVAL*2 ); + assertTrue( files.containsAll( result.filesRemoved ) ); + assertTrue( result.filesRemoved.containsAll( files ) ); + assertTrue( result.filesAdded.isEmpty() ); + result.filesRemoved.clear(); + + monitor.close(); + } + +} +