Searched defs:lock (Results 1 - 14 of 14) sorted by relevance

/lucene-3.6.0/lucene/core/src/java/org/apache/lucene/store/
H A DLock.java23 /** 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 DVerifyingLockFactory.java27 * 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 DNativeFSLockFactory.java32 * 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 DDummyConcurrentLock.java26 * 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 DPhoneticFilterFactory.java76 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 DTestTransactions.java81 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 DTestTransactions.java81 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 DStreamingUpdateSolrServer.java67 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 DConcurrentUpdateSolrServer.java71 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 DLuceneJUnitResultFormatter.java66 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 DLuceneJUnitResultFormatter.java66 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 DMultiSearcher.java359 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 DIndexSearcher.java449 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 DTrecContentSource.java95 private Object lock = new Object(); field in class:TrecContentSource
258 synchronized (lock) {
303 synchronized (lock) {

Completed in 30 milliseconds