Changeset 2a05aa2 in trunk
- Timestamp:
- 2010-08-04T07:28:08Z (15 years ago)
- Branches:
- master
- Children:
- fa34e4dd
- Parents:
- abcd6e0e
- Location:
- src/allmydata
- Files:
-
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
TabularUnified src/allmydata/immutable/filenode.py ¶
rabcd6e0e r2a05aa2 32 32 history.add_download(ds) 33 33 download_status = ds 34 self._node = DownloadNode(verifycap, storage_broker, secret_holder, 35 terminator, history, download_status) 34 self._terminator = terminator 35 self._history = history 36 self._download_status = download_status 37 self._node = None # created lazily, on read() 38 39 def _maybe_create_download_node(self): 40 if self._node is None: 41 self._node = DownloadNode(self._verifycap, self._storage_broker, 42 self._secret_holder, 43 self._terminator, 44 self._history, self._download_status) 36 45 37 46 def read(self, consumer, offset=0, size=None, read_ev=None): … … 40 49 return a Deferred that fires (with the consumer) when the read is 41 50 finished.""" 51 self._maybe_create_download_node() 42 52 return self._node.read(consumer, offset, size, read_ev) 43 53 … … 57 67 segment size, and still know which data you received. 58 68 """ 69 self._maybe_create_download_node() 59 70 return self._node.get_segment(segnum) 60 71 61 72 def get_segment_size(self): 62 73 # return a Deferred that fires with the file's real segment size 74 self._maybe_create_download_node() 63 75 return self._node.get_segsize() 64 76 -
TabularUnified src/allmydata/test/test_download.py ¶
rabcd6e0e r2a05aa2 328 328 self.load_shares() 329 329 n = self.c0.create_node_from_uri(immutable_uri) 330 n._cnode._maybe_create_download_node() 330 331 331 332 # Cause the downloader to guess a segsize that's too low, so it will … … 386 387 def _uploaded(ur): 387 388 n = self.c0.create_node_from_uri(ur.uri) 389 n._cnode._maybe_create_download_node() 388 390 n._cnode._node._build_guessed_tables(u.max_segment_size) 389 391 d1 = n.read(con1, 70, 20) … … 414 416 def _uploaded(ur): 415 417 n = self.c0.create_node_from_uri(ur.uri) 418 n._cnode._maybe_create_download_node() 416 419 n._cnode._node._build_guessed_tables(u.max_segment_size) 417 420 d = n.read(con1, 12000, 20) … … 621 624 def _uploaded(ur): 622 625 n = self.c0.create_node_from_uri(ur.uri) 626 n._cnode._maybe_create_download_node() 623 627 n._cnode._node._build_guessed_tables(u.max_segment_size) 624 628 … … 659 663 def _uploaded(ur): 660 664 n = self.c0.create_node_from_uri(ur.uri) 665 n._cnode._maybe_create_download_node() 661 666 n._cnode._node._build_guessed_tables(u.max_segment_size) 662 667 d1 = n.read(con1, 70, 20) … … 806 811 def _download(ign, imm_uri, which, expected): 807 812 n = self.c0.create_node_from_uri(imm_uri) 813 n._cnode._maybe_create_download_node() 808 814 # for this test to work, we need to have a new Node each time. 809 815 # Make sure the NodeMaker's weakcache hasn't interfered. … … 946 952 def _download(imm_uri): 947 953 n = self.c0.create_node_from_uri(imm_uri) 954 n._cnode._maybe_create_download_node() 948 955 # for this test to work, we need to have a new Node each time. 949 956 # Make sure the NodeMaker's weakcache hasn't interfered. -
TabularUnified src/allmydata/test/test_hung_server.py ¶
rabcd6e0e r2a05aa2 232 232 self._hang_shares(range(5)) 233 233 n = self.c0.create_node_from_uri(self.uri) 234 n._cnode._maybe_create_download_node() 234 235 self._sf = n._cnode._node._sharefinder 235 236 self._sf.max_outstanding_requests = 5
Note: See TracChangeset
for help on using the changeset viewer.