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
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
|
# Copyright (c) 2007, 2015, Oracle and/or its affiliates. All rights reserved.
#
# 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; version 2 of the
# License.
#
# 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 __future__ import with_statement
import os
import sys
import grt
from workbench.log import log_info, log_error, log_debug
from mforms import App, Utilities, newTabView
import mforms
from workbench.notifications import nc
from wb_common import dprint_ex
import wb_admin_utils
from wb_admin_configuration_startup import WbAdminConfigurationStartup
from wb_admin_config_file_ui import WbAdminConfigFileUI
from wb_admin_server_status import WbAdminServerStatus
from wb_admin_connections import WbAdminConnections
from wb_admin_variables import WbAdminVariables
from wb_admin_security import WbAdminSecurity
from wb_admin_logs import WbAdminLogs
from wb_admin_export import WbAdminExport, WbAdminImport
from wb_admin_performance_dashboard import WbAdminDashboard
from wb_admin_perfschema_reports import WbAdminPerformanceSchema
from wb_admin_perfschema_instrumentation import WbAdminPerformanceSchemaInstrumentation
from wb_admin_utils import weakcb
from wb_server_management import wbaOS
def scan_admin_modules():
# initialize the main WBA modules
modules = [WbAdminConfigurationStartup,
WbAdminLogs,
WbAdminConfigFileUI,
WbAdminServerStatus,
WbAdminConnections,
WbAdminSecurity,
WbAdminVariables,
WbAdminExport,
WbAdminImport,
WbAdminDashboard,
WbAdminPerformanceSchema,
WbAdminPerformanceSchemaInstrumentation]
# look for extension modules
#---------------------------------------------------------------------------
grt.log_info("WBA", "Looking for extension modules for WBA...\n")
init_count = 0
# search in the same dir where the WBA code itself is located
extra_mods = {}
for location in [os.path.dirname(__file__)]:
try:
folders = [f for f in os.listdir(location) if f.startswith("wba_") and os.path.isdir(os.path.join(location, f))]
except:
continue
sys.path.append(location)
for candidate in folders:
if os.path.exists(os.path.join(location, candidate, "__init__.py")):
mod = __import__(candidate)
if hasattr(mod, "wba_register"):
extra_mods[candidate] = mod
init_count+= 1
else:
# unload the module
del sys.modules[mod.__name__]
del mod
sys.path.pop()
if len(extra_mods) != 0:
import collections
od = collections.OrderedDict(sorted(extra_mods.items()))
for mod in od.values():
modules.append(mod)
grt.log_info("WBA", "%i extension modules found\n" % init_count)
return modules
#===============================================================================
#
#===============================================================================
class AdministratorTab(mforms.AppView):
def __init__(self, ctrl_be, server_profile, main_view, editor):
mforms.AppView.__init__(self, False, "administrator", False)
self.editor = editor
self.owner = main_view
self.tabs = []
self.name2page = {}
self.config_ui = None
self.closing = False
self.tabview = newTabView(True)
self.ctrl_be = ctrl_be
self.old_active_tab = None
self.server_profile = server_profile
# if we're in the Mac, we need to set the background color of the main view of the tab to white,
# so that MTabSwitcher will take the cue and set the tab color to white too
if self.server_profile.host_os == wbaOS.darwin:
self.set_back_color("#ffffff")
# Setup self
self.set_managed()
self.set_release_on_add()
self.on_close(wb_admin_utils.weakcb(self, "handle_on_close"))
nc.add_observer(self.handle_server_state_changed, "GRNServerStateChanged", editor)
self.ctrl_be.add_me_for_event("server_started", self)
self.ctrl_be.add_me_for_event("server_stopped", self)
self.add(self.tabview, True, True)
self._timeout_tm = Utilities.add_timeout(0.5, weakcb(self, "timeout"))
self.tabview.add_tab_changed_callback(self.tab_changed)
self.timeout()
# check initial state
if editor.isConnected == 1:
self.ctrl_be.event_from_main("server_started")
elif editor.isConnected == -1:
self.ctrl_be.event_from_main("server_offline")
self.ctrl_be.continue_events() # Process events which are queue during init
log_debug("WBA init complete\n")
#---------------------------------------------------------------------------
def handle_on_close(self):
log_debug("Closing admin\n")
if self._timeout_tm:
Utilities.cancel_timeout(self._timeout_tm)
self._timeout_tm = None
nc.remove_observer(self.handle_server_state_changed)
App.get().set_status_text("Closing Administator.")
self.shutdown()
if not self.closing:
log_debug("Admin close cancelled\n")
return False
self.ctrl_be.shutdown()
self.release()
self.owner.handle_close()
return True
#---------------------------------------------------------------------------
def set_content_label(self, text):
self.set_title(text)
#---------------------------------------------------------------------------
def add_page(self, page):
self.tabs.append(page)
# not needed in Mac since it's already done earlier and in Linux, we shouldn't set the background color,
# because you never know what gtk theme the user may be using
if self.server_profile.host_os == wbaOS.windows:
page.set_back_color("#ffffff")
self.tabview.add_page(page, "")
#---------------------------------------------------------------------------
def remove_page(self, page):
if page in self.tabs:
self.tabs.remove(page)
self.tabview.remove_page(page)
#---------------------------------------------------------------------------
def select_page(self, page):
self.tabview.set_active_tab(self.tabs.index(page))
self.owner.become_active_tab()
#---------------------------------------------------------------------------
def page_with_id(self, entry_id):
return self.owner.page_with_id(entry_id)
#---------------------------------------------------------------------------
def switch_to(self, entry_id):
#self.tasks_side.select_entry(entry_id)
self.tab_changed()
#---------------------------------------------------------------------------
def tab_changed(self):
if self.old_active_tab and hasattr(self.old_active_tab, "page_deactivated"):
self.old_active_tab.page_deactivated()
i = self.tabview.get_active_tab()
panel = self.tabs[i]
if panel is not None and hasattr(panel, "page_activated"):
try:
panel.page_activated()
except Exception, e:
import traceback
log_error("Unhandled exception in Admin for %s: %s\n" % (panel, traceback.format_exc()))
mforms.Utilities.show_error("Error", "An unhandled exception occurred (%s). Please refer to the log files for details." % e, "OK", "", "")
self.old_active_tab = panel
#---------------------------------------------------------------------------
def shutdown(self):
log_error("shutting down admn\n")
dprint_ex(2, " closing")
self.closing = True
for tab in self.tabs:
if hasattr(tab, "shutdown"):
res = tab.shutdown()
if res is False: # It has to explicitely return False to cancel shutdown
self.closing = False
#---------------------------------------------------------------------------
def shutdown_event(self):
self.shutdown()
#---------------------------------------------------------------------------
def handle_server_state_changed(self, name, sender, info):
# called from outside when running state of the server changes
log_info("received notification that server state changed to %s\n" % info["state"])
if info["state"] == 1:
self.ctrl_be.event_from_main("server_started")
elif info["state"] == -1:
self.ctrl_be.event_from_main("server_offline")
else:
self.ctrl_be.event_from_main("server_stopped")
#---------------------------------------------------------------------------
def server_started_event(self):
dprint_ex(1, "Handling start event")
if len(self.tabs) > 0 and hasattr(self.tabs[0], 'print_output'):
self.ctrl_be.uitask(self.tabs[0].print_output, "Server is running")
dprint_ex(1, "Done handling start event")
def server_offline_event(self):
dprint_ex(1, "Handling offline event")
if len(self.tabs) > 0 and hasattr(self.tabs[0], 'print_output'):
self.ctrl_be.uitask(self.tabs[0].print_output, "Server is running in offline mode")
dprint_ex(1, "Done handling offline event")
#---------------------------------------------------------------------------
def server_stopped_event(self):
dprint_ex(1, "Handling stop event")
if len(self.tabs) > 0 and hasattr(self.tabs[0], "print_output"):
self.ctrl_be.uitask(self.tabs[0].print_output, "Server is stopped")
dprint_ex(1, "Done handling stop event")
#---------------------------------------------------------------------------
def timeout(self):
if not self.closing:
self.ctrl_be.process_ui_task_queue()
if self.closing:
self._timeout_tm = None
return not self.closing
|
