Trees | Indices | Help |
---|
|
1 # -*- Mode: Python; test-case-name: flumotion.test.test_feedcomponent010 -*- 2 # vi:si:et:sw=4:sts=4:ts=4 3 # 4 # Flumotion - a streaming media server 5 # Copyright (C) 2004,2005,2006,2007,2008 Fluendo, S.L. (www.fluendo.com). 6 # All rights reserved. 7 8 # This file may be distributed and/or modified under the terms of 9 # the GNU General Public License version 2 as published by 10 # the Free Software Foundation. 11 # This file is distributed without any warranty; without even the implied 12 # warranty of merchantability or fitness for a particular purpose. 13 # See "LICENSE.GPL" in the source distribution for more information. 14 15 # Licensees having purchased or holding a valid Flumotion Advanced 16 # Streaming Server license may use this file in accordance with the 17 # Flumotion Advanced Streaming Server Commercial License Agreement. 18 # See "LICENSE.Flumotion" in the source distribution for more information. 19 20 # Headers in this file shall remain intact. 21 22 """ 23 Component tab in the component UI 24 """ 25 26 import gettext 27 import os 28 import time 29 30 import gtk 31 32 from flumotion.common.format import formatStorage, formatTime 33 from flumotion.common.i18n import gettexter 34 from flumotion.component.base.baseadminnode import BaseAdminGtkNode 35 from flumotion.extern.log.log import getDebug 36 from flumotion.common.planet import AdminFlowState 37 38 39 _ = gettext.gettext 40 __version__ = "$Rev: 7162 $" 41 T_ = gettexter() 42 4345 gladeFile = os.path.join('flumotion', 'component', 'base', 46 'component.glade') 4721049 BaseAdminGtkNode.__init__(self, state, admin, title=_("Component")) 50 51 self._startTime = None 52 self._debugging = None 53 self._initialFluMask = '' 54 self._initialGstMask = ''5557 BaseAdminGtkNode.setDebugEnabled(self, enabled) 58 if self._debugging: 59 self._debugging.set_property('visible', enabled) 60 61 self._initialFluMask = getDebug() 62 self._initialGstMask = os.environ.get('GST_DEBUG', '')6365 self.widget = self.wtree.get_widget('main-vbox') 66 assert self.widget, "No component-widget in %s" % self.gladeFile 67 self.gst_mask = self.wtree.get_widget('gst_mask') 68 self.gst_mask.connect('changed', self._on_gst_mask_changed) 69 self.gst_label = self.wtree.get_widget('gst_label') 70 self.flu_mask = self.wtree.get_widget('flu_mask') 71 self.flu_mask.connect('changed', self._on_flu_mask_changed) 72 self.gst_profile = self.wtree.get_widget('gst_profile') 73 self.gst_profile.connect('changed', self._on_gst_profile_changed) 74 self.flu_profile = self.wtree.get_widget('flu_profile') 75 self.flu_profile.connect('changed', self._on_flu_profile_changed) 76 77 # pid 78 l = self.wtree.get_widget('label-pid') 79 pid = self.state.get('pid') 80 l.set_text(str(pid)) 81 82 # Find the labels which we'll update when we get uiState updates. 83 self._label_start_time = self.wtree.get_widget('label-since') 84 self._label_uptime = self.wtree.get_widget('label-uptime') 85 self._label_cpu = self.wtree.get_widget('label-cpu') 86 self._label_vsize = self.wtree.get_widget('label-vsize') 87 self._label_component_type = self.wtree.get_widget( 88 'label-component-type') 89 90 self.widget.show() 91 92 self._prepareDebugging() 93 94 self._debugging = self.wtree.get_widget('debugging') 95 if self._debugEnabled: 96 self._debugging.show() 97 98 componentType = self.state.get('config')['type'] 99 self._label_component_type.set_text(componentType) 100 101 return self.widget102104 if ':' not in mask or mask.count(':') != 1: 105 return False 106 name, level = mask.split(':', 1) 107 try: 108 int(level) 109 except ValueError: 110 return False 111 return True112114 profile = combo.get_selected() 115 if profile is not None: 116 gtk.Entry.set_text(self.gst_mask, profile) 117 self.gst_mask.set_sensitive(profile is None)118120 profile = combo.get_selected() 121 if profile is not None: 122 gtk.Entry.set_text(self.flu_mask, profile) 123 self.flu_mask.set_sensitive(profile is None)124126 debug = entry.get_text() 127 if not self._debugEnabled or not self._validateMask(debug): 128 return 129 self.info('setting flu debug to %s for %s' % ( 130 debug, self.state.get('name'))) 131 self.admin.componentCallRemote(self.state, 'setFluDebug', debug)132134 debug = entry.get_text() 135 if not self._debugEnabled or not self._validateMask(debug): 136 return 137 self.info('setting gst debug to %s for %s' % ( 138 debug, self.state.get('name'))) 139 self.admin.componentCallRemote(self.state, 'setGstDebug', debug)140142 debugEnabled = self._debugEnabled 143 self._debugEnabled = False 144 default = [(_('Nothing'), '*:0'), 145 (_('Everything'), '*:4'), 146 (_('Custom'), None)] 147 self.flu_profile.prefill(default) 148 149 if isinstance(self.state.get('parent'), AdminFlowState): 150 self.gst_profile.prefill(default) 151 else: 152 self.gst_profile.hide() 153 self.gst_label.hide() 154 self.gst_mask.hide() 155 156 self._debugEnabled = debugEnabled157159 self._label_start_time.set_text( 160 time.strftime("%c", time.localtime(value))) 161 self._label_uptime.set_text(formatTime(0)) 162 163 self._startTime = value164166 if self._startTime is not None: 167 runtime = value - self._startTime 168 169 self._label_uptime.set_text(formatTime(runtime)) 170 else: 171 self._label_uptime.set_text(_("not available"))172 176178 # given int for vsize in bytes, update the label 179 if not vsize: 180 self._label_vsize.set_text(_('Unknown')) 181 else: 182 self._label_vsize.set_text('%sB' % formatStorage(vsize))183185 BaseAdminGtkNode.setUIState(self, uiState) 186 187 # Ick; we don't get these otherwise. 188 for key in uiState.keys(): 189 val = uiState.get(key) 190 if val is not None: 191 self.stateSet(uiState, key, uiState.get(key))192 193 # IStateListener Interface 194196 if key == 'cpu-percent': 197 self._updateCPU(value) 198 elif key == 'virtual-size': 199 self._updateVSize(value) 200 if key == 'start-time': 201 self._setStartTime(value) 202 elif key == 'current-time': 203 self._setCurrentTime(value)204 207
Trees | Indices | Help |
---|
Generated by Epydoc 3.0.1 on Wed Aug 11 21:33:24 2010 | http://epydoc.sourceforge.net |