#NEWLINE# def read_get( self , reader , with_cas_unique = False ) : #NEWLINE# #INDENT# result = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# while True : #NEWLINE# #INDENT# response_line = reader . read_line ( ) #NEWLINE# if response_line . startswith ( 'VALUE' ) : #NEWLINE# #INDENT# response_fields = response_line . split ( ' ' ) #NEWLINE# key = response_fields [ 1 ] #NEWLINE# flags = int ( response_fields [ 2 ] ) #NEWLINE# n = int ( response_fields [ 3 ] ) #NEWLINE# if with_cas_unique : #NEWLINE# #INDENT# cas_unique = int ( response_fields [ 4 ] ) #NEWLINE# #UNINDENT# encoded_value = reader . read_bytes ( n ) #NEWLINE# reader . read_line ( ) #NEWLINE# if with_cas_unique : #NEWLINE# #INDENT# result [ key ] = ( self . _codec . decode ( flags , encoded_value ) , cas_unique ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# result [ key ] = self . _codec . decode ( flags , encoded_value ) #NEWLINE# #UNINDENT# #UNINDENT# else : #NEWLINE# #INDENT# if ( response_line == 'END' ) : #NEWLINE# #INDENT# return ( MemcacheResult . OK , result ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# return ( MemcacheResult . get ( response_line ) , { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } )