/lucene-3.6.0/lucene/core/src/java/org/apache/lucene/store/ |
H A D | Lock.java | 23 /** An interprocess mutex lock. 25 * new Lock.With(directory.makeLock("my.lock")) { 37 * in between attempts to acquire the lock. */ 41 * forever to obtain the lock. */ 51 * If a lock obtain called, this failureReason may be set 52 * with the "root cause" Exception as to why the lock was 57 /** Attempts to obtain an exclusive lock within amount of 64 * @return true if lock was obtained 65 * @throws LockObtainFailedException if lock wait times out 110 private Lock lock; field in class:Lock.With 115 With(Lock lock, long lockWaitTimeout) argument [all...] |
H A D | VerifyingLockFactory.java | 27 * LockFactory} and verifies that each lock obtain/release 29 * lock at the same time). It does this by contacting an 31 * at most one process holds the lock at a time. To use 47 private Lock lock; field in class:VerifyingLockFactory.CheckedLock 49 public CheckedLock(Lock lock) { argument 50 this.lock = lock; 65 throw new RuntimeException("lock was double acquired"); 74 boolean obtained = lock.obtain(lockWaitTimeout); 83 return lock [all...] |
H A D | NativeFSLockFactory.java | 32 * environments the java.nio.* locks will fail (the lock can 37 * first and work around the one limitation that a lock file 41 * that lock files will be properly removed (by the OS) if 45 * leftover lock files in the filesystem on exiting the JVM 61 * lock directory. When you pass this factory to a {@link FSDirectory} 62 * subclass, the lock directory is automatically set to the 71 * Create a NativeFSLockFactory instance, storing lock 74 * @param lockDirName where lock files are created. 81 * Create a NativeFSLockFactory instance, storing lock 84 * @param lockDir where lock file 126 private FileLock lock; field in class:NativeFSLock [all...] |
/lucene-3.6.0/lucene/core/src/java/org/apache/lucene/util/ |
H A D | DummyConcurrentLock.java | 26 * A dummy lock as a replacement for {@link ReentrantLock} to disable locking 34 public void lock() {} method in class:DummyConcurrentLock
|
/lucene-3.6.0/solr/core/src/java/org/apache/solr/analysis/ |
H A D | PhoneticFilterFactory.java | 76 private static final Lock lock = new ReentrantLock(); field in class:PhoneticFilterFactory 95 lock.lock(); 99 lock.unlock();
|
/lucene-3.6.0/lucene/core/src/test/org/apache/lucene/index/ |
H A D | TestTransactions.java | 81 Object lock; field in class:TestTransactions.IndexerThread 84 public IndexerThread(Object lock, Directory dir1, Directory dir2, TimedThread[] threads) { argument 86 this.lock = lock; 119 synchronized(lock) { 168 Object lock; field in class:TestTransactions.SearcherThread 170 public SearcherThread(Object lock, Directory dir1, Directory dir2, TimedThread[] threads) { argument 172 this.lock = lock; 180 synchronized(lock) { [all...] |
/lucene-3.6.0/lucene/backwards/src/test/org/apache/lucene/index/ |
H A D | TestTransactions.java | 81 Object lock; field in class:TestTransactions.IndexerThread 84 public IndexerThread(Object lock, Directory dir1, Directory dir2, TimedThread[] threads) { argument 86 this.lock = lock; 119 synchronized(lock) { 168 Object lock; field in class:TestTransactions.SearcherThread 170 public SearcherThread(Object lock, Directory dir1, Directory dir2, TimedThread[] threads) { argument 172 this.lock = lock; 180 synchronized(lock) { [all...] |
/lucene-3.6.0/solr/solrj/src/java/org/apache/solr/client/solrj/impl/ |
H A D | StreamingUpdateSolrServer.java | 67 volatile CountDownLatch lock = null; // used to block everything field in class:StreamingUpdateSolrServer 100 runnerLock.lock(); 231 CountDownLatch tmpLock = lock; 250 // while we are still holding the runners lock to prevent race conditions. 256 // Retry to add to the queue w/o the runners lock held (else we risk temporary deadlock) 284 lock = new CountDownLatch(1); 293 runner.runnerLock.lock(); 297 lock.countDown(); 298 lock=null;
|
H A D | ConcurrentUpdateSolrServer.java | 71 volatile CountDownLatch lock = null; // used to block everything field in class:ConcurrentUpdateSolrServer 113 runnerLock.lock(); 250 CountDownLatch tmpLock = lock; 277 // while we are still holding the runners lock to prevent race 285 // Retry to add to the queue w/o the runners lock held (else we risk 314 lock = new CountDownLatch(1); 324 runner.runnerLock.lock(); 328 lock.countDown(); 329 lock = null;
|
/lucene-3.6.0/lucene/test-framework/src/java/org/apache/lucene/util/ |
H A D | LuceneJUnitResultFormatter.java | 66 private static final org.apache.lucene.store.Lock lock; field in class:LuceneJUnitResultFormatter 78 lock = lockFactory.makeLock("junit_lock"); 178 lock.obtain(5000); 184 lock.release();
|
/lucene-3.6.0/lucene/backwards/src/test-framework/java/org/apache/lucene/util/ |
H A D | LuceneJUnitResultFormatter.java | 66 private static final org.apache.lucene.store.Lock lock; field in class:LuceneJUnitResultFormatter 78 lock = lockFactory.makeLock("junit_lock"); 178 lock.obtain(5000); 184 lock.release();
|
/lucene-3.6.0/lucene/core/src/java/org/apache/lucene/search/ |
H A D | MultiSearcher.java | 359 private final Lock lock; field in class:MultiSearcher.MultiSearcherCallableNoSort 368 public MultiSearcherCallableNoSort(Lock lock, Searchable searchable, Weight weight, argument 370 this.lock = lock; 387 lock.lock(); 392 lock.unlock(); 404 private final Lock lock; field in class:MultiSearcher.MultiSearcherCallableWithSort 414 public MultiSearcherCallableWithSort(Lock lock, Searchable searchable, Weight weight, argument 416 this.lock [all...] |
H A D | IndexSearcher.java | 449 final Lock lock = new ReentrantLock(); 454 new MultiSearcherCallableNoSort(lock, subSearchers[i], weight, filter, after, nDocs, hq)); 526 final Lock lock = new ReentrantLock(); 530 new MultiSearcherCallableWithSort(lock, subSearchers[i], weight, filter, nDocs, topCollector, sort)); 672 private final Lock lock; field in class:IndexSearcher.MultiSearcherCallableNoSort 680 public MultiSearcherCallableNoSort(Lock lock, IndexSearcher searchable, Weight weight, argument 682 this.lock = lock; 702 lock.lock(); 723 private final Lock lock; field in class:IndexSearcher.MultiSearcherCallableWithSort 731 MultiSearcherCallableWithSort(Lock lock, IndexSearcher searchable, Weight weight, Filter filter, int nDocs, TopFieldCollector hq, Sort sort) argument [all...] |
/lucene-3.6.0/lucene/contrib/benchmark/src/java/org/apache/lucene/benchmark/byTask/feeds/ |
H A D | TrecContentSource.java | 95 private Object lock = new Object(); field in class:TrecContentSource 258 synchronized (lock) { 303 synchronized (lock) {
|