Module org.apache.lucene.core

Package org.apache.lucene.index

Class DocumentsWriterFlushQueue

java.lang.Object

org.apache.lucene.index.DocumentsWriterFlushQueue

final class DocumentsWriterFlushQueue
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	DocumentsWriterFlushQueue.FlushTicket

Field Summary

Fields

Modifier and Type	Field	Description
private final ReentrantLock	purgeLock
private final Queue<DocumentsWriterFlushQueue.FlushTicket>	queue
private final AtomicInteger	ticketCount

Constructor Summary

Constructors

Constructor	Description
DocumentsWriterFlushQueue()

Method Summary

Modifier and Type	Method	Description
(package private) boolean	addDeletes(DocumentsWriterDeleteQueue deleteQueue)
(package private) DocumentsWriterFlushQueue.FlushTicket	addFlushTicket(DocumentsWriterPerThread dwpt)
(package private) void	addSegment(DocumentsWriterFlushQueue.FlushTicket ticket, DocumentsWriterPerThread.FlushedSegment segment)
private void	decTickets()
(package private) void	forcePurge(IOConsumer<DocumentsWriterFlushQueue.FlushTicket> consumer)
(package private) int	getTicketCount()
(package private) boolean	hasTickets()
private void	incTickets()
private void	innerPurge(IOConsumer<DocumentsWriterFlushQueue.FlushTicket> consumer)
(package private) void	markTicketFailed(DocumentsWriterFlushQueue.FlushTicket ticket)
(package private) void	tryPurge(IOConsumer<DocumentsWriterFlushQueue.FlushTicket> consumer)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

queue

private final Queue<DocumentsWriterFlushQueue.FlushTicket> queue

ticketCount

private final AtomicInteger ticketCount

purgeLock

private final ReentrantLock purgeLock

Constructor Details

DocumentsWriterFlushQueue

DocumentsWriterFlushQueue()

Method Details

addDeletes

boolean addDeletes(DocumentsWriterDeleteQueue deleteQueue)
            throws IOException

Throws:

IOException

incTickets

private void incTickets()

decTickets

private void decTickets()

addFlushTicket

DocumentsWriterFlushQueue.FlushTicket addFlushTicket(DocumentsWriterPerThread dwpt)
                                              throws IOException

Throws:

IOException

addSegment

void addSegment(DocumentsWriterFlushQueue.FlushTicket ticket,
 DocumentsWriterPerThread.FlushedSegment segment)

markTicketFailed

void markTicketFailed(DocumentsWriterFlushQueue.FlushTicket ticket)

hasTickets

boolean hasTickets()

innerPurge

private void innerPurge(IOConsumer<DocumentsWriterFlushQueue.FlushTicket> consumer)
                 throws IOException

Throws:

IOException

forcePurge

void forcePurge(IOConsumer<DocumentsWriterFlushQueue.FlushTicket> consumer)
         throws IOException

Throws:

IOException

tryPurge

void tryPurge(IOConsumer<DocumentsWriterFlushQueue.FlushTicket> consumer)
       throws IOException

Throws:

IOException

getTicketCount

int getTicketCount()