1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
/*
* Copyright (C) 2009 Red Hat Inc.
*
* David Sommerseth <davids@redhat.com>
*
* Takes a standardised XML document (from parseToSQLdata()) and does
* the database operations based on that input
*
* This application is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License as published by the Free
* Software Foundation; version 2.
*
* This application is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* General Public License for more details.
*/
#ifndef _RTEVAL_PGSQL_H
#define _RTEVAL_PGSQL_H
#include <libpq-fe.h>
#include <libxml/parser.h>
#include <libxslt/transform.h>
#include <eurephia_values.h>
#include <parsethread.h>
#define STAT_NEW 0 /**< New, unparsed report in the submission queue */
#define STAT_ASSIGNED 1 /**< Submission is assigned to a parser */
#define STAT_INPROG 2 /**< Parsing has started */
#define STAT_SUCCESS 3 /**< Report parsed successfully */
#define STAT_UNKNFAIL 4 /**< Unkown failure */
#define STAT_XMLFAIL 5 /**< Failed to parse the report XML file */
#define STAT_SYSREG 6 /**< System registration failed */
#define STAT_RTERIDREG 7 /**< Failed to get a new rterid value for the rteval run */
#define STAT_GENDB 8 /**< General database error */
#define STAT_RTEVRUNS 9 /**< Registering rteval run information failed */
#define STAT_CYCLIC 10 /**< Registering cyclictest results failed */
#define STAT_REPMOVE 11 /**< Failed to move the report file */
typedef PGconn dbconn; /**< Wrapper definition, for a more generic DB API */
/* Generic database function */
void *db_connect(eurephiaVALUES *cfg);
void db_disconnect(dbconn *dbc);
int db_begin(dbconn *dbc);
int db_commit(dbconn *dbc);
int db_rollback(dbconn *dbc);
/* rteval specific database functions */
parseJob_t *db_get_submissionqueue_job(dbconn *dbc, pthread_mutex_t *mtx);
int db_update_submissionqueue(dbconn *dbc, unsigned int submid, int status);
int db_register_system(dbconn *dbc, xsltStylesheet *xslt, xmlDoc *summaryxml);
int db_get_new_rterid(dbconn *dbc);
int db_register_rtevalrun(dbconn *dbc, xsltStylesheet *xslt, xmlDoc *summaryxml,
int syskey, int rterid, const char *report_fname);
int db_register_cyclictest(dbconn *dbc, xsltStylesheet *xslt, xmlDoc *summaryxml, int rterid);
#endif
|
