← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/selftest/testfetch.py

  • Committer: Robert Collins
  • Date: 2005-10-09 23:42:12 UTC
  • Revision ID: robertc@robertcollins.net-20051009234212-7973344d900afb0b
merge in niemeyers prefixed-store patch

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/selftest/testfetch.py
13
13
# You should have received a copy of the GNU General Public License
14
14
# along with this program; if not, write to the Free Software
15
15
# Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 
16
 
 
17
import os
 
18
import sys
 
19
 
16
20
import bzrlib.errors
17
21
from bzrlib.selftest.testrevision import make_branches
18
22
from bzrlib.trace import mutter
19
23
from bzrlib.branch import Branch
20
 
import sys
21
 
import os
 
24
from bzrlib.fetch import greedy_fetch
22
25
 
23
26
from bzrlib.selftest import TestCaseInTempDir
 
27
from bzrlib.selftest.HTTPTestUtil import TestCaseWithWebserver
 
28
 
 
29
 
 
30
def has_revision(branch, revision_id):
 
31
    try:
 
32
        branch.get_revision_xml_file(revision_id)
 
33
        return True
 
34
    except bzrlib.errors.NoSuchRevision:
 
35
        return False
 
36
 
 
37
def fetch_steps(self, br_a, br_b, writable_a):
 
38
    """A foreign test method for testing fetch locally and remotely."""
 
39
    def new_branch(name):
 
40
        os.mkdir(name)
 
41
        return Branch.initialize(name)
 
42
            
 
43
    assert not has_revision(br_b, br_a.revision_history()[3])
 
44
    assert has_revision(br_b, br_a.revision_history()[2])
 
45
    assert len(br_b.revision_history()) == 7
 
46
    assert greedy_fetch(br_b, br_a, br_a.revision_history()[2])[0] == 0
 
47
 
 
48
    # greedy_fetch is not supposed to alter the revision history
 
49
    assert len(br_b.revision_history()) == 7
 
50
    assert not has_revision(br_b, br_a.revision_history()[3])
 
51
 
 
52
    assert len(br_b.revision_history()) == 7
 
53
    assert greedy_fetch(br_b, br_a, br_a.revision_history()[3])[0] == 1
 
54
    assert has_revision(br_b, br_a.revision_history()[3])
 
55
    assert not has_revision(br_a, br_b.revision_history()[6])
 
56
    assert has_revision(br_a, br_b.revision_history()[5])
 
57
 
 
58
    # When a non-branch ancestor is missing, it should be unlisted...
 
59
    # as its not reference from the inventory weave.
 
60
    br_b4 = new_branch('br_4')
 
61
    count, failures = greedy_fetch(br_b4, br_b)
 
62
    self.assertEqual(count, 7)
 
63
    self.assertEqual(failures, [])
 
64
 
 
65
    self.assertEqual(greedy_fetch(writable_a, br_b)[0], 1)
 
66
    assert has_revision(br_a, br_b.revision_history()[3])
 
67
    assert has_revision(br_a, br_b.revision_history()[4])
24
68
        
 
69
    br_b2 = new_branch('br_b2')
 
70
    assert greedy_fetch(br_b2, br_b)[0] == 7
 
71
    assert has_revision(br_b2, br_b.revision_history()[4])
 
72
    assert has_revision(br_b2, br_a.revision_history()[2])
 
73
    assert not has_revision(br_b2, br_a.revision_history()[3])
 
74
 
 
75
    br_a2 = new_branch('br_a2')
 
76
    assert greedy_fetch(br_a2, br_a)[0] == 9
 
77
    assert has_revision(br_a2, br_b.revision_history()[4])
 
78
    assert has_revision(br_a2, br_a.revision_history()[3])
 
79
    assert has_revision(br_a2, br_a.revision_history()[2])
 
80
 
 
81
    br_a3 = new_branch('br_a3')
 
82
    assert greedy_fetch(br_a3, br_a2)[0] == 0
 
83
    for revno in range(4):
 
84
        assert not has_revision(br_a3, br_a.revision_history()[revno])
 
85
    self.assertEqual(greedy_fetch(br_a3, br_a2, br_a.revision_history()[2])[0], 3)
 
86
    fetched = greedy_fetch(br_a3, br_a2, br_a.revision_history()[3])[0]
 
87
    assert fetched == 3, "fetched %d instead of 3" % fetched
 
88
    # InstallFailed should be raised if the branch is missing the revision
 
89
    # that was requested.
 
90
    self.assertRaises(bzrlib.errors.InstallFailed, greedy_fetch, br_a3,
 
91
                      br_a2, 'pizza')
 
92
    # InstallFailed should be raised if the branch is missing a revision
 
93
    # from its own revision history
 
94
    br_a2.append_revision('a-b-c')
 
95
    self.assertRaises(bzrlib.errors.InstallFailed, greedy_fetch, br_a3,
 
96
                      br_a2)
 
97
 
 
98
 
 
99
    #TODO: test that fetch correctly does reweaving when needed. RBC 20051008
25
100
 
26
101
class TestFetch(TestCaseInTempDir):
27
 
    def runTest(self):
28
 
        from bzrlib.fetch import greedy_fetch, has_revision
29
 
 
30
 
        def new_branch(name):
31
 
            os.mkdir(name)
32
 
            return Branch(name, init=True)
33
 
            
34
 
        #highest indices a: 5, b: 7
35
 
        br_a, br_b = make_branches()
