[Debconf-video-commits] r342 - in package/trunk: debian src
benh at alioth.debian.org
benh at alioth.debian.org
Fri Mar 20 04:01:32 UTC 2009
Author: benh
Date: 2009-03-20 04:01:32 +0000 (Fri, 20 Mar 2009)
New Revision: 342
Added:
package/trunk/src/debconfvideo/
Modified:
package/trunk/debian/rules
package/trunk/src/dc-do-transcoding
package/trunk/src/dc-import-recordings
package/trunk/src/dc-publish
Log:
Unify boilerplate config and database connection code.
Modified: package/trunk/debian/rules
===================================================================
--- package/trunk/debian/rules 2009-03-20 03:58:25 UTC (rev 341)
+++ package/trunk/debian/rules 2009-03-20 04:01:32 UTC (rev 342)
@@ -24,9 +24,10 @@
# debconf-video-encode: meta-packge only
mkdir -p -m 755 debian/debconf-video-encode
# debconf-video-store: scripts for the storage server
- mkdir -p -m 755 debian/debconf-video-store/usr/bin debian/debconf-video-store/usr/share/debconf-video-store
+ mkdir -p -m 755 debian/debconf-video-store/usr/bin debian/debconf-video-store/usr/share/debconf-video-store debian/debconf-video-store/usr/share/debconf-video-store/debconfvideo
install src/dc-import-recordings src/dc-do-transcoding src/dc-publish debian/debconf-video-store/usr/bin/
install -m 644 src/shellconfig.py debian/debconf-video-store/usr/share/debconf-video-store/
+ install -m 644 src/debconfvideo/*.py debian/debconf-video-store/usr/share/debconf-video-store/debconfvideo/
binary-indep: install
dh_testdir -i
Modified: package/trunk/src/dc-do-transcoding
===================================================================
--- package/trunk/src/dc-do-transcoding 2009-03-20 03:58:25 UTC (rev 341)
+++ package/trunk/src/dc-do-transcoding 2009-03-20 04:01:32 UTC (rev 342)
@@ -1,12 +1,15 @@
#!/usr/bin/python2.4
import os.path
-import pgdb
import re
import select
import sys
import time
+if __name__ == '__main__':
+ sys.path.insert(0, '/usr/share/debconf-video-store')
+from debconfvideo import config, database
+
# metadata
author = 'DebConf video team'
organisation = 'DebConf'
@@ -27,7 +30,7 @@
'filename_extension',
'priority', 'recording_time'
]
- cur = get_cursor()
+ cur = database.get_cursor()
cur.execute('SELECT ' + ', '.join(attrs) + """ FROM
((video_recording JOIN video_event_recording
ON video_recording.id = video_event_recording.recording_id)
@@ -58,7 +61,7 @@
return jobs
def mark_job_done(job, file_status_code):
- cur = get_cursor()
+ cur = database.get_cursor()
cur.execute("""
INSERT INTO video_target_file(event_recording_id, target_format_id,
file_status_id, generated_time)
@@ -179,26 +182,6 @@
return "'" + arg.replace("'", "'\\''") + "'"
return ' '.join(escape(arg) for arg in argv)
-_connection = None
-
-def get_cursor():
- global _connection
- if _connection:
- try:
- cur = _connection.cursor()
- # Check whether connection is working.
- cur.execute('SELECT 1')
- cur.fetchall()
- return cur
- except pgdb.DatabaseError:
- pass
- # (Re)connect to database.
- _connection = pgdb.connect(dsn=config['DATABASE_DSN'],
- user=config.get('DATABASE_USER'),
- password=config.get('DATABASE_PASSWORD'))
- cur = _connection.cursor()
- return cur
-
def main(pretend=False):
host_procs = []
for host_nproc in config['ENCODING_HOSTS'].split(' '):
@@ -212,7 +195,7 @@
jobs_by_host_proc = {}
jobs_by_key = {}
- cur = get_cursor()
+ cur = database.get_cursor()
while True:
# Generate a queue of jobs. Remove the jobs we're running.
@@ -310,9 +293,6 @@
if __name__ == '__main__':
try:
- sys.path.insert(0, '/usr/share/debconf-video-store')
- import shellconfig
- config = shellconfig.read_file('/etc/default/debconf-video')
main(pretend=('--dry-run' in sys.argv[1:]))
except Exception, e:
print >>sys.stderr, 'ERROR:', e.__class__.__name__, e
Modified: package/trunk/src/dc-import-recordings
===================================================================
--- package/trunk/src/dc-import-recordings 2009-03-20 03:58:25 UTC (rev 341)
+++ package/trunk/src/dc-import-recordings 2009-03-20 04:01:32 UTC (rev 342)
@@ -2,17 +2,17 @@
import glob
import os
-import pgdb
import sys
import time
+if __name__ == '__main__':
+ sys.path.insert(0, '/usr/share/debconf-video-store')
+from debconfvideo import config, database
+
dif_bytes_per_second = 300 * 150 * 80
-def main(config, do_delete):
- conn = pgdb.connect(dsn=config['DATABASE_DSN'],
- user=config.get('DATABASE_USER'),
- password=config.get('DATABASE_PASSWORD'))
- cur = conn.cursor()
+def main(do_delete):
+ cur = database.get_cursor()
# Find conference id.
cur.execute('SELECT conference_id FROM conference WHERE title=%(title)s',
@@ -86,10 +86,7 @@
if __name__ == '__main__':
try:
- sys.path.insert(0, '/usr/share/debconf-video-store')
- import shellconfig
- main(shellconfig.read_file('/etc/default/debconf-video'),
- do_delete=('--delete' in sys.argv[1:]))
+ main(do_delete=('--delete' in sys.argv[1:]))
except Exception, e:
print >>sys.stderr, 'ERROR:', e.__class__.__name__, e
sys.exit(2)
Modified: package/trunk/src/dc-publish
===================================================================
--- package/trunk/src/dc-publish 2009-03-20 03:58:25 UTC (rev 341)
+++ package/trunk/src/dc-publish 2009-03-20 04:01:32 UTC (rev 342)
@@ -3,10 +3,13 @@
import mx.DateTime
import os
import os.path
-import pgdb
import re
import sys
+if __name__ == '__main__':
+ sys.path.insert(0, '/usr/share/debconf-video-store')
+from debconfvideo import config, database
+
# metadata
author = 'DebConf video team'
licence = 'DebConf video licence; http://meetings-archive.debian.net/pub/debian-meetings/LICENCE'
@@ -122,11 +125,8 @@
+ file_names
+ [config['PUBLICATION_PATH']])
-def main(config):
- conn = pgdb.connect(dsn=config['DATABASE_DSN'],
- user=config.get('DATABASE_USER'),
- password=config.get('DATABASE_PASSWORD'))
- cur = conn.cursor()
+def main():
+ cur = database.get_cursor()
conference_title = config['CONFERENCE_NAME']
cur.execute('SELECT conference_id FROM conference'
@@ -164,6 +164,4 @@
cur.execute("COMMIT")
if __name__ == '__main__':
- sys.path.insert(0, '/usr/share/debconf-video-store')
- import shellconfig
- main(shellconfig.read_file('/etc/default/debconf-video'))
+ main()
Copied: package/trunk/src/debconfvideo (from rev 337, package/branches/pycon09/src/debconfvideo)
More information about the Debconf-video-commits
mailing list