1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
# Copyright (C) 2010, Paraguay Educa <tecnologia@paraguayeduca.org>
# Copyright (C) 2010, Plan Ceibal <comunidad@plan.ceibal.edu.uy>
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
# the Free Software Foundation; either version 2 of the License, or
# (at your option) any later version.
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU General Public License for more details.
#
# You should have received a copy of the GNU General Public License
# along with this program; if not, write to the Free Software
# Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
from gi.repository import GObject
from gi.repository import Gio
import os
from gi.repository import GLib
from sugar import env
from gettext import gettext as _
BYTES_TO_READ = 100
BACKUP_OF_CURRENT_SYSTEM_NOT_FOUND = 1
SCRIPT_EXIT_CODES_AND_MESSAGES = {}
SCRIPT_EXIT_CODES_AND_MESSAGES[BACKUP_OF_CURRENT_SYSTEM_NOT_FOUND] = \
_('No journal-backup has been taken for this XO. Please ' \
'ensure that you have a valid backup residing on the drive.')
class ProcessManagement(GObject.GObject):
__gtype_name__ = 'ProcessManagement'
__gsignals__ = {
'process-management-running' : (GObject.SignalFlags.RUN_FIRST, None, ([str])),
'process-management-started' : (GObject.SignalFlags.RUN_FIRST, None, ([])),
'process-management-finished' : (GObject.SignalFlags.RUN_FIRST, None, ([])),
'process-management-failed' : (GObject.SignalFlags.RUN_FIRST, None, ([str]))
}
def __init__(self):
GObject.GObject.__init__(self)
self._running = False
def do_process(self, cmd):
self._run_cmd_async(cmd)
def _report_process_status(self, stream, result, user_data=None):
data = stream.read_finish(result)
if data != 0:
self.emit('process-management-running', data)
stream.read_async([],
BYTES_TO_READ,
GObject.PRIORITY_LOW,
None,
self._report_process_status,
None)
def _report_process_error(self, concat_err):
self.emit('process-management-failed', concat_err)
def _notify_process_status(self, stdout):
stdin_stream = Gio.UnixInputStream(fd=stdout, close_fd=True)
stdin_stream.read_async([],
BYTES_TO_READ,
GObject.PRIORITY_LOW,
None,
self._report_process_status,
None)
def _run_cmd_async(self, cmd):
if self._running == False:
try:
pid, stdin, stdout, stderr = GLib.spawn_async(cmd, flags=GLib.SPAWN_DO_NOT_REAP_CHILD, standard_output=True, standard_error=True)
GObject.child_watch_add(pid, _handle_process_end, (self, stderr))
except Exception:
self.emit('process-management-failed', _("Error - Call process: ") + str(cmd))
else:
self._notify_process_status(stdout)
self._running = True
self.emit('process-management-started')
def _handle_process_end(pid, condition, (myself, stderr)):
myself._running = False
if os.WIFEXITED(condition) and\
os.WEXITSTATUS(condition) == 0:
myself.emit('process-management-finished')
else:
error_code_returned_from_script = os.WEXITSTATUS(condition)
error_message = \
SCRIPT_EXIT_CODES_AND_MESSAGES[error_code_returned_from_script]
myself._report_process_error(error_message)
def find_and_absolutize(script_name):
paths = env.os.environ['PATH'].split(':')
for path in paths:
looking_path = path + '/' + script_name
if env.os.path.isfile(looking_path):
return looking_path
return None
|
