Attachment 852398 Details for Bug 1052046 – Patch proposal

[patch] Patch proposal

bz1052046.patch (text/plain), 2.22 KB, created by Pavel Moravec on 2014-01-19 13:38:54 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Pavel Moravec

Created: 2014-01-19 13:38:54 UTC

Size: 2.22 KB

patch

obsolete

>Index: cpp/src/qpid/broker/Queue.cpp
>===================================================================
>--- cpp/src/qpid/broker/Queue.cpp	(revision 1559494)
>+++ cpp/src/qpid/broker/Queue.cpp	(working copy)
>@@ -1660,6 +1660,12 @@
>     }
> }
> 
>+void Queue::setOwningUser(std::string& _userId) {
>+    userId  = _userId;
>+    if (mgmtObject != 0)
>+        mgmtObject->set_creator(userId);
>+}
>+
> bool Queue::reroute(boost::shared_ptr<Exchange> e, const Message& m)
> {
>     if (e) {
>Index: cpp/src/qpid/broker/management-schema.xml
>===================================================================
>--- cpp/src/qpid/broker/management-schema.xml	(revision 1559494)
>+++ cpp/src/qpid/broker/management-schema.xml	(working copy)
>@@ -282,8 +282,9 @@
>     <statistic name="flowStopped"         type="bool"     desc="Flow control active."/>
>     <statistic name="flowStoppedCount"    type="count32"  desc="Number of times flow control was activated for this queue"/>
> 
>-   <statistic name="redirectPeer"         type="sstr"     desc="Partner queue for redirected pair"/>
>-   <statistic name="redirectSource"       type="bool"     desc="This queue is the redirect source"/>
>+    <statistic name="redirectPeer"        type="sstr"     desc="Partner queue for redirected pair"/>
>+    <statistic name="redirectSource"      type="bool"     desc="This queue is the redirect source"/>
>+    <statistic name="creator"             type="sstr"     desc="userId of creator of the queue"/>
> 
>     <method name="purge" desc="Discard all or some messages on a queue">
>       <arg name="request" dir="I" type="uint32" desc="0 for all messages or n>0 for n messages"/>
>Index: cpp/src/qpid/broker/Queue.h
>===================================================================
>--- cpp/src/qpid/broker/Queue.h	(revision 1559494)
>+++ cpp/src/qpid/broker/Queue.h	(working copy)
>@@ -400,7 +400,7 @@
>     QPID_BROKER_EXTERN bool find(framing::SequenceNumber pos, Message& msg ) const;
> 
>     // Remember the queue's owner so acl quotas can be restored after restart
>-    void setOwningUser(std::string& _userId) { userId  = _userId; }
>+    void setOwningUser(std::string& _userId);
>     void updateAclUserQueueCount();
> 
>     QPID_BROKER_EXTERN void setAlternateExchange(boost::shared_ptr<Exchange> exchange);

Actions: View | Diff

Attachments on bug 1052046: 852398