Global struct & enum types, global function declarations, global symbols in general. More...

#include "infinisql.h"

Include dependency graph for defs.h:

This graph shows which files directly or indirectly include this file:

Classes
struct	cfg_s
	global config parameters More...

struct	serventIdentity_s
	orphan More...

struct	procedures_s
	stored procedure creator and destructor function pointers More...

struct	newDeadLockLists_s
	items to add to wait-for graph More...

struct	rowOrField_s
	data items describing manipulation request More...

struct	searchParams_s
	describes how to perform an SQL search expression predicate More...

struct	nonLockingIndexEntry_s
	index map value for non-unique indices More...

struct	subtransactionCmd_s
	command contents between Transaction and Subtransaction More...

struct	listenerStruct_s
	used by Listner to know what to listen to More...

struct	locked_s
	orphan? More...

struct	lockFieldValue_s
	for tracking lock types for transactions with unique index entries More...

struct	stagedRow_s
	rows and unique index entries worked on by Transaction More...

Macros
#define	BUILTIN_STATUS_OK 0

#define	BUILTIN_STATUS_NOTOK 1

#define	PAYLOADSIZE 128

#define	NUMSOCKETS 1048576

#define	RTPRIO 30

#define	MSGRECEIVEBATCHSIZE 500

#define	OBGWMSGBATCHSIZE 5000

#define	OPERAND_STRING 'a'

#define	OPERAND_IDENTIFIER 'b'

#define	OPERAND_PARAMETER 'c'

#define	OPERAND_SUBQUERY 'd'

#define	OPERAND_INTEGER 'e'

#define	OPERAND_FLOAT 'f'

#define	OPERAND_AGGREGATE 'g'

#define	OPERAND_FIELDID 'h'

#define	OPERAND_NULL 'i'

#define	OPERAND_PREDICATERESULTS 'j'

#define	OPERAND_SUBQUERYRESULTS 'k'

#define	OPERAND_BOOLEAN 'l'

#define	AGGREGATE_AVG 'a'

#define	AGGREGATE_COUNT 'b'

#define	AGGREGATE_MAX 'c'

#define	AGGREGATE_MIN 'd'

#define	AGGREGATE_SUM 'e'

#define	BUILTINCREATESCHEMA 3

#define	BUILTINCREATETABLE 4

#define	BUILTINADDCOLUMN 5

#define	BUILTINDELETEINDEX 6

#define	BUILTINDELETETABLE 7

#define	BUILTINDELETESCHEMA 8

#define	BUILTINDUMPCONFIG 9

#define	ST_USM 1

#define	ST_TASENGINES 2

#define	OP_AUTH 1

#define	OP_SCHEMA 2

#define	OP_PGLOGIN 3

#define	SERIALIZEDMAXSIZE 1048576

#define	DELETEFLAG 0

#define	INSERTFLAG 1

#define	LOCKEDFLAG 2

#define	LOCKTYPEFLAG 3

#define	REPLACEDELETEFLAG 4

Typedefs
typedef nonLockingIndexEntry_s	indexEntry_s

typedef boost::unordered_map < int64_t, class Schema * >	domainidToSchemaMap

Enumerations
enum	listenertype_e { LISTENER_NONE = 0, LISTENER_RAW, LISTENER_PG }
	type of network listener More...

enum	builtincmds_e { NOCMD = 0, STARTCMD, OKCMD, NOTOKCMD, USMRESPONSECMD, TASENGINESRESPONSECMD, ABORTCMD }
	state of DDL operation on raw interface for create table, index, etc. More...

enum	indextype_e { NONE = 0, UNIQUE = 1, NONUNIQUE = 2, UNORDERED = 3, UNIQUENOTNULL = 4, NONUNIQUENOTNULL = 5, UNORDEREDNOTNULL = 6 }
	index types with or without NULL constraint More...

enum	indexmaptype_e { noindexmaptype = -1, uniqueint = 0, nonuniqueint = 1, unorderedint = 2, uniqueuint = 3, nonuniqueuint = 4, unordereduint = 5, uniquebool = 6, nonuniquebool = 7, unorderedbool = 8, uniquefloat = 9, nonuniquefloat = 10, unorderedfloat = 11, uniquechar = 12, nonuniquechar = 13, unorderedchar = 14, uniquecharx = 15, nonuniquecharx = 16, unorderedcharx = 17, uniquevarchar = 18, nonuniquevarchar = 19, unorderedvarchar = 20 }
	types of maps for various indices More...

enum	maptype_e { Nomaptype = -1, Unique = 0, Nonunique = 1, Unordered = 2 }
	map types More...