36
 
        assert not has_revision(br_b, br_a.revision_history()[3])
37
 
        assert has_revision(br_b, br_a.revision_history()[2])
38
 
        assert len(br_b.revision_history()) == 7
39
 
        assert greedy_fetch(br_b, br_a, br_a.revision_history()[2])[0] == 0
40
 
 
41
 
        # greedy_fetch is not supposed to alter the revision history
42
 
        assert len(br_b.revision_history()) == 7
43
 
        assert not has_revision(br_b, br_a.revision_history()[3])
44
 
 
45
 
        assert len(br_b.revision_history()) == 7
46
 
        assert greedy_fetch(br_b, br_a, br_a.revision_history()[3])[0] == 1
47
 
        assert has_revision(br_b, br_a.revision_history()[3])
48
 
        assert not has_revision(br_a, br_b.revision_history()[3])
49
 
        assert not has_revision(br_a, br_b.revision_history()[4])
50
 
 
51
 
        # When a non-branch ancestor is missing, it should be a failure, not
52
 
        # exception
53
 
        br_a4 = new_branch('br_a4')
54
 
        count, failures = greedy_fetch(br_a4, br_a)
55
 
        assert count == 6
56
 
        assert failures == set((br_b.revision_history()[4],
57
 
                                br_b.revision_history()[5])) 
58
 
 
59
 
        assert greedy_fetch(br_a, br_b)[0] == 4
60
 
        assert has_revision(br_a, br_b.revision_history()[3])
61
 
        assert has_revision(br_a, br_b.revision_history()[4])
62
 
 
63
 
        br_b2 = new_branch('br_b2')
64
 
        assert greedy_fetch(br_b2, br_b)[0] == 7
65
 
        assert has_revision(br_b2, br_b.revision_history()[4])
66
 
        assert has_revision(br_b2, br_a.revision_history()[2])
67
 
        assert not has_revision(br_b2, br_a.revision_history()[3])
68
 
 
69
 
        br_a2 = new_branch('br_a2')
70
 
        assert greedy_fetch(br_a2, br_a)[0] == 9
71
 
        assert has_revision(br_a2, br_b.revision_history()[4])
72
 
        assert has_revision(br_a2, br_a.revision_history()[3])
73
 
 
74
 
        br_a3 = new_branch('br_a3')
75
 
        assert greedy_fetch(br_a3, br_a2)[0] == 0
76
 
        for revno in range(4):
77
 
            assert not has_revision(br_a3, br_a.revision_history()[revno])
78
 
        assert greedy_fetch(br_a3, br_a2, br_a.revision_history()[2])[0] == 3
79
 
        fetched = greedy_fetch(br_a3, br_a2, br_a.revision_history()[3])[0]
80
 
        assert fetched == 3, "fetched %d instead of 3" % fetched
81
 
        # InstallFailed should be raised if the branch is missing the revision
82
 
        # that was requested.
83
 
        self.assertRaises(bzrlib.errors.InstallFailed, greedy_fetch, br_a3,
84
 
                          br_a2, 'pizza')
85
 
        # InstallFailed should be raised if the branch is missing a revision
86
 
        # from its own revision history
87
 
        br_a2.append_revision('a-b-c')
88
 
        self.assertRaises(bzrlib.errors.InstallFailed, greedy_fetch, br_a3,
89
 
                          br_a2)
90
 
 
91
 
 
92
 
 
93
 
if __name__ == '__main__':
94
 
    import unittest
95
 
    sys.exit(unittest.run_suite(unittest.makeSuite()))
 
102
 
 
103
    def test_fetch(self):
 
104
        #highest indices a: 5, b: 7
 
105
        br_a, br_b = make_branches()
 
106
        fetch_steps(self, br_a, br_b, br_a)
 
107
 
 
108
 
 
109
class TestHttpFetch(TestCaseWithWebserver):
 
110
 
 
111
    def setUp(self):
 
112
        super(TestHttpFetch, self).setUp()
 
113
        self.weblogs = []
 
114
 
 
115
    def test_fetch(self):
 
116
        #highest indices a: 5, b: 7
 
117
        br_a, br_b = make_branches()
 
118
        br_rem_a = Branch.open(self.get_remote_url(br_a._transport.base))
 
119
        fetch_steps(self, br_rem_a, br_b, br_a)
 
120
 
 
121
    def log(self, *args):
 
122
        """Capture web server log messages for introspection."""
 
123
        super(TestHttpFetch, self).log(*args)
 
124
        if args[0].startswith("webserver"):
 
125
            self.weblogs.append(args[0])
 
126
 
 
127
    def test_weaves_are_retrieved_once(self):
 
128
        self.build_tree(("source/", "source/file", "target/"))
 
129
        branch = Branch.initialize("source")
 
130
        branch.add(["file"], ["id"])
 
131
        branch.commit("added file")
 
132
        print >>open("source/file", 'w'), "blah"
 
133
        branch.commit("changed file")
 
134
        target = Branch.initialize("target/")
 
135
        source = Branch.open(self.get_remote_url("source/"))
 
136
        source.weave_store.enable_cache = False
 
137
        self.assertEqual(greedy_fetch(target, source), (2, []))
 
138
        weave_suffix = 'weaves/id.weave HTTP/1.1" 200 -'
 
139
        self.assertEqual(1,
 
140
            len([log for log in self.weblogs if log.endswith(weave_suffix)]))