#NEWLINE# def __init__( self , server , app_name = None ) : #NEWLINE# #INDENT# self . server = server #NEWLINE# self . app_name = app_name #NEWLINE# self . prefix = get_rpc_prefix ( self . app_name , FUNC_PREFIX ) #NEWLINE# self . inc_counter = Counter ( ) #NEWLINE# self . acc_counter = Counter ( agg = MergeAggregator ( ) ) #NEWLINE# self . lock = threading . Lock ( )