enum	topic_e { TOPIC_NONE = 0, TOPIC_MBOXES = 1, TOPIC_SOCKET = 2, TOPIC_LOGIN = 3, TOPIC_LOGINOK = 4, TOPIC_LOGINFAIL = 5, TOPIC_CHANGEPASSWORD = 6, TOPIC_CHANGEPASSWORDOK = 7, TOPIC_CHANGEPASSWORDFAIL = 8, TOPIC_CREATEDOMAIN = 9, TOPIC_CREATEDOMAINOK = 10, TOPIC_CREATEDOMAINFAIL = 11, TOPIC_CREATEUSER = 12, TOPIC_CREATEUSEROK = 13, TOPIC_CREATEUSERFAIL = 14, TOPIC_DELETEUSER = 15, TOPIC_DELETEUSEROK = 16, TOPIC_DELETEUSERFAIL = 17, TOPIC_DELETEDOMAIN = 18, TOPIC_DELETEDOMAINOK = 19, TOPIC_DELETEDOMAINFAIL = 20, TOPIC_SCHEMAREQUEST = 21, TOPIC_SCHEMAREPLY = 22, TOPIC_DEADLOCKNEW = 23, TOPIC_DEADLOCKCHANGE = 24, TOPIC_DEADLOCKREMOVE = 25, TOPIC_LOADPROCEDURE = 26, TOPIC_TRANSACTION = 27, TOPIC_DISPATCH = 28, TOPIC_ACKDISPATCH = 29, TOPIC_DEADLOCKABORT = 30, TOPIC_ENDSUBTRANSACTION = 31, TOPIC_TOPOLOGY = 33, TOPIC_NEWPROCEDURE = 34, TOPIC_PROCEDURE1 = 35, TOPIC_PROCEDURE2 = 36, TOPIC_APPLY = 37, TOPIC_ACKAPPLY = 38, TOPIC_OPERATION = 41, TOPIC_COMPILE = 42, TOPIC_TABLENAME = 43, TOPIC_FIELDNAME = 44, TOPIC_SERIALIZED = 45, TOPIC_BATCHSERIALIZED = 46, TOPIC_SOCKETCONNECTED = 47 }
	Message variant topics. More...

enum	payloadtype_e { PAYLOADNONE = 0, PAYLOADMESSAGE, PAYLOADSOCKET, PAYLOADUSERSCHEMA, PAYLOADDEADLOCK, PAYLOADSUBTRANSACTION, PAYLOADCOMMITROLLBACK, PAYLOADDISPATCH, PAYLOADACKDISPATCH, PAYLOADAPPLY, PAYLOADACKAPPLY, PAYLOADSERIALIZED, PAYLOADBATCHSERIALIZED }
	Message variant payloads. More...

enum	operationtype_e { OPERATION_NONE = 0, OPERATION_LOGIN }
	type of Operation (only currently used for SQL login) More...

enum	enginecmds_e { enginecmdnewrow }

enum	pendingprimitive_e { NOCOMMAND = 0, INSERT, UPDATE, DELETE, REPLACE, SELECT, FETCH, UNLOCK, COMMIT, ROLLBACK, PRIMITIVE_SQLPREDICATE, PRIMITIVE_SQLSELECTALL, PRIMITIVE_SQLSELECTALLFORDELETE, PRIMITIVE_SQLSELECTALLFORUPDATE, PRIMITIVE_SQLDELETE, PRIMITIVE_SQLINSERT, PRIMITIVE_SQLUPDATE, PRIMITIVE_SQLREPLACE }
	pending transactional activity More...

enum	enginecmd_e { NOENGINECMD = 0, NEWROW, UNIQUEINDEX, UPDATEROW, DELETEROW, REPLACEDELETEROW, INDEXSEARCH, SELECTROWS, COMMITCMD, ROLLBACKCMD, REVERTCMD, UNLOCKCMD, SEARCHRETURN1 }
	command for Engine / Subtransaction to perform More...

enum	deadlockchange_e { ADDLOCKEDENTRY = 1, ADDLOCKPENDINGENTRY, REMOVELOCKEDENTRY, REMOVELOCKPENDINGENTRY, TRANSITIONPENDINGTOLOCKEDENTRY }
	type of change for DeadlockMgr wait-for graph More...

Functions
void	debug (char , int, char )

void	trimspace (string &)

void	msgpack2Vector (vector< string > resultvector, char payload, int64_t length)
	convert msgpack to a vector of strings More...

char	setdeleteflag (char *c)
	for delete operations on row More...

bool	getdeleteflag (char c)
	check if row operation is delete More...

char	cleardeleteflag (char *c)
	clear delete operation on row More...

char	setinsertflag (char *c)
	for insert operations on row More...

bool	getinsertflag (char c)
	check if row operation is insert More...

char	clearinsertflag (char *c)
	clear insert operation on row More...

char	clearlockedflag (char *c)
	clear locked flag on row More...

locktype_e	getlocktype (char c)
	check if row is locked and type More...

bool	setwritelock (char *c)
	set write lock on row More...

bool	setreadlock (char *c)
	set read lock on row More...

char	setreplacedeleteflag (char *c)
	set delete as part of replace row flag More...

bool	getreplacedeleteflag (char c)
	get whether or not row is deleted as part of row replacement More...

char	clearreplacedeleteflag (char *c)
	clear row as deleted as part of row replacement More...

int16_t	getPartitionid (fieldValue_s &fieldVal, fieldtype_e type, int16_t numpartitions)
	hash of field value for partition id More...

void	like2Regex (string &likeStr)
	might be orpha, but convert LIKE operand to regex More...

bool	compareFields (fieldtype_e type, const fieldValue_s &val1, const fieldValue_s &val2)
	compare field values for equality More...

void	stagedRow2ReturnRow (const stagedRow_s &stagedRow, returnRow_s &returnRow)
	convert stagedRow_s to returnRow_s More...

void	setprio ()
	set real-time priority More...

Variables
cfg_s	cfgs

FILE *	logfile

std::string	zmqsocket

void *	zmqcontext

std::string	storedprocprefix

class Topology	nodeTopology

pthread_mutex_t	nodeTopologyMutex

pthread_mutex_t	connectionsMutex

std::vector< class MboxProducer * >	socketAffinity

std::vector< listenertype_e >	listenerTypes

Detailed Description

Global struct & enum types, global function declarations, global symbols in general.

Author: Mark Travis mtrav.nosp@m.is15.nosp@m.432+s.nosp@m.rc@g.nosp@m.mail..nosp@m.com

Date: Tue Dec 17 12:47:30 2013

Definition in file defs.h.

Macro Definition Documentation

