org.hibernate.search.util.logging.impl.Log.tracef()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(7.3k)|赞(0)|评价(0)|浏览(146)

本文整理了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

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();
}

相关文章

微信公众号

最新文章

更多

Log类方法