← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/transport/__init__.py

  • Committer: Canonical.com Patch Queue Manager
  • Date: 2007-12-10 12:06:11 UTC
  • mfrom: (3097.2.1 trunk)
  • Revision ID: pqm@pqm.ubuntu.com-20071210120611-a3j02d26cbzvlyju
Fix 173010 by reading data as it arrives on the http socket (vila)

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/transport/__init__.py
234
234
        return cmp((self.start, self.length, self.ranges),
235
235
                   (other.start, other.length, other.ranges))
236
236
 
 
237
    def __repr__(self):
 
238
        return '%s(%r, %r, %r)' % (self.__class__.__name__,
 
239
            self.start, self.length, self.ranges)
 
240
 
237
241
 
238
242
class LateReadError(object):
239
243
    """A helper for transports which pretends to be a readable file.
788
792
        return offsets
789
793
 
790
794
    @staticmethod
791
 
    def _coalesce_offsets(offsets, limit, fudge_factor):
 
795
    def _coalesce_offsets(offsets, limit=0, fudge_factor=0, max_size=0):
792
796
        """Yield coalesced offsets.
793
797
 
794
798
        With a long list of neighboring requests, combine them
797
801
        Turns  [(15, 10), (25, 10)] => [(15, 20, [(0, 10), (10, 10)])]
798
802
 
799
803
        :param offsets: A list of (start, length) pairs
800
 
        :param limit: Only combine a maximum of this many pairs
801
 
                      Some transports penalize multiple reads more than
802
 
                      others, and sometimes it is better to return early.
803
 
                      0 means no limit
 
804
 
 
805
        :param limit: Only combine a maximum of this many pairs Some transports
 
806
                penalize multiple reads more than others, and sometimes it is
 
807
                better to return early.
 
808
                0 means no limit
 
809
 
804
810
        :param fudge_factor: All transports have some level of 'it is
805
811
                better to read some more data and throw it away rather 
806
812
                than seek', so collapse if we are 'close enough'
 
813
 
 
814
        :param max_size: Create coalesced offsets no bigger than this size.
 
815
                When a single offset is bigger than 'max_size', it will keep
 
816
                its size and be alone in the coalesced offset.
 
817
                0 means no maximum size.
 
818
 
807
819
        :return: yield _CoalescedOffset objects, which have members for where
808
820
                to start, how much to read, and how to split those 
809
821
                chunks back up
813
825
 
814
826
        for start, size in offsets:
815
827
            end = start + size
816
 
            if (last_end is not None 
 
828
            if (last_end is not None
817
829
                and start <= last_end + fudge_factor
818
830
                and start >= cur.start
819
 
                and (limit <= 0 or len(cur.ranges) < limit)):
 
831
                and (limit <= 0 or len(cur.ranges) < limit)
 
832
                and (max_size <= 0 or end - cur.start <= max_size)):
820
833
                cur.length = end - cur.start
821
834
                cur.ranges.append((start-cur.start, size))
822
835
            else: