diff options
Diffstat (limited to 'cpp')
| -rwxr-xr-x | cpp/managementgen/qmf/schema.py | 2 | ||||
| -rw-r--r-- | cpp/src/qpid/agent/ManagementAgentImpl.cpp | 8 | ||||
| -rw-r--r-- | cpp/src/qpid/management/ManagementBroker.cpp | 10 |
3 files changed, 10 insertions, 10 deletions
diff --git a/cpp/managementgen/qmf/schema.py b/cpp/managementgen/qmf/schema.py index 72ee762fc5..031721f47f 100755 --- a/cpp/managementgen/qmf/schema.py +++ b/cpp/managementgen/qmf/schema.py @@ -1076,7 +1076,7 @@ class SchemaClass: stream.write (" status = coreObject->ManagementMethod (METHOD_" +\ method.getName().upper() + ", ioArgs, text);\n") stream.write (" outBuf.putLong (status);\n") - stream.write (" outBuf.putShortString (::qpid::management::Manageable::StatusText (status, text));\n") + stream.write (" outBuf.putMediumString(::qpid::management::Manageable::StatusText (status, text));\n") for arg in method.args: if arg.getDir () == "O" or arg.getDir () == "IO": stream.write (" " +\ diff --git a/cpp/src/qpid/agent/ManagementAgentImpl.cpp b/cpp/src/qpid/agent/ManagementAgentImpl.cpp index 36e56e48ae..d752312843 100644 --- a/cpp/src/qpid/agent/ManagementAgentImpl.cpp +++ b/cpp/src/qpid/agent/ManagementAgentImpl.cpp @@ -370,13 +370,13 @@ void ManagementAgentImpl::invokeMethodRequest(Buffer& inBuffer, uint32_t sequenc ManagementObjectMap::iterator iter = managementObjects.find(objId); if (iter == managementObjects.end() || iter->second->isDeleted()) { - outBuffer.putLong (Manageable::STATUS_UNKNOWN_OBJECT); - outBuffer.putShortString(Manageable::StatusText(Manageable::STATUS_UNKNOWN_OBJECT)); + outBuffer.putLong (Manageable::STATUS_UNKNOWN_OBJECT); + outBuffer.putMediumString(Manageable::StatusText(Manageable::STATUS_UNKNOWN_OBJECT)); } else { if ((iter->second->getPackageName() != packageName) || (iter->second->getClassName() != className)) { outBuffer.putLong (Manageable::STATUS_INVALID_PARAMETER); - outBuffer.putShortString (Manageable::StatusText (Manageable::STATUS_INVALID_PARAMETER)); + outBuffer.putMediumString(Manageable::StatusText (Manageable::STATUS_INVALID_PARAMETER)); } else try { @@ -385,7 +385,7 @@ void ManagementAgentImpl::invokeMethodRequest(Buffer& inBuffer, uint32_t sequenc } catch(std::exception& e) { outBuffer.restore(); outBuffer.putLong(Manageable::STATUS_EXCEPTION); - outBuffer.putShortString(e.what()); + outBuffer.putMediumString(e.what()); } } diff --git a/cpp/src/qpid/management/ManagementBroker.cpp b/cpp/src/qpid/management/ManagementBroker.cpp index 480c63b03a..53c82d17e4 100644 --- a/cpp/src/qpid/management/ManagementBroker.cpp +++ b/cpp/src/qpid/management/ManagementBroker.cpp @@ -494,7 +494,7 @@ void ManagementBroker::handleMethodRequestLH (Buffer& inBuffer, string replyToKe if (!acl->authorise(userId, acl::ACCESS, acl::METHOD, methodName, ¶ms)) { outBuffer.putLong(Manageable::STATUS_FORBIDDEN); - outBuffer.putShortString(Manageable::StatusText(Manageable::STATUS_FORBIDDEN)); + outBuffer.putMediumString(Manageable::StatusText(Manageable::STATUS_FORBIDDEN)); outLen = MA_BUFFER_SIZE - outBuffer.available(); outBuffer.reset(); sendBuffer(outBuffer, outLen, dExchange, replyToKey); @@ -505,12 +505,12 @@ void ManagementBroker::handleMethodRequestLH (Buffer& inBuffer, string replyToKe ManagementObjectMap::iterator iter = managementObjects.find(objId); if (iter == managementObjects.end() || iter->second->isDeleted()) { outBuffer.putLong (Manageable::STATUS_UNKNOWN_OBJECT); - outBuffer.putShortString (Manageable::StatusText (Manageable::STATUS_UNKNOWN_OBJECT)); + outBuffer.putMediumString(Manageable::StatusText (Manageable::STATUS_UNKNOWN_OBJECT)); } else { if ((iter->second->getPackageName() != packageName) || (iter->second->getClassName() != className)) { outBuffer.putLong (Manageable::STATUS_INVALID_PARAMETER); - outBuffer.putShortString (Manageable::StatusText (Manageable::STATUS_INVALID_PARAMETER)); + outBuffer.putMediumString(Manageable::StatusText (Manageable::STATUS_INVALID_PARAMETER)); } else try { @@ -519,7 +519,7 @@ void ManagementBroker::handleMethodRequestLH (Buffer& inBuffer, string replyToKe } catch(std::exception& e) { outBuffer.restore(); outBuffer.putLong(Manageable::STATUS_EXCEPTION); - outBuffer.putShortString(e.what()); + outBuffer.putMediumString(e.what()); } } @@ -926,7 +926,7 @@ bool ManagementBroker::authorizeAgentMessageLH(Message& msg) encodeHeader(outBuffer, 'm', sequence); outBuffer.putLong(Manageable::STATUS_FORBIDDEN); - outBuffer.putShortString(Manageable::StatusText(Manageable::STATUS_FORBIDDEN)); + outBuffer.putMediumString(Manageable::StatusText(Manageable::STATUS_FORBIDDEN)); outLen = MA_BUFFER_SIZE - outBuffer.available(); outBuffer.reset(); sendBuffer(outBuffer, outLen, dExchange, replyToKey); |
