~facundo/ubuntuone-client/support-initial-disconnection

« back to all changes in this revision

Viewing changes to tests/syncdaemon/test_action_predicates.py

  • Committer: Tarmac
  • Author(s): facundo at com
  • Date: 2010-09-01 21:20:58 UTC
  • mfrom: (664.1.5 release-waiting)
  • Revision ID: tarmac-20100901212058-p4t5ord4m9csiczd
Cancelled uploads don't survive forever now.

Show diffs side-by-side

added added

removed removed

Lines of Context:
26
26
 
27
27
class AppendCommand(ActionQueueCommand):
28
28
    """Simple command which appends a value to a list."""
29
 
    blocked = False
30
29
 
31
30
    def __init__(self, request_queue, append_to, value):
32
31
        """Initialize, remembering list and value."""
34
33
        self.append_to = append_to
35
34
        self.value = value
36
35
 
37
 
    def _is_runnable(self):
38
 
        """Returns the opposite of self.blocked."""
39
 
        return not self.blocked
40
 
 
41
36
    def _run(self):
42
37
        """Do the actual append."""
43
38
        self.append_to.append(self.value)
107
102
                for v in ("a", "b", "c")]
108
103
        for cmd in cmds:
109
104
            cmd.start()
110
 
        cmds[1].blocked = True
111
 
        self.request_queue.run()
112
 
        self.request_queue.run()
113
 
        self.assertEqual(["a", "c"], out)
114
 
        self.request_queue.run()
115
 
        self.assertEqual(["a", "c"], out)
116
 
        cmds[1].blocked = False
 
105
        cmds[1].is_runnable = False
 
106
        self.request_queue.run()
 
107
        self.request_queue.run()
 
108
        self.assertEqual(["a", "c"], out)
 
109
        self.request_queue.run()
 
110
        self.assertEqual(["a", "c"], out)
 
111
        cmds[1].is_runnable = True
117
112
        self.request_queue.check_conditions()
118
113
        self.request_queue.run()
119
114
        self.assertEqual(["a", "c", "b"], out)
125
120
                for v in ("a", "b", "c")]
126
121
        for cmd in cmds:
127
122
            cmd.start()
128
 
        cmds[1].blocked = True
 
123
        cmds[1].is_runnable = False
129
124
        self.request_queue.run()
130
125
        self.request_queue.run()
131
126
        self.assertEqual(["a"], out)
132
 
        cmds[1].blocked = False
 
127
        cmds[1].is_runnable = True
133
128
        self.request_queue.check_conditions()
134
129
        self.request_queue.run()
135
130
        self.assertEqual(["a", "b"], out)