#include <DBHandler.h>

Inheritance diagram for TrackingProcessor:

Collaboration diagram for TrackingProcessor:

Public Member Functions
	TrackingProcessor (std::shared_ptr< HeavyIf > handler, const bool check_origin)

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

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 114 of file DBHandler.h.

Constructor & Destructor Documentation

TrackingProcessor::TrackingProcessor	(	std::shared_ptr< HeavyIf >	handler,
		const bool	check_origin
	)

inline

Definition at line 116 of file DBHandler.h.

117 : HeavyProcessor(handler), check_origin_(check_origin) {}

TrackingProcessor::check_origin_

const bool check_origin_

Definition: DBHandler.h:158

Member Function Documentation

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

inlineoverride

Definition at line 119 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 HeavyProcessor::process(in, out, connectionContext);
   }

Here is the call graph for this function:

Member Data Documentation

const bool TrackingProcessor::check_origin_

private

Definition at line 158 of file DBHandler.h.

thread_local std::string TrackingProcessor::client_address

static

Definition at line 154 of file DBHandler.h.

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

thread_local ClientProtocol TrackingProcessor::client_protocol

static

Definition at line 155 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

Public Member Functions

Static Public Attributes

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation