summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/EndpointI.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/Ice/EndpointI.cpp')
-rw-r--r--cpp/src/Ice/EndpointI.cpp24
1 files changed, 23 insertions, 1 deletions
diff --git a/cpp/src/Ice/EndpointI.cpp b/cpp/src/Ice/EndpointI.cpp
index d3e9779154d..3840656abee 100644
--- a/cpp/src/Ice/EndpointI.cpp
+++ b/cpp/src/Ice/EndpointI.cpp
@@ -11,6 +11,8 @@
#include <Ice/Instance.h>
#include <Ice/LocalException.h>
#include <Ice/Network.h>
+#include <Ice/PropertiesI.h>
+#include <Ice/LoggerUtil.h>
using namespace std;
using namespace IceInternal;
@@ -35,7 +37,27 @@ IceInternal::EndpointHostResolver::EndpointHostResolver(const InstancePtr& insta
_destroyed(false)
{
__setNoDelete(true);
- start();
+ try
+ {
+ bool hasPriority = _instance->initializationData().properties->getProperty("Ice.ThreadPriority") != "";
+ int priority = _instance->initializationData().properties->getPropertyAsInt("Ice.ThreadPriority");
+ if(hasPriority)
+ {
+ start(0, priority);
+ }
+ else
+ {
+ start();
+ }
+ }
+ catch(const IceUtil::Exception& ex)
+ {
+ {
+ Ice::Error out(_instance->initializationData().logger);
+ out << "cannot create thread for enpoint host resolver:\n" << ex;
+ }
+ throw;
+ }
__setNoDelete(false);
}