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 @@
…
[View More]
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
[View Less]
16 years, 1 month
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
…
[View More] 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)
-
-
[View Less]
16 years, 1 month
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)/…
[View More]sesame
-EXTRA_DIST = sesame.conf
+EXTRA_DIST = sesame.conf sysvinit-sesame
nobase_conf_DATA = sesame.conf
[View Less]
16 years, 1 month
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 = …
[View More]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
-
[View Less]
16 years, 1 month
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 …
[View More]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,
[View Less]
16 years, 1 month
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 …
[View More]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
[View Less]
16 years, 1 month
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)
…
[View More]@@ -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]
[View Less]
16 years, 1 month
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 …
[View More]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
+ *
[View Less]
16 years, 1 month
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/…
[View More]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
);
[View Less]
16 years, 1 month
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,…
[View More]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"])
[View Less]
16 years, 1 month