#NEWLINE# def decode_packet( self , pid , length , data ) : #NEWLINE# #INDENT# data = super ( DownloadProtocol , self ) . decode_packet ( pid , length , data ) #NEWLINE# try : #NEWLINE# #INDENT# if ( pid == self . link_proto . PID_RECORDS ) : #NEWLINE# #INDENT# self . on_start ( pid , data ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( pid in self . pid_data ) : #NEWLINE# #INDENT# self . on_data ( pid , data ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( pid == self . link_proto . PID_XFER_CMPLT ) : #NEWLINE# #INDENT# self . on_finish ( pid , data ) #NEWLINE# #UNINDENT# #UNINDENT# #UNINDENT# #UNINDENT# except Exception : #NEWLINE# #INDENT# _log . warning ( 'Caught exception sending notification of download status, ignoring error' , exc_info = True ) #NEWLINE# #UNINDENT# finally : #NEWLINE# #INDENT# return data