summaryrefslogtreecommitdiff
path: root/cpp/demo/Ice/bidir/CallbackI.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/demo/Ice/bidir/CallbackI.cpp')
-rw-r--r--cpp/demo/Ice/bidir/CallbackI.cpp21
1 files changed, 2 insertions, 19 deletions
diff --git a/cpp/demo/Ice/bidir/CallbackI.cpp b/cpp/demo/Ice/bidir/CallbackI.cpp
index 6693ef279a2..52dfb263154 100644
--- a/cpp/demo/Ice/bidir/CallbackI.cpp
+++ b/cpp/demo/Ice/bidir/CallbackI.cpp
@@ -10,26 +10,18 @@
#include <Ice/Ice.h>
#include <CallbackI.h>
-#if defined(_MSC_VER) && (_MSC_VER < 1700)
-# pragma warning( 4 : 4355 ) // C4355 'this' : used in base member initializer list
-#endif
-
using namespace std;
using namespace Ice;
using namespace Demo;
CallbackSenderI::CallbackSenderI(const Ice::CommunicatorPtr& communicator) :
- _communicator(communicator),
- _destroy(false),
- _callbackSenderThread(new CallbackSenderThread(this))
+ _communicator(communicator), _destroy(false)
{
}
void
CallbackSenderI::destroy()
{
- IceUtil::ThreadPtr callbackSenderThread;
-
{
IceUtil::Monitor<IceUtil::Mutex>::Lock lock(*this);
@@ -37,12 +29,9 @@ CallbackSenderI::destroy()
_destroy = true;
notify();
-
- callbackSenderThread = _callbackSenderThread;
- _callbackSenderThread = 0; // Resolve cyclic dependency.
}
- callbackSenderThread->getThreadControl().join();
+ getThreadControl().join();
}
void
@@ -57,12 +46,6 @@ CallbackSenderI::addClient(const Identity& ident, const Current& current)
}
void
-CallbackSenderI::start()
-{
- _callbackSenderThread->start();
-}
-
-void
CallbackSenderI::run()
{
int num = 0;