grr/server/grr_response_server/databases/mysql_flows.py
def _FlowObjectFromRow(self, row):
    """Generates a flow object from a database row."""

    flow, cci, pt, nr, pd, po, ps, ts, lut = row

    flow_obj = rdf_flow_objects.Flow.FromSerializedString(flow)
    if cci is not None:
      cc_cls = rdf_client.ClientCrash
      flow_obj.client_crash_info = cc_cls.FromSerializedString(cci)
    if pt is not None:
      pt_cls = rdf_flow_objects.PendingFlowTermination
      flow_obj.pending_termination = pt_cls.FromSerializedString(pt)
    if nr:
      flow_obj.next_request_to_process = nr
    if pd is not None:
      flow_obj.processing_deadline = mysql_utils.MysqlToRDFDatetime(pd)
    if po is not None:
      flow_obj.processing_on = po
    if ps is not None:
      flow_obj.processing_since = mysql_utils.MysqlToRDFDatetime(ps)
    flow_obj.timestamp = mysql_utils.MysqlToRDFDatetime(ts)
    flow_obj.last_update_time = mysql_utils.MysqlToRDFDatetime(lut)

    return flow_obj
Generates a flow object from a database row.
Generates a flow object from a database row.
Generates a flow object from a database row .
def _FlowObjectFromRow(self, row):
    flow, cci, pt, nr, pd, po, ps, ts, lut = row
    flow_obj = rdf_flow_objects.Flow.FromSerializedString(flow)
    if cci is not None:
      cc_cls = rdf_client.ClientCrash
      flow_obj.client_crash_info = cc_cls.FromSerializedString(cci)
    if pt is not None:
      pt_cls = rdf_flow_objects.PendingFlowTermination
      flow_obj.pending_termination = pt_cls.FromSerializedString(pt)
    if nr:
      flow_obj.next_request_to_process = nr
    if pd is not None:
      flow_obj.processing_deadline = mysql_utils.MysqlToRDFDatetime(pd)
    if po is not None:
      flow_obj.processing_on = po
    if ps is not None:
      flow_obj.processing_since = mysql_utils.MysqlToRDFDatetime(ps)
    flow_obj.timestamp = mysql_utils.MysqlToRDFDatetime(ts)
    flow_obj.last_update_time = mysql_utils.MysqlToRDFDatetime(lut)
    return flow_obj
def _FlowObjectFromRow ( self , row ) : flow , cci , pt , nr , pd , po , ps , ts , lut = row flow_obj = rdf_flow_objects . Flow . FromSerializedString ( flow ) if cci is not None : cc_cls = rdf_client . ClientCrash flow_obj . client_crash_info = cc_cls . FromSerializedString ( cci ) if pt is not None : pt_cls = rdf_flow_objects . PendingFlowTermination flow_obj . pending_termination = pt_cls . FromSerializedString ( pt ) if nr : flow_obj . next_request_to_process = nr if pd is not None : flow_obj . processing_deadline = mysql_utils . MysqlToRDFDatetime ( pd ) if po is not None : flow_obj . processing_on = po if ps is not None : flow_obj . processing_since = mysql_utils . MysqlToRDFDatetime ( ps ) flow_obj . timestamp = mysql_utils . MysqlToRDFDatetime ( ts ) flow_obj . last_update_time = mysql_utils . MysqlToRDFDatetime ( lut ) return flow_obj
Generates a flow object from a database row.
Generates a flow object from a database row .
"""Generates a flow object from a database row."""
self
row