November 2008 - rhmessaging-commits

rhmessaging commits: r2897 - mgmt/trunk/sesame/cpp/etc.

by rhmessaging-commits＠lists.jboss.org

Author: justi9 Date: 2008-11-29 17:06:22 -0500 (Sat, 29 Nov 2008) New Revision: 2897 Modified: mgmt/trunk/sesame/cpp/etc/sysvinit-sesame Log: Make the init script start sesame as the sesame user Modified: mgmt/trunk/sesame/cpp/etc/sysvinit-sesame =================================================================== --- mgmt/trunk/sesame/cpp/etc/sysvinit-sesame 2008-11-29 20:40:25 UTC (rev 2896) +++ mgmt/trunk/sesame/cpp/etc/sysvinit-sesame 2008-11-29 22:06:22 UTC (rev 2897) @@ -19,7 +19,7 @@ start() { echo -n $"Starting Sesame daemon: " - daemon --check $servicename $processname \& + daemon --user sesame --check $servicename $processname \& RETVAL=$? echo [ $RETVAL -eq 0 ] && touch /var/lock/subsys/$servicename

15 years, 6 months

1
0
0 / 0

rhmessaging commits: r2896 - mgmt/trunk/sesame/cpp/src.

by rhmessaging-commits＠lists.jboss.org

Author: justi9 Date: 2008-11-29 15:40:25 -0500 (Sat, 29 Nov 2008) New Revision: 2896 Modified: mgmt/trunk/sesame/cpp/src/Makefile.am Log: Make the paths in CXX flags reflect the new defaults Modified: mgmt/trunk/sesame/cpp/src/Makefile.am =================================================================== --- mgmt/trunk/sesame/cpp/src/Makefile.am 2008-11-29 19:53:02 UTC (rev 2895) +++ mgmt/trunk/sesame/cpp/src/Makefile.am 2008-11-29 20:40:25 UTC (rev 2896) @@ -1,7 +1,7 @@ SUBDIRS = qmfgen sesame_CXXFLAGS = -I$(QPID_DIR)/cpp/src -I$(QPID_DIR)/cpp/src/gen -Iqmfgen \ - -DCONF_FILE=\"$(sysconfdir)/sesame.conf\" \ - -DLOCSTATE_DIR=\"$(localstatedir)/sesame\" + -DCONF_FILE=\"$(sysconfdir)/sesame/sesame.conf\" \ + -DLOCSTATE_DIR=\"$(localstatedir)/lib/sesame\" include qmfgen/qmfgen.mk @@ -10,5 +10,3 @@ sesame_SOURCES = SysAgent.cpp sesame_LDADD = $(QPID_LIBS) - -

15 years, 6 months

1
0
0 / 0

rhmessaging commits: r2895 - mgmt/trunk/sesame/cpp/etc.

by rhmessaging-commits＠lists.jboss.org

Author: justi9 Date: 2008-11-29 14:53:02 -0500 (Sat, 29 Nov 2008) New Revision: 2895 Modified: mgmt/trunk/sesame/cpp/etc/Makefile.am Log: Add the init script to the dist tarball Modified: mgmt/trunk/sesame/cpp/etc/Makefile.am =================================================================== --- mgmt/trunk/sesame/cpp/etc/Makefile.am 2008-11-29 19:42:36 UTC (rev 2894) +++ mgmt/trunk/sesame/cpp/etc/Makefile.am 2008-11-29 19:53:02 UTC (rev 2895) @@ -1,5 +1,5 @@ confdir = $(sysconfdir)/sesame -EXTRA_DIST = sesame.conf +EXTRA_DIST = sesame.conf sysvinit-sesame nobase_conf_DATA = sesame.conf

15 years, 6 months

1
0
0 / 0

rhmessaging commits: r2894 - mgmt/trunk/sesame/cpp.

by rhmessaging-commits＠lists.jboss.org

Author: justi9 Date: 2008-11-29 14:42:36 -0500 (Sat, 29 Nov 2008) New Revision: 2894 Modified: mgmt/trunk/sesame/cpp/Makefile.am Log: This conf dist stuff is superceded by the new Makefile.am in etc Modified: mgmt/trunk/sesame/cpp/Makefile.am =================================================================== --- mgmt/trunk/sesame/cpp/Makefile.am 2008-11-26 23:12:06 UTC (rev 2893) +++ mgmt/trunk/sesame/cpp/Makefile.am 2008-11-29 19:42:36 UTC (rev 2894) @@ -1,14 +1,8 @@ AUTOMAKE_OPTIONS = 1.9.6 foreign ACLOCAL_AMFLAGS = -I m4 - -EXTRA_DIST = README etc/sesame.conf - -sysconf_DATA = etc/sesame.conf - SUBDIRS = src etc # Update libtool, if needed. libtool: $(LIBTOOL_DEPS) $(SHELL) ./config.status --recheck -

15 years, 6 months

1
0
0 / 0

rhmessaging commits: r2893 - mgmt/trunk/cumin/python/cumin.

by rhmessaging-commits＠lists.jboss.org

Author: eallen Date: 2008-11-26 18:12:06 -0500 (Wed, 26 Nov 2008) New Revision: 2893 Modified: mgmt/trunk/cumin/python/cumin/slot.strings Log: Hopefully returning the correct slotset count for multiple collector situations. Modified: mgmt/trunk/cumin/python/cumin/slot.strings =================================================================== --- mgmt/trunk/cumin/python/cumin/slot.strings 2008-11-26 22:53:03 UTC (rev 2892) +++ mgmt/trunk/cumin/python/cumin/slot.strings 2008-11-26 23:12:06 UTC (rev 2893) @@ -16,10 +16,10 @@ {sql_limit} [SlotSet.count_sql] -select count(*) -from slot as s -{sql_where} +select count(1) +from (select distinct name, machine, system, pool, deletion_time from slot as s {sql_where}) as s + [MachineSet.sql] select machine as id,

15 years, 6 months

1
0
0 / 0

rhmessaging commits: r2892 - in mgmt/trunk/sesame/cpp: etc and 1 other directory.

by rhmessaging-commits＠lists.jboss.org

Author: justi9 Date: 2008-11-26 17:53:03 -0500 (Wed, 26 Nov 2008) New Revision: 2892 Added: mgmt/trunk/sesame/cpp/etc/Makefile.am Modified: mgmt/trunk/sesame/cpp/Makefile.am mgmt/trunk/sesame/cpp/configure.ac Log: Move the conf file Modified: mgmt/trunk/sesame/cpp/Makefile.am =================================================================== --- mgmt/trunk/sesame/cpp/Makefile.am 2008-11-26 22:35:22 UTC (rev 2891) +++ mgmt/trunk/sesame/cpp/Makefile.am 2008-11-26 22:53:03 UTC (rev 2892) @@ -6,7 +6,7 @@ sysconf_DATA = etc/sesame.conf -SUBDIRS = src +SUBDIRS = src etc # Update libtool, if needed. libtool: $(LIBTOOL_DEPS) Modified: mgmt/trunk/sesame/cpp/configure.ac =================================================================== --- mgmt/trunk/sesame/cpp/configure.ac 2008-11-26 22:35:22 UTC (rev 2891) +++ mgmt/trunk/sesame/cpp/configure.ac 2008-11-26 22:53:03 UTC (rev 2892) @@ -184,6 +184,7 @@ Makefile src/Makefile src/qmfgen/Makefile + etc/Makefile ]) AC_OUTPUT Added: mgmt/trunk/sesame/cpp/etc/Makefile.am =================================================================== --- mgmt/trunk/sesame/cpp/etc/Makefile.am (rev 0) +++ mgmt/trunk/sesame/cpp/etc/Makefile.am 2008-11-26 22:53:03 UTC (rev 2892) @@ -0,0 +1,5 @@ +confdir = $(sysconfdir)/sesame + +EXTRA_DIST = sesame.conf + +nobase_conf_DATA = sesame.conf

15 years, 6 months

1
0
0 / 0

rhmessaging commits: r2891 - mgmt/trunk/cumin/python/cumin.

by rhmessaging-commits＠lists.jboss.org

Author: eallen Date: 2008-11-26 17:35:22 -0500 (Wed, 26 Nov 2008) New Revision: 2891 Modified: mgmt/trunk/cumin/python/cumin/pool.py mgmt/trunk/cumin/python/cumin/slot.strings Log: Partial solution to multiple collectors. Modified: mgmt/trunk/cumin/python/cumin/pool.py =================================================================== --- mgmt/trunk/cumin/python/cumin/pool.py 2008-11-26 20:26:37 UTC (rev 2890) +++ mgmt/trunk/cumin/python/cumin/pool.py 2008-11-26 22:35:22 UTC (rev 2891) @@ -286,7 +286,7 @@ return {"pool": pool.id} def render_sql_orderby(self, session, pool): - return "order by machine asc" + return "order by id asc" class PoolStats(Widget): def __init__(self, app, name): Modified: mgmt/trunk/cumin/python/cumin/slot.strings =================================================================== --- mgmt/trunk/cumin/python/cumin/slot.strings 2008-11-26 20:26:37 UTC (rev 2890) +++ mgmt/trunk/cumin/python/cumin/slot.strings 2008-11-26 22:35:22 UTC (rev 2891) @@ -1,6 +1,6 @@ [SlotSet.sql] -select - s.id, +select distinct + s.name as id, s.name, s.machine, s.system, @@ -21,16 +21,21 @@ {sql_where} [MachineSet.sql] -select +select machine as id, - machine, - sum(case c.activity when 'Busy' then 1 else 0 end) as busy, - sum(case c.activity when 'Idle' then 1 else 0 end) as idle, - sum(1) as total -from slot as s -left outer join slot_stats as c on c.id = s.stats_curr_id + machine, + sum(case activity when 'Busy' then 1 else 0 end) / coll_count as busy, + sum(case activity when 'Idle' then 1 else 0 end) / coll_count as idle, + sum(1) / coll_count as total +from +(select + machine, s.pool, c.activity, count(coll.id) as coll_count + from slot as s + left outer join slot_stats as c on c.id = s.stats_curr_id + left outer join collector as coll on coll.pool = s.pool + group by machine, s.pool, c.activity, s.stats_curr_id) as s {sql_where} -group by machine +group by machine, coll_count {sql_orderby} [MachineSet.count_sql]

15 years, 6 months

1
0
0 / 0

rhmessaging commits: r2890 - mgmt/trunk/sesame/cpp/etc.

by rhmessaging-commits＠lists.jboss.org

Author: justi9 Date: 2008-11-26 15:26:37 -0500 (Wed, 26 Nov 2008) New Revision: 2890 Added: mgmt/trunk/sesame/cpp/etc/sysvinit-sesame Log: Add an init script for sesame Added: mgmt/trunk/sesame/cpp/etc/sysvinit-sesame =================================================================== --- mgmt/trunk/sesame/cpp/etc/sysvinit-sesame (rev 0) +++ mgmt/trunk/sesame/cpp/etc/sysvinit-sesame 2008-11-26 20:26:37 UTC (rev 2890) @@ -0,0 +1,68 @@ +#!/bin/sh +# +# sesame: Sesame daemon +# processname: sesame +# pidfile: /var/run/sesame.pid +# + +# Sanity checks. +[ -x /usr/bin/sesame ] || exit 0 + +# Source function library. +. /etc/rc.d/init.d/functions + +# so we can rearrange this easily +processname=sesame +servicename=sesame + +RETVAL=0 + +start() { + echo -n $"Starting Sesame daemon: " + daemon --check $servicename $processname \& + RETVAL=$? + echo + [ $RETVAL -eq 0 ] && touch /var/lock/subsys/$servicename +} + +stop() { + echo -n $"Stopping Sesame daemon: " + + killproc $servicename -TERM + RETVAL=$? + echo + if [ $RETVAL -eq 0 ]; then + rm -f /var/lock/subsys/$servicename + rm -f /var/run/sesame.pid + fi +} + +# See how we were called. +case "$1" in + start) + start + ;; + stop) + stop + ;; + status) + status $processname + RETVAL=$? + ;; + restart) + stop + sleep 3 + start + ;; + condrestart) + if [ -f /var/lock/subsys/$servicename ]; then + stop + sleep 3 + start + fi + ;; + *) + echo $"Usage: $0 {start|stop|status|restart|condrestart}" + ;; +esac +exit $RETVAL Property changes on: mgmt/trunk/sesame/cpp/etc/sysvinit-sesame ___________________________________________________________________ Name: svn:executable + *

15 years, 6 months

1
0
0 / 0

rhmessaging commits: r2889 - in mgmt/trunk: mint/python/mint and 1 other directories.

by rhmessaging-commits＠lists.jboss.org

Author: justi9 Date: 2008-11-26 13:25:55 -0500 (Wed, 26 Nov 2008) New Revision: 2889 Modified: mgmt/trunk/cumin/python/cumin/binding.py mgmt/trunk/cumin/python/cumin/brokerlink.py mgmt/trunk/cumin/python/cumin/brokerlink.strings mgmt/trunk/cumin/python/cumin/client.strings mgmt/trunk/cumin/python/cumin/collector.py mgmt/trunk/cumin/python/cumin/exchange.strings mgmt/trunk/cumin/python/cumin/job.py mgmt/trunk/cumin/python/cumin/job.strings mgmt/trunk/cumin/python/cumin/limits.py mgmt/trunk/cumin/python/cumin/model.py mgmt/trunk/cumin/python/cumin/negotiator.py mgmt/trunk/cumin/python/cumin/queue.py mgmt/trunk/cumin/python/cumin/queue.strings mgmt/trunk/cumin/python/cumin/system.py mgmt/trunk/cumin/python/cumin/test.py mgmt/trunk/cumin/python/cumin/util.py mgmt/trunk/cumin/python/cumin/widgets.py mgmt/trunk/cumin/python/cumin/widgets.strings mgmt/trunk/mint/python/mint/schema.py mgmt/trunk/mint/python/mint/schemaparser.py mgmt/trunk/mint/python/mint/update.py mgmt/trunk/mint/sql/schema.sql Log: Rename timestamp fields to reflect their origin in the qmf infrastructure. Note! With this change, a reschema is required. Modified: mgmt/trunk/cumin/python/cumin/binding.py =================================================================== --- mgmt/trunk/cumin/python/cumin/binding.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/binding.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -298,7 +298,7 @@ writer = Writer() for exchange in sortedExchanges: if ExchangeInfo.is_builtin(exchange) or \ - (not exchange._get_deletionTime() and \ + (not exchange._get_qmfDeleteTime() and \ not (self.state.is_active(session) and not is_active(exchange))): # instance_key gives us a unique path for each exchange # we will be rendering Modified: mgmt/trunk/cumin/python/cumin/brokerlink.py =================================================================== --- mgmt/trunk/cumin/python/cumin/brokerlink.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/brokerlink.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -153,7 +153,7 @@ return "Link Routes %s" % fmt_count(count) def render_sql_where(self, session, link): - return "where l.id = %(link_id)r and b.deletion_time is null" + return "where l.id = %(link_id)r and b.qmf_delete_time is null" def get_sql_values(self, session, link): return {"link_id": link.id} @@ -352,7 +352,7 @@ for exchange in sortedExchanges: if ExchangeInfo.is_builtin(exchange) or \ - (not exchange._get_deletionTime() and \ + (not exchange._get_qmfDeleteTime() and \ not (self.state.is_active(session) and not is_active(exchange))): if not exchange.name in ["qpid.management", ""]: if not self.param.get(session): @@ -426,7 +426,7 @@ def process_display(self, session, *args): if not self.tag.get(session): - self.tag.set(session, args[0].managedBroker) + self.tag.set(session, args[0].qmfBrokerId) if not self.excludes.get(session): self.excludes.set(session, "%s:%s" % (args[0].host, args[0].port)) Modified: mgmt/trunk/cumin/python/cumin/brokerlink.strings =================================================================== --- mgmt/trunk/cumin/python/cumin/brokerlink.strings 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/brokerlink.strings 2008-11-26 18:25:55 UTC (rev 2889) @@ -57,7 +57,7 @@ b.excludes, l.host, l.port, - l.managed_broker + l.qmf_broker_id from bridge as b join link as l on l.id = b.link_id left outer join bridge_stats as c on c.id = b.stats_curr_id Modified: mgmt/trunk/cumin/python/cumin/client.strings =================================================================== --- mgmt/trunk/cumin/python/cumin/client.strings 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/client.strings 2008-11-26 18:25:55 UTC (rev 2889) @@ -6,18 +6,18 @@ l.federation_link as fedlink, l.address as addr, (c.bytes_from_client - p.bytes_from_client) - / (extract(epoch from (c.rec_time - p.rec_time)) + 0.0001) as bs, + / (extract(epoch from (c.qmf_update_time - p.qmf_update_time)) + 0.0001) as bs, case when p.bytes_from_client is null then true else false end as bs_is_null, (c.frames_from_client - p.frames_from_client) - / (extract(epoch from (c.rec_time - p.rec_time)) + 0.0001) as fs, + / (extract(epoch from (c.qmf_update_time - p.qmf_update_time)) + 0.0001) as fs, case when p.frames_from_client is null then true else false end as fs_is_null, (c.bytes_to_client - p.bytes_to_client) - / (extract(epoch from (c.rec_time - p.rec_time)) + 0.0001) as br, + / (extract(epoch from (c.qmf_update_time - p.qmf_update_time)) + 0.0001) as br, case when p.bytes_to_client is null then true else false end as br_is_null, (c.frames_to_client - p.frames_to_client) - / (extract(epoch from (c.rec_time - p.rec_time)) + 0.0001) as fr, + / (extract(epoch from (c.qmf_update_time - p.qmf_update_time)) + 0.0001) as fr, case when p.frames_to_client is null then true else false end as fr_is_null, - c.rec_time + c.qmf_update_time from client_connection as l left outer join client_connection_stats as c on c.id = l.stats_curr_id left outer join client_connection_stats as p on p.id = l.stats_prev_id Modified: mgmt/trunk/cumin/python/cumin/collector.py =================================================================== --- mgmt/trunk/cumin/python/cumin/collector.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/collector.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -44,10 +44,10 @@ return "Collectors %s" % fmt_count(count) def render_sql_where(self, session, collector): - sql = "deletion_time is null" - #sql = "((cs.rec_time is null and c.rec_time > now() - interval '10 minutes') or " + \ - # "(cs.rec_time > now() - interval '10 minutes')" + \ - # " and deletion_time is null)" + sql = "qmf_delete_time is null" + #sql = "((cs.qmf_update_time is null and c.qmf_update_time > now() - interval '10 minutes') or " + \ + # "(cs.qmf_update_time > now() - interval '10 minutes')" + \ + # " and qmf_delete_time is null)" return "where %s" % sql class NameColumn(SqlTableColumn): Modified: mgmt/trunk/cumin/python/cumin/exchange.strings =================================================================== --- mgmt/trunk/cumin/python/cumin/exchange.strings 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/exchange.strings 2008-11-26 18:25:55 UTC (rev 2889) @@ -11,20 +11,20 @@ c.producer_count as producers, c.binding_count as bindings, (c.msg_receives - p.msg_receives) - / (extract(epoch from (c.rec_time - p.rec_time)) + 0.0001) as mreceived, + / (extract(epoch from (c.qmf_update_time - p.qmf_update_time)) + 0.0001) as mreceived, case when p.msg_receives is null then true else false end as mreceived_is_null, (c.byte_receives - p.byte_receives) - / (extract(epoch from (c.rec_time - p.rec_time)) + 0.0001) as breceived, + / (extract(epoch from (c.qmf_update_time - p.qmf_update_time)) + 0.0001) as breceived, case when p.byte_receives is null then true else false end as breceived_is_null, (c.msg_routes - p.msg_routes) - / (extract(epoch from (c.rec_time - p.rec_time)) + 0.0001) as mrouted, + / (extract(epoch from (c.qmf_update_time - p.qmf_update_time)) + 0.0001) as mrouted, case when p.msg_routes is null then true else false end as mrouted_is_null, (c.byte_routes - p.byte_routes) - / (extract(epoch from (c.rec_time - p.rec_time)) + 0.0001) as brouted, + / (extract(epoch from (c.qmf_update_time - p.qmf_update_time)) + 0.0001) as brouted, case when p.byte_routes is null then true else false end as brouted_is_null, c.msg_drops as mdropped, c.byte_drops as bdropped, - c.rec_time + c.qmf_update_time from exchange as e left outer join exchange_stats as c on c.id = e.stats_curr_id left outer join exchange_stats as p on p.id = e.stats_prev_id Modified: mgmt/trunk/cumin/python/cumin/job.py =================================================================== --- mgmt/trunk/cumin/python/cumin/job.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/job.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -1253,9 +1253,9 @@ if not phase: phase = self.get(session) - alive = "((c.rec_time is null or " + \ - "c.rec_time <= now() - interval '10 minutes')" + \ - " and j.deletion_time is null and j.job_status != %i)" % JobStatusInfo.get_status_int("Removed") + alive = "((c.qmf_update_time is null or " + \ + "c.qmf_update_time <= now() - interval '10 minutes')" + \ + " and j.qmf_delete_time is null and j.job_status != %i)" % JobStatusInfo.get_status_int("Removed") if phase == "a": sql = alive @@ -1269,12 +1269,12 @@ sql = "(j.job_status = %i" % JobStatusInfo.get_status_int("Held") + \ " and %s)" % alive elif phase == "c": - comotose = "(c.rec_time is null or " + \ - "c.rec_time <= now() - interval '10 minutes')" + comotose = "(c.qmf_update_time is null or " + \ + "c.qmf_update_time <= now() - interval '10 minutes')" sql = "(j.job_status = %i" % JobStatusInfo.get_status_int("Completed") + \ " and %s)" % comotose else: - not_completed = "(j.deletion_time is not null and j.job_status <> %i )" % JobStatusInfo.get_status_int("Completed") + not_completed = "(j.qmf_delete_time is not null and j.job_status <> %i )" % JobStatusInfo.get_status_int("Completed") is_removed = "j.job_status = %i" % JobStatusInfo.get_status_int("Removed") sql = " or ".join((not_completed, is_removed)) Modified: mgmt/trunk/cumin/python/cumin/job.strings =================================================================== --- mgmt/trunk/cumin/python/cumin/job.strings 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/job.strings 2008-11-26 18:25:55 UTC (rev 2889) @@ -15,7 +15,7 @@ j.scheduler_id, j.submitter_id, j.cmd, - j.deletion_time + j.qmf_delete_time from job as j left outer join job_stats as c on c.id = j.stats_curr_id left outer join job_stats as p on p.id = j.stats_prev_id Modified: mgmt/trunk/cumin/python/cumin/limits.py =================================================================== --- mgmt/trunk/cumin/python/cumin/limits.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/limits.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -33,10 +33,11 @@ most_recent = None negotiators = Negotiator.select("pool='%s'" % pool.id) for negotiator in negotiators: - if negotiator.managedBroker: + if negotiator.qmfBrokerId: if not most_recent: most_recent = negotiator - if negotiator.statsCurr.recTime > most_recent.statsCurr.recTime: + if negotiator.statsCurr.qmfUpdateTime > \ + most_recent.statsCurr.qmfUpdateTime: most_recent = negotiator return most_recent Modified: mgmt/trunk/cumin/python/cumin/model.py =================================================================== --- mgmt/trunk/cumin/python/cumin/model.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/model.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -257,9 +257,9 @@ def get_session_by_registration(self, reg): assert reg.broker - assert reg.broker.managedBroker in self.model.data.mintBrokers + assert reg.broker.qmfBrokerId in self.model.data.mintBrokers - broker = self.model.data.mintBrokers[reg.broker.managedBroker] + broker = self.model.data.mintBrokers[reg.broker.qmfBrokerId] return broker.getAmqpSession() class CuminActionInvocation(object): @@ -321,17 +321,17 @@ def samples(self, object, secs): stats = object.stats - col = self.cumin_class.mint_stats_class.q.recTime + col = self.cumin_class.mint_stats_class.q.qmfUpdateTime dt = datetime.now() - timedelta(seconds=secs) stats = stats.filter(col >= dt) - stats = stats.orderBy("-recTime") + stats = stats.orderBy("-qmfUpdateTime") samples = list() for stat in stats: value = getattr(stat, self.name, 0) - samples.append((stat.recTime, value)) + samples.append((stat.qmfUpdateTime, value)) return samples @@ -392,14 +392,14 @@ threshold = datetime.now() - timedelta(minutes=10) try: - if object.statsCurr and object.statsCurr.recTime > threshold: + if object.statsCurr and object.statsCurr.qmfUpdateTime > threshold: curr = getattr(object.statsCurr, self.name) - ctime = object.statsCurr.recTime + ctime = object.statsCurr.qmfUpdateTime csecs = mktime(ctime.timetuple()) if object.statsPrev: prev = getattr(object.statsPrev, self.name) - ptime = object.statsPrev.recTime + ptime = object.statsPrev.qmfUpdateTime psecs = mktime(ptime.timetuple()) if curr is not None and prev is not None: @@ -510,16 +510,16 @@ self.mint_stats_class = mint_stats_class - prop = CuminProperty(self, "sourceObjectId") + prop = CuminProperty(self, "qmfObjectId") prop.title = "Management ID" - prop = CuminProperty(self, "creationTime") + prop = CuminProperty(self, "qmfCreateTime") prop.title = "Creation Time" - prop = CuminProperty(self, "deletionTime") + prop = CuminProperty(self, "qmfDeleteTime") prop.title = "Deletion Time" - prop = CuminProperty(self, "recTime") + prop = CuminProperty(self, "qmfUpdateTime") prop.title = "Last Updated" prop.summary = True @@ -1999,13 +1999,13 @@ class IdlePercentStat(PercentStat): def get_sql_and_elem(self): # manually removed jobs will have a state of Idle - # with a deletion_time - return "job.deletion_time is null" + # with a qmf_delete_time + return "job.qmf_delete_time is null" class RemovedPercentStat(PercentStat): def get_sql_or_elem(self): - # if a job is idle, but has a deletion_time, it's actually Removed - return "(job.deletion_time is not null and job_status = %i)" % \ + # if a job is idle, but has a qmf_delete_time, it's actually Removed + return "(job.qmf_delete_time is not null and job_status = %i)" % \ JobStatusInfo.get_status_int("Idle") class PoolSlotVisualization(SlotVisualization): @@ -2485,7 +2485,7 @@ def get_enabled(self, session, job): is_held = JobStatusInfo.get_status_int("Held") == job.JobStatus - is_deleted = job.deletionTime is not None + is_deleted = job.qmfDeleteTime is not None return not (is_held or is_deleted) class Release(CuminAction): @@ -2502,7 +2502,7 @@ def get_enabled(self, session, job): is_held = JobStatusInfo.get_status_int("Held") == job.JobStatus - is_deleted = job.deletionTime is not None + is_deleted = job.qmfDeleteTime is not None return is_held and not is_deleted class Remove(CuminAction): @@ -2518,7 +2518,7 @@ job.Remove(self.model.data, completion, reason) def get_enabled(self, session, job): - is_deleted = job.deletionTime is not None + is_deleted = job.qmfDeleteTime is not None return not is_deleted class SetAttribute(CuminAction): @@ -2535,10 +2535,11 @@ class GetStartedAction(CuminAction): def get_xml_response(self, session, object, *args): - recTime = object.statsCurr and object.statsCurr.recTime or object.recTime - delta = secs(recTime) - secs(datetime.now()) + updateTime = object.statsCurr and object.statsCurr.qmfUpdateTime \ + or object.qmfUpdateTime + delta = secs(updateTime) - secs(datetime.now()) conf = "<age>%i</age>" % -delta - rect = "<rectime>%s</rectime>" % fmt_duration(delta) + rect = "<updatetime>%s</updatetime>" % fmt_duration(delta) return "%s%s" % (conf, rect) Modified: mgmt/trunk/cumin/python/cumin/negotiator.py =================================================================== --- mgmt/trunk/cumin/python/cumin/negotiator.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/negotiator.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -44,9 +44,9 @@ return "Negotiators %s" % fmt_count(count) def render_sql_where(self, session, negotiator): - sql = "((c.rec_time is not null and " + \ - "c.rec_time > now() - interval '10 minutes')" + \ - " and deletion_time is null)" + sql = "((c.qmf_update_time is not null and " + \ + "c.qmf_update_time > now() - interval '10 minutes')" + \ + " and qmf_delete_time is null)" return "where %s" % sql class NameColumn(SqlTableColumn): Modified: mgmt/trunk/cumin/python/cumin/queue.py =================================================================== --- mgmt/trunk/cumin/python/cumin/queue.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/queue.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -963,7 +963,7 @@ delta = timedelta(minutes=10) queue_list = [] for _queue in queue_list_full: - if (_queue.recTime > (datetime.now() - delta)) and (_queue.name != queue.name): + if (_queue.qmfUpdateTime > (datetime.now() - delta)) and (_queue.name != queue.name): queue_list.append(_queue) return queue_list Modified: mgmt/trunk/cumin/python/cumin/queue.strings =================================================================== --- mgmt/trunk/cumin/python/cumin/queue.strings 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/queue.strings 2008-11-26 18:25:55 UTC (rev 2889) @@ -5,22 +5,22 @@ c.consumer_count as consumers, c.binding_count as bindings, (c.msg_total_enqueues - p.msg_total_enqueues) - / (extract(epoch from (c.rec_time - p.rec_time)) + 0.0001) as menqueued, + / (extract(epoch from (c.qmf_update_time - p.qmf_update_time)) + 0.0001) as menqueued, case when p.msg_total_enqueues is null then true else false end as menqueued_is_null, (c.byte_total_enqueues - p.byte_total_enqueues) - / (extract(epoch from (c.rec_time - p.rec_time)) + 0.0001) as benqueued, + / (extract(epoch from (c.qmf_update_time - p.qmf_update_time)) + 0.0001) as benqueued, case when p.byte_total_enqueues is null then true else false end as benqueued_is_null, (c.msg_total_dequeues - p.msg_total_dequeues) - / (extract(epoch from (c.rec_time - p.rec_time)) + 0.0001) as mdequeued, + / (extract(epoch from (c.qmf_update_time - p.qmf_update_time)) + 0.0001) as mdequeued, case when p.msg_total_dequeues is null then true else false end as mdequeued_is_null, (c.byte_total_dequeues - p.byte_total_dequeues) - / (extract(epoch from (c.rec_time - p.rec_time)) + 0.0001) as bdequeued, + / (extract(epoch from (c.qmf_update_time - p.qmf_update_time)) + 0.0001) as bdequeued, case when p.byte_total_dequeues is null then true else false end as bdequeued_is_null, c.msg_depth as mdepth, c.byte_depth as bdepth, 1 as mdepthaccel, 1 as bdepthaccel, - c.rec_time + c.qmf_update_time from queue as q left outer join queue_stats as c on c.id = q.stats_curr_id left outer join queue_stats as p on p.id = q.stats_prev_id Modified: mgmt/trunk/cumin/python/cumin/system.py =================================================================== --- mgmt/trunk/cumin/python/cumin/system.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/system.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -144,7 +144,7 @@ def render_sql_where(self, session, system): elems = list() elems.append("system = %(nodeName)s") - elems.append("s.deletion_time is null") + elems.append("s.qmf_delete_time is null") return "where %s" % " and ".join(elems) def get_sql_values(self, session, system): @@ -212,4 +212,4 @@ - \ No newline at end of file + Modified: mgmt/trunk/cumin/python/cumin/test.py =================================================================== --- mgmt/trunk/cumin/python/cumin/test.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/test.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -299,7 +299,7 @@ self.env.check_redirect(p, s) def predicate(): - return self.env.link.deletionTime + return self.env.link.qmfDeleteTime wait(predicate) @@ -361,7 +361,7 @@ self.env.check_redirect(p, s) def predicate(): - return self.env.bridge.deletionTime + return self.env.bridge.qmfDeleteTime wait(predicate) @@ -584,7 +584,7 @@ self.env.check_redirect(p, s) def predicate(): - return self.env.binding_direct.deletionTime + return self.env.binding_direct.qmfDeleteTime wait(predicate) @@ -638,7 +638,7 @@ self.env.check_redirect(p, s) def predicate(): - return self.env.binding_topic.deletionTime + return self.env.binding_topic.qmfDeleteTime wait(predicate) @@ -692,7 +692,7 @@ self.env.check_redirect(p, s) def predicate(): - return self.env.binding_fanout.deletionTime + return self.env.binding_fanout.qmfDeleteTime wait(predicate) @@ -812,7 +812,7 @@ # wait for newly created queue to get marked as deleted def predicate(): - return self.env.queue.deletionTime + return self.env.queue.qmfDeleteTime wait(predicate) @@ -883,7 +883,7 @@ # wait for newly created exchange to get marked as deleted def predicate(): - return self.env.added_exchange.deletionTime + return self.env.added_exchange.qmfDeleteTime wait(predicate) Modified: mgmt/trunk/cumin/python/cumin/util.py =================================================================== --- mgmt/trunk/cumin/python/cumin/util.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/util.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -43,12 +43,12 @@ return host, port def is_active(obj): - delTime = obj._get_deletionTime() + delTime = obj._get_qmfDeleteTime() if not delTime: - recTime = obj.statsCurr.recTime + updateTime = obj.statsCurr.qmfUpdateTime delta = timedelta(minutes=10) # mirroring logic in widgets/PhaseSwitch.get_sql_constraint - if not recTime or (recTime > datetime.now() - delta): + if not updateTime or (updateTime > datetime.now() - delta): return True class Identifiable(object): Modified: mgmt/trunk/cumin/python/cumin/widgets.py =================================================================== --- mgmt/trunk/cumin/python/cumin/widgets.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/widgets.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -607,15 +607,15 @@ phase = self.get(session) if phase == "a": - sql = "((c.rec_time is null or " + \ - "c.rec_time > now() - interval '10 minutes')" + \ - " and deletion_time is null)" + sql = "((c.qmf_update_time is null or " + \ + "c.qmf_update_time > now() - interval '10 minutes')" + \ + " and qmf_delete_time is null)" elif phase == "i": - sql = "((c.rec_time is null or " + \ - "c.rec_time <= now() - interval '10 minutes')" + \ - " and deletion_time is null)" + sql = "((c.qmf_update_time is null or " + \ + "c.qmf_update_time <= now() - interval '10 minutes')" + \ + " and qmf_delete_time is null)" else: - sql = "deletion_time is not null" + sql = "qmf_delete_time is not null" return sql @@ -716,7 +716,7 @@ def render_content(self, session, data): key = self.get_column_key(session) - value = data["rec_time"] + value = data["qmf_update_time"] if value and value > self.__ago.get(session): html = self.render_value(session, data[key]) Modified: mgmt/trunk/cumin/python/cumin/widgets.strings =================================================================== --- mgmt/trunk/cumin/python/cumin/widgets.strings 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/cumin/python/cumin/widgets.strings 2008-11-26 18:25:55 UTC (rev 2889) @@ -1076,21 +1076,21 @@ function got_startstop_status(obj, id) { var elem = document.getElementById(id); if (elem) { - var recTime = obj.rectime; - var age = obj.age; + var updateTime = obj.updatetime; + var age = obj.age; var color = "clear"; - - var oRecTime = document.getElementById("recTime"); - if (oRecTime) { - oRecTime.innerHTML = recTime; - if (age > 150) { /* hasn't changed in 2.5 minutes */ - color = "yellow"; - } else { - color = "green"; - } - elem.className = "CuminStatus " + color; - } - setTimeout("get_status()", 5000); + + var oUpdateTime = document.getElementById("updateTime"); + if (oUpdateTime) { + oUpdateTime.innerHTML = updateTime; + if (age > 150) { /* hasn't changed in 2.5 minutes */ + color = "yellow"; + } else { + color = "green"; + } + elem.className = "CuminStatus " + color; + } + setTimeout("get_status()", 5000); } } @@ -1098,7 +1098,7 @@ <div id="{id}" class="CuminStatus {color}"> <h2>{title}</h2> <div class="status_time"> - Last update was <span id="recTime"></span> + Last update was <span id="updateTime"></span> </div> </div>{start_stop_script} Modified: mgmt/trunk/mint/python/mint/schema.py =================================================================== --- mgmt/trunk/mint/python/mint/schema.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/mint/python/mint/schema.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -13,14 +13,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('SlotStats', cascade='null', default=None) statsPrev = ForeignKey('SlotStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -84,7 +84,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) slot = ForeignKey('Slot', cascade='null', default=None) classInfos = dict() # brokerId => classInfo Activity = StringCol(length=1000, default=None) @@ -134,14 +134,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('JobStats', cascade='null', default=None) statsPrev = ForeignKey('JobStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -235,7 +235,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) job = ForeignKey('Job', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -246,14 +246,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('SchedulerStats', cascade='null', default=None) statsPrev = ForeignKey('SchedulerStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -275,7 +275,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) scheduler = ForeignKey('Scheduler', cascade='null', default=None) classInfos = dict() # brokerId => classInfo NumUsers = BigIntCol(default=None) @@ -299,14 +299,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('SubmitterStats', cascade='null', default=None) statsPrev = ForeignKey('SubmitterStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -321,7 +321,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) submitter = ForeignKey('Submitter', cascade='null', default=None) classInfos = dict() # brokerId => classInfo HeldJobs = BigIntCol(default=None) @@ -335,14 +335,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('NegotiatorStats', cascade='null', default=None) statsPrev = ForeignKey('NegotiatorStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -385,7 +385,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) negotiator = ForeignKey('Negotiator', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -403,14 +403,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('CollectorStats', cascade='null', default=None) statsPrev = ForeignKey('CollectorStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -426,7 +426,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) collector = ForeignKey('Collector', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -437,14 +437,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('MasterStats', cascade='null', default=None) statsPrev = ForeignKey('MasterStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -481,7 +481,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) master = ForeignKey('Master', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -499,14 +499,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('AclStats', cascade='null', default=None) statsPrev = ForeignKey('AclStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -528,7 +528,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) acl = ForeignKey('Acl', cascade='null', default=None) classInfos = dict() # brokerId => classInfo aclDenyCount = BigIntCol(default=None) @@ -540,14 +540,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('ClusterStats', cascade='null', default=None) statsPrev = ForeignKey('ClusterStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -576,7 +576,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) cluster = ForeignKey('Cluster', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -587,14 +587,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('StoreStats', cascade='null', default=None) statsPrev = ForeignKey('StoreStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -615,7 +615,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) store = ForeignKey('Store', cascade='null', default=None) classInfos = dict() # brokerId => classInfo tplTransactionDepth = IntCol(default=None) @@ -635,14 +635,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('JournalStats', cascade='null', default=None) statsPrev = ForeignKey('JournalStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -672,7 +672,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) journal = ForeignKey('Journal', cascade='null', default=None) classInfos = dict() # brokerId => classInfo recordDepth = IntCol(default=None) @@ -711,14 +711,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('SystemStats', cascade='null', default=None) statsPrev = ForeignKey('SystemStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -734,7 +734,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) system = ForeignKey('System', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -745,14 +745,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('BrokerStats', cascade='null', default=None) statsPrev = ForeignKey('BrokerStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -816,7 +816,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) broker = ForeignKey('Broker', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -827,14 +827,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('AgentStats', cascade='null', default=None) statsPrev = ForeignKey('AgentStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -850,7 +850,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) agent = ForeignKey('Agent', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -861,14 +861,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('VhostStats', cascade='null', default=None) statsPrev = ForeignKey('VhostStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -881,7 +881,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) vhost = ForeignKey('Vhost', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -892,14 +892,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('QueueStats', cascade='null', default=None) statsPrev = ForeignKey('QueueStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -924,7 +924,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) queue = ForeignKey('Queue', cascade='null', default=None) classInfos = dict() # brokerId => classInfo msgTotalEnqueues = BigIntCol(default=None) @@ -962,14 +962,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('ExchangeStats', cascade='null', default=None) statsPrev = ForeignKey('ExchangeStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -984,7 +984,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) exchange = ForeignKey('Exchange', cascade='null', default=None) classInfos = dict() # brokerId => classInfo producerCount = IntCol(default=None) @@ -1007,14 +1007,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('BindingStats', cascade='null', default=None) statsPrev = ForeignKey('BindingStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -1029,7 +1029,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) binding = ForeignKey('Binding', cascade='null', default=None) classInfos = dict() # brokerId => classInfo msgMatched = BigIntCol(default=None) @@ -1041,14 +1041,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('ClientConnectionStats', cascade='null', default=None) statsPrev = ForeignKey('ClientConnectionStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -1070,7 +1070,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) clientConnection = ForeignKey('ClientConnection', cascade='null', default=None) classInfos = dict() # brokerId => classInfo closing = BoolCol(default=None) @@ -1086,14 +1086,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('LinkStats', cascade='null', default=None) statsPrev = ForeignKey('LinkStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -1139,7 +1139,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) link = ForeignKey('Link', cascade='null', default=None) classInfos = dict() # brokerId => classInfo state = StringCol(length=1000, default=None) @@ -1152,14 +1152,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('BridgeStats', cascade='null', default=None) statsPrev = ForeignKey('BridgeStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -1186,7 +1186,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) bridge = ForeignKey('Bridge', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -1197,14 +1197,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('SessionStats', cascade='null', default=None) statsPrev = ForeignKey('SessionStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -1245,7 +1245,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) session = ForeignKey('Session', cascade='null', default=None) classInfos = dict() # brokerId => classInfo framesOutstanding = IntCol(default=None) @@ -1261,14 +1261,14 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) qmfBrokerId = StringCol(length=1000, default=None) qmfScopeId = BigIntCol(default=None) qmfObjectId = BigIntCol(default=None) - source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) + qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True) qmfClassKey = StringCol(length=1000, default=None) - creationTime = TimestampCol(default=None) - deletionTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) + qmfCreateTime = TimestampCol(default=None) + qmfDeleteTime = TimestampCol(default=None) statsCurr = ForeignKey('SysimageStats', cascade='null', default=None) statsPrev = ForeignKey('SysimageStats', cascade='null', default=None) classInfos = dict() # brokerId => classInfo @@ -1286,7 +1286,7 @@ class sqlmeta: lazyUpdate = True - recTime = TimestampCol(default=None) + qmfUpdateTime = TimestampCol(default=None) sysimage = ForeignKey('Sysimage', cascade='null', default=None) classInfos = dict() # brokerId => classInfo memFree = BigIntCol(default=None) Modified: mgmt/trunk/mint/python/mint/schemaparser.py =================================================================== --- mgmt/trunk/mint/python/mint/schemaparser.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/mint/python/mint/schemaparser.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -64,7 +64,7 @@ self.pythonOutput += " %s = %s(%s)\n" % (attribName, attribType, params) def generateTimestampAttrib(self, col): - self.generateAttrib(col + "Time", "TimestampCol") #, "default=datetime.min") + self.generateAttrib("qmf" + col + "Time", "TimestampCol") #, "default=datetime.min") def generateForeignKeyAttrib(self, name, reference): params = "'%s', cascade='null'" % (reference) @@ -91,8 +91,8 @@ self.pythonOutput += " class sqlmeta:\n" self.pythonOutput += " lazyUpdate = %s\n\n" % (lazyUpdate) - def generateSourceIdsIndex(self, className): - self.pythonOutput += " source_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True)\n" + def generateQmfIdsIndex(self, className): + self.pythonOutput += " qmf_ids_unique = DatabaseIndex(qmfBrokerId, qmfScopeId, qmfObjectId, unique=True)\n" def generateClassAttribs(self, schemaName, elements): if (schemaName == "JournalStats"): @@ -138,18 +138,19 @@ self.currentClass = pythonName self.pythonOutput += "\nclass %s(SQLObject):\n" % (pythonName) self.generateLazyUpdate() - self.generateTimestampAttrib("rec") if (stats): + self.generateTimestampAttrib("Update") self.generateForeignKeyAttrib(colPythonName[0].lower() + colPythonName[1:], keyPythonName) self.generateMultipleJoin(origPythonName, pythonName, "stats") else: self.generateAttrib("qmfBrokerId", "StringCol", "length=1000") self.generateAttrib("qmfScopeId", "BigIntCol") self.generateAttrib("qmfObjectId", "BigIntCol") - self.generateSourceIdsIndex(pythonName) + self.generateQmfIdsIndex(pythonName) self.generateAttrib("qmfClassKey", "StringCol", "length=1000") - self.generateTimestampAttrib("creation") - self.generateTimestampAttrib("deletion") + self.generateTimestampAttrib("Update") + self.generateTimestampAttrib("Create") + self.generateTimestampAttrib("Delete") self.generateForeignKeyAttrib("statsCurr", statsPythonName) self.generateForeignKeyAttrib("statsPrev", statsPythonName) self.finalPythonOutput += "classToSchemaNameMap['%s'] = '%s'\n" % (pythonName, schemaName) Modified: mgmt/trunk/mint/python/mint/update.py =================================================================== --- mgmt/trunk/mint/python/mint/update.py 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/mint/python/mint/update.py 2008-11-26 18:25:55 UTC (rev 2889) @@ -192,11 +192,11 @@ timestamps = self.object.getTimestamps() - self.processTimestamp("recTime", timestamps[0], attrs) - self.processTimestamp("creationTime", timestamps[1], attrs) + self.processTimestamp("qmfUpdateTime", timestamps[0], attrs) + self.processTimestamp("qmfCreateTime", timestamps[1], attrs) if timestamps[2] != 0: - self.processTimestamp("deletionTime", timestamps[2], attrs) + self.processTimestamp("qmfDeleteTime", timestamps[2], attrs) log.debug("%s(%s) marked deleted", cls.__name__, oid) @@ -317,7 +317,7 @@ timestamps = self.object.getTimestamps() - self.processTimestamp("recTime", timestamps[0], attrs) + self.processTimestamp("qmfUpdateTime", timestamps[0], attrs) attrs["%s_id" % cls.sqlmeta.table] = id Modified: mgmt/trunk/mint/sql/schema.sql =================================================================== --- mgmt/trunk/mint/sql/schema.sql 2008-11-26 16:52:44 UTC (rev 2888) +++ mgmt/trunk/mint/sql/schema.sql 2008-11-26 18:25:55 UTC (rev 2889) @@ -64,13 +64,13 @@ CREATE TABLE acl ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, broker_id INT, @@ -79,24 +79,24 @@ transfer_acl BOOL, last_acl_load TIMESTAMP ); -CREATE UNIQUE INDEX acl_source_ids_unique ON acl (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX acl_qmf_ids_unique ON acl (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE acl_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, acl_id INT, acl_deny_count BIGINT ); CREATE TABLE agent ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, client_connection_id INT, @@ -106,23 +106,23 @@ broker_bank BIGINT, agent_bank BIGINT ); -CREATE UNIQUE INDEX agent_source_ids_unique ON agent (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX agent_qmf_ids_unique ON agent (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE agent_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, agent_id INT ); CREATE TABLE binding ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, exchange_id INT, @@ -131,24 +131,24 @@ arguments BYTEA, origin VARCHAR(1000) ); -CREATE UNIQUE INDEX binding_source_ids_unique ON binding (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX binding_qmf_ids_unique ON binding (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE binding_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, binding_id INT, msg_matched BIGINT ); CREATE TABLE bridge ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, link_id INT, @@ -163,23 +163,23 @@ excludes VARCHAR(1000), dynamic BOOL ); -CREATE UNIQUE INDEX bridge_source_ids_unique ON bridge (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX bridge_qmf_ids_unique ON bridge (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE bridge_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, bridge_id INT ); CREATE TABLE broker ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, system_id INT, @@ -193,23 +193,23 @@ data_dir VARCHAR(1000), registration_id INT ); -CREATE UNIQUE INDEX broker_source_ids_unique ON broker (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX broker_qmf_ids_unique ON broker (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE broker_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, broker_id INT ); CREATE TABLE client_connection ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, vhost_id INT, @@ -219,11 +219,11 @@ federation_link BOOL, auth_identity VARCHAR(1000) ); -CREATE UNIQUE INDEX client_connection_source_ids_unique ON client_connection (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX client_connection_qmf_ids_unique ON client_connection (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE client_connection_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, client_connection_id INT, closing BOOL, frames_from_client BIGINT, @@ -234,13 +234,13 @@ CREATE TABLE cluster ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, broker_id INT, @@ -251,23 +251,23 @@ status VARCHAR(1000), members VARCHAR(4000) ); -CREATE UNIQUE INDEX cluster_source_ids_unique ON cluster (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX cluster_qmf_ids_unique ON cluster (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE cluster_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, cluster_id INT ); CREATE TABLE collector ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, pool VARCHAR(1000), @@ -277,23 +277,23 @@ name VARCHAR(1000), public_network_ip_addr VARCHAR(1000) ); -CREATE UNIQUE INDEX collector_source_ids_unique ON collector (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX collector_qmf_ids_unique ON collector (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE collector_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, collector_id INT ); CREATE TABLE exchange ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, vhost_id INT, @@ -302,11 +302,11 @@ durable BOOL, arguments BYTEA ); -CREATE UNIQUE INDEX exchange_source_ids_unique ON exchange (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX exchange_qmf_ids_unique ON exchange (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE exchange_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, exchange_id INT, producer_count INT, producer_count_low INT, @@ -324,13 +324,13 @@ CREATE TABLE job ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, scheduler_id INT, @@ -362,23 +362,23 @@ dag_man_job_id BIGINT, ad BYTEA ); -CREATE UNIQUE INDEX job_source_ids_unique ON job (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX job_qmf_ids_unique ON job (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE job_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, job_id INT ); CREATE TABLE journal ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, queue_id INT, @@ -393,11 +393,11 @@ data_file_size BIGINT, current_file_count BIGINT ); -CREATE UNIQUE INDEX journal_source_ids_unique ON journal (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX journal_qmf_ids_unique ON journal (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE journal_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, journal_id INT, record_depth INT, record_depth_low INT, @@ -431,13 +431,13 @@ CREATE TABLE link ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, vhost_id INT, @@ -446,11 +446,11 @@ transport VARCHAR(1000), durable BOOL ); -CREATE UNIQUE INDEX link_source_ids_unique ON link (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX link_qmf_ids_unique ON link (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE link_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, link_id INT, state VARCHAR(1000), last_error VARCHAR(1000) @@ -458,13 +458,13 @@ CREATE TABLE master ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, pool VARCHAR(1000), @@ -478,11 +478,11 @@ condor_version VARCHAR(1000), daemon_start_time TIMESTAMP ); -CREATE UNIQUE INDEX master_source_ids_unique ON master (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX master_qmf_ids_unique ON master (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE master_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, master_id INT, monitor_self_age BIGINT, monitor_self_cpu_usage FLOAT, @@ -494,13 +494,13 @@ CREATE TABLE negotiator ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, pool VARCHAR(1000), @@ -512,11 +512,11 @@ condor_version VARCHAR(1000), daemon_start_time TIMESTAMP ); -CREATE UNIQUE INDEX negotiator_source_ids_unique ON negotiator (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX negotiator_qmf_ids_unique ON negotiator (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE negotiator_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, negotiator_id INT, monitor_self_age BIGINT, monitor_self_cpu_usage FLOAT, @@ -533,13 +533,13 @@ CREATE TABLE queue ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, vhost_id INT, @@ -549,11 +549,11 @@ exclusive BOOL, arguments BYTEA ); -CREATE UNIQUE INDEX queue_source_ids_unique ON queue (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX queue_qmf_ids_unique ON queue (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE queue_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, queue_id INT, msg_total_enqueues BIGINT, msg_total_dequeues BIGINT, @@ -586,13 +586,13 @@ CREATE TABLE scheduler ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, pool VARCHAR(1000), @@ -607,11 +607,11 @@ condor_version VARCHAR(1000), daemon_start_time TIMESTAMP ); -CREATE UNIQUE INDEX scheduler_source_ids_unique ON scheduler (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX scheduler_qmf_ids_unique ON scheduler (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE scheduler_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, scheduler_id INT, num_users BIGINT, total_held_jobs BIGINT, @@ -629,13 +629,13 @@ CREATE TABLE session ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, vhost_id INT, @@ -646,11 +646,11 @@ attached BOOL, expire_time TIMESTAMP ); -CREATE UNIQUE INDEX session_source_ids_unique ON session (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX session_qmf_ids_unique ON session (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE session_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, session_id INT, frames_outstanding INT, txn_starts BIGINT, @@ -661,13 +661,13 @@ CREATE TABLE slot ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, pool VARCHAR(1000), @@ -724,11 +724,11 @@ condor_version VARCHAR(1000), daemon_start_time TIMESTAMP ); -CREATE UNIQUE INDEX slot_source_ids_unique ON slot (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX slot_qmf_ids_unique ON slot (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE slot_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, slot_id INT, activity VARCHAR(1000), clock_day BIGINT, @@ -772,13 +772,13 @@ CREATE TABLE store ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, broker_id INT, @@ -793,11 +793,11 @@ tpl_data_file_size BIGINT, tpl_current_file_count BIGINT ); -CREATE UNIQUE INDEX store_source_ids_unique ON store (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX store_qmf_ids_unique ON store (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE store_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, store_id INT, tpl_transaction_depth INT, tpl_transaction_depth_low INT, @@ -812,13 +812,13 @@ CREATE TABLE submitter ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, scheduler_id INT, @@ -827,11 +827,11 @@ name VARCHAR(1000), schedd_name VARCHAR(1000) ); -CREATE UNIQUE INDEX submitter_source_ids_unique ON submitter (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX submitter_qmf_ids_unique ON submitter (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE submitter_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, submitter_id INT, held_jobs BIGINT, idle_jobs BIGINT, @@ -840,13 +840,13 @@ CREATE TABLE sysimage ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, uuid BYTEA, @@ -858,11 +858,11 @@ mem_total BIGINT, swap_total BIGINT ); -CREATE UNIQUE INDEX sysimage_source_ids_unique ON sysimage (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX sysimage_qmf_ids_unique ON sysimage (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE sysimage_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, sysimage_id INT, mem_free BIGINT, swap_free BIGINT, @@ -875,13 +875,13 @@ CREATE TABLE system ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, system_id BYTEA, @@ -891,34 +891,34 @@ version VARCHAR(1000), machine VARCHAR(1000) ); -CREATE UNIQUE INDEX system_source_ids_unique ON system (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX system_qmf_ids_unique ON system (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE system_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, system_id INT ); CREATE TABLE vhost ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, qmf_broker_id VARCHAR(1000), qmf_scope_id BIGINT, qmf_object_id BIGINT, qmf_class_key VARCHAR(1000), - creation_time TIMESTAMP, - deletion_time TIMESTAMP, + qmf_update_time TIMESTAMP, + qmf_create_time TIMESTAMP, + qmf_delete_time TIMESTAMP, stats_curr_id INT, stats_prev_id INT, broker_id INT, name VARCHAR(1000), federation_tag VARCHAR(1000) ); -CREATE UNIQUE INDEX vhost_source_ids_unique ON vhost (qmf_broker_id, qmf_scope_id, qmf_object_id); +CREATE UNIQUE INDEX vhost_qmf_ids_unique ON vhost (qmf_broker_id, qmf_scope_id, qmf_object_id); CREATE TABLE vhost_stats ( id SERIAL PRIMARY KEY, - rec_time TIMESTAMP, + qmf_update_time TIMESTAMP, vhost_id INT );

15 years, 6 months

1
0
0 / 0

rhmessaging commits: r2888 - mgmt/trunk/cumin/python/cumin.

by rhmessaging-commits＠lists.jboss.org

Author: eallen Date: 2008-11-26 11:52:44 -0500 (Wed, 26 Nov 2008) New Revision: 2888 Modified: mgmt/trunk/cumin/python/cumin/page.py mgmt/trunk/cumin/python/cumin/pool.py Log: Make last pool selected "sticky" Modified: mgmt/trunk/cumin/python/cumin/page.py =================================================================== --- mgmt/trunk/cumin/python/cumin/page.py 2008-11-26 16:06:25 UTC (rev 2887) +++ mgmt/trunk/cumin/python/cumin/page.py 2008-11-26 16:52:44 UTC (rev 2888) @@ -57,6 +57,9 @@ self.pool = PoolFrame(app, "pool") self.add_mode(self.pool) + self.sticky_pool = Parameter(app, "last_pool") + self.add_parameter(self.sticky_pool) + self.change_password = ChangePasswordForm(app, "password") self.add_mode(self.change_password) @@ -128,6 +131,12 @@ self.__tabs.set_messaging_tab(session) self.view.set_messaging_mode(session) + def set_last_pool(self, session, pool): + self.sticky_pool.set(session, pool) + + def get_last_pool(self, session): + return self.sticky_pool.get(session) + class MainFrameTabs(LinkSet): def __init__(self, app, name): super(MainFrameTabs, self).__init__(app, name) @@ -182,7 +191,11 @@ self.parent.selection.set(session, self.name) self.page.main.view.grid.show(session) - pool = self.app.model.get_main_pool() + last_pool = self.page.main.get_last_pool(session) + if last_pool: + pool = model.Pool.get(last_pool) + else: + pool = self.app.model.get_main_pool() if pool: self.page.main.pool.show_object(session, pool) Modified: mgmt/trunk/cumin/python/cumin/pool.py =================================================================== --- mgmt/trunk/cumin/python/cumin/pool.py 2008-11-26 16:06:25 UTC (rev 2887) +++ mgmt/trunk/cumin/python/cumin/pool.py 2008-11-26 16:52:44 UTC (rev 2888) @@ -47,6 +47,7 @@ def render_content(self, session, data): pool = Identifiable(data["id"]) + self.page.main.set_last_pool(session, data["id"]) href = self.frame.pool.get_href(session, pool) return fmt_link(href, data["name"])

15 years, 6 months

1
0
0 / 0

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

2007

rhmessaging-commits November 2008