MessageSubtransactionCmd Class Reference

Message variant for subtransactions. More...

#include <Message.h>

Inheritance diagram for MessageSubtransactionCmd:

Collaboration diagram for MessageSubtransactionCmd:

Classes
struct	subtransaction_s
	MessageSubtransactionCmd POD (serializable by memcpy) data members. More...

Public Member Functions
	MessageSubtransactionCmd ()
virtual	~MessageSubtransactionCmd ()
size_t	size ()
	get Message size More...
string *	ser ()
	create string with serialized message More...
void	package (class SerializedMessage &serobj)
	serialize this More...
void	unpack (SerializedMessage &serobj)
	deserialize into this More...
void	clear ()
	clear contents of this More...
Public Member Functions inherited from MessageTransaction
	MessageTransaction ()
virtual	~MessageTransaction ()
size_t	size ()
	get Message size More...
string *	ser ()
	create string with serialized message More...
void	package (class SerializedMessage &serobj)
	serialize this More...
void	unpack (SerializedMessage &serobj)
	deserialize into this More...
void	clear ()
	clear contents of this More...
Public Member Functions inherited from Message
	Message ()
virtual	~Message ()
size_t	size ()
	get Message size More...
std::string *	ser ()
	create string with serialized message More...
void	package (class SerializedMessage &serobj)
	serialize this More...
void	unpack (SerializedMessage &serobj)
	deserialize into this More...
void	clear ()
	clear contents of this More...
string *	sermsg ()
	return serialized Message variant string More...
void	setEnvelope (const Topology::addressStruct &source, const Topology::addressStruct &dest, class Message &msg)
	put addresses in Message variant envelope More...

Public Attributes
subtransaction_s	subtransactionStruct
std::string	row
fieldValue_s	fieldVal
std::vector < nonLockingIndexEntry_s >	indexHits
searchParams_s	searchParameters
std::vector< int64_t >	rowids
std::vector< returnRow_s >	returnRows
Public Attributes inherited from MessageTransaction
transaction_s	transactionStruct
Public Attributes inherited from Message
__int128	nextmsg
message_s	messageStruct

Additional Inherited Members
Static Public Member Functions inherited from Message
static class Message *	des (string *serstr)
	deserialize entire message More...

Detailed Description

Message variant for subtransactions.

Returns

Definition at line 439 of file Message.h.

Constructor & Destructor Documentation

MessageSubtransactionCmd::MessageSubtransactionCmd

(

)

Definition at line 432 of file Message.cc.

Referenced by SubTransaction::drainIndexLockQueue(), and SubTransaction::drainRowLockQueue().

                                                   :
    subtransactionStruct (), fieldVal ()
{
}

Here is the caller graph for this function:

MessageSubtransactionCmd::~MessageSubtransactionCmd ( )

virtual

Definition at line 437 of file Message.cc.

{
}

Member Function Documentation

void MessageSubtransactionCmd::clear

(

)

clear contents of this

Definition at line 489 of file Message.cc.

References MessageTransaction::clear(), fieldVal, indexHits, returnRows, row, rowids, searchParameters, and subtransactionStruct.

{
    MessageTransaction::clear();
    subtransactionStruct={};
    row.clear();
    fieldVal={};
    indexHits.clear();
    searchParameters={};
    rowids.clear();
    returnRows.clear();
}

Here is the call graph for this function:

void MessageSubtransactionCmd::package

(

class SerializedMessage &

serobj)

serialize this

Parameters

serobj

SerializedMessage

Definition at line 465 of file Message.cc.

References fieldVal, indexHits, MessageTransaction::package(), returnRows, row, rowids, searchParameters, SerializedMessage::ser(), and subtransactionStruct.

Referenced by ser().

{
    MessageTransaction::package(serobj);
    serobj.ser(subtransactionStruct);
    serobj.ser(row);
    serobj.ser(fieldVal);
    serobj.ser(indexHits);
    serobj.ser(searchParameters);
    serobj.ser(rowids);
    serobj.ser(returnRows);
}

Here is the call graph for this function:

Here is the caller graph for this function:

string * MessageSubtransactionCmd::ser

(

)

create string with serialized message

Returns

serialized message string

Definition at line 453 of file Message.cc.

References SerializedMessage::data, SerializedMessage::getpayloadtype(), logfile, package(), and SerializedMessage::pos.

{
    class SerializedMessage serobj(size());
    package(serobj);
    if (serobj.data->size() != serobj.pos)
    {
        fprintf(logfile, "%s %i ser %i size %lu pos %lu\n", __FILE__, __LINE__,
                serobj.getpayloadtype(), serobj.data->size(), serobj.pos);
    }
    return serobj.data;
}

Here is the call graph for this function:

size_t MessageSubtransactionCmd::size

(

)

get Message size

Returns

size in bytes

Definition at line 441 of file Message.cc.

References fieldVal, indexHits, returnRows, row, rowids, searchParameters, SerializedMessage::sersize(), MessageTransaction::size(), and subtransactionStruct.

{
    return MessageTransaction::size() +
        SerializedMessage::sersize(subtransactionStruct) +
        SerializedMessage::sersize(row) +
        SerializedMessage::sersize(fieldVal) +
        SerializedMessage::sersize(indexHits) +
        SerializedMessage::sersize(searchParameters) +
        SerializedMessage::sersize(rowids) +
        SerializedMessage::sersize(returnRows);
}

Here is the call graph for this function:

void MessageSubtransactionCmd::unpack

(

SerializedMessage &

serobj)

deserialize into this

Parameters

serobj

SerializedMessage

Definition at line 477 of file Message.cc.

References SerializedMessage::des(), fieldVal, indexHits, returnRows, row, rowids, searchParameters, subtransactionStruct, and MessageTransaction::unpack().

Referenced by Message::des().

{
    MessageTransaction::unpack(serobj);
    serobj.des(subtransactionStruct);
    serobj.des(row);
    serobj.des(fieldVal);
    serobj.des(indexHits);
    serobj.des(searchParameters);
    serobj.des(rowids);
    serobj.des(returnRows);
}

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

fieldValue_s MessageSubtransactionCmd::fieldVal

Definition at line 494 of file Message.h.

Referenced by clear(), Transaction::continueInsertRow(), Transaction::continueSqlInsert(), Transaction::continueSqlReplace(), Statement::continueUpdate(), Transaction::continueUpdateRow(), SubTransaction::drainIndexLockQueue(), package(), SubTransaction::processTransactionMessage(), ApiInterface::selectRows(), size(), and unpack().

std::vector<nonLockingIndexEntry_s> MessageSubtransactionCmd::indexHits

Definition at line 495 of file Message.h.

Referenced by clear(), Transaction::continueSelectRows(), Transaction::continueSqlPredicate(), package(), SubTransaction::processTransactionMessage(), size(), and unpack().

std::vector<returnRow_s> MessageSubtransactionCmd::returnRows

Definition at line 498 of file Message.h.

Referenced by clear(), Transaction::continueSelectRows(), Transaction::continueSqlPredicate(), SubTransaction::drainRowLockQueue(), package(), SubTransaction::processTransactionMessage(), size(), and unpack().

std::string MessageSubtransactionCmd::row

Definition at line 493 of file Message.h.

Referenced by Statement::branchtotype(), clear(), Statement::continueUpdate(), Transaction::continueUpdateRow(), ApiInterface::insertRow(), package(), SubTransaction::processTransactionMessage(), Transaction::replace(), size(), and unpack().

std::vector<int64_t> MessageSubtransactionCmd::rowids

Definition at line 497 of file Message.h.

Referenced by clear(), Transaction::continueSelectRows(), Transaction::continueSqlPredicate(), package(), SubTransaction::processTransactionMessage(), SubTransaction::searchReturn1(), size(), and unpack().

searchParams_s MessageSubtransactionCmd::searchParameters

Definition at line 496 of file Message.h.

Referenced by clear(), package(), SubTransaction::processTransactionMessage(), Transaction::select(), ApiInterface::selectRows(), size(), Transaction::sqlPredicate(), Transaction::sqlSelectAll(), and unpack().

subtransaction_s MessageSubtransactionCmd::subtransactionStruct

Definition at line 491 of file Message.h.

Referenced by Statement::branchtotype(), clear(), Statement::continueDelete(), Transaction::continueDeleteRow(), Transaction::continueInsertRow(), Transaction::continueReplaceRow(), Transaction::continueSelectRows(), Transaction::continueSqlDelete(), Transaction::continueSqlInsert(), Transaction::continueSqlPredicate(), Transaction::continueSqlReplace(), Transaction::continueSqlUpdate(), Statement::continueUpdate(), Transaction::continueUpdateRow(), ApiInterface::deleteRow(), SubTransaction::drainIndexLockQueue(), ApiInterface::insertRow(), package(), SubTransaction::processTransactionMessage(), Transaction::replace(), Transaction::select(), size(), Transaction::sqlPredicate(), Transaction::sqlSelectAll(), and unpack().

---

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

• /home/infinisql/build/infinisql/infinisqld/Message.h
• /home/infinisql/build/infinisql/infinisqld/Message.cc