equal
deleted
inserted
replaced
886 |
886 |
887 cg = self.changegroup(update) |
887 cg = self.changegroup(update) |
888 return remote.addchangegroup(cg) |
888 return remote.addchangegroup(cg) |
889 |
889 |
890 def changegroup(self, basenodes): |
890 def changegroup(self, basenodes): |
891 class genread: |
891 genread = util.chunkbuffer |
892 def __init__(self, generator): |
|
893 self.g = generator |
|
894 self.buf = "" |
|
895 def fillbuf(self): |
|
896 self.buf += "".join(self.g) |
|
897 |
|
898 def read(self, l): |
|
899 while l > len(self.buf): |
|
900 try: |
|
901 self.buf += self.g.next() |
|
902 except StopIteration: |
|
903 break |
|
904 d, self.buf = self.buf[:l], self.buf[l:] |
|
905 return d |
|
906 |
892 |
907 def gengroup(): |
893 def gengroup(): |
908 nodes = self.newer(basenodes) |
894 nodes = self.newer(basenodes) |
909 |
895 |
910 # construct the link map |
896 # construct the link map |