X-Git-Url: https://git.mdrn.pl/pylucene.git/blobdiff_plain/a2e61f0c04805cfcb8706176758d1283c7e3a55c..aaeed5504b982cf3545252ab528713250aa33eed:/lucene-java-3.4.0/lucene/src/test/org/apache/lucene/index/TestIndexWriterOnJRECrash.java

diff --git a/lucene-java-3.4.0/lucene/src/test/org/apache/lucene/index/TestIndexWriterOnJRECrash.java b/lucene-java-3.4.0/lucene/src/test/org/apache/lucene/index/TestIndexWriterOnJRECrash.java
deleted file mode 100644
index 4950436..0000000
--- a/lucene-java-3.4.0/lucene/src/test/org/apache/lucene/index/TestIndexWriterOnJRECrash.java
+++ /dev/null
@@ -1,162 +0,0 @@
-package org.apache.lucene.index;
-
-/**
- *  Licensed to the Apache Software Foundation (ASF) under one or more
- *  contributor license agreements.  See the NOTICE file distributed with
- *  this work for additional information regarding copyright ownership.
- *  The ASF licenses this file to You under the Apache License, Version 2.0
- *  (the "License"); you may not use this file except in compliance with
- *  the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- *  Unless required by applicable law or agreed to in writing, software
- *  distributed under the License is distributed on an "AS IS" BASIS,
- *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *  See the License for the specific language governing permissions and
- *  limitations under the License.
- *
- */
-
-import java.io.BufferedInputStream;
-import java.io.File;
-import java.io.IOException;
-import java.io.InputStream;
-import java.lang.reflect.Field;
-import java.lang.reflect.Method;
-import java.util.ArrayList;
-import java.util.List;
-
-import org.apache.lucene.store.Directory;
-import org.apache.lucene.store.MockDirectoryWrapper;
-import org.apache.lucene.util.Constants;
-import org.apache.lucene.util._TestUtil;
-
-/**
- * Runs TestNRTThreads in a separate process, crashes the JRE in the middle
- * of execution, then runs checkindex to make sure its not corrupt.
- */
-public class TestIndexWriterOnJRECrash extends TestNRTThreads {
-  private File tempDir;
-  
-  @Override
-  public void setUp() throws Exception {
-    super.setUp();
-    tempDir = _TestUtil.getTempDir("jrecrash");
-    tempDir.delete();
-    tempDir.mkdir();
-  }
-  
-  @Override
-  public void testNRTThreads() throws Exception {
-    String vendor = Constants.JAVA_VENDOR;
-    assumeTrue(vendor + " JRE not supported.", 
-        vendor.startsWith("Oracle") || vendor.startsWith("Sun") || vendor.startsWith("Apple"));
-    
-    // if we are not the fork
-    if (System.getProperty("tests.crashmode") == null) {
-      // try up to 10 times to create an index
-      for (int i = 0; i < 10; i++) {
-        forkTest();
-        // if we succeeded in finding an index, we are done.
-        if (checkIndexes(tempDir))
-          return;
-      }
-    } else {
-      // we are the fork, setup a crashing thread
-      final int crashTime = _TestUtil.nextInt(random, 3000, 4000);
-      Thread t = new Thread() {
-        @Override
-        public void run() {
-          try {
-            Thread.sleep(crashTime);
-          } catch (InterruptedException e) {}
-          crashJRE();
-        }
-      };
-      t.setPriority(Thread.MAX_PRIORITY);
-      t.start();
-      // run the test until we crash.
-      for (int i = 0; i < 1000; i++) {
-        super.testNRTThreads();
-      }
-    }
-  }
-  
-  /** fork ourselves in a new jvm. sets -Dtests.crashmode=true */
-  public void forkTest() throws Exception {
-    List<String> cmd = new ArrayList<String>();
-    cmd.add(System.getProperty("java.home") 
-        + System.getProperty("file.separator")
-        + "bin"
-        + System.getProperty("file.separator")
-        + "java");
-    cmd.add("-Xmx512m");
-    cmd.add("-Dtests.crashmode=true");
-    // passing NIGHTLY to this test makes it run for much longer, easier to catch it in the act...
-    cmd.add("-Dtests.nightly=true");
-    cmd.add("-DtempDir=" + tempDir.getPath());
-    cmd.add("-Dtests.seed=" + random.nextLong() + ":" + random.nextLong());
-    cmd.add("-ea");
-    cmd.add("-cp");
-    cmd.add(System.getProperty("java.class.path"));
-    cmd.add("org.junit.runner.JUnitCore");
-    cmd.add(getClass().getName());
-    ProcessBuilder pb = new ProcessBuilder(cmd);
-    pb.directory(tempDir);
-    pb.redirectErrorStream(true);
-    Process p = pb.start();
-    InputStream is = p.getInputStream();
-    BufferedInputStream isl = new BufferedInputStream(is);
-    byte buffer[] = new byte[1024];
-    int len = 0;
-    if (VERBOSE) System.err.println(">>> Begin subprocess output");
-    while ((len = isl.read(buffer)) != -1) {
-      if (VERBOSE) {
-        System.err.write(buffer, 0, len);
-      }
-    }
-    if (VERBOSE) System.err.println("<<< End subprocess output");
-    p.waitFor();
-  }
-  
-  /**
-   * Recursively looks for indexes underneath <code>file</code>,
-   * and runs checkindex on them. returns true if it found any indexes.
-   */
-  public boolean checkIndexes(File file) throws IOException {
-    if (file.isDirectory()) {
-      MockDirectoryWrapper dir = newFSDirectory(file);
-      dir.setCheckIndexOnClose(false); // don't double-checkindex
-      if (IndexReader.indexExists(dir)) {
-        if (VERBOSE) {
-          System.err.println("Checking index: " + file);
-        }
-        _TestUtil.checkIndex(dir);
-        dir.close();
-        return true;
-      }
-      dir.close();
-      for (File f : file.listFiles())
-        if (checkIndexes(f))
-          return true;
-    }
-    return false;
-  }
-  
-  /**
-   * currently, this only works/tested on Sun and IBM.
-   */
-  public void crashJRE() {
-    try {
-      Class<?> clazz = Class.forName("sun.misc.Unsafe");
-      // we should use getUnsafe instead, harmony implements it, etc.
-      Field field = clazz.getDeclaredField("theUnsafe");
-      field.setAccessible(true);
-      Object o = field.get(null);
-      Method m = clazz.getMethod("putAddress", long.class, long.class);
-      m.invoke(o, 0L, 0L);
-    } catch (Exception e) { e.printStackTrace(); }
-    fail();
-  }
-}