aboutsummaryrefslogtreecommitdiff
path: root/contrib
diff options
context:
space:
mode:
authorLaurent Goujon <laurent@dremio.com>2017-01-25 10:52:31 -0800
committerParth Chandra <pchandra@maprtech.com>2017-02-03 17:41:44 -0800
commit53ca55f91c40dcc488d6ecbd08b3e04907b62399 (patch)
tree50ca561fa05551673abcac9a7fdd7612d03ad37e /contrib
parent63ae6cffc23f1de8159217da9a8879b9ffb86423 (diff)
DRILL-5220: Provide API to set application/client names in C++ connector
Add method to DrillClientConfig to set the client and the application names in the C++ connector. Allow the ODBC driver (or any user of the C++ connector) to provide more specific informations like the application using the client. This closes #728
Diffstat (limited to 'contrib')
-rw-r--r--contrib/native/client/src/clientlib/drillClient.cpp22
-rw-r--r--contrib/native/client/src/clientlib/drillClientImpl.cpp3
-rw-r--r--contrib/native/client/src/include/drill/drillClient.hpp42
3 files changed, 66 insertions, 1 deletions
diff --git a/contrib/native/client/src/clientlib/drillClient.cpp b/contrib/native/client/src/clientlib/drillClient.cpp
index fe9c3a6b1..b456d1780 100644
--- a/contrib/native/client/src/clientlib/drillClient.cpp
+++ b/contrib/native/client/src/clientlib/drillClient.cpp
@@ -52,6 +52,8 @@ int32_t DrillClientConfig::s_socketTimeout=0;
int32_t DrillClientConfig::s_handshakeTimeout=5;
int32_t DrillClientConfig::s_queryTimeout=180;
int32_t DrillClientConfig::s_heartbeatFrequency=15; // 15 seconds
+std::string DrillClientConfig::s_clientName(DRILL_CONNECTOR_NAME);
+std::string DrillClientConfig::s_applicationName;
boost::mutex DrillClientConfig::s_mutex;
@@ -136,6 +138,26 @@ logLevel_t DrillClientConfig::getLogLevel(){
return s_logLevel;
}
+const std::string& DrillClientConfig::getClientName() {
+ boost::lock_guard<boost::mutex> configLock(DrillClientConfig::s_mutex);
+ return s_clientName;
+}
+
+void DrillClientConfig::setClientName(const std::string& name) {
+ boost::lock_guard<boost::mutex> configLock(DrillClientConfig::s_mutex);
+ s_clientName = name;
+}
+
+const std::string& DrillClientConfig::getApplicationName() {
+ boost::lock_guard<boost::mutex> configLock(DrillClientConfig::s_mutex);
+ return s_applicationName;
+}
+
+void DrillClientConfig::setApplicationName(const std::string& name) {
+ boost::lock_guard<boost::mutex> configLock(DrillClientConfig::s_mutex);
+ s_applicationName = name;
+}
+
//Using boost assign to initialize maps.
const std::map<std::string, uint32_t> DrillUserProperties::USER_PROPERTIES=boost::assign::map_list_of
( USERPROP_USERNAME, USERPROP_FLAGS_SERVERPROP|USERPROP_FLAGS_USERNAME|USERPROP_FLAGS_STRING )
diff --git a/contrib/native/client/src/clientlib/drillClientImpl.cpp b/contrib/native/client/src/clientlib/drillClientImpl.cpp
index 038ca90cf..8794044af 100644
--- a/contrib/native/client/src/clientlib/drillClientImpl.cpp
+++ b/contrib/native/client/src/clientlib/drillClientImpl.cpp
@@ -351,7 +351,8 @@ connectionStatus_t DrillClientImpl::validateHandshake(DrillUserProperties* prope
// Adding version info
exec::user::RpcEndpointInfos* infos = u2b.mutable_client_infos();
- infos->set_name(DRILL_CONNECTOR_NAME);
+ infos->set_name(DrillClientConfig::getClientName());
+ infos->set_application(DrillClientConfig::getApplicationName());
infos->set_version(DRILL_VERSION_STRING);
infos->set_majorversion(DRILL_VERSION_MAJOR);
infos->set_minorversion(DRILL_VERSION_MINOR);
diff --git a/contrib/native/client/src/include/drill/drillClient.hpp b/contrib/native/client/src/include/drill/drillClient.hpp
index 29ae6c284..00ff72344 100644
--- a/contrib/native/client/src/include/drill/drillClient.hpp
+++ b/contrib/native/client/src/include/drill/drillClient.hpp
@@ -91,6 +91,43 @@ class DECLSPEC_DRILL_CLIENT DrillClientConfig{
static int32_t getQueryTimeout();
static int32_t getHeartbeatFrequency();
static logLevel_t getLogLevel();
+
+ /**
+ * Return the client name sent to the server when connecting
+ *
+ * @return the current client name
+ */
+ static const std::string& getClientName();
+
+ /**
+ * Set the client name to be sent to the server when connecting.
+ *
+ * Only new connections will use the new value. Existing connections
+ * will be left unchanged.
+ *
+ * @param name the name to be send to the server
+ */
+ static void setClientName(const std::string& name);
+
+ /**
+ * Return the application name sent to the server when connecting
+ *
+ * @return the current application name
+ */
+ static const std::string& getApplicationName();
+
+ /**
+ * Set the application name to be sent to the server when connecting.
+ *
+ * Only new connections will use the new value. Existing connections
+ * will be left unchanged.
+ *
+ * @param name the name to be send to the server
+ */
+ static void setApplicationName(const std::string& name);
+
+
+
private:
// The logging level
static logLevel_t s_logLevel;
@@ -122,6 +159,11 @@ class DECLSPEC_DRILL_CLIENT DrillClientConfig{
static int32_t s_queryTimeout;
static int32_t s_heartbeatFrequency;
static boost::mutex s_mutex;
+
+ // The client name (default to DRILL_CONNECTOR_NAME)
+ static std::string s_clientName;
+ // The application name (default to <empty>)
+ static std::string s_applicationName;
};