+++ /dev/null
-package org.apache.lucene.store;
-
-/**
- * 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.IOException;
-
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.Collections;
-import java.util.List;
-import java.util.Set;
-import java.util.HashSet;
-
-/**
- * Expert: A Directory instance that switches files between
- * two other Directory instances.
-
- * <p>Files with the specified extensions are placed in the
- * primary directory; others are placed in the secondary
- * directory. The provided Set must not change once passed
- * to this class, and must allow multiple threads to call
- * contains at once.</p>
- *
- * @lucene.experimental
- */
-
-public class FileSwitchDirectory extends Directory {
- private final Directory secondaryDir;
- private final Directory primaryDir;
- private final Set<String> primaryExtensions;
- private boolean doClose;
-
- public FileSwitchDirectory(Set<String> primaryExtensions, Directory primaryDir, Directory secondaryDir, boolean doClose) {
- this.primaryExtensions = primaryExtensions;
- this.primaryDir = primaryDir;
- this.secondaryDir = secondaryDir;
- this.doClose = doClose;
- this.lockFactory = primaryDir.getLockFactory();
- }
-
- /** Return the primary directory */
- public Directory getPrimaryDir() {
- return primaryDir;
- }
-
- /** Return the secondary directory */
- public Directory getSecondaryDir() {
- return secondaryDir;
- }
-
- @Override
- public void close() throws IOException {
- if (doClose) {
- try {
- secondaryDir.close();
- } finally {
- primaryDir.close();
- }
- doClose = false;
- }
- }
-
- @Override
- public String[] listAll() throws IOException {
- Set<String> files = new HashSet<String>();
- // LUCENE-3380: either or both of our dirs could be FSDirs,
- // but if one underlying delegate is an FSDir and mkdirs() has not
- // yet been called, because so far everything is written to the other,
- // in this case, we don't want to throw a NoSuchDirectoryException
- NoSuchDirectoryException exc = null;
- try {
- for(String f : primaryDir.listAll()) {
- files.add(f);
- }
- } catch (NoSuchDirectoryException e) {
- exc = e;
- }
- try {
- for(String f : secondaryDir.listAll()) {
- files.add(f);
- }
- } catch (NoSuchDirectoryException e) {
- // we got NoSuchDirectoryException from both dirs
- // rethrow the first.
- if (exc != null) {
- throw exc;
- }
- // we got NoSuchDirectoryException from the secondary,
- // and the primary is empty.
- if (files.isEmpty()) {
- throw e;
- }
- }
- // we got NoSuchDirectoryException from the primary,
- // and the secondary is empty.
- if (exc != null && files.isEmpty()) {
- throw exc;
- }
- return files.toArray(new String[files.size()]);
- }
-
- /** Utility method to return a file's extension. */
- public static String getExtension(String name) {
- int i = name.lastIndexOf('.');
- if (i == -1) {
- return "";
- }
- return name.substring(i+1, name.length());
- }
-
- private Directory getDirectory(String name) {
- String ext = getExtension(name);
- if (primaryExtensions.contains(ext)) {
- return primaryDir;
- } else {
- return secondaryDir;
- }
- }
-
- @Override
- public boolean fileExists(String name) throws IOException {
- return getDirectory(name).fileExists(name);
- }
-
- @Override
- public long fileModified(String name) throws IOException {
- return getDirectory(name).fileModified(name);
- }
-
- @Deprecated
- @Override
- /* @deprecated Lucene never uses this API; it will be
- * removed in 4.0. */
- public void touchFile(String name) throws IOException {
- getDirectory(name).touchFile(name);
- }
-
- @Override
- public void deleteFile(String name) throws IOException {
- getDirectory(name).deleteFile(name);
- }
-
- @Override
- public long fileLength(String name) throws IOException {
- return getDirectory(name).fileLength(name);
- }
-
- @Override
- public IndexOutput createOutput(String name) throws IOException {
- return getDirectory(name).createOutput(name);
- }
-
- @Deprecated
- @Override
- public void sync(String name) throws IOException {
- sync(Collections.singleton(name));
- }
-
- @Override
- public void sync(Collection<String> names) throws IOException {
- List<String> primaryNames = new ArrayList<String>();
- List<String> secondaryNames = new ArrayList<String>();
-
- for (String name : names)
- if (primaryExtensions.contains(getExtension(name)))
- primaryNames.add(name);
- else
- secondaryNames.add(name);
-
- primaryDir.sync(primaryNames);
- secondaryDir.sync(secondaryNames);
- }
-
- @Override
- public IndexInput openInput(String name) throws IOException {
- return getDirectory(name).openInput(name);
- }
-}
fnp / pylucene.git / blobdiff