ThriftBroker.cc File Reference

ThriftBroker server. More...

#include <Common/Compat.h>
#include <ThriftBroker/Config.h>
#include <ThriftBroker/MetricsHandler.h>
#include <ThriftBroker/SerializedCellsReader.h>
#include <ThriftBroker/SerializedCellsWriter.h>
#include <ThriftBroker/ThriftHelper.h>
#include <HyperAppHelper/Unique.h>
#include <HyperAppHelper/Error.h>
#include <Hypertable/Lib/Client.h>
#include <Hypertable/Lib/Future.h>
#include <Hypertable/Lib/HqlInterpreter.h>
#include <Hypertable/Lib/Key.h>
#include <Hypertable/Lib/NamespaceListing.h>
#include <Hypertable/Lib/ProfileDataScanner.h>
#include <Common/Cronolog.h>
#include <Common/fast_clock.h>
#include <Common/Init.h>
#include <Common/Logger.h>
#include <Common/Random.h>
#include <Common/System.h>
#include <Common/Time.h>
#include <concurrency/ThreadManager.h>
#include <protocol/TBinaryProtocol.h>
#include <server/TThreadedServer.h>
#include <transport/TBufferTransports.h>
#include <transport/TServerSocket.h>
#include <transport/TSocket.h>
#include <transport/TTransportUtils.h>
#include <boost/shared_ptr.hpp>
#include <iostream>
#include <iomanip>
#include <map>
#include <memory>
#include <mutex>
#include <sstream>
#include <unordered_map>
#include <signal.h>
#include <sys/types.h>
#include <unistd.h>

Include dependency graph for ThriftBroker.cc:

Go to the source code of this file.

Classes
class	Hypertable::ThriftBroker::SharedMutatorMapKey
class	Hypertable::ThriftBroker::Context
class	Hypertable::ThriftBroker::ScannerInfo
struct	Hypertable::ThriftBroker::HqlCallback< ResultT, CellT >
class	Hypertable::ThriftBroker::ServerHandler
struct	Hypertable::ThriftBroker::ServerHandler::Statistics
class	Hypertable::ThriftBroker::ServerHandlerFactory
class	Hypertable::ThriftBroker::ThriftBrokerIfFactory

Namespaces
	Hypertable
	Hypertable definitions
	Hypertable::ThriftBroker

Macros
#define	THROW_TE(_code_, _str_)
#define	RETHROW(_expr_)
#define	LOG_API_START(_expr_)
#define	LOG_API_FINISH
#define	LOG_API_FINISH_E(_expr_)
#define	LOG_API(_expr_)
#define	LOG_HQL_RESULT(_res_)
#define	LOG_SLOW_QUERY(_pd_, _ns_, _hql_)
#define	LOG_SLOW_QUERY_SCANNER(_scanner_, _ns_, _table_, _ss_)

Typedefs
typedef Meta::list < ThriftBrokerPolicy, DefaultCommPolicy >	Hypertable::ThriftBroker::Policies
typedef std::map < SharedMutatorMapKey, TableMutator * >	Hypertable::ThriftBroker::SharedMutatorMap
typedef std::unordered_map < ::int64_t, ClientObjectPtr >	Hypertable::ThriftBroker::ObjectMap
typedef std::vector < ThriftGen::Cell >	Hypertable::ThriftBroker::ThriftCells
typedef std::vector< CellAsArray >	Hypertable::ThriftBroker::ThriftCellsAsArrays
typedef std::shared_ptr < ScannerInfo >	Hypertable::ThriftBroker::ScannerInfoPtr

Functions
bool	Hypertable::ThriftBroker::operator< (const SharedMutatorMapKey &skey1, const SharedMutatorMapKey &skey2)
int64_t	Hypertable::ThriftBroker::cell_str_to_num (const std::string &from, const char *label, int64_t min_num=INT64_MIN, int64_t max_num=INT64_MAX)
void	Hypertable::ThriftBroker::convert_scan_spec (const ThriftGen::ScanSpec &tss, Hypertable::ScanSpec &hss)
void	Hypertable::ThriftBroker::convert_scan_spec (const ThriftGen::ScanSpec &tss, Hypertable::ScanSpecBuilder &ssb)
void	Hypertable::ThriftBroker::convert_cell (const ThriftGen::Cell &tcell, Hypertable::Cell &hcell)
void	Hypertable::ThriftBroker::convert_key (const ThriftGen::Key &tkey, Hypertable::KeySpec &hkey)
int32_t	Hypertable::ThriftBroker::convert_cell (const Hypertable::Cell &hcell, ThriftGen::Cell &tcell)
void	Hypertable::ThriftBroker::convert_cell (const CellAsArray &tcell, Hypertable::Cell &hcell)
int32_t	Hypertable::ThriftBroker::convert_cell (const Hypertable::Cell &hcell, CellAsArray &tcell)
int32_t	Hypertable::ThriftBroker::convert_cells (const Hypertable::Cells &hcells, ThriftCells &tcells)
void	Hypertable::ThriftBroker::convert_cells (const ThriftCells &tcells, Hypertable::Cells &hcells)
int32_t	Hypertable::ThriftBroker::convert_cells (const Hypertable::Cells &hcells, ThriftCellsAsArrays &tcells)
int32_t	Hypertable::ThriftBroker::convert_cells (Hypertable::Cells &hcells, CellsSerialized &tcells)
void	Hypertable::ThriftBroker::convert_cells (const ThriftCellsAsArrays &tcells, Hypertable::Cells &hcells)
void	Hypertable::ThriftBroker::convert_table_split (const Hypertable::TableSplit &hsplit, ThriftGen::TableSplit &tsplit)
bool	Hypertable::ThriftBroker::convert_column_family_options (const Hypertable::ColumnFamilyOptions &hoptions, ThriftGen::ColumnFamilyOptions &toptions)
void	Hypertable::ThriftBroker::convert_column_family_options (const ThriftGen::ColumnFamilyOptions &toptions, Hypertable::ColumnFamilyOptions &hoptions)
bool	Hypertable::ThriftBroker::convert_access_group_options (const Hypertable::AccessGroupOptions &hoptions, ThriftGen::AccessGroupOptions &toptions)
void	Hypertable::ThriftBroker::convert_access_group_options (const ThriftGen::AccessGroupOptions &toptions, Hypertable::AccessGroupOptions &hoptions)
void	Hypertable::ThriftBroker::convert_schema (const Hypertable::SchemaPtr &hschema, ThriftGen::Schema &tschema)
void	Hypertable::ThriftBroker::convert_schema (const ThriftGen::Schema &tschema, Hypertable::SchemaPtr &hschema)
int	main (int argc, char **argv)

Detailed Description

ThriftBroker server.

This file contains the main function and server definition for the ThriftBroker, a server that provides client language independent access to Hypertable.

Definition in file ThriftBroker.cc.