From: Brian Warner <warner@allmydata.com>
Date: Sat, 3 Nov 2007 05:59:02 +0000 (-0700)
Subject: mutable.py: start writing share-mapping code
X-Git-Tag: allmydata-tahoe-0.7.0~290
X-Git-Url: https://git.rkrishnan.org/components/com_hotproperty/reliability?a=commitdiff_plain;h=6137329f05db9dc18adc444b4e2c29a7b2264a25;p=tahoe-lafs%2Ftahoe-lafs.git

mutable.py: start writing share-mapping code
---

diff --git a/src/allmydata/mutable.py b/src/allmydata/mutable.py
index 90952699..d40b602d 100644
--- a/src/allmydata/mutable.py
+++ b/src/allmydata/mutable.py
@@ -26,7 +26,7 @@ class MutableFileNode:
         self._client = client
         self._pubkey = None # filled in upon first read
         self._privkey = None # filled in if we're mutable
-        self._sharemap = {} # known shares, shnum-to-nodeid
+        self._sharemap = {} # known shares, shnum-to-[nodeids]
 
         self._current_data = None # SDMF: we're allowed to cache the contents
         self._current_roothash = None # ditto
@@ -178,8 +178,7 @@ class Publish:
         d.addCallback(self._generate_shares, old_seqnum+1,
                       privkey, self._encprivkey, pubkey)
 
-        d.addCallback(self._get_peers)
-        d.addCallback(self._map_shares)
+        d.addCallback(self._choose_peers_and_map_shares)
         d.addCallback(self._send_shares)
         d.addCallback(self._wait_for_responses)
         d.addCallback(lambda res: None)
@@ -333,3 +332,23 @@ class Publish:
                            offsets['enc_privkey'],
                            offsets['EOF'])
 
+    def _choose_peers_and_map_shares(self, (seqnum, root_hash, final_shares) ):
+        self._new_seqnum = seqnum
+        self._new_root_hash = root_hash
+        self._new_shares = final_shares
+
+        storage_index = self._node._uri.storage_index
+        peerlist = self._node._client.get_permuted_peers(storage_index,
+                                                         include_myself=False)
+        # we don't include ourselves in the N peers, but we *do* push an
+        # extra copy of share[0] to ourselves so we're more likely to have
+        # the signing key around later. This way, even if all the servers die
+        # and the directory contents are unrecoverable, at least we can still
+        # push out a new copy with brand-new contents.
+
+        new_sharemap = {}
+
+        # build the reverse sharehintmap
+        old_hints = {} # nodeid .. ?
+        for shnum, nodeids in self._node._sharemap:
+            pass