Changeset 3ee7406 in trunk


Ignore:
Timestamp:
2009-10-12T22:45:06Z (15 years ago)
Author:
Brian Warner <warner@…>
Branches:
master
Children:
e2ffc3d
Parents:
576c47d
Message:

replace Client.create_empty_dirnode() with create_dirnode(), in anticipation
of adding initial_children= argument.

Includes stubbed-out initial_children= support.

Location:
src/allmydata
Files:
8 edited

Legend:

Unmodified
Added
Removed

  • TabularUnified src/allmydata/client.py

    r576c47d r3ee7406  
    458458        return self.nodemaker.create_from_cap(writecap, readcap)
    459459
    460     def create_empty_dirnode(self):
    461         return self.nodemaker.create_new_mutable_directory()
     460    def create_dirnode(self, initial_children={}):
     461        d = self.nodemaker.create_new_mutable_directory()
     462        assert not initial_children, "not ready yet: %s" % (initial_children,)
     463        if initial_children:
     464            d.addCallback(lambda n: n.set_children(initial_children))
     465        return d
    462466
    463467    def create_mutable_file(self, contents="", keysize=None):

  • TabularUnified src/allmydata/interfaces.py

    r576c47d r3ee7406  
    20042004        """
    20052005
    2006     def create_empty_dirnode():
    2007         """Create a new dirnode, empty and unattached.
     2006    def create_dirnode(initial_children={}):
     2007        """Create a new unattached dirnode, possibly with initial children.
     2008
     2009        @param initial_children: dict with keys that are unicode child names,
     2010        and values that are (child_writecap, child_readcap, metadata) tuples.
     2011
    20082012        @return: a Deferred that fires with the new IDirectoryNode instance.
    20092013        """

  • TabularUnified src/allmydata/test/test_cli.py

    r576c47d r3ee7406  
    749749        self.set_up_grid()
    750750        c0 = self.g.clients[0]
    751         d = c0.create_empty_dirnode()
     751        d = c0.create_dirnode()
    752752        def _stash_root_and_create_file(n):
    753753            self.rootnode = n
    … …  
    13181318        self.fileurls = {}
    13191319        DATA = "data" * 100
    1320         d = c0.create_empty_dirnode()
     1320        d = c0.create_dirnode()
    13211321        def _stash_root_and_create_file(n):
    13221322            self.rootnode = n
    … …  
    15501550        c0 = self.g.clients[0]
    15511551        self.fileurls = {}
    1552         d = c0.create_empty_dirnode()
     1552        d = c0.create_dirnode()
    15531553        def _stash_root(n):
    15541554            self.rootnode = n

  • TabularUnified src/allmydata/test/test_deepcheck.py

    r576c47d r3ee7406  
    215215        #   loop -> root
    216216        c0 = self.g.clients[0]
    217         d = c0.create_empty_dirnode()
     217        d = c0.create_dirnode()
    218218        def _created_root(n):
    219219            self.root = n
    … …  
    869869
    870870        c0 = self.g.clients[0]
    871         d = c0.create_empty_dirnode()
     871        d = c0.create_dirnode()
    872872        def _created_root(n):
    873873            self.root = n
    … …  
    882882        d.addCallback(self.create_mangled, "large-corrupt-shares")
    883883        d.addCallback(self.create_mangled, "large-unrecoverable")
    884         d.addCallback(lambda ignored: c0.create_empty_dirnode())
     884        d.addCallback(lambda ignored: c0.create_dirnode())
    885885        d.addCallback(self._stash_node, "broken")
    886886        large1 = upload.Data("Lots of data\n" * 1000 + "large1" + "\n", None)
    … …  
    11761176        COUNT = 400
    11771177        c0 = self.g.clients[0]
    1178         d = c0.create_empty_dirnode()
     1178        d = c0.create_dirnode()
    11791179        self.stash = {}
    11801180        def _created_root(n):

  • TabularUnified src/allmydata/test/test_dirnode.py

    r576c47d r3ee7406  
    2929        self.set_up_grid()
    3030        c = self.g.clients[0]
    31         d = c.create_empty_dirnode()
     31        d = c.create_dirnode()
    3232        def _done(res):
    3333            self.failUnless(isinstance(res, dirnode.DirectoryNode))
    … …  
    4141        self.set_up_grid()
    4242        c = self.g.clients[0]
    43         d = c.create_empty_dirnode()
     43        d = c.create_dirnode()
    4444        d.addCallback(lambda dn: dn.check(Monitor()))
    4545        def _done(res):
    … …  
    5656        #  root/rodir
    5757        c = self.g.clients[0]
    58         d = c.create_empty_dirnode()
     58        d = c.create_dirnode()
    5959        def _created_root(rootnode):
    6060            self._rootnode = rootnode
    … …  
    6565            d = subdir.add_file(u"file1", upload.Data("data"*100, None))
    6666            d.addCallback(lambda res: subdir.set_node(u"link", self._rootnode))
    67             d.addCallback(lambda res: c.create_empty_dirnode())
     67            d.addCallback(lambda res: c.create_dirnode())
    6868            d.addCallback(lambda dn:
    6969                          self._rootnode.set_uri(u"rodir",
    … …  
    158158        uploadable = upload.Data("some data", convergence="some convergence string")
    159159
    160         d = c.create_empty_dirnode()
     160        d = c.create_dirnode()
    161161        def _created(rw_dn):
    162162            d2 = rw_dn.set_uri(u"child", filecap)
    … …  
    211211        self.expected_storage_indexes = set()
    212212
    213         d = c.create_empty_dirnode()
     213        d = c.create_dirnode()
    214214        def _then(n):
    215215            # /
    … …  
    410410            # it should be possible to add a child without any metadata
    411411            d.addCallback(lambda res: n.set_node(u"d2", n, {}))
    412             d.addCallback(lambda res: c.create_empty_dirnode())
     412            d.addCallback(lambda res: c.create_dirnode())
    413413            d.addCallback(lambda n2:
    414414                          self.shouldFail(ExistingChildError, "set_node-no",
    … …  
    909909        self.set_up_grid()
    910910        c0 = self.g.clients[0]
    911         d = c0.create_empty_dirnode()
     911        d = c0.create_dirnode()
    912912        small = upload.Data("Small enough for a LIT", None)
    913913        def _created_dir(dn):
    … …  
    945945        fileuri = make_chk_file_uri(1234)
    946946        filenode = c.nodemaker.create_from_cap(fileuri)
    947         d = c.create_empty_dirnode()
     947        d = c.create_dirnode()
    948948
    949949        def _create_directory_tree(root_node):

  • TabularUnified src/allmydata/test/test_system.py

    r576c47d r3ee7406  
    684684        d.addCallback(_check_empty_file)
    685685
    686         d.addCallback(lambda res: self.clients[0].create_empty_dirnode())
     686        d.addCallback(lambda res: self.clients[0].create_dirnode())
    687687        def _created_dirnode(dnode):
    688688            log.msg("_created_dirnode(%s)" % (dnode,))
    … …  
    711711        d.addCallback(lambda junk: self.clients[3].create_mutable_file('hello, world'))
    712712        d.addCallback(check_kg_poolsize, -1)
    713         d.addCallback(lambda junk: self.clients[3].create_empty_dirnode())
     713        d.addCallback(lambda junk: self.clients[3].create_dirnode())
    714714        d.addCallback(check_kg_poolsize, -2)
    715715        # use_helper induces use of clients[3], which is the using-key_gen client
    … …  
    821821        ut = upload.Data(self.data, convergence=None)
    822822        c0 = self.clients[0]
    823         d = c0.create_empty_dirnode()
     823        d = c0.create_dirnode()
    824824        def _made_root(new_dirnode):
    825825            self._root_directory_uri = new_dirnode.get_uri()
    … …  
    853853        self.smalldata = "sssh, very secret stuff"
    854854        ut = upload.Data(self.smalldata, convergence=None)
    855         d = self.clients[0].create_empty_dirnode()
     855        d = self.clients[0].create_dirnode()
    856856        d.addCallback(self.log, "GOT private directory")
    857857        def _got_new_dir(privnode):

  • TabularUnified src/allmydata/test/test_web.py

    r576c47d r3ee7406  
    122122        self.webish_url = "http://localhost:%d" % port
    123123
    124         l = [ self.s.create_empty_dirnode() for x in range(6) ]
     124        l = [ self.s.create_dirnode() for x in range(6) ]
    125125        d = defer.DeferredList(l)
    126126        def _then(res):
    … …  
    22482248
    22492249    def test_PUT_DIRURL_uri(self):
    2250         d = self.s.create_empty_dirnode()
     2250        d = self.s.create_dirnode()
    22512251        def _made_dir(dn):
    22522252            new_uri = dn.get_uri()
    … …  
    22642264
    22652265    def test_PUT_DIRURL_uri_noreplace(self):
    2266         d = self.s.create_empty_dirnode()
     2266        d = self.s.create_dirnode()
    22672267        def _made_dir(dn):
    22682268            new_uri = dn.get_uri()
    … …  
    28162816        future_node = UnknownNode(future_writecap, future_readcap)
    28172817
    2818         d = c0.create_empty_dirnode()
     2818        d = c0.create_dirnode()
    28192819        def _stash_root_and_create_file(n):
    28202820            self.rootnode = n
    … …  
    28762876        self.fileurls = {}
    28772877        DATA = "data" * 100
    2878         d = c0.create_empty_dirnode()
     2878        d = c0.create_dirnode()
    28792879        def _stash_root_and_create_file(n):
    28802880            self.rootnode = n
    … …  
    30493049        self.fileurls = {}
    30503050        DATA = "data" * 100
    3051         d = c0.create_empty_dirnode()
     3051        d = c0.create_dirnode()
    30523052        def _stash_root_and_create_file(n):
    30533053            self.rootnode = n
    … …  
    32563256        self.fileurls = {}
    32573257        DATA = "data" * 100
    3258         d = c0.create_empty_dirnode()
     3258        d = c0.create_dirnode()
    32593259        def _stash_root_and_create_file(n):
    32603260            self.rootnode = n
    … …  
    33233323        self.fileurls = {}
    33243324        DATA = "data" * 100
    3325         d = c0.create_empty_dirnode()
     3325        d = c0.create_dirnode()
    33263326        def _stash_root(n):
    33273327            self.fileurls["root"] = "uri/" + urllib.quote(n.get_uri()) + "/"
    … …  
    33393339            self.fileurls["0shares"] = "uri/" + urllib.quote(baduri)
    33403340        d.addCallback(_stash_bad)
    3341         d.addCallback(lambda ign: c0.create_empty_dirnode())
     3341        d.addCallback(lambda ign: c0.create_dirnode())
    33423342        def _mangle_dirnode_1share(n):
    33433343            u = n.get_uri()
    … …  
    33463346            self.delete_shares_numbered(u, range(1,10))
    33473347        d.addCallback(_mangle_dirnode_1share)
    3348         d.addCallback(lambda ign: c0.create_empty_dirnode())
     3348        d.addCallback(lambda ign: c0.create_dirnode())
    33493349        def _mangle_dirnode_0share(n):
    33503350            u = n.get_uri()

  • TabularUnified src/allmydata/web/unlinked.py

    r576c47d r3ee7406  
    2626def PUTUnlinkedCreateDirectory(req, client):
    2727    # "PUT /uri?t=mkdir", to create an unlinked directory.
    28     d = client.create_empty_dirnode()
     28    d = client.create_dirnode()
    2929    d.addCallback(lambda dirnode: dirnode.get_uri())
    3030    # XXX add redirect_to_result
    … …  
    9191def POSTUnlinkedCreateDirectory(req, client):
    9292    # "POST /uri?t=mkdir", to create an unlinked directory.
    93     d = client.create_empty_dirnode()
     93    d = client.create_dirnode()
    9494    redirect = get_arg(req, "redirect_to_result", "false")
    9595    if boolean_of_arg(redirect):
Note: See TracChangeset for help on using the changeset viewer.