#define AGGREGATE_AVG 'a'

Definition at line 232 of file defs.h.

#define AGGREGATE_COUNT 'b'

Definition at line 233 of file defs.h.

#define AGGREGATE_MAX 'c'

Definition at line 234 of file defs.h.

#define AGGREGATE_MIN 'd'

Definition at line 235 of file defs.h.

#define AGGREGATE_SUM 'e'

Definition at line 236 of file defs.h.

#define BUILTIN_STATUS_NOTOK 1

Definition at line 34 of file defs.h.

Referenced by UserSchemaMgr::addcolumn(), createSchema(), Schema::createTable(), and UserSchemaMgr::createtable().

#define BUILTIN_STATUS_OK 0

Definition at line 33 of file defs.h.

Referenced by Engine::addcolumn(), UserSchemaMgr::addcolumn(), createSchema(), Schema::createTable(), UserSchemaMgr::createtable(), Engine::deleteindex(), UserSchemaMgr::deleteindex(), Engine::deleteschema(), UserSchemaMgr::deleteschema(), Engine::deletetable(), UserSchemaMgr::deletetable(), TransactionAgent::schemaBoilerplate(), TransactionAgent::TAaddcolumn(), TransactionAgent::TAdeleteindex(), TransactionAgent::TAdeleteschema(), and TransactionAgent::TAdeletetable().

#define BUILTINADDCOLUMN 5

Definition at line 241 of file defs.h.

Referenced by TransactionAgent::addcolumn(), Engine::Engine(), TransactionAgent::TransactionAgent(), and UserSchemaMgr::UserSchemaMgr().

#define BUILTINCREATESCHEMA 3

Definition at line 239 of file defs.h.

Referenced by TransactionAgent::createschema(), Engine::Engine(), TransactionAgent::TransactionAgent(), and UserSchemaMgr::UserSchemaMgr().

#define BUILTINCREATETABLE 4

Definition at line 240 of file defs.h.

Referenced by TransactionAgent::createtable(), Engine::Engine(), TransactionAgent::TransactionAgent(), and UserSchemaMgr::UserSchemaMgr().

#define BUILTINDELETEINDEX 6

Definition at line 242 of file defs.h.

Referenced by TransactionAgent::deleteindex(), Engine::Engine(), TransactionAgent::TransactionAgent(), and UserSchemaMgr::UserSchemaMgr().

#define BUILTINDELETESCHEMA 8

Definition at line 244 of file defs.h.

Referenced by TransactionAgent::deleteschema(), Engine::Engine(), TransactionAgent::TransactionAgent(), and UserSchemaMgr::UserSchemaMgr().

#define BUILTINDELETETABLE 7

Definition at line 243 of file defs.h.

Referenced by TransactionAgent::deletetable(), Engine::Engine(), TransactionAgent::TransactionAgent(), and UserSchemaMgr::UserSchemaMgr().

#define BUILTINDUMPCONFIG 9

Definition at line 245 of file defs.h.

#define DELETEFLAG 0

Definition at line 507 of file defs.h.

Referenced by cleardeleteflag(), getdeleteflag(), and setdeleteflag().

#define INSERTFLAG 1

Definition at line 508 of file defs.h.

Referenced by clearinsertflag(), getinsertflag(), and setinsertflag().

#define LOCKEDFLAG 2

Definition at line 509 of file defs.h.

Referenced by clearlockedflag(), getlocktype(), setreadlock(), and setwritelock().

#define LOCKTYPEFLAG 3

Definition at line 510 of file defs.h.

Referenced by getlocktype(), setreadlock(), and setwritelock().

#define MSGRECEIVEBATCHSIZE 500

Definition at line 43 of file defs.h.

Referenced by DeadlockMgr::DeadlockMgr(), Engine::Engine(), and TransactionAgent::TransactionAgent().

#define NUMSOCKETS 1048576

Definition at line 37 of file defs.h.

Referenced by Listener::Listener(), and Pg::pgclosesocket().

#define OBGWMSGBATCHSIZE 5000

Definition at line 44 of file defs.h.

Referenced by MboxProducer::sendMsg().

#define OP_AUTH 1

Definition at line 252 of file defs.h.

#define OP_PGLOGIN 3

Definition at line 254 of file defs.h.

#define OP_SCHEMA 2

Definition at line 253 of file defs.h.

Referenced by Operation::Operation().

#define OPERAND_AGGREGATE 'g'

Definition at line 225 of file defs.h.

Referenced by Larxer::pushaggregate(), and Statement::resolveTableFields2().

#define OPERAND_BOOLEAN 'l'

Definition at line 230 of file defs.h.

Referenced by Larxer::printstack(), Transaction::sqlPredicate(), Statement::subqueryExists(), Statement::subqueryScalar(), and Statement::subqueryUnique().

#define OPERAND_FIELDID 'h'

Definition at line 226 of file defs.h.

Referenced by Statement::andPredicate(), Ast::normalizeSetAssignmentOperand(), Statement::resolveFieldNames(), Statement::resolveTableFields2(), Transaction::sqlPredicate(), and Statement::stagedPredicate().

#define OPERAND_FLOAT 'f'

Definition at line 224 of file defs.h.

Referenced by Ast::evaluate(), Ast::evaluateAssignment(), Ast::normalizeSetAssignmentOperand(), Larxer::printstack(), Transaction::sqlPredicate(), Statement::subqueryScalar(), and Ast::toFloat().

#define OPERAND_IDENTIFIER 'b'

Definition at line 220 of file defs.h.

Referenced by Larxer::consumeGroupby(), Larxer::printstack(), Statement::resolveFieldNames(), Statement::resolveTableFields2(), and Transaction::sqlPredicate().

