Package flumotion :: Package component :: Package base :: Module componentnode
[hide private]

Source Code for Module flumotion.component.base.componentnode

  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   
 43   
44 -class ComponentAdminGtkNode(BaseAdminGtkNode):
45 gladeFile = os.path.join('flumotion', 'component', 'base', 46 'component.glade') 47
48 - def __init__(self, state, admin):
49 BaseAdminGtkNode.__init__(self, state, admin, title=_("Component")) 50 51 self._startTime = None 52 self._debugging = None 53 self._initialFluMask = '' 54 self._initialGstMask = ''
55
56 - def setDebugEnabled(self, enabled):
57 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', '')
63
64 - def haveWidgetTree(self):
65 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.widget
102
103 - def _validateMask(self, mask):
104 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 True
112
113 - def _on_gst_profile_changed(self, combo):
114 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)
118
119 - def _on_flu_profile_changed(self, combo):
120 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)
124
125 - def _on_flu_mask_changed(self, entry):
126 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)
132
133 - def _on_gst_mask_changed(self, entry):
134 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)
140
141 - def _prepareDebugging(self):
142 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 = debugEnabled
157
158 - def _setStartTime(self, value):
159 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 = value
164
165 - def _setCurrentTime(self, value):
166 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
173 - def _updateCPU(self, cpu):
174 # given float for cpu, update the label 175 self._label_cpu.set_text('%.2f %%' % (cpu * 100.0))
176
177 - def _updateVSize(self, vsize):
178 # 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))
183
184 - def setUIState(self, uiState):
185 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 194
195 - def stateSet(self, object, key, value):
196 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
205 - def stateAppend(self, object, key, value):
206 pass
207
208 - def stateRemove(self, object, key, value):
209 pass
210