epics/pvAccess
0
0
Fork 0
Code Issues Pull Requests Projects Wiki Activity

MB_POINT stage description added

Browse Source
This commit is contained in:
Matej Sekoranja
2013-03-13 21:39:19 +01:00
parent 9755c3b016
commit fd56d36b09
2 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pvAccessApp/remoteClient/clientContextImpl.cpp
+5 -5
View File
@@ -546,7 +546,7 @@ namespace epics {
int32 pendingRequest = getPendingRequest();
bool initStage = (pendingRequest & QOS_INIT);
MB_POINT_CONDITIONAL(channelGet, 1, !initStage);
MB_POINT_CONDITIONAL(channelGet, 1, "client channelGet->serialize (start)", !initStage);
if (pendingRequest < 0)
{
@@ -565,7 +565,7 @@ namespace epics {
SerializationHelper::serializePVRequest(buffer, control, m_pvRequest);
}
MB_POINT_CONDITIONAL(channelGet, 2, !initStage);
MB_POINT_CONDITIONAL(channelGet, 2, "client channelGet->serialize (end)", !initStage);
stopRequest();
}
@@ -600,7 +600,7 @@ namespace epics {
virtual bool normalResponse(Transport::shared_pointer const & transport, int8 /*version*/, ByteBuffer* payloadBuffer, int8 /*qos*/, const Status& status) {
MB_POINT(channelGet, 8);
MB_POINT(channelGet, 8, "client channelGet->deserialize (start)");
if (!status.isSuccess())
{
@@ -615,7 +615,7 @@ namespace epics {
m_structure->deserialize(payloadBuffer, transport.get(), m_bitSet.get());
}
MB_POINT(channelGet, 9);
MB_POINT(channelGet, 9, "client channelGet->deserialize (end), just before channelGet->getDone() is called");
EXCEPTION_GUARD(m_channelGetRequester->getDone(status));
return true;
@@ -625,7 +625,7 @@ namespace epics {
{
MB_INC_AUTO_ID(channelGet);
MB_POINT(channelGet, 0);
MB_POINT(channelGet, 0, "client channelGet->get()");
Lock guard(m_mutex);
if (m_destroyed) {
pvAccessApp/server/responseHandlers.cpp
+5 -5
View File
@@ -558,7 +558,7 @@ void ServerGetHandler::handleResponse(osiSockAddr* responseFrom,
else
{
MB_INC_AUTO_ID(channelGet);
MB_POINT(channelGet, 3);
MB_POINT(channelGet, 3, "server channelGet->deserialize request (start)");
const bool lastRequest = (QOS_DESTROY & qosCode) != 0;
@@ -575,7 +575,7 @@ void ServerGetHandler::handleResponse(osiSockAddr* responseFrom,
return;
}
MB_POINT(channelGet, 4);
MB_POINT(channelGet, 4, "server channelGet->deserialize request (end)");
request->getChannelGet()->get(lastRequest);
}
@@ -640,7 +640,7 @@ void ServerChannelGetRequesterImpl::channelGetConnect(const Status& status, Chan
void ServerChannelGetRequesterImpl::getDone(const Status& status)
{
MB_POINT(channelGet, 5);
MB_POINT(channelGet, 5, "server channelGet->getDone()");
{
Lock guard(_mutex);
_status = status;
@@ -700,7 +700,7 @@ void ServerChannelGetRequesterImpl::send(ByteBuffer* buffer, TransportSendContro
}
else
{
MB_POINT(channelGet, 6);
MB_POINT(channelGet, 6, "server channelGet->serialize response (start)");
{
// we locked _mutex above, so _channelGet is valid
ScopedLock lock(_channelGet);
@@ -708,7 +708,7 @@ void ServerChannelGetRequesterImpl::send(ByteBuffer* buffer, TransportSendContro
_bitSet->serialize(buffer, control);
_pvStructure->serialize(buffer, control, _bitSet.get());
}
MB_POINT(channelGet, 7);
MB_POINT(channelGet, 7, "server channelGet->serialize response (end)");
}
}