#define OPERAND_INTEGER 'e'

Definition at line 223 of file defs.h.

Referenced by Ast::evaluate(), Ast::evaluateAssignment(), Ast::normalizeSetAssignmentOperand(), Larxer::printstack(), Transaction::sqlPredicate(), Statement::subqueryScalar(), and Ast::toFloat().

#define OPERAND_NULL 'i'

Definition at line 227 of file defs.h.

Referenced by Statement::branchtotype(), Statement::continueUpdate(), Ast::evaluate(), and Statement::subqueryScalar().

#define OPERAND_PARAMETER 'c'

Definition at line 221 of file defs.h.

Referenced by Ast::evaluate(), Ast::normalizeSetAssignmentOperand(), and Larxer::printstack().

#define OPERAND_PREDICATERESULTS 'j'

Definition at line 228 of file defs.h.

#define OPERAND_STRING 'a'

Definition at line 219 of file defs.h.

Referenced by Ast::evaluate(), Ast::evaluateAssignment(), Ast::normalizeSetAssignmentOperand(), Larxer::printstack(), Transaction::sqlPredicate(), and Statement::subqueryScalar().

#define OPERAND_SUBQUERY 'd'

Definition at line 222 of file defs.h.

Referenced by Larxer::consumeExpression(), Ast::evaluate(), Ast::normalizeSetAssignmentOperand(), Larxer::printstack(), and Statement::subqueryScalar().

#define OPERAND_SUBQUERYRESULTS 'k'

Definition at line 229 of file defs.h.

#define PAYLOADSIZE 128

Definition at line 36 of file defs.h.

Referenced by TransactionAgent::readSocket(), and TransactionAgent::sendResponse().

#define REPLACEDELETEFLAG 4

Definition at line 511 of file defs.h.

Referenced by clearreplacedeleteflag(), getreplacedeleteflag(), and setreplacedeleteflag().

#define RTPRIO 30

Definition at line 42 of file defs.h.

Referenced by setprio().

#define SERIALIZEDMAXSIZE 1048576

Global configs

Definition at line 321 of file defs.h.

Referenced by IbGateway::IbGateway(), IbGateway::inbufhandler(), and ObGateway::ObGateway().

#define ST_TASENGINES 2

Definition at line 249 of file defs.h.

#define ST_USM 1

Definition at line 248 of file defs.h.

Typedef Documentation

typedef boost::unordered_map<int64_t, class Schema *> domainidToSchemaMap

Definition at line 500 of file defs.h.

typedef nonLockingIndexEntry_s indexEntry_s

Definition at line 412 of file defs.h.

Enumeration Type Documentation

enum builtincmds_e

state of DDL operation on raw interface for create table, index, etc.

Enumerator
NOCMD
STARTCMD
OKCMD
NOTOKCMD
USMRESPONSECMD
TASENGINESRESPONSECMD
ABORTCMD

Definition at line 64 of file defs.h.

 {
     NOCMD = 0,
     STARTCMD,
     OKCMD,
     NOTOKCMD,
     USMRESPONSECMD,
     TASENGINESRESPONSECMD,
     ABORTCMD
 };

enum deadlockchange_e

type of change for DeadlockMgr wait-for graph

Enumerator
ADDLOCKEDENTRY
ADDLOCKPENDINGENTRY
REMOVELOCKEDENTRY
REMOVELOCKPENDINGENTRY
TRANSITIONPENDINGTOLOCKEDENTRY

Definition at line 517 of file defs.h.

 {
     ADDLOCKEDENTRY = 1,
     ADDLOCKPENDINGENTRY,
     REMOVELOCKEDENTRY,
     REMOVELOCKPENDINGENTRY,
     TRANSITIONPENDINGTOLOCKEDENTRY
 };

enum enginecmd_e

command for Engine / Subtransaction to perform

Enumerator
NOENGINECMD
NEWROW
UNIQUEINDEX
UPDATEROW
DELETEROW
REPLACEDELETEROW
INDEXSEARCH
SELECTROWS
COMMITCMD
ROLLBACKCMD
REVERTCMD
UNLOCKCMD
SEARCHRETURN1

Definition at line 303 of file defs.h.

 {
     NOENGINECMD = 0,
     NEWROW,
     UNIQUEINDEX,
     UPDATEROW,
     DELETEROW,
     REPLACEDELETEROW,
     INDEXSEARCH,
     SELECTROWS,
     COMMITCMD,
     ROLLBACKCMD,
     REVERTCMD,
     UNLOCKCMD,
     SEARCHRETURN1
 };

enum enginecmds_e

Enumerator
enginecmdnewrow

Definition at line 268 of file defs.h.

 {
     enginecmdnewrow
 };

enum indexmaptype_e

types of maps for various indices

Enumerator
noindexmaptype
uniqueint
nonuniqueint
unorderedint
uniqueuint
nonuniqueuint
unordereduint
uniquebool
nonuniquebool
unorderedbool
uniquefloat
nonuniquefloat
unorderedfloat
uniquechar
nonuniquechar
unorderedchar
uniquecharx
nonuniquecharx
unorderedcharx
uniquevarchar
nonuniquevarchar
unorderedvarchar

Definition at line 94 of file defs.h.

 {
     noindexmaptype = -1,
     uniqueint = 0,
     nonuniqueint = 1,
     unorderedint = 2,
     uniqueuint = 3,
     nonuniqueuint = 4,
     unordereduint = 5,
     uniquebool = 6,
     nonuniquebool = 7,
     unorderedbool = 8,
     uniquefloat = 9,
     nonuniquefloat = 10,
     unorderedfloat = 11,
     uniquechar = 12,
     nonuniquechar = 13,
     unorderedchar = 14,
     uniquecharx = 15,
     nonuniquecharx = 16,
     unorderedcharx = 17,
     uniquevarchar = 18,
     nonuniquevarchar = 19,
     unorderedvarchar = 20
 };

