rhmessaging commits: r3557 - in mgmt/trunk: wooly/python/wooly and 1 other directory.
by rhmessaging-commits＠lists.jboss.org
Author: eallen
Date: 2009-08-12 13:35:37 -0400 (Wed, 12 Aug 2009)
New Revision: 3557
Modified:
mgmt/trunk/cumin/python/cumin/messaging/queue.py
mgmt/trunk/cumin/python/cumin/messaging/queue.strings
mgmt/trunk/wooly/python/wooly/widgets.py
mgmt/trunk/wooly/python/wooly/widgets.strings
Log:
Added a RadioModeSet to display modes as radio buttons
Modified: mgmt/trunk/cumin/python/cumin/messaging/queue.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/messaging/queue.py 2009-08-11 21:06:33 UTC (rev 3556)
+++ mgmt/trunk/cumin/python/cumin/messaging/queue.py 2009-08-12 17:35:37 UTC (rev 3557)
@@ -653,7 +653,7 @@
self.object = BindingParameter(app, "binding")
self.add_parameter(self.object)
-class QueueStats(TabbedModeSet):
+class QueueStats(RadioModeSet):
def __init__(self, app, name):
super(QueueStats, self).__init__(app, name)
Modified: mgmt/trunk/cumin/python/cumin/messaging/queue.strings
===================================================================
--- mgmt/trunk/cumin/python/cumin/messaging/queue.strings 2009-08-11 21:06:33 UTC (rev 3556)
+++ mgmt/trunk/cumin/python/cumin/messaging/queue.strings 2009-08-12 17:35:37 UTC (rev 3557)
@@ -51,10 +51,6 @@
[TopQueueSet.count_sql]
--
-[QueueStats.html]
-<ul class="radiotabs tabs">{tabs}</ul>
-<div class="radiotabs mode">{content}</div>
-
[QueueStatsGeneral.html]
<table class="twocol">
<tbody>
Modified: mgmt/trunk/wooly/python/wooly/widgets.py
===================================================================
--- mgmt/trunk/wooly/python/wooly/widgets.py 2009-08-11 21:06:33 UTC (rev 3556)
+++ mgmt/trunk/wooly/python/wooly/widgets.py 2009-08-12 17:35:37 UTC (rev 3557)
@@ -79,6 +79,10 @@
args = tab.get_args(session)
return tab.render_title(session, *args)
+class RadioModeSet(TabbedModeSet):
+ """ exists just to provide different class/styles """
+ pass
+
class WidgetSet(Widget):
def __init__(self, app, name):
super(WidgetSet, self).__init__(app, name)
Modified: mgmt/trunk/wooly/python/wooly/widgets.strings
===================================================================
--- mgmt/trunk/wooly/python/wooly/widgets.strings 2009-08-11 21:06:33 UTC (rev 3556)
+++ mgmt/trunk/wooly/python/wooly/widgets.strings 2009-08-12 17:35:37 UTC (rev 3557)
@@ -50,6 +50,10 @@
[TabbedModeSet.tab_html]
<li><a href="{tab_href}" {tab_class}>{tab_content}</a></li>
+[RadioModeSet.html]
+<ul class="radiotabs tabs">{tabs}</ul>
+<div class="radiotabs mode">{content}</div>
+
[WidgetSet.html]
<ul id="{id}" class="{class}">{widgets}</ul>
15 years, 4 months
rhmessaging commits: r3556 - store/trunk/cpp/tests.
by rhmessaging-commits＠lists.jboss.org
Author: rschloming
Date: 2009-08-11 17:06:33 -0400 (Tue, 11 Aug 2009)
New Revision: 3556
Modified:
store/trunk/cpp/tests/persistence.py
store/trunk/cpp/tests/run_python_tests
Log:
fixed store/python test integration
Modified: store/trunk/cpp/tests/persistence.py
===================================================================
--- store/trunk/cpp/tests/persistence.py 2009-08-10 18:18:00 UTC (rev 3555)
+++ store/trunk/cpp/tests/persistence.py 2009-08-11 21:06:33 UTC (rev 3556)
@@ -24,7 +24,6 @@
from qpid.connection import Connection
from qpid.util import connect
-from qpid.spec010 import load
from qpid.datatypes import Message, RangedSet
from qpid.queue import Empty
from qpid.session import SessionException
@@ -498,7 +497,7 @@
def connect(self):
""" Connects to the broker """
- self.conn = Connection(connect(self.host, self.port), load(self.spec, *self.errata))
+ self.conn = Connection(connect(self.host, self.port))
self.conn.start(timeout=10)
self.session = self.conn.session("test-session", timeout=10)
Modified: store/trunk/cpp/tests/run_python_tests
===================================================================
--- store/trunk/cpp/tests/run_python_tests 2009-08-10 18:18:00 UTC (rev 3555)
+++ store/trunk/cpp/tests/run_python_tests 2009-08-11 21:06:33 UTC (rev 3556)
@@ -62,8 +62,6 @@
fi
STORE_DIR=${TMP_DATA_DIR}/python
-BROKER_OPTS="--no-module-dir --load-module=${STORE_LIB} --data-dir=${STORE_DIR} --auth=no --log-enable info+ --log-to-file ${STORE_DIR}/broker.python-test.log"
-AMQP_SPEC=0-10-errata
#Make sure temp dir exists if this is the first to use it
if test -d ${STORE_DIR} ; then
@@ -75,12 +73,22 @@
export QPIDD=${QPID_BLD}/src/qpidd
fi
+trap stop_broker INT TERM QUIT
+
+start_broker() {
+ ${QPIDD} --daemon --port 0 --no-module-dir --load-module=${STORE_LIB} --data-dir=${STORE_DIR} --auth=no --log-enable info+ --log-to-file ${STORE_DIR}/broker.python-test.log > qpidd.port
+ LOCAL_PORT=`cat qpidd.port`
+}
+
+stop_broker() {
+ ${QPIDD} -q --port $LOCAL_PORT
+}
+
fail=0
# Run all python tests
-pwdir=$(pwd)
-cd ${QPID_PYTHON_DIR}
-./run-tests --skip-self-test -v -s ${AMQP_SPEC} -I ${FAILING_PYTHON_TESTS} -B "${BROKER_OPTS}" ${PYTHON_TESTS} || { echo "FAIL python tests for ${AMQP_SPEC}"; fail=1; }
-cd ${pwdir}
+start_broker
+$QPID_PYTHON_DIR/qpid-python-test -m python_tests -b localhost:$LOCAL_PORT -I ${FAILING_PYTHON_TESTS} ${PYTHON_TESTS} || { echo "FAIL python tests"; fail=1; }
+stop_broker || fail=1
exit ${fail}
15 years, 4 months
rhmessaging commits: r3555 - mgmt/trunk/bin.
by rhmessaging-commits＠lists.jboss.org
Author: justi9
Date: 2009-08-10 14:18:00 -0400 (Mon, 10 Aug 2009)
New Revision: 3555
Modified:
mgmt/trunk/bin/find-code
Log:
Add a trailing slash in order to resolve symlinks
Modified: mgmt/trunk/bin/find-code
===================================================================
--- mgmt/trunk/bin/find-code 2009-08-10 15:34:51 UTC (rev 3554)
+++ mgmt/trunk/bin/find-code 2009-08-10 18:18:00 UTC (rev 3555)
@@ -1,6 +1,6 @@
-#!/bin/bash
+#!/bin/bash
-find "$DEVEL_HOME" \
+exec find "${DEVEL_HOME}/" \
-regextype posix-awk \
-regex '.*\.(py|strings|sql|xml|js|css)$' \
-or \
15 years, 4 months
rhmessaging commits: r3554 - mgmt/trunk/cumin/python/cumin/grid.
by rhmessaging-commits＠lists.jboss.org
Author: justi9
Date: 2009-08-10 11:34:51 -0400 (Mon, 10 Aug 2009)
New Revision: 3554
Modified:
mgmt/trunk/cumin/python/cumin/grid/pool.py
Log:
Make the pool stat code resilient to multiple collectors for the same pool id
Modified: mgmt/trunk/cumin/python/cumin/grid/pool.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/grid/pool.py 2009-08-07 18:16:41 UTC (rev 3553)
+++ mgmt/trunk/cumin/python/cumin/grid/pool.py 2009-08-10 15:34:51 UTC (rev 3554)
@@ -277,8 +277,8 @@
return pool.name
def get_collector_args(self, session):
- pool = self.frame.get_args(session)[0]
- return Collector.select("pool='%s'" % pool.id)
+ args = self.frame.get_args(session)
+ return (args[0].collector,)
class CollectorStatSet(StatSet):
def get_args(self, session):
15 years, 4 months
rhmessaging commits: r3553 - store/trunk/cpp/lib.
by rhmessaging-commits＠lists.jboss.org
Author: astitcher
Date: 2009-08-07 14:16:41 -0400 (Fri, 07 Aug 2009)
New Revision: 3553
Modified:
store/trunk/cpp/lib/JournalImpl.cpp
store/trunk/cpp/lib/JournalImpl.h
Log:
Change store to use the sys::Timer API instead of the broker::Timer one in preparation
for removing broker::Timer
Modified: store/trunk/cpp/lib/JournalImpl.cpp
===================================================================
--- store/trunk/cpp/lib/JournalImpl.cpp 2009-08-07 15:28:42 UTC (rev 3552)
+++ store/trunk/cpp/lib/JournalImpl.cpp 2009-08-07 18:16:41 UTC (rev 3553)
@@ -40,7 +40,7 @@
using qpid::management::ManagementAgent;
namespace _qmf = qmf::com::redhat::rhm::store;
-qpid::broker::Timer* JournalImpl::journalTimerPtr = 0;
+qpid::sys::Timer* JournalImpl::journalTimerPtr = 0;
u_int32_t JournalImpl::cnt = 0;
void InactivityFireEvent::fire() { slock s(&_ife_mutex); if (parent) parent->flushFire(); }
@@ -70,7 +70,7 @@
getEventsFireEventsPtr = new GetEventsFireEvent(this, getEventsTimeout);
inactivityFireEventPtr = new InactivityFireEvent(this, flushTimeout);
if (journalTimerPtr == 0)
- journalTimerPtr = new qpid::broker::Timer;
+ journalTimerPtr = new qpid::sys::Timer;
assert (journalTimerPtr != 0);
cnt++;
journalTimerPtr->start();
@@ -109,8 +109,8 @@
try { stop(true); } // NOTE: This will *block* until all outstanding disk aio calls are complete!
catch (const jexception& e) { log(LOG_ERROR, e.what()); }
}
- (dynamic_cast<GetEventsFireEvent*>(getEventsFireEventsPtr.get()))->cancel();
- (dynamic_cast<InactivityFireEvent*>(inactivityFireEventPtr.get()))->cancel();
+ getEventsFireEventsPtr->cancel();
+ inactivityFireEventPtr->cancel();
free_read_buffers();
// TODO: Make this if() thread-safe
@@ -533,7 +533,7 @@
flushTriggeredFlag = true;
}
}
- inactivityFireEventPtr->reset();
+ inactivityFireEventPtr->setupNextFire();
assert(journalTimerPtr != 0);
journalTimerPtr->add(inactivityFireEventPtr);
}
Modified: store/trunk/cpp/lib/JournalImpl.h
===================================================================
--- store/trunk/cpp/lib/JournalImpl.h 2009-08-07 15:28:42 UTC (rev 3552)
+++ store/trunk/cpp/lib/JournalImpl.h 2009-08-07 18:16:41 UTC (rev 3553)
@@ -30,8 +30,8 @@
#include "jrnl/slock.hpp"
#include "DataTokenImpl.h"
#include "PreparedTransaction.h"
-#include <qpid/broker/Timer.h>
#include <qpid/broker/PersistableQueue.h>
+#include <qpid/sys/Timer.h>
#include <qpid/sys/Time.h>
#include <boost/ptr_container/ptr_list.hpp>
#include <boost/intrusive_ptr.hpp>
@@ -43,27 +43,27 @@
class JournalImpl;
- class InactivityFireEvent : public virtual qpid::broker::TimerTask
+ class InactivityFireEvent : public qpid::sys::TimerTask
{
JournalImpl* parent;
pthread_mutex_t _ife_mutex;
public:
InactivityFireEvent(JournalImpl* p, const qpid::sys::Duration timeout):
- qpid::broker::TimerTask(timeout), parent(p) { ::pthread_mutex_init(&_ife_mutex, 0); }
+ qpid::sys::TimerTask(timeout), parent(p) { ::pthread_mutex_init(&_ife_mutex, 0); }
virtual ~InactivityFireEvent() { ::pthread_mutex_destroy(&_ife_mutex); }
void fire();
inline void cancel() { mrg::journal::slock s(&_ife_mutex); parent = 0; }
};
- class GetEventsFireEvent : public virtual qpid::broker::TimerTask
+ class GetEventsFireEvent : public qpid::sys::TimerTask
{
JournalImpl* parent;
pthread_mutex_t _gefe_mutex;
public:
GetEventsFireEvent(JournalImpl* p, const qpid::sys::Duration timeout):
- qpid::broker::TimerTask(timeout), parent(p) { ::pthread_mutex_init(&_gefe_mutex, 0); }
+ qpid::sys::TimerTask(timeout), parent(p) { ::pthread_mutex_init(&_gefe_mutex, 0); }
virtual ~GetEventsFireEvent() { ::pthread_mutex_destroy(&_gefe_mutex); }
void fire();
inline void cancel() { mrg::journal::slock s(&_gefe_mutex); parent = 0; }
@@ -72,18 +72,18 @@
class JournalImpl : public qpid::broker::ExternalQueueStore, public mrg::journal::jcntl, public mrg::journal::aio_callback
{
private:
- static qpid::broker::Timer* journalTimerPtr;
+ static qpid::sys::Timer* journalTimerPtr;
static u_int32_t cnt;
bool getEventsTimerSetFlag;
- boost::intrusive_ptr<qpid::broker::TimerTask> getEventsFireEventsPtr;
+ boost::intrusive_ptr<qpid::sys::TimerTask> getEventsFireEventsPtr;
pthread_mutex_t _getf_mutex;
u_int64_t lastReadRid; // rid of last read msg for loadMsgContent()
bool writeActivityFlag;
bool flushTriggeredFlag;
- boost::intrusive_ptr<qpid::broker::TimerTask> inactivityFireEventPtr;
+ boost::intrusive_ptr<qpid::sys::TimerTask> inactivityFireEventPtr;
// temp local vars for loadMsgContent below
void* _xidp;
@@ -211,6 +211,7 @@
inline void setGetEventTimer()
{
assert(journalTimerPtr != 0);
+ getEventsFireEventsPtr->setupNextFire();
journalTimerPtr->add(getEventsFireEventsPtr);
getEventsTimerSetFlag = true;
}
15 years, 4 months
rhmessaging commits: r3552 - in mgmt/trunk: cumin/python/cumin/account and 1 other directories.
by rhmessaging-commits＠lists.jboss.org
Author: justi9
Date: 2009-08-07 11:28:42 -0400 (Fri, 07 Aug 2009)
New Revision: 3552
Added:
mgmt/trunk/cumin/python/cumin/account/widgets.py
mgmt/trunk/cumin/python/cumin/account/widgets.strings
mgmt/trunk/cumin/python/cumin/user.py
Removed:
mgmt/trunk/cumin/python/cumin/account/main.strings
mgmt/trunk/cumin/python/cumin/account/user.py
mgmt/trunk/cumin/python/cumin/account/user.strings
Modified:
mgmt/trunk/cumin/python/cumin/account/main.py
mgmt/trunk/cumin/python/cumin/account/model.py
mgmt/trunk/cumin/python/cumin/main.py
mgmt/trunk/cumin/python/cumin/stat.py
mgmt/trunk/cumin/python/cumin/util.py
mgmt/trunk/wooly/python/wooly/forms.py
Log:
Reorganize user and account code to clean things up a little and resolve an import conflict
Modified: mgmt/trunk/cumin/python/cumin/account/main.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/account/main.py 2009-08-07 10:11:31 UTC (rev 3551)
+++ mgmt/trunk/cumin/python/cumin/account/main.py 2009-08-07 15:28:42 UTC (rev 3552)
@@ -1,17 +1,8 @@
-from wooly import *
-from wooly.widgets import *
-from wooly.resources import *
-
from cumin import *
-from cumin.widgets import *
from cumin.util import *
from model import *
-from wooly import Session
-
-strings = StringCatalog(__file__)
-
class AccountModule(object):
def init(self, app):
subject = app.model.subject
@@ -19,196 +10,3 @@
self.change_password = ChangePasswordTask(app, subject)
module = AccountModule()
-
-class AccountPage(CuminPage, ModeSet):
- def __init__(self, app, name):
- super(AccountPage, self).__init__(app, name)
-
- self.account = AccountContainerView(app, "account")
- self.add_mode(self.account)
- self.set_default_frame(self.account)
-
- def render_title(self, session):
- return "MRG Account"
-
-class AccountContainerView(CuminMainView):
- def __init__(self, app, name):
- super(AccountContainerView, self).__init__(app, name)
-
- self.main = AccountFrame(app, "main")
- self.add_tab(self.main)
-
- def render_admin_href(self, session):
- return Session(self.app.main_page).marshal()
-
-class AccountFrame(CuminFrame):
- def __init__(self, app, name):
- super(AccountFrame, self).__init__(app, name)
-
- self.view = AccountView(app, "view")
- self.add_mode(self.view)
-
- def render_title(self, session):
- return "Account"
-
-class AccountView(Widget):
- def __init__(self, app, name):
- super(AccountView, self).__init__(app, name)
-
- self.add_child(self.Heading(app, "heading"))
-
- self.__tabs = TabbedModeSet(app, "tabs")
- self.add_child(self.__tabs)
-
- self.__tabs.add_tab(self.AccountTab(app, "acct"))
- #self.__tabs.add_tab(UserGridJobs(app, "jobs", None))
-
- class AccountTab(ActionSet):
- def __init__(self, app, name):
- super(AccountView.AccountTab, self).__init__(app, name)
-
- def init(self):
- # XXX deferring this, but I don't like it
- task = module.change_password
- link = TaskLink(self.app, "change_password", task, None)
- self.add_child(link)
-
- super(AccountView.AccountTab, self).init()
-
- def render_title(self, session):
- return "Account Settings"
-
- class Heading(CuminHeading):
- def render_title(self, session):
- return "Account"
-
- def render_icon_href(self, session):
- return "resource?name=pool-36.png"
-
-from cumin.grid.job import JobTab
-
-class UserGridJobs(JobTab):
- def render_title(self, session):
- return "Your Grid Jobs %s" % fmt_count(self.get_item_count(session))
-
- def render_sql_where(self, session):
- if hasattr(session, "user_session"):
- user = session.user_session.subject.name
- else:
- user = ""
- elems = list()
- elems.append("b.name like '%s%s'" % (user, "%"))
- elems.append(self.get_phase_sql(session))
- return "where %s" % " and ".join(elems)
-
- def get_sql_values(self, session):
- pass
-
- def get_visible_columns(self, session):
- return self.get_request_visible_columns(session, ["custom_group", "scheduler"])
-
- def render_user(self, session, *args):
- if hasattr(session, "user_session"):
- return session.user_session.subject.name
-
-class LoginPage(HtmlPage):
- def __init__(self, app, name):
- super(LoginPage, self).__init__(app, name)
-
- self.html_class = LoginPage.__name__
-
- self.logout = BooleanParameter(app, "logout")
- self.add_parameter(self.logout)
-
- self.origin = self.Origin(app, "origin")
- self.add_parameter(self.origin)
-
- form = LoginForm(app, "form")
- self.add_child(form)
-
- def do_process(self, session):
- if self.logout.get(session):
- #id = session.get_cookie("session")
- session.expire_cookie("session")
-
- super(LoginPage, self).do_process(session)
-
- def render_title(self, session):
- return "Log In"
-
- class Origin(Parameter):
- def get_default(self, session):
- return Session(self.app.main_page).marshal()
-
-class LoginForm(Form):
- def __init__(self, app, name):
- super(LoginForm, self).__init__(app, name)
-
- self.__login_invalid = Attribute(app, "login_invalid")
- self.add_attribute(self.__login_invalid)
-
- self.fields = FormFieldSet(app, "fields")
- self.add_child(self.fields)
-
- self.__name = self.Name(app, "name")
- self.fields.add_field(self.__name)
- self.__name.input.size = 20
-
- self.__password = self.Password(app, "password")
- self.fields.add_field(self.__password)
- self.__password.input.size = 20
-
- self.__submit = self.Submit(app, "submit")
- self.add_child(self.__submit)
-
- def do_process(self, session):
- if self.__submit.get(session):
- name = self.__name.get(session)
- password = self.__password.get(session)
-
- errors = self.validate(session)
-
- if not errors:
- try:
- user = Subject.selectBy(name=name)[0]
- except IndexError:
- self.__login_invalid.set(session, True)
- return
-
- crypted = user.password
-
- if crypted and crypt(password, crypted) == crypted:
- # You're in!
-
- usess = UserSession(self.app, user)
- session.set_cookie("session", usess.id)
-
- url = self.page.origin.get(session)
-
- self.page.set_redirect_url(session, url)
- else:
- self.__login_invalid.set(session, True)
-
- def render_operator_link(self, session):
- email = self.app.config.operator_email
-
- if email:
- return "<a href=\"mailto:%s\">site operator</a>" % email
- else:
- return "site operator"
-
- def render_login_invalid(self, session):
- if self.__login_invalid.get(session):
- return self.get_string("login_invalid")
-
- class Name(StringField):
- def render_title(self, session):
- return "User Name"
-
- class Password(PasswordField):
- def render_title(self, session):
- return "Password"
-
- class Submit(FormButton):
- def render_content(self, session):
- return "Submit"
Deleted: mgmt/trunk/cumin/python/cumin/account/main.strings
===================================================================
--- mgmt/trunk/cumin/python/cumin/account/main.strings 2009-08-07 10:11:31 UTC (rev 3551)
+++ mgmt/trunk/cumin/python/cumin/account/main.strings 2009-08-07 15:28:42 UTC (rev 3552)
@@ -1,120 +0,0 @@
-[LoginPage.css]
-body.LoginPage {
- background: #f7f7f7;
- padding: 4em;
-}
-
-[LoginForm.css]
-form.LoginForm {
- background: #fff;
- width: 16em;
- margin: 0 auto;
- border: 1px solid #ddd;
- -moz-border-radius: 0.5em;
- -webkit-border-radius: 0.5em;
- padding: 2em;
-}
-
-form.LoginForm > h1 {
- margin: 0 0 1em 0;
-}
-
-form.LoginForm h1 img {
- vertical-align: -60%;
- margin: 0 0.25em 0 0;
-}
-
-form.LoginForm input {
- width: 12em;
-}
-
-form.LoginForm input.submit {
- width: auto;
-}
-
-form.LoginForm > div.buttons {
- margin: 1.5em 0 0 0;
-}
-
-form.LoginForm p.login_invalid {
- color: red;
-}
-
-[LoginForm.html]
-<form id="{id}" class="LoginForm" method="post" action="?">
- <h1><img src="resource?name=mrg-36.png"/> MRG Management</h1>
-
- <p>Enter your user name and password to log in.</p>
-
- <p>If you do not have an account or have trouble logging in, contact
- the {operator_link}.</p>
-
- {login_invalid}
-
- {fields}
-
- <div class="buttons">{submit}</div>
-
- <div>{hidden_inputs}</div>
-</form>
-
-<script type="text/javascript">
- $("{id}").elements[0].focus();
-
-</script>
-
-[LoginForm.login_invalid]
-<p class="login_invalid">The user name and password you entered do not
-match any account.</p>
-
-[AccountContainerView.html]
-<div id="head">
- <div id="user">
- Hi, {user_name}
- <strong>·</strong>
- <a id="account" onclick="wooly.clearUpdates()" href="{admin_href}">MRG Management</a>
- <strong>·</strong>
- <a id="logout" onclick="wooly.clearUpdates()" href="{logout_href}">Log Out</a>
- </div>
-
- <img id="logo" src="resource?name=rhlogo-32.png"/>
-
-</div>
-<div id="body">
-
-<div id="messages" style="display: {action_display};"><p title="close" onclick="cumin.hideActions()">x</p>{actions}</div>
- {heartbeat}
-
-{content}</div>
-
-<div id="foot"/>
-
-[AccountTab.html]
-<ul class="actions">
- <li>{change_password}</li>
-</ul>
-
-[MyGridJobs.html]
-<form id="{id}" method="post" action="?">
-<div class="rfloat">{phase}</div>
-Jobs submitted by {user}
-
- <div class="sactions" style="clear:right;">
- <h2>Act on Selected Jobs:</h2>
- {hold} {release} {remove}
- </div>
-
- <table class="mobjects">
- <thead>
- <tr>
- <th class="setnav" colspan="{column_count}">
- <div class="rfloat">{page}</div>
- {count}
- </th>
- </tr>
- <tr>{headers}</tr>
- </thead>
- <tbody>{items}</tbody>
- </table>
- <div>{hidden_inputs}</div>
-</form>
Modified: mgmt/trunk/cumin/python/cumin/account/model.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/account/model.py 2009-08-07 10:11:31 UTC (rev 3551)
+++ mgmt/trunk/cumin/python/cumin/account/model.py 2009-08-07 15:28:42 UTC (rev 3552)
@@ -1,6 +1,7 @@
from cumin.model import *
+from cumin.user import *
-from user import *
+from widgets import *
class ChangePasswordTask(Task):
def __init__(self, app, cls):
Deleted: mgmt/trunk/cumin/python/cumin/account/user.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/account/user.py 2009-08-07 10:11:31 UTC (rev 3551)
+++ mgmt/trunk/cumin/python/cumin/account/user.py 2009-08-07 15:28:42 UTC (rev 3552)
@@ -1,65 +0,0 @@
-from wooly import *
-from wooly.widgets import *
-from wooly.resources import *
-
-from cumin.widgets import *
-from cumin.util import *
-
-strings = StringCatalog(__file__)
-
-log = logging.getLogger("cumin.user")
-
-class ChangePasswordForm(CuminFieldForm):
- def __init__(self, app, name, task):
- super(ChangePasswordForm, self).__init__(app, name)
-
- self.task = task
-
- self.__current = self.Current(app, "current")
- self.add_field(self.__current)
- self.__current.input.size = 20
-
- self.__new0 = self.New0(app, "new0")
- self.add_field(self.__new0)
- self.__new0.input.size = 20
-
- self.__new1 = self.New1(app, "new1")
- self.add_field(self.__new1)
- self.__new1.input.size = 20
-
- def process_submit(self, session):
- curr = self.__current.get(session)
- new0 = self.__new0.get(session)
- new1 = self.__new1.get(session)
-
- subject = session.user_session.subject
- crypted = subject.password
-
- if crypt_password(curr, crypted) != crypted:
- error = FormError("The password is incorrect", self.__current)
- self.errors.add(session, error)
-
- if new0 != new1:
- error = FormError("The new passwords do not match")
- self.errors.add(session, error)
-
- self.check(session)
-
- if not self.errors.get(session):
- self.task.invoke(session, subject, new0)
- self.task.exit_with_redirect(session, subject)
-
- def render_title(self, session):
- return "Change password"
-
- class Current(PasswordField):
- def render_title(self, session):
- return "Current password"
-
- class New0(PasswordField):
- def render_title(self, session):
- return "New password"
-
- class New1(PasswordField):
- def render_title(self, session):
- return "Repeat new password"
Deleted: mgmt/trunk/cumin/python/cumin/account/user.strings
===================================================================
Added: mgmt/trunk/cumin/python/cumin/account/widgets.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/account/widgets.py (rev 0)
+++ mgmt/trunk/cumin/python/cumin/account/widgets.py 2009-08-07 15:28:42 UTC (rev 3552)
@@ -0,0 +1,266 @@
+import logging
+
+from wooly import *
+from wooly.widgets import *
+from wooly.resources import *
+
+from cumin import *
+from cumin.user import *
+from cumin.widgets import *
+from cumin.util import *
+
+import main
+
+from wooly import Session
+
+log = logging.getLogger("cumin.account.widgets")
+
+strings = StringCatalog(__file__)
+
+class AccountPage(CuminPage, ModeSet):
+ def __init__(self, app, name):
+ super(AccountPage, self).__init__(app, name)
+
+ self.account = AccountMainView(app, "account")
+ self.add_mode(self.account)
+ self.set_default_frame(self.account)
+
+ def render_title(self, session):
+ return "MRG Account"
+
+class AccountMainView(CuminMainView):
+ def __init__(self, app, name):
+ super(AccountMainView, self).__init__(app, name)
+
+ self.main = AccountFrame(app, "main")
+ self.add_tab(self.main)
+
+ def render_admin_href(self, session):
+ return Session(self.app.main_page).marshal()
+
+class AccountFrame(CuminFrame):
+ def __init__(self, app, name):
+ super(AccountFrame, self).__init__(app, name)
+
+ self.view = AccountView(app, "view")
+ self.add_mode(self.view)
+
+ def render_title(self, session):
+ return "Account"
+
+class AccountView(Widget):
+ def __init__(self, app, name):
+ super(AccountView, self).__init__(app, name)
+
+ self.add_child(self.Heading(app, "heading"))
+
+ self.__tabs = TabbedModeSet(app, "tabs")
+ self.add_child(self.__tabs)
+
+ self.__tabs.add_tab(self.AccountTab(app, "acct"))
+ #self.__tabs.add_tab(UserGridJobs(app, "jobs", None))
+
+ class AccountTab(ActionSet):
+ def __init__(self, app, name):
+ super(AccountView.AccountTab, self).__init__(app, name)
+
+ def init(self):
+ # XXX deferring this, but I don't like it
+ task = main.module.change_password
+ link = TaskLink(self.app, "change_password", task, None)
+ self.add_child(link)
+
+ super(AccountView.AccountTab, self).init()
+
+ def render_title(self, session):
+ return "Account Settings"
+
+ class Heading(CuminHeading):
+ def render_title(self, session):
+ return "Account"
+
+ def render_icon_href(self, session):
+ return "resource?name=pool-36.png"
+
+from cumin.grid.job import JobTab
+
+class UserGridJobs(JobTab):
+ def render_title(self, session):
+ return "Your Grid Jobs %s" % fmt_count(self.get_item_count(session))
+
+ def render_sql_where(self, session):
+ if hasattr(session, "user_session"):
+ user = session.user_session.subject.name
+ else:
+ user = ""
+ elems = list()
+ elems.append("b.name like '%s%s'" % (user, "%"))
+ elems.append(self.get_phase_sql(session))
+ return "where %s" % " and ".join(elems)
+
+ def get_sql_values(self, session):
+ pass
+
+ def get_visible_columns(self, session):
+ return self.get_request_visible_columns(session, ["custom_group", "scheduler"])
+
+ def render_user(self, session, *args):
+ if hasattr(session, "user_session"):
+ return session.user_session.subject.name
+
+class LoginPage(HtmlPage):
+ def __init__(self, app, name):
+ super(LoginPage, self).__init__(app, name)
+
+ self.html_class = LoginPage.__name__
+
+ self.logout = BooleanParameter(app, "logout")
+ self.add_parameter(self.logout)
+
+ self.origin = self.Origin(app, "origin")
+ self.add_parameter(self.origin)
+
+ form = LoginForm(app, "form")
+ self.add_child(form)
+
+ def do_process(self, session):
+ if self.logout.get(session):
+ #id = session.get_cookie("session")
+ session.expire_cookie("session")
+
+ super(LoginPage, self).do_process(session)
+
+ def render_title(self, session):
+ return "Log In"
+
+ class Origin(Parameter):
+ def get_default(self, session):
+ return Session(self.app.main_page).marshal()
+
+class LoginForm(Form):
+ def __init__(self, app, name):
+ super(LoginForm, self).__init__(app, name)
+
+ self.__login_invalid = Attribute(app, "login_invalid")
+ self.add_attribute(self.__login_invalid)
+
+ self.fields = FormFieldSet(app, "fields")
+ self.add_child(self.fields)
+
+ self.__name = self.Name(app, "name")
+ self.fields.add_field(self.__name)
+ self.__name.input.size = 20
+
+ self.__password = self.Password(app, "password")
+ self.fields.add_field(self.__password)
+ self.__password.input.size = 20
+
+ self.__submit = self.Submit(app, "submit")
+ self.add_child(self.__submit)
+
+ def do_process(self, session):
+ if self.__submit.get(session):
+ name = self.__name.get(session)
+ password = self.__password.get(session)
+
+ self.check(session)
+
+ if not self.errors.get(session):
+ try:
+ user = Subject.selectBy(name=name)[0]
+ except IndexError:
+ self.__login_invalid.set(session, True)
+ return
+
+ crypted = user.password
+
+ if crypted and crypt(password, crypted) == crypted:
+ # You're in!
+
+ usess = UserSession(self.app, user)
+ session.set_cookie("session", usess.id)
+
+ url = self.page.origin.get(session)
+
+ self.page.set_redirect_url(session, url)
+ else:
+ self.__login_invalid.set(session, True)
+
+ def render_operator_link(self, session):
+ email = self.app.config.operator_email
+
+ if email:
+ return "<a href=\"mailto:%s\">site operator</a>" % email
+ else:
+ return "site operator"
+
+ def render_login_invalid(self, session):
+ if self.__login_invalid.get(session):
+ return self.get_string("login_invalid")
+
+ class Name(StringField):
+ def render_title(self, session):
+ return "User Name"
+
+ class Password(PasswordField):
+ def render_title(self, session):
+ return "Password"
+
+ class Submit(FormButton):
+ def render_content(self, session):
+ return "Submit"
+
+class ChangePasswordForm(CuminFieldForm):
+ def __init__(self, app, name, task):
+ super(ChangePasswordForm, self).__init__(app, name)
+
+ self.task = task
+
+ self.__current = self.Current(app, "current")
+ self.add_field(self.__current)
+ self.__current.input.size = 20
+
+ self.__new0 = self.New0(app, "new0")
+ self.add_field(self.__new0)
+ self.__new0.input.size = 20
+
+ self.__new1 = self.New1(app, "new1")
+ self.add_field(self.__new1)
+ self.__new1.input.size = 20
+
+ def process_submit(self, session):
+ curr = self.__current.get(session)
+ new0 = self.__new0.get(session)
+ new1 = self.__new1.get(session)
+
+ subject = session.user_session.subject
+ crypted = subject.password
+
+ if crypt_password(curr, crypted) != crypted:
+ error = FormError("The password is incorrect", self.__current)
+ self.errors.add(session, error)
+
+ if new0 != new1:
+ error = FormError("The new passwords do not match")
+ self.errors.add(session, error)
+
+ self.check(session)
+
+ if not self.errors.get(session):
+ self.task.invoke(session, subject, new0)
+ self.task.exit_with_redirect(session, subject)
+
+ def render_title(self, session):
+ return "Change password"
+
+ class Current(PasswordField):
+ def render_title(self, session):
+ return "Current password"
+
+ class New0(PasswordField):
+ def render_title(self, session):
+ return "New password"
+
+ class New1(PasswordField):
+ def render_title(self, session):
+ return "Repeat new password"
Added: mgmt/trunk/cumin/python/cumin/account/widgets.strings
===================================================================
--- mgmt/trunk/cumin/python/cumin/account/widgets.strings (rev 0)
+++ mgmt/trunk/cumin/python/cumin/account/widgets.strings 2009-08-07 15:28:42 UTC (rev 3552)
@@ -0,0 +1,120 @@
+[LoginPage.css]
+body.LoginPage {
+ background: #f7f7f7;
+ padding: 4em;
+}
+
+[LoginForm.css]
+form.LoginForm {
+ background: #fff;
+ width: 16em;
+ margin: 0 auto;
+ border: 1px solid #ddd;
+ -moz-border-radius: 0.5em;
+ -webkit-border-radius: 0.5em;
+ padding: 2em;
+}
+
+form.LoginForm > h1 {
+ margin: 0 0 1em 0;
+}
+
+form.LoginForm h1 img {
+ vertical-align: -60%;
+ margin: 0 0.25em 0 0;
+}
+
+form.LoginForm input {
+ width: 12em;
+}
+
+form.LoginForm input.submit {
+ width: auto;
+}
+
+form.LoginForm > div.buttons {
+ margin: 1.5em 0 0 0;
+}
+
+form.LoginForm p.login_invalid {
+ color: red;
+}
+
+[LoginForm.html]
+<form id="{id}" class="LoginForm" method="post" action="?">
+ <h1><img src="resource?name=mrg-36.png"/> MRG Management</h1>
+
+ <p>Enter your user name and password to log in.</p>
+
+ <p>If you do not have an account or have trouble logging in, contact
+ the {operator_link}.</p>
+
+ {login_invalid}
+
+ {fields}
+
+ <div class="buttons">{submit}</div>
+
+ <div>{hidden_inputs}</div>
+</form>
+
+<script type="text/javascript">
+ $("{id}").elements[0].focus();
+
+</script>
+
+[LoginForm.login_invalid]
+<p class="login_invalid">The user name and password you entered do not
+match any account.</p>
+
+[AccountMainView.html]
+<div id="head">
+ <div id="user">
+ Hi, {user_name}
+ <strong>·</strong>
+ <a id="account" onclick="wooly.clearUpdates()" href="{admin_href}">MRG Management</a>
+ <strong>·</strong>
+ <a id="logout" onclick="wooly.clearUpdates()" href="{logout_href}">Log Out</a>
+ </div>
+
+ <img id="logo" src="resource?name=rhlogo-32.png"/>
+
+</div>
+<div id="body">
+
+<div id="messages" style="display: {action_display};"><p title="close" onclick="cumin.hideActions()">x</p>{actions}</div>
+ {heartbeat}
+
+{content}</div>
+
+<div id="foot"/>
+
+[AccountTab.html]
+<ul class="actions">
+ <li>{change_password}</li>
+</ul>
+
+[MyGridJobs.html]
+<form id="{id}" method="post" action="?">
+<div class="rfloat">{phase}</div>
+Jobs submitted by {user}
+
+ <div class="sactions" style="clear:right;">
+ <h2>Act on Selected Jobs:</h2>
+ {hold} {release} {remove}
+ </div>
+
+ <table class="mobjects">
+ <thead>
+ <tr>
+ <th class="setnav" colspan="{column_count}">
+ <div class="rfloat">{page}</div>
+ {count}
+ </th>
+ </tr>
+ <tr>{headers}</tr>
+ </thead>
+ <tbody>{items}</tbody>
+ </table>
+ <div>{hidden_inputs}</div>
+</form>
Modified: mgmt/trunk/cumin/python/cumin/main.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/main.py 2009-08-07 10:11:31 UTC (rev 3551)
+++ mgmt/trunk/cumin/python/cumin/main.py 2009-08-07 15:28:42 UTC (rev 3552)
@@ -2,15 +2,11 @@
import os
import sys
-from datetime import datetime, timedelta
from mint import *
from parsley.config import Config, ConfigParameter
from parsley.loggingex import *
-from qpid.datatypes import uuid4
from stat import StatChartPage, StatStackedPage, SlotMapPage, \
StatFlashPage, FlashFullPage
-from threading import Thread, Event
-from time import sleep
from wooly import Application, Session, Page
from wooly.devel import DevelPage
from wooly.pages import ResourcePage
@@ -18,6 +14,7 @@
from config import *
from model import *
+from user import *
from widgets import *
from managementserver import *
@@ -115,41 +112,6 @@
def stop(self):
self.model.stop()
-class UserSession(object):
- def __init__(self, app, subject):
- self.app = app
- self.subject = subject
- self.id = str(uuid4())
- self.created = datetime.now()
-
- self.app.user_sessions_by_id[self.id] = self
-
- def delete(self):
- del self.app.user_sessions_by_id[self.id]
-
-class UserSessionExpireThread(Thread):
- def __init__(self, app):
- super(UserSessionExpireThread, self).__init__()
-
- self.app = app
- self.setDaemon(True)
-
- def run(self):
- while True:
- self.expire_sessions()
- sleep(60)
-
- def expire_sessions(self):
- when = datetime.now() - timedelta(hours=2)
- count = 0
-
- for session in self.app.user_sessions_by_id.values():
- if session.created < when:
- session.delete()
- count += 1
-
- log.info("Expired %i user sessions", count)
-
class MainPage(CuminPage, ModeSet):
def __init__(self, app, name):
super(MainPage, self).__init__(app, name)
Modified: mgmt/trunk/cumin/python/cumin/stat.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/stat.py 2009-08-07 10:11:31 UTC (rev 3551)
+++ mgmt/trunk/cumin/python/cumin/stat.py 2009-08-07 15:28:42 UTC (rev 3552)
@@ -1,16 +1,15 @@
-from wooly import *
-from wooly.widgets import *
-from mint import *
+import cStringIO
+
from math import sqrt
+from mint import *
from random import randint
+from wooly import *
+from wooly.widgets import *
from widgets import *
from parameters import *
from util import *
from formats import *
-#import tempfile
-import cStringIO
-from datetime import timedelta, datetime
from OpenFlashChart import Chart, Element
@@ -552,8 +551,8 @@
samples[stat] = stat.samples(object, duration, interval, method)
# take stddev into account for max and min y values
- deviated_values = [(nvl(x[1],0) + float(nvl(x[2],0))/2,
- nvl(x[1],0) - float(nvl(x[2],0))/2)
+ deviated_values = [(nvl(x[1],0) + float(nvl(x[2],0))/2,
+ nvl(x[1],0) - float(nvl(x[2],0))/2)
for x in samples[stat] for stat in stats]
max_value = deviated_values and max(max(deviated_values)) or 1
min_value = deviated_values and min(min(deviated_values)) or 0
@@ -745,7 +744,7 @@
animation.type = "bounce"
animation.distance = 8
element.animate.append(animation)
-
+
element.tip = "#percent# (Click to modify)"
element.colours = self.colors
element.on_click = "ofc_change_priority"
@@ -759,7 +758,7 @@
{"value": 6, "label": "Reporting"},
{"value": 9, "label": "Management"}
]
-
+
chart.elements.append(element)
return chart.create()
@@ -873,9 +872,9 @@
max_of_axiis = max(max_value, axis_for_vals)
# the most recent value(s) changed the y-axis range
if axis_max != max_of_axiis:
- samples = self.fetch_samples(object, time_span, interval,
- self.fix_method(method, mode),
- mode, False, stats,
+ samples = self.fetch_samples(object, time_span, interval,
+ self.fix_method(method, mode),
+ mode, False, stats,
end_seconds_ago=end_seconds_ago)
max_value, min_value = self.get_max_min(session, stats, samples)
else:
Added: mgmt/trunk/cumin/python/cumin/user.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/user.py (rev 0)
+++ mgmt/trunk/cumin/python/cumin/user.py 2009-08-07 15:28:42 UTC (rev 3552)
@@ -0,0 +1,38 @@
+from util import *
+
+log = logging.getLogger("cumin.user")
+
+class UserSession(object):
+ def __init__(self, app, subject):
+ self.app = app
+ self.subject = subject
+ self.id = str(uuid4())
+ self.created = datetime.now()
+
+ self.app.user_sessions_by_id[self.id] = self
+
+ def delete(self):
+ del self.app.user_sessions_by_id[self.id]
+
+class UserSessionExpireThread(Thread):
+ def __init__(self, app):
+ super(UserSessionExpireThread, self).__init__()
+
+ self.app = app
+ self.setDaemon(True)
+
+ def run(self):
+ while True:
+ self.expire_sessions()
+ sleep(60)
+
+ def expire_sessions(self):
+ when = datetime.now() - timedelta(hours=2)
+ count = 0
+
+ for session in self.app.user_sessions_by_id.values():
+ if session.created < when:
+ session.delete()
+ count += 1
+
+ log.info("Expired %i user sessions", count)
Modified: mgmt/trunk/cumin/python/cumin/util.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/util.py 2009-08-07 10:11:31 UTC (rev 3551)
+++ mgmt/trunk/cumin/python/cumin/util.py 2009-08-07 15:28:42 UTC (rev 3552)
@@ -1,11 +1,15 @@
import sys
+import os
+import logging
+
+from crypt import crypt
from datetime import datetime, timedelta
-from logging import getLogger
+from qpid.datatypes import uuid4
+from random import randint
+from random import sample
+from threading import Thread, Event
from time import mktime, time, sleep
-from random import randint
from xml.sax.saxutils import escape as xml_escape
-from crypt import crypt
-from random import sample
def short_id():
return "%08x" % randint(0, sys.maxint)
Modified: mgmt/trunk/wooly/python/wooly/forms.py
===================================================================
--- mgmt/trunk/wooly/python/wooly/forms.py 2009-08-07 10:11:31 UTC (rev 3551)
+++ mgmt/trunk/wooly/python/wooly/forms.py 2009-08-07 15:28:42 UTC (rev 3552)
@@ -21,6 +21,9 @@
def has_errors(self, session):
return len(self.errors.get(session))
+ def check(self, session):
+ pass
+
def get_origin(self, session):
origin = self.origin.get(session)
@@ -540,9 +543,6 @@
def cancel(self, session):
self.cancel_button.set(session, True)
- def check(self, session):
- pass
-
def do_process(self, session):
if self.cancel_button.get(session):
self.cancel_button.set(session, False)
15 years, 4 months
rhmessaging commits: r3551 - store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb.
by rhmessaging-commits＠lists.jboss.org
Author: ritchiem
Date: 2009-08-07 06:11:31 -0400 (Fri, 07 Aug 2009)
New Revision: 3551
Modified:
store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java
Log:
Update to BDBMessageStore to have new operational logging messages
Modified: store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java
===================================================================
--- store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java 2009-08-07 10:03:43 UTC (rev 3550)
+++ store/trunk/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/BDBMessageStore.java 2009-08-07 10:11:31 UTC (rev 3551)
@@ -43,6 +43,7 @@
import org.apache.qpid.server.queue.AMQQueueFactory;
import org.apache.qpid.server.store.MessageStore;
import org.apache.qpid.server.store.StoreContext;
+import org.apache.qpid.server.store.AbstractMessageStore;
import org.apache.qpid.server.store.berkeleydb.tuples.QueueTupleBindingFactory;
import org.apache.qpid.server.store.berkeleydb.tuples.BindingTupleBindingFactory;
import org.apache.qpid.server.store.berkeleydb.tuples.QueueTuple;
@@ -50,6 +51,8 @@
import org.apache.qpid.server.txn.TransactionalContext;
import org.apache.qpid.server.virtualhost.VirtualHost;
import org.apache.qpid.server.configuration.VirtualHostConfiguration;
+import org.apache.qpid.server.logging.actors.CurrentActor;
+import org.apache.qpid.server.logging.messages.MessageStoreMessages;
import java.io.File;
import java.util.ArrayList;
@@ -73,7 +76,7 @@
* exchanges. <tr><td> Store and remove messages. <tr><td> Bind and unbind queues to exchanges. <tr><td> Enqueue and
* dequeue messages to queues. <tr><td> Generate message identifiers. </table>
*/
-public class BDBMessageStore implements MessageStore
+public class BDBMessageStore extends AbstractMessageStore
{
private static final Logger _log = Logger.getLogger(BDBMessageStore.class);
@@ -184,6 +187,8 @@
*/
public void configure(VirtualHost virtualHost, String base, VirtualHostConfiguration vHostConfig) throws Exception
{
+ super.configure(virtualHost, base, vHostConfig);
+
Configuration config = vHostConfig.getStoreConfiguration();
File environmentPath = new File(config.getString(ENVIRONMENT_PATH_PROPERTY, "bdbEnv"));
if (!environmentPath.exists())
@@ -195,6 +200,8 @@
}
}
+ CurrentActor.get().message(_logSubject, MessageStoreMessages.MST_1002(environmentPath.getAbsolutePath()));
+
_version = config.getInt(DATABASE_FORMAT_VERSION_PROPERTY, DATABASE_FORMAT_VERSION);
configure(virtualHost, environmentPath, false);
@@ -447,6 +454,8 @@
closeEnvironment();
_state = State.CLOSED;
+
+ super.close();
}
private void closeEnvironment() throws DatabaseException
@@ -1220,6 +1229,8 @@
stateTransition(State.CONFIGURED, State.RECOVERING);
_log.info("Recovering persistent state...");
+ CurrentActor.get().message(_logSubject,MessageStoreMessages.MST_1004(null, false));
+
StoreContext context = new StoreContext();
try
{
@@ -1228,13 +1239,18 @@
for (AMQQueue q : queues.values())
{
+ CurrentActor.get().message(_logSubject,MessageStoreMessages.MST_1004(String.valueOf(q.getName()), true));
+
q.configure(virtualHost.getConfiguration().getQueueConfiguration(q.getName().asString()));
+
}
recoverExchanges();
deliverMessages(context, queues);
_log.info("Persistent state recovered successfully");
+ CurrentActor.get().message(_logSubject, MessageStoreMessages.MST_1006(null, false));
+
commitTran(context);
}
@@ -1658,18 +1674,14 @@
_log.debug("On recovery, delivering Message ID:" + message.getMessageId() + " to " + queue.getName());
}
- if (_log.isInfoEnabled())
+ Integer count = queueRecoveries.get(queueName);
+ if (count == null)
{
- Integer count = queueRecoveries.get(queueName);
- if (count == null)
- {
- count = 0;
- }
+ count = 0;
+ }
- queueRecoveries.put(queueName, ++count);
+ queueRecoveries.put(queueName, ++count);
- }
-
actions.add(new ProcessAction(queue, context, message));
}
@@ -1703,6 +1715,13 @@
{
_log.info("Recovered message counts: " + queueRecoveries);
}
+
+ for(Map.Entry<AMQShortString,Integer> entry : queueRecoveries.entrySet())
+ {
+ CurrentActor.get().message(_logSubject, MessageStoreMessages.MST_1005(entry.getValue(), String.valueOf(entry.getKey())));
+
+ CurrentActor.get().message(_logSubject, MessageStoreMessages.MST_1006(String.valueOf(entry.getKey()), true));
+ }
}
QueueRegistry getQueueRegistry()
15 years, 4 months
rhmessaging commits: r3550 - store/trunk/java/bdbstore/bin.
by rhmessaging-commits＠lists.jboss.org
Author: ritchiem
Date: 2009-08-07 06:03:43 -0400 (Fri, 07 Aug 2009)
New Revision: 3550
Modified:
store/trunk/java/bdbstore/bin/qpid-server-bdb.bat
Log:
Ensure command line args are passed through in qpid-server-bdb.bat
Modified: store/trunk/java/bdbstore/bin/qpid-server-bdb.bat
===================================================================
--- store/trunk/java/bdbstore/bin/qpid-server-bdb.bat 2009-08-07 09:58:08 UTC (rev 3549)
+++ store/trunk/java/bdbstore/bin/qpid-server-bdb.bat 2009-08-07 10:03:43 UTC (rev 3550)
@@ -38,4 +38,4 @@
set BDBSTORE_HOME=%QPID_HOME%
set QPID_MODULE_JARS=%BDBSTORE_HOME%\lib\qpid-bdbstore-%VERSION%.jar;%BDBSTORE_HOME%\lib\je-3.3.62.jar
-.\qpid-server.bat
+.\qpid-server.bat %*
15 years, 4 months
rhmessaging commits: r3549 - store/trunk/java.
by rhmessaging-commits＠lists.jboss.org
Author: ritchiem
Date: 2009-08-07 05:58:08 -0400 (Fri, 07 Aug 2009)
New Revision: 3549
Added:
store/trunk/java/bdbstore/
Log:
Copied 0.5-release code base back to trunk to mirror changes done on Apache
Copied: store/trunk/java/bdbstore (from rev 3548, store/branches/java/0.5-release)
15 years, 4 months
rhmessaging commits: r3548 - store/trunk/java.
by rhmessaging-commits＠lists.jboss.org
Author: ritchiem
Date: 2009-08-07 05:57:23 -0400 (Fri, 07 Aug 2009)
New Revision: 3548
Removed:
store/trunk/java/bdbstore/
Log:
Remove old trunk for replacement with 0.5-release as per Apache
15 years, 4 months