TrackingProcessor Class Reference

#include <DBHandler.h>

Inheritance diagram for TrackingProcessor:

Collaboration diagram for TrackingProcessor:

Public Member Functions
	TrackingProcessor (mapd::shared_ptr< OmniSciIf > handler, const bool check_origin)
bool	process (mapd::shared_ptr<::apache::thrift::protocol::TProtocol > in, mapd::shared_ptr<::apache::thrift::protocol::TProtocol > out, void *connectionContext)

Static Public Attributes
static thread_local std::string	client_address
static thread_local ClientProtocol	client_protocol

Private Attributes
const bool	check_origin_

Detailed Description

Definition at line 108 of file DBHandler.h.

Constructor & Destructor Documentation

TrackingProcessor::TrackingProcessor ( mapd::shared_ptr< OmniSciIf >  handler, const bool  check_origin  )

inline

Definition at line 110 of file DBHandler.h.

      : OmniSciProcessor(handler), check_origin_(check_origin) {}

Member Function Documentation

bool TrackingProcessor::process ( mapd::shared_ptr<::apache::thrift::protocol::TProtocol >  in, mapd::shared_ptr<::apache::thrift::protocol::TProtocol >  out, void *  connectionContext  )

inline

Definition at line 113 of file DBHandler.h.

References client_address, client_protocol, HTTP, Other, split(), and TCP.

                                        {
    using namespace ::apache::thrift;

    auto transport = in->getTransport();
    if (transport && check_origin_) {
      static std::mutex processor_mutex;
      std::lock_guard lock(processor_mutex);
      const auto origin_str = transport->getOrigin();
      std::vector<std::string> origins;
      boost::split(origins, origin_str, boost::is_any_of(","));
      if (origins.empty()) {
        TrackingProcessor::client_address = origin_str;
      } else {
        // Take the first origin, which should be the client IP before any intermediate
        // servers (e.g. the web server)
        auto trimmed_origin = origins.front();
        boost::algorithm::trim(trimmed_origin);
        TrackingProcessor::client_address = trimmed_origin;
      }
      if (dynamic_cast<transport::THttpTransport*>(transport.get())) {
        TrackingProcessor::client_protocol = ClientProtocol::HTTP;
      } else if (dynamic_cast<transport::TBufferedTransport*>(transport.get())) {
        TrackingProcessor::client_protocol = ClientProtocol::TCP;
      } else {
        TrackingProcessor::client_protocol = ClientProtocol::Other;
      }
    } else {
      TrackingProcessor::client_address = "";
    }

    return OmniSciProcessor::process(in, out, connectionContext);
  }

Here is the call graph for this function:

Member Data Documentation

const bool TrackingProcessor::check_origin_

private

Definition at line 152 of file DBHandler.h.

thread_local std::string TrackingProcessor::client_address

static

Definition at line 148 of file DBHandler.h.

Referenced by DBHandler::getConnectionInfo(), and process().

thread_local ClientProtocol TrackingProcessor::client_protocol

static

Definition at line 149 of file DBHandler.h.

Referenced by DBHandler::getConnectionInfo(), and process().

---

The documentation for this class was generated from the following files:

• /home/jenkins-slave/workspace/core-os-doxygen/ThriftHandler/DBHandler.h
• /home/jenkins-slave/workspace/core-os-doxygen/ThriftHandler/DBHandler.cpp