Applier Class Reference

On replicas, this class replicates "applies" transactions received by TransactionAgent. More...

#include <Applier.h>

Collaboration diagram for Applier:

Public Member Functions
	Applier (class TransactionAgent *taPtrarg, int64_t domainidarg, Topology::addressStruct sourceAddrarg, int64_t partitionidarg)
virtual	~Applier ()
void	ackedApply (class MessageAckApply &msg)

Public Attributes
int64_t	applierid
class TransactionAgent *	taPtr
int64_t	domainid
Topology::addressStruct	sourceAddr
int64_t	partitioncount

Detailed Description

On replicas, this class replicates "applies" transactions received by TransactionAgent.

The receiving TransactionAgent begins the process by sending data to each Engine, and then creating an Applier object and putting it in a map. Engines apply replicated transaction data in strict order based on subtransactionid.

Definition at line 43 of file Applier.h.

Constructor & Destructor Documentation

Applier::Applier	(	class TransactionAgent *	taPtrarg,
		int64_t	domainidarg,
		Topology::addressStruct	sourceAddrarg,
		int64_t	partitionidarg
	)

Creates Applier Object. This is created to keep state of a transaction being replicated.

Parameters

taPtrarg	pointer to calling TransactionAgent
domainidarg	domainid
sourceAddrarg	address of master TransactionAgent
partitionidarg	partitionid

Definition at line 39 of file Applier.cc.

References applierid, TransactionAgent::Appliers, and TransactionAgent::getnextapplierid().

                                            :
    taPtr(taPtrarg), domainid(domainidarg), sourceAddr(sourceAddrarg),
    partitioncount(partitioncountarg)
{
    applierid = taPtr->getnextapplierid();
    taPtr->Appliers[applierid] = this;
}

Here is the call graph for this function:

Applier::~Applier ( )

virtual

Definition at line 49 of file Applier.cc.

{
}

Member Function Documentation

void Applier::ackedApply

(

class MessageAckApply &

msg)

handles replies from Engines that have applied transaction replication. Counts down and deletes Applier object when all replies have been received

Parameters

msg

Definition at line 53 of file Applier.cc.

References MessageAckApply::ackapplyStruct, applierid, MessageAckApply::ackapply_s::applierid, TransactionAgent::Appliers, partitioncount, MessageAckApply::ackapply_s::partitionid, MessageAckApply::ackapply_s::status, STATUS_OK, and MessageAckApply::ackapply_s::subtransactionid.

{
    if (msg.ackapplyStruct.status != STATUS_OK)
    {
        printf("%s %i bad apply ack status %i %li,%li,%li\n", __FILE__, __LINE__,
               msg.ackapplyStruct.status, msg.ackapplyStruct.subtransactionid, msg.ackapplyStruct.applierid, msg.ackapplyStruct.partitionid);
        delete this;
        return;
    }

    if (!--partitioncount)
    {
        taPtr->Appliers.erase(applierid);
        delete this;
    }
}

Member Data Documentation

int64_t Applier::applierid

Definition at line 70 of file Applier.h.

Referenced by ackedApply(), and Applier().

int64_t Applier::domainid

Definition at line 72 of file Applier.h.

int64_t Applier::partitioncount

Definition at line 74 of file Applier.h.

Referenced by ackedApply().

Topology::addressStruct Applier::sourceAddr

Definition at line 73 of file Applier.h.

class TransactionAgent* Applier::taPtr

Definition at line 71 of file Applier.h.

---

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

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