grr/server/grr_response_server/databases/mysql_flows.py
def ReadFlowProcessingRequests(self, cursor=None):
    """Reads all flow processing requests from the database."""
    query = "SELECT request, timestamp FROM flow_processing_requests"
    cursor.execute(query)

    res = []
    for serialized_request, ts in cursor.fetchall():
      req = rdf_flows.FlowProcessingRequest.FromSerializedString(
          serialized_request)
      req.timestamp = mysql_utils.MysqlToRDFDatetime(ts)
      res.append(req)
    return res
Reads all flow processing requests from the database.
Reads all flow processing requests from the database.
Reads all flow processing requests from the database .
def ReadFlowProcessingRequests(self, cursor=None):
    query = "SELECT request, timestamp FROM flow_processing_requests"
    cursor.execute(query)
    res = []
    for serialized_request, ts in cursor.fetchall():
      req = rdf_flows.FlowProcessingRequest.FromSerializedString(
          serialized_request)
      req.timestamp = mysql_utils.MysqlToRDFDatetime(ts)
      res.append(req)
    return res
def ReadFlowProcessingRequests ( self , cursor = None ) : query = "SELECT request, timestamp FROM flow_processing_requests" cursor . execute ( query ) res = [ ] for serialized_request , ts in cursor . fetchall ( ) : req = rdf_flows . FlowProcessingRequest . FromSerializedString ( serialized_request ) req . timestamp = mysql_utils . MysqlToRDFDatetime ( ts ) res . append ( req ) return res
Reads all flow processing requests from the database.
Reads all flow processing requests from the database .
"""Reads all flow processing requests from the database."""
self
cursor