enum indextype_e

index types with or without NULL constraint

Enumerator
NONE
UNIQUE
NONUNIQUE
UNORDERED
UNIQUENOTNULL
NONUNIQUENOTNULL
UNORDEREDNOTNULL

Definition at line 79 of file defs.h.

 {
     NONE = 0,
         UNIQUE = 1,
         NONUNIQUE = 2,
         UNORDERED = 3,
         UNIQUENOTNULL = 4,
         NONUNIQUENOTNULL = 5,
         UNORDEREDNOTNULL = 6
         };

enum listenertype_e

type of network listener

Enumerator
LISTENER_NONE
LISTENER_RAW	for create table, etc.
LISTENER_PG	for SQL

Definition at line 52 of file defs.h.

 {
     LISTENER_NONE = 0,
         LISTENER_RAW,           
         LISTENER_PG             
         };

enum maptype_e

map types

Enumerator
Nomaptype
Unique
Nonunique
Unordered

Definition at line 124 of file defs.h.

 {
     Nomaptype = -1,
     Unique = 0,
     Nonunique = 1,
     Unordered = 2
 };

enum operationtype_e

type of Operation (only currently used for SQL login)

Enumerator
OPERATION_NONE
OPERATION_LOGIN

Definition at line 212 of file defs.h.

 {
     OPERATION_NONE = 0,
         OPERATION_LOGIN
         };

enum payloadtype_e

Message variant payloads.

tend to correspond with specific Message variant

Enumerator
PAYLOADNONE
PAYLOADMESSAGE
PAYLOADSOCKET
PAYLOADUSERSCHEMA
PAYLOADDEADLOCK
PAYLOADSUBTRANSACTION
PAYLOADCOMMITROLLBACK
PAYLOADDISPATCH
PAYLOADACKDISPATCH
PAYLOADAPPLY
PAYLOADACKAPPLY
PAYLOADSERIALIZED
PAYLOADBATCHSERIALIZED

Definition at line 191 of file defs.h.

 {
     PAYLOADNONE = 0,
         PAYLOADMESSAGE,
         PAYLOADSOCKET,
         PAYLOADUSERSCHEMA,
         PAYLOADDEADLOCK,
         PAYLOADSUBTRANSACTION,
         PAYLOADCOMMITROLLBACK,
         PAYLOADDISPATCH,
         PAYLOADACKDISPATCH,
         PAYLOADAPPLY,
         PAYLOADACKAPPLY,
         PAYLOADSERIALIZED,
         PAYLOADBATCHSERIALIZED
         };

enum pendingprimitive_e

pending transactional activity

Enumerator
NOCOMMAND
INSERT
UPDATE
DELETE
REPLACE
SELECT
FETCH
UNLOCK
COMMIT
ROLLBACK
PRIMITIVE_SQLPREDICATE
PRIMITIVE_SQLSELECTALL
PRIMITIVE_SQLSELECTALLFORDELETE
PRIMITIVE_SQLSELECTALLFORUPDATE
PRIMITIVE_SQLDELETE
PRIMITIVE_SQLINSERT
PRIMITIVE_SQLUPDATE
PRIMITIVE_SQLREPLACE

Definition at line 277 of file defs.h.

 {
     NOCOMMAND = 0,
         INSERT,
         UPDATE,
         DELETE,
         REPLACE,
         SELECT,
         FETCH,
         UNLOCK,
         COMMIT,
         ROLLBACK,
         PRIMITIVE_SQLPREDICATE,
         PRIMITIVE_SQLSELECTALL,
         PRIMITIVE_SQLSELECTALLFORDELETE,
         PRIMITIVE_SQLSELECTALLFORUPDATE,
         PRIMITIVE_SQLDELETE,
         PRIMITIVE_SQLINSERT,
         PRIMITIVE_SQLUPDATE,
         PRIMITIVE_SQLREPLACE
         };

enum topic_e

Message variant topics.

Enumerator
TOPIC_NONE
TOPIC_MBOXES
TOPIC_SOCKET
TOPIC_LOGIN
TOPIC_LOGINOK
TOPIC_LOGINFAIL
TOPIC_CHANGEPASSWORD
TOPIC_CHANGEPASSWORDOK
TOPIC_CHANGEPASSWORDFAIL
TOPIC_CREATEDOMAIN
TOPIC_CREATEDOMAINOK
TOPIC_CREATEDOMAINFAIL
TOPIC_CREATEUSER
TOPIC_CREATEUSEROK
TOPIC_CREATEUSERFAIL
TOPIC_DELETEUSER
TOPIC_DELETEUSEROK
TOPIC_DELETEUSERFAIL
TOPIC_DELETEDOMAIN
TOPIC_DELETEDOMAINOK
TOPIC_DELETEDOMAINFAIL
TOPIC_SCHEMAREQUEST
TOPIC_SCHEMAREPLY
TOPIC_DEADLOCKNEW
TOPIC_DEADLOCKCHANGE
TOPIC_DEADLOCKREMOVE
TOPIC_LOADPROCEDURE
TOPIC_TRANSACTION
TOPIC_DISPATCH
TOPIC_ACKDISPATCH
TOPIC_DEADLOCKABORT
TOPIC_ENDSUBTRANSACTION
TOPIC_TOPOLOGY
TOPIC_NEWPROCEDURE
TOPIC_PROCEDURE1
TOPIC_PROCEDURE2
TOPIC_APPLY
TOPIC_ACKAPPLY
TOPIC_OPERATION
TOPIC_COMPILE
TOPIC_TABLENAME
TOPIC_FIELDNAME
TOPIC_SERIALIZED
TOPIC_BATCHSERIALIZED
TOPIC_SOCKETCONNECTED

Definition at line 136 of file defs.h.

 {
     TOPIC_NONE = 0,
         TOPIC_MBOXES = 1,
         TOPIC_SOCKET = 2,
         TOPIC_LOGIN = 3,
         TOPIC_LOGINOK = 4,
         TOPIC_LOGINFAIL = 5,
         TOPIC_CHANGEPASSWORD = 6,
         TOPIC_CHANGEPASSWORDOK = 7,
         TOPIC_CHANGEPASSWORDFAIL = 8,
         TOPIC_CREATEDOMAIN = 9,
         TOPIC_CREATEDOMAINOK = 10,
         TOPIC_CREATEDOMAINFAIL = 11,
         TOPIC_CREATEUSER = 12,
         TOPIC_CREATEUSEROK = 13,
         TOPIC_CREATEUSERFAIL = 14,
         TOPIC_DELETEUSER = 15,
         TOPIC_DELETEUSEROK = 16,
         TOPIC_DELETEUSERFAIL = 17,
         TOPIC_DELETEDOMAIN = 18,
         TOPIC_DELETEDOMAINOK = 19,
         TOPIC_DELETEDOMAINFAIL = 20,
         TOPIC_SCHEMAREQUEST = 21,
         TOPIC_SCHEMAREPLY = 22,
         TOPIC_DEADLOCKNEW = 23,
         TOPIC_DEADLOCKCHANGE = 24,
         TOPIC_DEADLOCKREMOVE = 25,
         TOPIC_LOADPROCEDURE = 26,
         TOPIC_TRANSACTION = 27,
         TOPIC_DISPATCH = 28,
         TOPIC_ACKDISPATCH = 29,
         TOPIC_DEADLOCKABORT = 30,
         TOPIC_ENDSUBTRANSACTION = 31,
         TOPIC_TOPOLOGY = 33,
         TOPIC_NEWPROCEDURE = 34,
         TOPIC_PROCEDURE1 = 35,
         TOPIC_PROCEDURE2 = 36,
         TOPIC_APPLY = 37,
         TOPIC_ACKAPPLY = 38,
         TOPIC_OPERATION = 41,
         TOPIC_COMPILE = 42,
         TOPIC_TABLENAME = 43,
         TOPIC_FIELDNAME = 44,
         TOPIC_SERIALIZED = 45,
         TOPIC_BATCHSERIALIZED = 46,
         TOPIC_SOCKETCONNECTED = 47
         };

Function Documentation

char cleardeleteflag ( char * c)

clear delete operation on row

Parameters

c	rowdata_s flags

Returns: rowdata_s flags

Definition at line 156 of file main.cc.

References DELETEFLAG.

Referenced by Table::commitRollbackUnlock().

 {
     return *c &= ~(1 << DELETEFLAG);
 }

Here is the caller graph for this function:

char clearinsertflag ( char * c)

clear insert operation on row

Parameters

c	rowdata_s flags

Returns: rowdata_s flags

Definition at line 171 of file main.cc.

References INSERTFLAG.

 {
     return *c &= ~(1 << INSERTFLAG);
 }

char clearlockedflag ( char * c)

clear locked flag on row

Parameters

c	rowdata_s flags

Returns: rowdata_s flags

Definition at line 200 of file main.cc.

References LOCKEDFLAG.

Referenced by Table::commitRollbackUnlock().

 {
     return *c &= ~(1 << LOCKEDFLAG);
 }

Here is the caller graph for this function:

char clearreplacedeleteflag ( char * c)

clear row as deleted as part of row replacement

Parameters

c	rowdata_s flags

Returns: rowdata_s flags

Definition at line 222 of file main.cc.

References REPLACEDELETEFLAG.

Referenced by Table::commitRollbackUnlock().

 {
     return *c &= ~(1 << REPLACEDELETEFLAG);
 }

Here is the caller graph for this function:

bool compareFields	(	fieldtype_e	type,
		const fieldValue_s &	val1,
		const fieldValue_s &	val2
	)

compare field values for equality

Parameters

type	field type
val1	operand 1
val2	operand 2

Returns: true (equal), false (unequal)

Definition at line 305 of file main.cc.

References BOOL, fieldInput_u::boolean, CHAR, fieldInput_u::character, CHARX, FLOAT, fieldInput_u::floating, INT, fieldInput_u::integer, fieldValue_s::isnull, fieldValue_s::str, UINT, fieldInput_u::uinteger, fieldValue_s::value, and VARCHAR.

Referenced by Statement::andPredicate(), Statement::stagedPredicate(), and Statement::subqueryUnique().

 {
     if (val1.isnull==true && val2.isnull==true)
     {
         return true;
     }
     else if (val1.isnull==true || val2.isnull==true)
     {
         return false;
     }
 
     switch (type)
     {
     case INT:
         if (val1.value.integer==val2.value.integer)
         {
             return true;
         }
 
         break;
 
     case UINT:
         if (val1.value.uinteger==val2.value.uinteger)
         {
             return true;
         }
 
         break;
 
     case BOOL:
         if (val1.value.boolean==val2.value.boolean)
         {
             return true;
         }
 
         break;
 
     case FLOAT:
         if (val1.value.floating==val2.value.floating)
         {
             return true;
         }
 
         break;
 
     case CHAR:
         if (val1.value.character==val2.value.character)
         {
             return true;
         }
 
         break;
 
     case CHARX:
         if (val1.str.compare(val2.str)==0)
         {
             return true;
         }
 
         break;
 
     case VARCHAR:
         if (val1.str.compare(val2.str)==0)
         {
             return true;
         }
 
         break;
 
     default:
         printf("%s %i anomaly %i\n", __FILE__, __LINE__, type);
     }
 
     return false;
 }

