[rhmessaging-commits] rhmessaging commits: r4279 - mgmt/newdata/cumin/python/cumin/grid.

rhmessaging-commits at lists.jboss.org rhmessaging-commits at lists.jboss.org
Mon Sep 13 12:44:19 EDT 2010


Author: eallen
Date: 2010-09-13 12:44:19 -0400 (Mon, 13 Sep 2010)
New Revision: 4279

Modified:
   mgmt/newdata/cumin/python/cumin/grid/limit.py
   mgmt/newdata/cumin/python/cumin/grid/negotiator.py
Log:
Call reconfig after a SetLimit call returns.

Modified: mgmt/newdata/cumin/python/cumin/grid/limit.py
===================================================================
--- mgmt/newdata/cumin/python/cumin/grid/limit.py	2010-09-13 16:32:26 UTC (rev 4278)
+++ mgmt/newdata/cumin/python/cumin/grid/limit.py	2010-09-13 16:44:19 UTC (rev 4279)
@@ -184,46 +184,6 @@
         def render_title(self, session):
             return "Max Allowance"
 
-class NegotiatorLimitSetForm(CuminForm):
-    def __init__(self, app, name, task):
-        super(LimitEdit, self).__init__(app, name)
-
-        self.task = task
-
-        self.negotiator = NegotiatorParameter(app, "negotiator")
-        self.add_parameter(self.negotiator)
-
-        self.limit_name = Parameter("name")
-        self.add_parameter(self.limit_name)
-
-        self.limit_max = Parameter(app, "max")
-        self.add_parameter(self.max)
-
-    def render_title(self, session):
-        negotiator = self.negotiator.get(session)
-        name = self.limit_name.get(session)
-        
-        return self.task.get_description(session, (negotiator, name))
-
-    def xxx_render_inline_help(self, session):
-        return "Set the maximum number of jobs that can run " + \
-            "concurrently using this limiter."
-
-    def process_submit(self, session):
-        negotiator = self.negotiator.get(session)
-        name = self.limit_name.get(session)
-        max = self.limit_max.get(session)
-
-        self.check()
-
-        # XXX add errors
-        # 1. max is float
-        # 2. max > 1.0 and max < 99999.0
-
-        if not self.errors.get(session):
-            self.task.invoke(session, negotiator, name, max)
-            self.task.exit_with_redirect(session)
-
 class LimitView(CuminView):
     def __init__(self, app, name, limit):
         super(LimitView, self).__init__(app, name, None)

Modified: mgmt/newdata/cumin/python/cumin/grid/negotiator.py
===================================================================
--- mgmt/newdata/cumin/python/cumin/grid/negotiator.py	2010-09-13 16:32:26 UTC (rev 4278)
+++ mgmt/newdata/cumin/python/cumin/grid/negotiator.py	2010-09-13 16:44:19 UTC (rev 4279)
@@ -918,33 +918,6 @@
 
         return params
 
-class NegotiatorLimitSet(ObjectFrameTask):
-    def __init__(self, app, frame):
-        super(NegotiatorLimitSet, self).__init__(app, frame)
-
-        self.form = NegotiatorLimitSetForm(module.app, self.name, self)
-
-    def do_enter(self, session, osession):
-        pass
-        #self.form.negotiator.set(session, limit[0])
-        #self.form.limit_name.set(session, limit[1])
-
-    def get_title(self, session):
-        return "Set limit"
-
-    def do_invoke(self, invoc, negotiator, name, max):
-        action = SetLimit(self.app)
-        result = action.execute(negotiator, name, max)
-        if result.error:
-            raise result.error
-
-        invoc.status_code = invoc.status
-
-        action = QmfCall(self.app)
-        action.execute(negotiator, "Reconfig")
-
-        invoc.end()
-
 class NegotiatorGroupTask(ObjectFrameTask):
     def do_exit(self, session):
         self.app.main_page.main.grid.pool.view.show(session)



More information about the rhmessaging-commits mailing list