3 _Afw@sPddlmZddlZddlZdZdZdZGdddeZej dd Z d d Z dS) )print_functionNcommandz sync-networkz sync-localc@sJeZdZdZddZdddZd d Zd d Zd dZddZ ddZ dS)EventLogaEvent log that records events that occurred during a repo invocation. Events are written to the log as a consecutive JSON entries, one per line. Each entry contains the following keys: - id: A ('RepoOp', ID) tuple, suitable for storing in a datastore. The ID is only unique for the invocation of the repo command. - name: Name of the object being operated upon. - task_name: The task that was performed. - start: Timestamp of when the operation started. - finish: Timestamp of when the operation finished. - success: Boolean indicating if the operation was successful. - try_count: A counter indicating the try count of this task. Optionally: - parent: A ('RepoOp', ID) tuple indicating the parent event for nested events. Valid task_names include: - command: The invocation of a subcommand. - sync-network: The network component of a sync command. - sync-local: The local component of a sync command. Specific tasks may include additional informational properties. cCsg|_d|_dS)zInitializes the event log.N)_log_parent)selfr;/home/qytech/356xLinux510-101server/.repo/repo/event_log.py__init__5szEventLog.__init__NRepoOpc CsX|tf||||d}|jr*|jd|d<|dk s:|dk rH|j||||jj||S)aAdd an event to the log. Args: name: Name of the object being operated upon. task_name: A sub-task that was performed for name. start: Timestamp of when the operation started. finish: Timestamp of when the operation finished. success: Boolean indicating if the operation was successful. try_count: A counter indicating the try count of this task. kind: The kind of the object for the unique identifier. Returns: A dictionary of the event added to the log. )idname task_nameZ start_timetryr parentN) _NextEventIdr FinishEventrappend) rrrstartfinishsuccessZ try_countkindeventrrr Add:s z EventLog.Addc Cs|j|j||||}|dk r|j|d<|jr6|j|d<|jjrJ|jj|d<|jjr^|jj|d<y|j|d<Wntk rYnX|S)aAdd a event to the log for a sync command. Args: project: Project being synced. task_name: A sub-task that was performed for name. One of (TASK_SYNC_NETWORK, TASK_SYNC_LOCAL) start: Timestamp of when the operation started. finish: Timestamp of when the operation finished. success: Boolean indicating if the operation was successful. Returns: A dictionary of the event added to the log. NprojectrevisionZ project_urlZ remote_urlZgit_hash) rrelpathrZ revisionExprZremoteurlZfetchUrlZGetCommitRevisionId Exception)rrrrrrrrrr AddSync[s    zEventLog.AddSynccCs |rdSdS)zConverst a boolean success to a status string. Args: success: Boolean indicating if the operation was successful. Returns: status string. passZfailr)rrrrr GetStatusStringxs zEventLog.GetStatusStringcCs|j||d<||d<|S)aFinishes an incomplete event. Args: event: An event that has been added to the log. finish: Timestamp of when the operation finished. success: Boolean indicating if the operation was successful. Returns: A dictionary of the event added to the log. statusZ finish_time)r")rrrrrrr rs zEventLog.FinishEventcCs ||_dS)zcSet a parent event for all new entities. Args: event: The event to use as a parent. N)r)rrrrr SetParentszEventLog.SetParentc CsDt|d0}x(|jD]}tj||dd|jdqWWdQRXdS)z[Writes the log out to a file. Args: filename: The file to write the log to. zw+T)Z sort_keys N)openrjsondumpwrite)rfilenameferrr Writes  zEventLog.Write)NNr r ) __name__ __module__ __qualname____doc__r rr r"rr$r-rrrr rs  rir c Cs,tjtj}tjd7_WdQRX|S)z|Helper function for grabbing the next unique id. Returns: A unique, to this invocation of the program, integer id. r N) _EVENT_IDZget_lockvalue)valrrr rs r) __future__rr'Zmultiprocessing TASK_COMMANDZTASK_SYNC_NETWORKZTASK_SYNC_LOCALobjectrZValuer3rrrrr s