TransactionAgent.h File Reference

Actor which communicates with clients and executes transactions. Coordinates of activities between several other actors. More...

#include "gch.h"
#include "Operation.h"
#include "Table.h"
#include "Schema.h"
#include "Larxer.h"
#include "Transaction.h"
#include "Applier.h"

Include dependency graph for TransactionAgent.h:

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

Go to the source code of this file.

Classes
struct	idl
	orphan More...
struct	responseData
	for storing network responses held up by EAGAIN on raw interface More...
struct	authInfo
	authentication information, uniquely identifying a user More...
class	TransactionAgent
	execute Transaction Agent actor More...

Typedefs
typedef vector< idl >	cmds
typedef boost::unordered_map < std::string, procedures_s >	domainProceduresMap
typedef boost::unordered_map < int, responseData >	sendLaterMap
typedef std::map< int, authInfo >	socketAuthInfo
typedef boost::unordered_map < int64_t, class Operation * >	operationMap
typedef ApiInterface *(*	spclasscreate )(class TransactionAgent *, class ApiInterface *, void *)
typedef void(*	spclassdestroy )(ApiInterface *)

Enumerations
enum	transactionpayload_e { NOPAYLOAD = 0, SUBTRANSACTIONCMDPAYLOAD, COMMITROLLBACKPAYLOAD }
	type of MessageTransaction variant. likely an orphan More...
enum	idlcmd_e {   IDLNOCMD = 0, IDLROWLOCK, IDLINDEXLOCK, IDLINSERTROW,   IDLINDEX, IDLDELETEUNIQUEINDEX, IDLINSERTNONUNIQUEINDEX, IDLINSERTNULLINDEX,   IDLDELETENONUNIQUEINDEX, IDLDELETENULLINDEX, IDLREPLACEINDEX, IDLROLLBACKROW,   IDLROLLBACKINDEX }
	likely an orphan More...

Functions
msgpack::sbuffer *	makeSbuf (msgpack::sbuffer *)
msgpack::sbuffer *	makeSbuf (vector< string > *)
msgpack::sbuffer *	makeSbuf (std::map< string, string > *)
template<typename T >
void	replyTa (T servent, topic_e result, void *msg)
	orphan More...
void *	transactionAgent (void *identity)
	launch Transaction Agent actor More...

Detailed Description

Actor which communicates with clients and executes transactions. Coordinates of activities between several other actors.

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 14:03:09 2013

Definition in file TransactionAgent.h.

Typedef Documentation

typedef vector<idl> cmds

Definition at line 94 of file TransactionAgent.h.

typedef boost::unordered_map<std::string, procedures_s> domainProceduresMap

Definition at line 99 of file TransactionAgent.h.

typedef boost::unordered_map<int64_t, class Operation *> operationMap

Definition at line 129 of file TransactionAgent.h.

typedef boost::unordered_map<int, responseData> sendLaterMap

Definition at line 123 of file TransactionAgent.h.

typedef std::map<int, authInfo> socketAuthInfo

Definition at line 128 of file TransactionAgent.h.

typedef ApiInterface*(* spclasscreate)(class TransactionAgent *, class ApiInterface *, void *)

Definition at line 506 of file TransactionAgent.h.

typedef void(* spclassdestroy)(ApiInterface *)

Definition at line 508 of file TransactionAgent.h.

Enumeration Type Documentation

enum idlcmd_e

likely an orphan

Enumerator
IDLNOCMD
IDLROWLOCK
IDLINDEXLOCK
IDLINSERTROW
IDLINDEX
IDLDELETEUNIQUEINDEX
IDLINSERTNONUNIQUEINDEX
IDLINSERTNULLINDEX
IDLDELETENONUNIQUEINDEX
IDLDELETENULLINDEX
IDLREPLACEINDEX
IDLROLLBACKROW
IDLROLLBACKINDEX

Definition at line 55 of file TransactionAgent.h.

{
    IDLNOCMD = 0,
    IDLROWLOCK,
    IDLINDEXLOCK,
    IDLINSERTROW,
    IDLINDEX,
    IDLDELETEUNIQUEINDEX,
    IDLINSERTNONUNIQUEINDEX,
    IDLINSERTNULLINDEX,
    IDLDELETENONUNIQUEINDEX,
    IDLDELETENULLINDEX,
    IDLREPLACEINDEX,
    IDLROLLBACKROW,
    IDLROLLBACKINDEX,
};

enum transactionpayload_e

type of MessageTransaction variant. likely an orphan

Returns

Enumerator
NOPAYLOAD
SUBTRANSACTIONCMDPAYLOAD
COMMITROLLBACKPAYLOAD

Definition at line 44 of file TransactionAgent.h.

{
    NOPAYLOAD = 0,
    SUBTRANSACTIONCMDPAYLOAD,
    COMMITROLLBACKPAYLOAD
};

Function Documentation

msgpack::sbuffer* makeSbuf

(

msgpack::sbuffer *

)

Definition at line 1344 of file TransactionAgent.cc.

Referenced by TransactionAgent::sendResponse().

{
    return sbuf;
}

Here is the caller graph for this function:

msgpack::sbuffer* makeSbuf

(

vector< string > *

)

Definition at line 1349 of file TransactionAgent.cc.

{
    msgpack::sbuffer *sbuf = new msgpack::sbuffer;
    msgpack::pack(*sbuf, *v);
    return sbuf;
}

msgpack::sbuffer* makeSbuf

(

std::map< string, string > *

)

Definition at line 1356 of file TransactionAgent.cc.

{
    msgpack::sbuffer *sbuf = new msgpack::sbuffer;
    msgpack::pack(*sbuf, *m);
    return sbuf;
}

template<typename T >

void replyTa	(	T	servent,
		topic_e	result,
		void *	msg
	)

orphan

Parameters

servent
result
msg

Definition at line 518 of file TransactionAgent.h.

References MessageUserSchema::userschema_s::domainid, Message::messageStruct, MessageUserSchema::userschema_s::operationid, PAYLOADUSERSCHEMA, MessageUserSchema::userschema_s::status, Message::message_s::topic, MessageUserSchema::userschema_s::userid, and MessageUserSchema::userschemaStruct.

{
    class MessageUserSchema &msgref = *(class MessageUserSchema *)msg;
    servent->msgsnd.data = (void *)msg;
    ((class Message *)servent->msgsnd.data)->messageStruct.topic = result;
    ((class Message *)servent->msgsnd.data)->messageStruct.payloadtype =
        PAYLOADUSERSCHEMA;
    msgref.userschemaStruct.operationid = servent->operationid;
    msgref.userschemaStruct.domainid = servent->domainid;
    msgref.userschemaStruct.userid = servent->userid;
    msgref.userschemaStruct.status = servent->status;
}

void* transactionAgent

(

void *

identity)

launch Transaction Agent actor

Parameters

identity

how to identify actor instance

Returns

Definition at line 633 of file TransactionAgent.cc.

{
    TransactionAgent((Topology::partitionAddress *)identity);
    return NULL;
}