← Back to branch summary

~shakhat/os-faults/master

« back to all changes in this revision

Viewing changes to os_faults/drivers/services/process.py

  • Committer: Gerrit Code Review
  • Author(s): Zuul
  • Date: 2018-11-27 10:04:18 UTC
  • mfrom: (177.1.2)
  • Revision ID: git-v1:62b96dd2a4fcee9ca5410b447fd34bd900b93b6e
Merge "Remove old drivers"

Show diffs side-by-side

added added

removed removed

Lines of Context:
os_faults/drivers/services/process.py
124
124
        self._run_task(nodes, {'shell': self.start_cmd}, 'Start')
125
125
 
126
126
    def kill(self, nodes=None):
127
 
        task = {'kill': {'grep': self.grep, 'sig': signal.SIGKILL}}
 
127
        task = {
 
128
            'kill': {
 
129
                'grep': self.grep, 'sig': signal.SIGKILL
 
130
            },
 
131
            'become': 'yes',
 
132
        }
128
133
        self._run_task(nodes, task, 'Kill')
129
134
 
130
135
    def freeze(self, nodes=None, sec=None):
131
136
        if sec:
132
 
            task = {'freeze': {'grep': self.grep, 'sec': sec}}
 
137
            task = {
 
138
                'freeze': {
 
139
                    'grep': self.grep, 'sec': sec
 
140
                },
 
141
                'become': 'yes',
 
142
            }
133
143
        else:
134
 
            task = {'kill': {'grep': self.grep, 'sig': signal.SIGSTOP}}
 
144
            task = {
 
145
                'kill': {
 
146
                    'grep': self.grep, 'sig': signal.SIGSTOP
 
147
                },
 
148
                'become': 'yes',
 
149
            }
135
150
        message = "Freeze %s" % (('for %s sec ' % sec) if sec else '')
136
151
        self._run_task(nodes, task, message)
137
152
 
138
153
    def unfreeze(self, nodes=None):
139
 
        task = {'kill': {'grep': self.grep, 'sig': signal.SIGCONT}}
 
154
        task = {
 
155
            'kill': {
 
156
                'grep': self.grep, 'sig': signal.SIGCONT
 
157
            },
 
158
            'become': 'yes',
 
159
        }
140
160
        self._run_task(nodes, task, 'Unfreeze')
141
161
 
142
162
    @utils.require_variables('port')
147
167
            'iptables': {
148
168
                'protocol': self.port[0], 'port': self.port[1],
149
169
                'action': 'unblock', 'service': self.service_name
150
 
            }
 
170
            },
 
171
            'become': 'yes',
151
172
        }
152
173
        self._run_task(nodes, task, message)
153
174
 
159
180
            'iptables': {
160
181
                'protocol': self.port[0], 'port': self.port[1],
161
182
                'action': 'block', 'service': self.service_name
162
 
            }
 
183
            },
 
184
            'become': 'yes',
163
185
        }
164
186
        self._run_task(nodes, task, message)