Here is the caller graph for this function:

void debug	(	char *	,
		int	,
		char *
	)

Definition at line 141 of file main.cc.

References logfile.

 {
     fprintf(logfile, "DEBUG %i %s %s\n", line, file, description);
 }

bool getdeleteflag ( char c)

check if row operation is delete

Parameters

c	rowdata_s flags

Returns: is or is not set

Definition at line 151 of file main.cc.

References DELETEFLAG.

Referenced by Table::commitRollbackUnlock().

 {
     return c & 1 << DELETEFLAG;
 }

Here is the caller graph for this function:

bool getinsertflag ( char c)

check if row operation is insert

Parameters

c	rowdata_s flags

Returns: is or is not set

Definition at line 166 of file main.cc.

References INSERTFLAG.

Referenced by Table::assignToLockQueue(), Table::commitRollbackUnlock(), and Table::getrows().

 {
     return c & 1 << INSERTFLAG;
 }

Here is the caller graph for this function:

locktype_e getlocktype ( char c)

check if row is locked and type

Parameters

c	rowdata_s flags

Returns: NOLOCK|READLOCK|WRITELOCK

Definition at line 205 of file main.cc.

References LOCKEDFLAG, LOCKTYPEFLAG, NOLOCK, READLOCK, and WRITELOCK.

Referenced by Table::commitRollbackUnlock(), Table::deleterow(), Table::getrows(), Table::selectrows(), and Table::updaterow().

 {
     if (!(c & 1 << LOCKEDFLAG))
     {
         return NOLOCK;
     }
 
     if (c & 1 << LOCKTYPEFLAG)
     {
         return WRITELOCK;
     }
     else
     {
         return READLOCK;
     }
 }

Here is the caller graph for this function:

int16_t getPartitionid	(	fieldValue_s &	fieldVal,
		fieldtype_e	type,
		int16_t	numpartitions
	)

hash of field value for partition id

Parameters

fieldVal	field value
type	field type
numpartitions	number of partitions

Returns

Definition at line 237 of file main.cc.

References BOOL, fieldInput_u::boolean, CHAR, fieldInput_u::character, CHARX, FLOAT, fieldInput_u::floating, SpookyHash::Hash64(), INT, fieldInput_u::integer, fieldValue_s::str, UINT, fieldInput_u::uinteger, fieldValue_s::value, and VARCHAR.

Referenced by TransactionAgent::handledispatch().

 {
     switch (type)
     {
     case INT:
         return SpookyHash::Hash64((void *) &fieldVal.value.integer,
                                   sizeof(fieldVal.value.integer), 0) %
                                   numpartitions;
         break;
 
     case UINT:
         return SpookyHash::Hash64((void *) &fieldVal.value.uinteger,
                                   sizeof(fieldVal.value.uinteger), 0) %
             numpartitions;
         break;
 
     case BOOL:
         return SpookyHash::Hash64((void *) &fieldVal.value.boolean,
                                   sizeof(fieldVal.value.boolean), 0) %
             numpartitions;
         break;
 
     case FLOAT:
         return SpookyHash::Hash64((void *) &fieldVal.value.floating,
                                   sizeof(fieldVal.value.floating), 0) %
             numpartitions;
         break;
 
     case CHAR:
         return SpookyHash::Hash64((void *) &fieldVal.value.character,
                                   sizeof(fieldVal.value.character), 0) %
             numpartitions;
         break;
 
     case CHARX:
         return SpookyHash::Hash64((void *) fieldVal.str.c_str(),
                                   fieldVal.str.length(), 0) % numpartitions;
         break;
 
     case VARCHAR:
         return SpookyHash::Hash64((void *) fieldVal.str.c_str(),
                                   fieldVal.str.length(), 0) % numpartitions;
         break;
 
     default:
         printf("%s %i anomaly fieldtype %i\n", __FILE__, __LINE__, type);
         return -1;
     }
 }

Here is the call graph for this function:

Here is the caller graph for this function:

bool getreplacedeleteflag ( char c)

get whether or not row is deleted as part of row replacement

Parameters

c	rowdata_s flags

Returns: is or is not

Definition at line 227 of file main.cc.

References REPLACEDELETEFLAG.

Referenced by Table::commitRollbackUnlock().

 {
     return c & 1 << REPLACEDELETEFLAG;
 }

Here is the caller graph for this function:

void like2Regex ( string & likeStr)

might be orpha, but convert LIKE operand to regex

Parameters

likeStr LIKE operand

Definition at line 289 of file main.cc.

Referenced by Statement::andPredicate(), Index::like(), and Index::notlike().

 {
     size_t pos;
 
     while ((pos = likeStr.find('_', 0)) != string::npos)
     {
         likeStr[pos]='.';
     }
 
     while ((pos = likeStr.find('%', 0)) != string::npos)
     {
         likeStr[pos]='*';
         likeStr.insert(pos, 1, '.');
     }
 }

Here is the caller graph for this function:

void msgpack2Vector	(	vector< string > *	resultvector,
		char *	payload,
		int64_t	length
	)

convert msgpack to a vector of strings

Parameters

resultvector	output
payload	msgpack data
length	msgpack length

