#NEWLINE# def FetchWindow( self , number_of_chunks_to_readahead ) : #NEWLINE# #INDENT# 'Read ahead a number of buffers to fill the window.' #NEWLINE# for _ in range ( number_of_chunks_to_readahead ) : #NEWLINE# #INDENT# if ( self . state . current_chunk_number > self . state . max_chunk_number ) : #NEWLINE# #INDENT# return #NEWLINE# #UNINDENT# request = rdf_client . BufferReference ( pathspec = self . args . pathspec , offset = ( self . state . current_chunk_number * self . CHUNK_SIZE ) , length = self . CHUNK_SIZE ) #NEWLINE# self . CallClient ( 'TransferBuffer' , request , next_state = 'ReadBuffer' ) #NEWLINE# self . state . current_chunk_number += 1