mirror of
https://github.com/codex-storage/deluge.git
synced 2025-02-20 15:18:20 +00:00
disable queue
This commit is contained in:
parent
fb85b87580
commit
d9868b0ce2
@ -19,7 +19,7 @@ def deluge_page_noauth(func):
|
|||||||
def deco(self, name = None):
|
def deco(self, name = None):
|
||||||
web.header("Content-Type", "text/html; charset=utf-8")
|
web.header("Content-Type", "text/html; charset=utf-8")
|
||||||
web.header("Cache-Control", "no-cache, must-revalidate")
|
web.header("Cache-Control", "no-cache, must-revalidate")
|
||||||
res = func(self, name)
|
res = func(self, name) #deluge_page_noauth
|
||||||
print res
|
print res
|
||||||
deco.__name__ = func.__name__
|
deco.__name__ = func.__name__
|
||||||
return deco
|
return deco
|
||||||
@ -49,8 +49,8 @@ def check_connected(func):
|
|||||||
try:
|
try:
|
||||||
proxy.ping()
|
proxy.ping()
|
||||||
connected = True
|
connected = True
|
||||||
except:
|
except Exception, e:
|
||||||
pass
|
log.debug("not_connected: %s" % e)
|
||||||
if connected:
|
if connected:
|
||||||
return func(self, name) #check_connected:ok
|
return func(self, name) #check_connected:ok
|
||||||
else:
|
else:
|
||||||
@ -72,7 +72,7 @@ def torrent_ids(func):
|
|||||||
for pages that allow a list of torrents.
|
for pages that allow a list of torrents.
|
||||||
"""
|
"""
|
||||||
def deco(self, name):
|
def deco(self, name):
|
||||||
return func (self, name.split(','))
|
return func (self, name.split(',')) #torrent_ids
|
||||||
deco.__name__ = func.__name__
|
deco.__name__ = func.__name__
|
||||||
return deco
|
return deco
|
||||||
|
|
||||||
@ -83,7 +83,7 @@ def torrent_list(func):
|
|||||||
"""
|
"""
|
||||||
def deco(self, name):
|
def deco(self, name):
|
||||||
torrent_list = [get_torrent_status(id) for id in name.split(',')]
|
torrent_list = [get_torrent_status(id) for id in name.split(',')]
|
||||||
return func (self, torrent_list)
|
return func (self, torrent_list) #torrent_list
|
||||||
deco.__name__ = func.__name__
|
deco.__name__ = func.__name__
|
||||||
return deco
|
return deco
|
||||||
|
|
||||||
@ -94,7 +94,7 @@ def torrent(func):
|
|||||||
def deco(self, name):
|
def deco(self, name):
|
||||||
torrent_id = name.split(',')[0]
|
torrent_id = name.split(',')[0]
|
||||||
torrent =get_torrent_status(torrent_id)
|
torrent =get_torrent_status(torrent_id)
|
||||||
return func (self, torrent)
|
return func (self, torrent) #torrent
|
||||||
deco.__name__ = func.__name__
|
deco.__name__ = func.__name__
|
||||||
return deco
|
return deco
|
||||||
|
|
||||||
@ -104,7 +104,7 @@ def auto_refreshed(func):
|
|||||||
if getcookie('auto_refresh') == '1':
|
if getcookie('auto_refresh') == '1':
|
||||||
web.header("Refresh", "%i ; url=%s" %
|
web.header("Refresh", "%i ; url=%s" %
|
||||||
(int(getcookie('auto_refresh_secs',10)),self_url()))
|
(int(getcookie('auto_refresh_secs',10)),self_url()))
|
||||||
return func(self, name)
|
return func(self, name) #auto_refreshed
|
||||||
deco.__name__ = func.__name__
|
deco.__name__ = func.__name__
|
||||||
return deco
|
return deco
|
||||||
|
|
||||||
@ -113,7 +113,7 @@ def remote(func):
|
|||||||
def deco(self, name = None):
|
def deco(self, name = None):
|
||||||
try:
|
try:
|
||||||
log.debug('%s.%s(%s)' ,self.__class__.__name__, func.__name__,name )
|
log.debug('%s.%s(%s)' ,self.__class__.__name__, func.__name__,name )
|
||||||
print func(self, name)
|
print func(self, name) #remote
|
||||||
except Exception, e:
|
except Exception, e:
|
||||||
print 'error:%s' % e.message
|
print 'error:%s' % e.message
|
||||||
print '-'*20
|
print '-'*20
|
||||||
|
@ -224,6 +224,7 @@ class torrent_queue_up:
|
|||||||
@deco.check_session
|
@deco.check_session
|
||||||
@deco.torrent_list
|
@deco.torrent_list
|
||||||
def POST(self, torrent_list):
|
def POST(self, torrent_list):
|
||||||
|
return error_page('Queue is broken, we know about it.')
|
||||||
#a bit too verbose..
|
#a bit too verbose..
|
||||||
torrent_list.sort(lambda x, y : x.queue - y.queue)
|
torrent_list.sort(lambda x, y : x.queue - y.queue)
|
||||||
torrent_ids = [t.id for t in torrent_list]
|
torrent_ids = [t.id for t in torrent_list]
|
||||||
@ -236,6 +237,7 @@ class torrent_queue_down:
|
|||||||
@deco.check_session
|
@deco.check_session
|
||||||
@deco.torrent_list
|
@deco.torrent_list
|
||||||
def POST(self, torrent_list):
|
def POST(self, torrent_list):
|
||||||
|
return error_page('Queue is broken, we know about it.')
|
||||||
#a bit too verbose..
|
#a bit too verbose..
|
||||||
torrent_list.sort(lambda x, y : x.queue - y.queue)
|
torrent_list.sort(lambda x, y : x.queue - y.queue)
|
||||||
torrent_ids = [t.id for t in torrent_list]
|
torrent_ids = [t.id for t in torrent_list]
|
||||||
|
Loading…
x
Reference in New Issue
Block a user