+def check_daily_lock():
+ """
+ Raises CantGetLockError if the dinstall daily.lock exists.
+ """
+
+ cnf = Config()
+ try:
+ os.open(cnf["Process-New::DinstallLockFile"],
+ os.O_RDONLY | os.O_CREAT | os.O_EXCL)
+ except OSError, e:
+ if e.errno == errno.EEXIST or e.errno == errno.EACCES:
+ raise CantGetLockError
+
+ os.unlink(cnf["Process-New::DinstallLockFile"])
+
+
+@contextlib.contextmanager
+def lock_package(package):
+ """
+ Lock C{package} so that noone else jumps in processing it.
+
+ @type package: string
+ @param package: source package name to lock
+ """
+
+ path = os.path.join(Config()["Process-New::LockDir"], package)
+ try:
+ fd = os.open(path, os.O_CREAT | os.O_EXCL | os.O_RDONLY)
+ except OSError, e:
+ if e.errno == errno.EEXIST or e.errno == errno.EACCES:
+ user = pwd.getpwuid(os.stat(path)[stat.ST_UID])[4].split(',')[0].replace('.', '')
+ raise AlreadyLockedError, user
+
+ try:
+ yield fd
+ finally:
+ os.unlink(path)
+
+def changes_to_unchecked(upload, session):
+ """move a changes file to unchecked"""
+ unchecked = get_policy_queue('unchecked', session );
+
+# changes.in_queue = unchecked
+
+ chg = session.query(DBChange).filter_by(changesname=os.path.basename(upload.pkg.changes_file)).one()
+ chg.approved_for = unchecked.policy_queue_id
+
+ for f in upload.pkg.files:
+ # update the changes_pending_files row
+ f.queue = unchecked
+
+ # actually move files
+ upload.move_to_queue(unchecked)
+
+def _accept(upload, session):
+ if Options["No-Action"]:
+ return
+ (summary, short_summary) = upload.build_summaries()
+# upload.accept(summary, short_summary, targetqueue)
+ changes_to_unchecked(upload, session)
+
+def do_accept(upload, session):