Go to the source code of this file.
Defines | |
#define | STRING_SIZE 1024 |
#define | SQL_GETJOBS "SELECT id,user,hpss_file FROM requests WHERE status=?" |
#define | SQL_GETNEWJOBS "SELECT id,user,hpss_file,tries FROM requests WHERE status=0" |
#define | SQL_NEW_REQUESTS "UPDATE requests\ SET status=0 \ WHERE status BETWEEN 1 AND 3" |
#define | SQL_UPDATE_REQUEST_ID "UPDATE requests\ SET status=?,\ message=?\ WHERE id=?" |
#define | SQL_UPDATE_FINAL_REQUEST_ID "UPDATE requests\ SET status=?,\ errorcode=?,\ message=?,\ end_time=FROM_UNIXTIME(?)\ WHERE id=?" |
#define | SQL_UPDATE_REQUEST_SUBMITTED "UPDATE requests\ SET status=?,\ message=?,\ queue_id=?,\ cartridge=?,\ position=?,\ cos=?,\ size=?,\ errorcode=0,\ submission_time=FROM_UNIXTIME(?) \ WHERE hpss_file=? AND end_time IS NULL" |
#define | SQL_UPDATE_REQUEST_RESUBMITTED "UPDATE requests\ SET queued_time=NULL, \ queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL" |
#define | SQL_UPDATE_REQUEST_QUEUED "UPDATE requests\ SET queued_time=FROM_UNIXTIME(?), \ queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL" |
#define | SQL_UPDATE_REQUEST_RETRY "UPDATE requests\ SET queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL" |
#define | SQL_UPDATE_REQUEST_ENDED "UPDATE requests\ SET end_time=FROM_UNIXTIME(?), \ queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL" |
#define | SQL_INSERT_QUEUE "INSERT INTO queues\ (status,name,nbjobs,master_queue,owner, byte_size,creation_time)\ VALUES (?,?,?,?,?,?,FROM_UNIXTIME(?))" |
#define | SQL_UPDATE_QUEUE_ADD_REQUEST "UPDATE queues\ SET nbjobs=?,\ owner=?,\ byte_size=?\ WHERE id=?" |
#define | SQL_UPDATE_QUEUE_ACTIVATED "UPDATE queues\ SET activation_time=FROM_UNIXTIME(?),\ status=?,\ nbjobs=?,\ nbdone=?,\ nbfailed=?,\ owner=?,\ byte_size=?\ WHERE id=?" |
#define | SQL_UPDATE_QUEUE_ENDED "UPDATE queues\ SET end_time=FROM_UNIXTIME(?),\ status=?,\ nbjobs=?,\ nbdone=?,\ nbfailed=?,\ owner=?,\ byte_size=?\ WHERE id=?" |
#define | SQL_UPDATE_QUEUE_UNSUSPENDED "UPDATE queues\ SET activation_time=NULL,\ end_time=NULL,\ status=?,\ nbjobs=?,\ nbdone=?,\ nbfailed=?,\ owner=?,\ byte_size=?\ WHERE id=?" |
#define | SQL_UPDATE_QUEUES_ON_STARTUP "UPDATE queues\ SET status=3,\ end_time=FROM_UNIXTIME(UNIX_TIMESTAMP())\ WHERE status<3" |
#define | SQL_SELECTMEDIA "SELECT pvrname FROM mediatype WHERE ? LIKE volume_pattern" |
#define | SQL_SELECTPVRID "SELECT pvrid FROM mediatype WHERE pvrname=?" |
#define | SQL_TABLE_JOBS_REQUESTS "(\ `id` int(11) NOT NULL auto_increment,\ `email` varchar(128) default NULL,\ `user` varchar(32) default NULL,\ `hpss_file` varchar(256),\ `client` varchar(128),\ `creation_time` datetime default NULL,\ `expiration_time` mediumint(9) default NULL,\ `status` tinyint(4) default 0,\ `message` varchar(128) default NULL,\ `tries` int(11) default '0',\ `errorcode` int(11) default '0',\ `submission_time` datetime default NULL,\ `queued_time` datetime default NULL,\ `end_time` datetime default NULL,\ `cartridge` varchar(8) default '',\ `position` int(11) default '-1',\ `cos` int(11) default '-1',\ `size` bigint(20) unsigned default '0',\ `queue_id` int(11) default NULL,\ PRIMARY KEY (`id`,`hpss_file`)\)" |
#define | SQL_TABLE_JOBS_QUEUES "(\ `id` int(11) NOT NULL auto_increment,\ `name` char(12) default NULL,\ `nbjobs` int(11) default 0,\ `nbdone` int(11) default 0,\ `nbfailed` int(11) default 0,\ `status` tinyint(1) default NULL,\ `master_queue` int(11) default NULL,\ `owner` char(20) default NULL,\ `creation_time` datetime default NULL,\ `activation_time` datetime default NULL,\ `end_time` datetime default NULL,\ `byte_size` bigint(20) default 0,\ PRIMARY KEY (`id`)\) " |
#define | SQL_CREATE_TABLE_CONF_MEDIATYPE "CREATE TABLE `mediatype` (\ `pvrid` int(11) NOT NULL,\ `pvrname` char(20) default NULL,\ `drives` int(11) default NULL,\ `lock_time` mediumtext,\ `volume_pattern` char(20) default NULL,\ PRIMARY KEY (`pvrid`)\) " |
#define | SQL_CREATE_TABLE_CONF_USERS "CREATE TABLE `allocation` (\ `user` varchar(32) default NULL,\ `pvrid` int(11) default NULL,\ `default_share` decimal(5,2) default NULL,\ `share` decimal(5,2) default NULL,\ `default_depth` int(11) default NULL,\ `depth` int(11) default NULL,\ `grp` varchar(10) default NULL,\ `expr` varchar(10) default NULL,\ `org` varchar(10) default NULL\)" |
#define | SQL_SELECT_ALLOCATIONS "SELECT pvrid,user,default_share,share FROM allocation" |
#define | SQL_SELECT_DRIVES "SELECT pvrid,drives FROM mediatype" |
#define SQL_CREATE_TABLE_CONF_MEDIATYPE "CREATE TABLE `mediatype` (\ `pvrid` int(11) NOT NULL,\ `pvrname` char(20) default NULL,\ `drives` int(11) default NULL,\ `lock_time` mediumtext,\ `volume_pattern` char(20) default NULL,\ PRIMARY KEY (`pvrid`)\) " |
#define SQL_CREATE_TABLE_CONF_USERS "CREATE TABLE `allocation` (\ `user` varchar(32) default NULL,\ `pvrid` int(11) default NULL,\ `default_share` decimal(5,2) default NULL,\ `share` decimal(5,2) default NULL,\ `default_depth` int(11) default NULL,\ `depth` int(11) default NULL,\ `grp` varchar(10) default NULL,\ `expr` varchar(10) default NULL,\ `org` varchar(10) default NULL\)" |
#define SQL_GETJOBS "SELECT id,user,hpss_file FROM requests WHERE status=?" |
#define SQL_GETNEWJOBS "SELECT id,user,hpss_file,tries FROM requests WHERE status=0" |
#define SQL_INSERT_QUEUE "INSERT INTO queues\ (status,name,nbjobs,master_queue,owner, byte_size,creation_time)\ VALUES (?,?,?,?,?,?,FROM_UNIXTIME(?))" |
#define SQL_NEW_REQUESTS "UPDATE requests\ SET status=0 \ WHERE status BETWEEN 1 AND 3" |
#define SQL_SELECT_ALLOCATIONS "SELECT pvrid,user,default_share,share FROM allocation" |
#define SQL_SELECT_DRIVES "SELECT pvrid,drives FROM mediatype" |
#define SQL_SELECTMEDIA "SELECT pvrname FROM mediatype WHERE ? LIKE volume_pattern" |
#define SQL_SELECTPVRID "SELECT pvrid FROM mediatype WHERE pvrname=?" |
#define SQL_TABLE_JOBS_QUEUES "(\ `id` int(11) NOT NULL auto_increment,\ `name` char(12) default NULL,\ `nbjobs` int(11) default 0,\ `nbdone` int(11) default 0,\ `nbfailed` int(11) default 0,\ `status` tinyint(1) default NULL,\ `master_queue` int(11) default NULL,\ `owner` char(20) default NULL,\ `creation_time` datetime default NULL,\ `activation_time` datetime default NULL,\ `end_time` datetime default NULL,\ `byte_size` bigint(20) default 0,\ PRIMARY KEY (`id`)\) " |
#define SQL_TABLE_JOBS_REQUESTS "(\ `id` int(11) NOT NULL auto_increment,\ `email` varchar(128) default NULL,\ `user` varchar(32) default NULL,\ `hpss_file` varchar(256),\ `client` varchar(128),\ `creation_time` datetime default NULL,\ `expiration_time` mediumint(9) default NULL,\ `status` tinyint(4) default 0,\ `message` varchar(128) default NULL,\ `tries` int(11) default '0',\ `errorcode` int(11) default '0',\ `submission_time` datetime default NULL,\ `queued_time` datetime default NULL,\ `end_time` datetime default NULL,\ `cartridge` varchar(8) default '',\ `position` int(11) default '-1',\ `cos` int(11) default '-1',\ `size` bigint(20) unsigned default '0',\ `queue_id` int(11) default NULL,\ PRIMARY KEY (`id`,`hpss_file`)\)" |
#define SQL_UPDATE_FINAL_REQUEST_ID "UPDATE requests\ SET status=?,\ errorcode=?,\ message=?,\ end_time=FROM_UNIXTIME(?)\ WHERE id=?" |
#define SQL_UPDATE_QUEUE_ACTIVATED "UPDATE queues\ SET activation_time=FROM_UNIXTIME(?),\ status=?,\ nbjobs=?,\ nbdone=?,\ nbfailed=?,\ owner=?,\ byte_size=?\ WHERE id=?" |
#define SQL_UPDATE_QUEUE_ADD_REQUEST "UPDATE queues\ SET nbjobs=?,\ owner=?,\ byte_size=?\ WHERE id=?" |
#define SQL_UPDATE_QUEUE_ENDED "UPDATE queues\ SET end_time=FROM_UNIXTIME(?),\ status=?,\ nbjobs=?,\ nbdone=?,\ nbfailed=?,\ owner=?,\ byte_size=?\ WHERE id=?" |
#define SQL_UPDATE_QUEUE_UNSUSPENDED "UPDATE queues\ SET activation_time=NULL,\ end_time=NULL,\ status=?,\ nbjobs=?,\ nbdone=?,\ nbfailed=?,\ owner=?,\ byte_size=?\ WHERE id=?" |
#define SQL_UPDATE_QUEUES_ON_STARTUP "UPDATE queues\ SET status=3,\ end_time=FROM_UNIXTIME(UNIX_TIMESTAMP())\ WHERE status<3" |
#define SQL_UPDATE_REQUEST_ENDED "UPDATE requests\ SET end_time=FROM_UNIXTIME(?), \ queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL" |
#define SQL_UPDATE_REQUEST_ID "UPDATE requests\ SET status=?,\ message=?\ WHERE id=?" |
#define SQL_UPDATE_REQUEST_QUEUED "UPDATE requests\ SET queued_time=FROM_UNIXTIME(?), \ queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL" |
#define SQL_UPDATE_REQUEST_RESUBMITTED "UPDATE requests\ SET queued_time=NULL, \ queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL" |
#define SQL_UPDATE_REQUEST_RETRY "UPDATE requests\ SET queue_id=?,\ cartridge=?,\ position=?,\ errorcode=?,\ tries=?,\ status=?,\ message=?\ WHERE hpss_file=? AND end_time IS NULL" |
#define SQL_UPDATE_REQUEST_SUBMITTED "UPDATE requests\ SET status=?,\ message=?,\ queue_id=?,\ cartridge=?,\ position=?,\ cos=?,\ size=?,\ errorcode=0,\ submission_time=FROM_UNIXTIME(?) \ WHERE hpss_file=? AND end_time IS NULL" |
#define STRING_SIZE 1024 |