grr/server/grr_response_server/databases/mysql_flows.py
def AckFlowProcessingRequests(self, requests, cursor=None):
    """Deletes a list of flow processing requests from the database."""
    if not requests:
      return

    query = "DELETE FROM flow_processing_requests WHERE "

    conditions = []
    args = []
    for r in requests:
      conditions.append("(client_id=%s AND flow_id=%s AND timestamp=%s)")
      args.append(mysql_utils.ClientIDToInt(r.client_id))
      args.append(mysql_utils.FlowIDToInt(r.flow_id))
      args.append(mysql_utils.RDFDatetimeToMysqlString(r.timestamp))

    query += " OR ".join(conditions)
    cursor.execute(query, args)
Deletes a list of flow processing requests from the database.
Deletes a list of flow processing requests from the database.
Deletes a list of flow processing requests from the database .
def AckFlowProcessingRequests(self, requests, cursor=None):
    if not requests:
      return
    query = "DELETE FROM flow_processing_requests WHERE "
    conditions = []
    args = []
    for r in requests:
      conditions.append("(client_id=%s AND flow_id=%s AND timestamp=%s)")
      args.append(mysql_utils.ClientIDToInt(r.client_id))
      args.append(mysql_utils.FlowIDToInt(r.flow_id))
      args.append(mysql_utils.RDFDatetimeToMysqlString(r.timestamp))
    query += " OR ".join(conditions)
    cursor.execute(query, args)
def AckFlowProcessingRequests ( self , requests , cursor = None ) : if not requests : return query = "DELETE FROM flow_processing_requests WHERE " conditions = [ ] args = [ ] for r in requests : conditions . append ( "(client_id=%s AND flow_id=%s AND timestamp=%s)" ) args . append ( mysql_utils . ClientIDToInt ( r . client_id ) ) args . append ( mysql_utils . FlowIDToInt ( r . flow_id ) ) args . append ( mysql_utils . RDFDatetimeToMysqlString ( r . timestamp ) ) query += " OR " . join ( conditions ) cursor . execute ( query , args )
Deletes a list of flow processing requests from the database.
Deletes a list of flow processing requests from the database .
"""Deletes a list of flow processing requests from the database."""
self
requests
cursor