grr/server/grr_response_server/flow_base.py
def TerminateFlow(client_id, flow_id, reason=None):
  """Terminates a flow and all of its children."""

  to_terminate = [data_store.REL_DB.ReadFlowObject(client_id, flow_id)]

  while to_terminate:
    next_to_terminate = []
    for rdf_flow in to_terminate:
      _TerminateFlow(rdf_flow, reason=reason)
      next_to_terminate.extend(
          data_store.REL_DB.ReadChildFlowObjects(rdf_flow.client_id,
                                                 rdf_flow.flow_id))
    to_terminate = next_to_terminate
Terminates a flow and all of its children.
Terminates a flow and all of its children.
Terminates a flow and all of its children .
def TerminateFlow(client_id, flow_id, reason=None):
  to_terminate = [data_store.REL_DB.ReadFlowObject(client_id, flow_id)]
  while to_terminate:
    next_to_terminate = []
    for rdf_flow in to_terminate:
      _TerminateFlow(rdf_flow, reason=reason)
      next_to_terminate.extend(
          data_store.REL_DB.ReadChildFlowObjects(rdf_flow.client_id,
                                                 rdf_flow.flow_id))
    to_terminate = next_to_terminate
def TerminateFlow ( client_id , flow_id , reason = None ) : to_terminate = [ data_store . REL_DB . ReadFlowObject ( client_id , flow_id ) ] while to_terminate : next_to_terminate = [ ] for rdf_flow in to_terminate : _TerminateFlow ( rdf_flow , reason = reason ) next_to_terminate . extend ( data_store . REL_DB . ReadChildFlowObjects ( rdf_flow . client_id , rdf_flow . flow_id ) ) to_terminate = next_to_terminate
Terminates a flow and all of its children.
Terminates a flow and all of its children .
"""Terminates a flow and all of its children."""
client_id
flow_id
reason