本文整理了Java中org.hibernate.search.util.logging.impl.Log.tracef()
方法的一些代码示例,展示了Log.tracef()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Log.tracef()
方法的具体详情如下:
包路径:org.hibernate.search.util.logging.impl.Log
类名称:Log
方法名:tracef
暂无
代码示例来源:origin: hibernate/hibernate-search
@Override
public void beforeCompletion() {
if ( prepared ) {
log.tracef( "Transaction's beforeCompletion() phase already been processed, ignoring: %s", this );
}
else {
log.tracef( "Processing Transaction's beforeCompletion() phase: %s", this );
queueingProcessor.prepareWorks( queue );
prepared = true;
}
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
@Override
public void beforeCompletion() {
if ( prepared ) {
log.tracef( "Transaction's beforeCompletion() phase already been processed, ignoring: %s", this );
}
else {
log.tracef( "Processing Transaction's beforeCompletion() phase: %s", this );
queueingProcessor.prepareWorks( queue );
prepared = true;
}
}
代码示例来源:origin: hibernate/hibernate-search
@Override
public String getProperty(String key) {
String compositeKey = radix + key;
String value = masked.getProperty( compositeKey );
if ( value != null ) {
log.tracef( "found a match for key: [%s] value: %s", compositeKey, value );
return value;
}
else if ( fallBack != null ) {
return fallBack.getProperty( key );
}
else {
return null;
}
}
代码示例来源:origin: hibernate/hibernate-search
private void enqueueList(final List<Serializable> idsList) throws InterruptedException {
if ( ! idsList.isEmpty() ) {
destination.put( idsList );
log.tracef( "produced a list of ids %s", idsList );
}
}
代码示例来源:origin: hibernate/hibernate-search
@Override
public void closeIndexReader(IndexReader reader) {
if ( reader == null ) {
return;
}
log.tracef( "Closing IndexReader: %s", reader );
ReaderUsagePair container = allReaders.get( reader );
container.close(); //virtual
}
代码示例来源:origin: hibernate/hibernate-search
@Override
public void closeIndexReader(IndexReader reader) {
if ( reader == null ) {
return;
}
log.tracef( "Closing IndexReader: %s", reader );
ReaderUsagePair container = allReaders.get( reader );
container.close(); //virtual
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
@Override
public void closeIndexReader(IndexReader reader) {
if ( reader == null ) {
return;
}
log.tracef( "Closing IndexReader: %s", reader );
ReaderUsagePair container = allReaders.get( reader );
container.close(); //virtual
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
@Override
public void closeIndexReader(IndexReader reader) {
if ( reader == null ) {
return;
}
log.tracef( "Closing IndexReader: %s", reader );
ReaderUsagePair container = allReaders.get( reader );
container.close(); //virtual
}
代码示例来源:origin: hibernate/hibernate-search
@Override
public void run() {
if ( copyTask.inProgress.compareAndSet( false, true ) ) {
executor.execute( copyTask );
}
else {
if ( log.isTraceEnabled() ) {
@SuppressWarnings("unused")
int unneeded = current;//ensure visibility of indexName in Timer threads.
log.tracef( "Skipping directory synchronization, previous work still in progress: %s", indexDir );
}
}
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
@Override
public void run() {
if ( copyTask.inProgress.compareAndSet( false, true ) ) {
executor.execute( copyTask );
}
else {
if ( log.isTraceEnabled() ) {
@SuppressWarnings("unused")
int unneeded = current;//ensure visibility of indexName in Timer threads.
log.tracef( "Skipping directory synchronization, previous work still in progress: %s", indexDir );
}
}
}
代码示例来源:origin: hibernate/hibernate-search
public boolean massIndexerThreadsAreInterruptedOrDied() {
for ( Thread th : threads ) {
if ( th.isAlive() ) {
if ( !th.isInterrupted() ) {
log.tracef( "Thread [" + th + "] is not interrupted or alive" );
return false;
}
}
}
return true;
}
代码示例来源:origin: hibernate/hibernate-search
@Override
public IndexReader openIndexReader() {
log.tracef( "Opening IndexReader for directoryProvider %s", indexName );
Directory directory = directoryProvider.getDirectory();
PerDirectoryLatestReader directoryLatestReader = currentReaders.get( directory );
// might eg happen for FSSlaveDirectoryProvider or for mutable SearchFactory
if ( directoryLatestReader == null ) {
directoryLatestReader = createReader( directory );
}
return directoryLatestReader.getLatestReader();
}
代码示例来源:origin: hibernate/hibernate-search
@Override
public DirectoryReader openIndexReader() {
log.tracef( "Opening IndexReader for directoryProvider %s", indexName );
Directory directory = directoryProvider.getDirectory();
PerDirectoryLatestReader directoryLatestReader = currentReaders.get( directory );
// might eg happen for FSSlaveDirectoryProvider or for mutable SearchFactory
if ( directoryLatestReader == null ) {
directoryLatestReader = createReader( directory );
}
return directoryLatestReader.refreshAndGet();
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
@Override
public DirectoryReader openIndexReader() {
log.tracef( "Opening IndexReader for directoryProvider %s", indexName );
Directory directory = directoryProvider.getDirectory();
PerDirectoryLatestReader directoryLatestReader = currentReaders.get( directory );
// might eg happen for FSSlaveDirectoryProvider or for mutable SearchFactory
if ( directoryLatestReader == null ) {
directoryLatestReader = createReader( directory );
}
return directoryLatestReader.refreshAndGet();
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
@Override
public IndexReader openIndexReader() {
log.tracef( "Opening IndexReader for directoryProvider %s", indexName );
Directory directory = directoryProvider.getDirectory();
PerDirectoryLatestReader directoryLatestReader = currentReaders.get( directory );
// might eg happen for FSSlaveDirectoryProvider or for mutable SearchFactory
if ( directoryLatestReader == null ) {
directoryLatestReader = createReader( directory );
}
return directoryLatestReader.getLatestReader();
}
代码示例来源:origin: hibernate/hibernate-search
@Override
public void performWork(LuceneWork work, IndexWriterDelegate delegate, IndexingMonitor monitor) {
final IndexedTypeIdentifier entityType = work.getEntityType();
log.tracef( "optimize Lucene index: %s", entityType );
workspace.performOptimization( delegate.getIndexWriter() );
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
@Override
public void performWork(LuceneWork work, IndexWriterDelegate delegate, IndexingMonitor monitor) {
final IndexedTypeIdentifier entityType = work.getEntityType();
log.tracef( "optimize Lucene index: %s", entityType );
workspace.performOptimization( delegate.getIndexWriter() );
}
代码示例来源:origin: hibernate/hibernate-search
public WorkQueue splitQueue() {
if ( log.isTraceEnabled() ) {
log.tracef( "Splitting work queue with %d works", (Integer) plan.size() );
}
WorkQueue subQueue = new WorkQueue( extendedIntegrator, plan );
this.plan = new WorkPlan( extendedIntegrator );
this.sealedAndUnchanged = false;
return subQueue;
}
代码示例来源:origin: org.infinispan/infinispan-embedded-query
public WorkQueue splitQueue() {
if ( log.isTraceEnabled() ) {
log.tracef( "Splitting work queue with %d works", (Integer) plan.size() );
}
WorkQueue subQueue = new WorkQueue( extendedIntegrator, plan );
this.plan = new WorkPlan( extendedIntegrator );
this.sealedAndUnchanged = false;
return subQueue;
}
代码示例来源:origin: hibernate/hibernate-search
@Override
public void documentsBuilt(int number) {
super.documentsBuilt( number );
log.debug( "enlist EntityLoader thread [" + Thread.currentThread() + "] and simulate document producer activity" );
threads.add( Thread.currentThread() );
busyThreads.incrementAndGet();
while ( true ) {
// simulate activity until thread interrupted
if ( Thread.currentThread().isInterrupted() ) {
log.tracef( "Indexing thread is interrupted : end activity simulation " );
break;
}
}
busyThreads.decrementAndGet();
}
内容来源于网络,如有侵权,请联系作者删除!