Definition at line 133 of file main.cc.

Referenced by TransactionAgent::compile(), TransactionAgent::login(), TransactionAgent::newprocedure(), and UserSchemaMgr::UserSchemaMgr().

 {
     msgpack::unpacked msg;
     msgpack::unpack(&msg, payload, length);
     msgpack::object obj = msg.get();
     obj.convert(resultvector);
 }

Here is the caller graph for this function:

char setdeleteflag ( char * c)

for delete operations on row

Parameters

c	rowdata_s flags

Returns: rowdata_s flags

Definition at line 146 of file main.cc.

References DELETEFLAG.

Referenced by Table::deleterow().

 {
     return *c |= 1 << DELETEFLAG;
 }

Here is the caller graph for this function:

char setinsertflag ( char * c)

for insert operations on row

Parameters

c	rowdata_s flags

Returns: rowdata_s flags

Definition at line 161 of file main.cc.

References INSERTFLAG.

Referenced by Table::newrow().

 {
     return *c |= 1 << INSERTFLAG;
 }

Here is the caller graph for this function:

void setprio ( )

set real-time priority

for IbGateway and ObGateway to maximize throughput. Needs to be configured at OS level

Definition at line 424 of file main.cc.

References logfile, and RTPRIO.

Referenced by IbGateway::IbGateway(), and ObGateway::updateRemoteGateways().

 {
     struct sched_param params;
     params.sched_priority=RTPRIO;
     int rv=pthread_setschedparam(pthread_self(), SCHED_FIFO, &params);
     if (rv != 0)
     {
         fprintf(logfile, "%s %i some problem setting priority %i for tid %li error %i\n", __FILE__, __LINE__, RTPRIO, pthread_self(), rv);
     }
 }

Here is the caller graph for this function:

bool setreadlock ( char * c)

set read lock on row

Parameters

c	rowdata_s flags

Returns: success or failure

Definition at line 188 of file main.cc.

References LOCKEDFLAG, and LOCKTYPEFLAG.

Referenced by Table::commitRollbackUnlock(), Table::getrows(), and Table::selectrows().

 {
     if (*c & 1 << LOCKEDFLAG)   // already locked
     {
         return false;
     }
 
     *c |= 1 << LOCKEDFLAG;
     *c &= ~(1 << LOCKTYPEFLAG);
     return true;
 }

Here is the caller graph for this function:

char setreplacedeleteflag ( char * c)

set delete as part of replace row flag

Parameters

c	rowdata_s flags

Returns: rowdata_s flags

Definition at line 232 of file main.cc.

References REPLACEDELETEFLAG.

Referenced by Table::deleterow().

 {
     return *c |= 1 << REPLACEDELETEFLAG;
 }

Here is the caller graph for this function:

bool setwritelock ( char * c)

set write lock on row

Parameters

c	rowdata_s flags

Returns: success or failure

Definition at line 176 of file main.cc.

References LOCKEDFLAG, and LOCKTYPEFLAG.

Referenced by Table::getrows(), Table::newrow(), and Table::selectrows().

 {
     if (*c & 1 << LOCKEDFLAG)   // already locked
     {
         return false;
     }
 
     *c |= 1 << LOCKEDFLAG;
     *c |= 1 << LOCKTYPEFLAG;
     return true;
 }

Here is the caller graph for this function:

void stagedRow2ReturnRow	(	const stagedRow_s &	stagedRow,
		returnRow_s &	returnRow
	)

convert stagedRow_s to returnRow_s

Parameters

stagedRow	input stagedRow_s
returnRow	output returnRow_s

Definition at line 396 of file main.cc.

References stagedRow_s::cmd, INSERT, returnRow_s::locktype, stagedRow_s::locktype, stagedRow_s::newRow, stagedRow_s::newrowid, NOCOMMAND, stagedRow_s::originalRow, stagedRow_s::originalrowid, returnRow_s::previoussubtransactionid, stagedRow_s::previoussubtransactionid, returnRow_s::row, returnRow_s::rowid, and UPDATE.

Referenced by Statement::branchtotype(), and Statement::stagedPredicate().

 {
     returnRow.previoussubtransactionid=stagedRow.previoussubtransactionid;
     returnRow.locktype=stagedRow.locktype;
 
     switch (stagedRow.cmd)
     {
     case NOCOMMAND:
         returnRow.rowid=stagedRow.originalrowid;
         returnRow.row=stagedRow.originalRow;
         break;
 
     case INSERT:
         returnRow.rowid=stagedRow.newrowid;
         returnRow.row=stagedRow.newRow;
         break;
 
     case UPDATE:
         returnRow.rowid=stagedRow.newrowid;
         returnRow.row=stagedRow.newRow;
         break;
 
     default:
         printf("%s %i anomaly %i\n", __FILE__, __LINE__, stagedRow.cmd);
         returnRow=returnRow_s();
     }
 }

Here is the caller graph for this function:

void trimspace ( string & )

Definition at line 382 of file main.cc.

Referenced by Index::between(), Index::comparison(), Transaction::continueCommitTransaction(), Index::deleteNonuniqueEntry(), Index::deleteUniqueEntry(), Transaction::getengine(), Transaction::getEngineid(), Index::getequal_f(), Index::getnotequal(), Index::getnotin(), Index::insertNonuniqueEntry(), Index::like(), Index::notlike(), Index::replaceNonunique(), Index::replaceUnique(), and SubTransaction::uniqueIndex().

 {
     size_t last=input.find_last_not_of(' ');
 
     if (last != string::npos)
     {
         input.erase(last+1);
     }
     else
     {
         input.clear();
     }
 }