mirror of
https://github.com/tahoe-lafs/tahoe-lafs.git
synced 2025-04-07 10:56:49 +00:00
get rid of .remember() / IOpHandleTable
This commit is contained in:
parent
473a935aab
commit
385df39981
@ -40,9 +40,6 @@ def get_filenode_metadata(filenode):
|
||||
metadata['size'] = size
|
||||
return metadata
|
||||
|
||||
class IOpHandleTable(Interface):
|
||||
pass
|
||||
|
||||
def getxmlfile(name):
|
||||
return loaders.xmlfile(resource_filename('allmydata.web', '%s' % name))
|
||||
|
||||
|
@ -22,7 +22,7 @@ from allmydata.blacklist import ProhibitedNode
|
||||
from allmydata.monitor import Monitor, OperationCancelledError
|
||||
from allmydata import dirnode
|
||||
from allmydata.web.common import text_plain, WebError, \
|
||||
IOpHandleTable, NeedOperationHandleError, \
|
||||
NeedOperationHandleError, \
|
||||
boolean_of_arg, get_arg, get_root, parse_replace_arg, \
|
||||
should_create_intermediate_directories, \
|
||||
getxmlfile, RenderMixin, humanize_failure, convert_children_json, \
|
||||
@ -63,6 +63,9 @@ class DirectoryNodeHandler(RenderMixin, rend.Page, ReplaceMeMixin):
|
||||
self.parentnode = parentnode
|
||||
self.name = name
|
||||
|
||||
# probably better to just pass this in? can we?
|
||||
self._operations = client.getServiceNamed("webish").getServiceNamed("operations")
|
||||
|
||||
def childFactory(self, ctx, name):
|
||||
name = name.decode("utf-8")
|
||||
if not name:
|
||||
@ -442,9 +445,8 @@ class DirectoryNodeHandler(RenderMixin, rend.Page, ReplaceMeMixin):
|
||||
return d
|
||||
|
||||
def _start_operation(self, monitor, renderer, ctx):
|
||||
table = IOpHandleTable(ctx)
|
||||
table.add_monitor(ctx, monitor, renderer)
|
||||
return table.redirect_to(ctx)
|
||||
self._operations.add_monitor(ctx, monitor, renderer)
|
||||
return self._operations.redirect_to(ctx)
|
||||
|
||||
def _POST_start_deep_check(self, ctx):
|
||||
# check this directory and everything reachable from it
|
||||
|
@ -9,7 +9,7 @@ from twisted.web.http import NOT_FOUND
|
||||
from twisted.web.html import escape
|
||||
from twisted.application import service
|
||||
|
||||
from allmydata.web.common import IOpHandleTable, WebError, \
|
||||
from allmydata.web.common import WebError, \
|
||||
get_root, get_arg, boolean_of_arg
|
||||
|
||||
MINUTE = 60
|
||||
@ -18,8 +18,8 @@ DAY = 24*HOUR
|
||||
|
||||
(MONITOR, RENDERER, WHEN_ADDED) = range(3)
|
||||
|
||||
@implementer(IOpHandleTable)
|
||||
class OphandleTable(rend.Page, service.Service):
|
||||
name = "operations"
|
||||
|
||||
UNCOLLECTED_HANDLE_LIFETIME = 4*DAY
|
||||
COLLECTED_HANDLE_LIFETIME = 1*DAY
|
||||
|
@ -10,7 +10,7 @@ from nevow import appserver, inevow
|
||||
from allmydata.util import log, fileutil
|
||||
|
||||
from allmydata.web import introweb, root
|
||||
from allmydata.web.common import IOpHandleTable, MyExceptionHandler
|
||||
from allmydata.web.common import MyExceptionHandler
|
||||
|
||||
# we must override twisted.web.http.Request.requestReceived with a version
|
||||
# that doesn't use cgi.parse_multipart() . Since we actually use Nevow, we
|
||||
@ -167,7 +167,6 @@ class WebishServer(service.MultiService):
|
||||
|
||||
# XXX FIXME what does this really do?
|
||||
if self.root.child_operations:
|
||||
self.site.remember(self.root.child_operations, IOpHandleTable)
|
||||
self.root.child_operations.setServiceParent(self)
|
||||
|
||||
def buildServer(self, webport, nodeurl_path, staticdir):
|
||||
|
Loading…
x
Reference in New Issue
Block a user