From 0fde239f2374817f95c5bcb6f7682f70ff637506 Mon Sep 17 00:00:00 2001 From: Michael Davidsaver Date: Mon, 6 Nov 2017 12:37:42 -0600 Subject: [PATCH] std::auto_ptr -> epics::auto_ptr --- src/remote/pv/blockingUDP.h | 2 +- src/remote/transportRegistry.cpp | 18 ++++++++++-------- src/rpcService/rpcServer.cpp | 2 +- testApp/remote/testCodec.cpp | 32 ++++++++++---------------------- 4 files changed, 22 insertions(+), 32 deletions(-) diff --git a/src/remote/pv/blockingUDP.h b/src/remote/pv/blockingUDP.h index 9a92175..4f1c03e 100644 --- a/src/remote/pv/blockingUDP.h +++ b/src/remote/pv/blockingUDP.h @@ -420,7 +420,7 @@ private: /** * Thread ID */ - std::auto_ptr _thread; + epics::auto_ptr _thread; epics::pvData::int8 _clientServerWithEndianFlag; diff --git a/src/remote/transportRegistry.cpp b/src/remote/transportRegistry.cpp index 69225c3..929dc88 100644 --- a/src/remote/transportRegistry.cpp +++ b/src/remote/transportRegistry.cpp @@ -8,7 +8,6 @@ #include using namespace epics::pvData; -using namespace std; namespace epics { namespace pvAccess { @@ -65,14 +64,15 @@ Transport::shared_pointer TransportRegistry::get(std::string const & /*type*/, c return Transport::shared_pointer(); } -auto_ptr TransportRegistry::get(std::string const & /*type*/, const osiSockAddr* address) +std::auto_ptr +TransportRegistry::get(std::string const & /*type*/, const osiSockAddr* address) { Lock guard(_mutex); transportsMap_t::iterator transportsIter = _transports.find(address); if(transportsIter != _transports.end()) { prioritiesMapSharedPtr_t priorities = transportsIter->second; - auto_ptr transportArray(new transportVector_t(priorities->size())); + std::auto_ptr transportArray(new transportVector_t(priorities->size())); int32 i = 0; for(prioritiesMap_t::iterator prioritiesIter = priorities->begin(); prioritiesIter != priorities->end(); @@ -82,7 +82,7 @@ auto_ptr TransportRegistry::get(std::strin } return transportArray; } - return auto_ptr(); + return std::auto_ptr(); } Transport::shared_pointer TransportRegistry::remove(Transport::shared_pointer const & transport) @@ -124,20 +124,22 @@ int32 TransportRegistry::numberOfActiveTransports() } -auto_ptr TransportRegistry::toArray(std::string const & /*type*/) +std::auto_ptr +TransportRegistry::toArray(std::string const & /*type*/) { // TODO support type return toArray(); } -auto_ptr TransportRegistry::toArray() +std::auto_ptr +TransportRegistry::toArray() { Lock guard(_mutex); if (_transportCount == 0) - return auto_ptr(0); + return std::auto_ptr(0); - auto_ptr transportArray(new transportVector_t(_transportCount)); + std::auto_ptr transportArray(new transportVector_t(_transportCount)); int32 i = 0; for (transportsMap_t::iterator transportsIter = _transports.begin(); diff --git a/src/rpcService/rpcServer.cpp b/src/rpcService/rpcServer.cpp index a57d422..37fa5f3 100644 --- a/src/rpcService/rpcServer.cpp +++ b/src/rpcService/rpcServer.cpp @@ -460,7 +460,7 @@ static void threadRunner(void* usr) /// owned by a shared_ptr instance. void RPCServer::runInNewThread(int seconds) { - std::auto_ptr param(new ThreadRunnerParam()); + epics::auto_ptr param(new ThreadRunnerParam()); param->server = shared_from_this(); param->timeToRun = seconds; diff --git a/testApp/remote/testCodec.cpp b/testApp/remote/testCodec.cpp index 74b4108..f5be58e 100644 --- a/testApp/remote/testCodec.cpp +++ b/testApp/remote/testCodec.cpp @@ -424,14 +424,14 @@ public: bool _disconnected; int _forcePayloadRead; - std::auto_ptr _readBuffer; + epics::auto_ptr _readBuffer; epics::pvData::ByteBuffer _writeBuffer; std::vector _receivedAppMessages; std::vector _receivedControlMessages; - std::auto_ptr _readPollOneCallback; - std::auto_ptr _writePollOneCallback; + epics::auto_ptr _readPollOneCallback; + epics::auto_ptr _writePollOneCallback; osiSockAddr _dummyAddress; @@ -1424,12 +1424,8 @@ private: codec._readBuffer->setLimit(splitAt); - std::auto_ptr - readPollOneCallback( - new ReadPollOneCallbackForTestSegmentedSplitMessage - (codec, realReadBufferEnd)); - - codec._readPollOneCallback = readPollOneCallback; + codec._readPollOneCallback.reset(new ReadPollOneCallbackForTestSegmentedSplitMessage + (codec, realReadBufferEnd)); int32_t payloadSizeSum = @@ -2042,13 +2038,9 @@ private: codec._readBuffer->setLimit(splitAt); - std::auto_ptr - readPollOneCallback( new - ReadPollOneCallbackForTestSegmentedSplitConnectionLoss - (codec)); - - - codec._readPollOneCallback = readPollOneCallback; + codec._readPollOneCallback.reset(new + ReadPollOneCallbackForTestSegmentedSplitConnectionLoss + (codec)); int32_t payloadSizeSum = payloadSize1+payloadSize2+payloadSize3; @@ -2628,17 +2620,13 @@ private: codec._readBuffer.reset( new ByteBuffer(11*DEFAULT_BUFFER_SIZE)); - std::auto_ptr - writePollOneCallback( - new WritePollOneCallbackForTestSendHugeMessagePartes - (codec)); - std::tr1::shared_ptr sender = std::tr1::shared_ptr( new TransportSenderForTestSendHugeMessagePartes( codec, bytesToSent)); - codec._writePollOneCallback = writePollOneCallback; + codec._writePollOneCallback.reset(new WritePollOneCallbackForTestSendHugeMessagePartes + (codec)); // process