UserSchemaMgr Class Reference

execute User Schema Manager actor More...

#include <UserSchemaMgr.h>

Collaboration diagram for UserSchemaMgr:

Public Member Functions
	UserSchemaMgr (Topology::partitionAddress *myIdentityArg)
virtual	~UserSchemaMgr ()

Public Attributes
class Message *	msgsnd
int64_t	operationid
int64_t	domainid
int64_t	userid
int64_t	status
int64_t	tainstance
class Message *	msgrcv
REUSEMESSAGES domainidToSchemaMap	domainidsToSchemata
class Mboxes	mboxes
Topology::partitionAddress	myIdentity

Private Member Functions
int64_t	getnextdomainid ()
	generate unique, ever-increasing domain identifier More...
int64_t	getnextuserid (int64_t argdomainid)
	generate unique, ever-increasing user identifier More...
void	operationHandler (class MessageUserSchema &msgrcvref)
	perform operation (currently only login for SQL) More...
int64_t	operationLogin (string &username, string &domainname, string &password, int64_t *uid, int64_t *did)
	login for SQL session More...
void	login ()
	login (raw interface) More...
void	changepassword ()
	change password More...
void	createdomain ()
	create domain More...
void	createuser ()
	create user More...
void	deleteuser ()
	delete user More...
void	deletedomain ()
	delete domain More...
void	createschema (builtincmds_e cmd)
	create schema More...
void	createtable (builtincmds_e cmd)
	create table More...
void	addcolumn (builtincmds_e cmd)
	add column More...
void	deleteindex (builtincmds_e cmd)
	delete index More...
void	deletetable (builtincmds_e cmd)
	delete table More...
void	deleteschema (builtincmds_e cmd)
	delete schema More...

Private Attributes
class Topology	myTopology
int64_t	argsize
int64_t	instance
class Mbox *	mymboxPtr
domainNameToDomainIdMap	domainNameToDomainId
domainNameToDomainIdMap::iterator	domainNameToDomainIdIterator
domainIdToUserNamesMap	domainIdToUserNames
domainIdToUserNamesMap::iterator	domainIdToUserNamesIterator
domainIdToUserIdsMap	domainIdToUserIds
domainIdToUserIdsMap::iterator	domainIdToUserIdsIterator
domainIdToNextUserIdMap	domainIdToNextUserId
domainIdToNextUserIdMap::iterator	domainIdToNextUserIdIterator
userNameToUserIdMap *	userNameToUserId
userNameToUserIdMap::iterator	userNameToUserIdIterator
userIdToPasswordMap *	userIdToPassword
userIdToPasswordMap::iterator	userIdToPasswordIterator
passwordStruct	pwdStruct
passwordStruct *	pwdStructPtr
std::vector< std::string > *	resultVector
int64_t	nextdomainid
domainidToSchemaMap::iterator	domainidsToSchemataIterator
boost::unordered_map < std::string, fieldtype_e >	fieldTypeMap
boost::unordered_map < std::string, indextype_e >	indexTypeMap

Detailed Description

execute User Schema Manager actor

Parameters

myIdentityArg

how to identify this

Definition at line 62 of file UserSchemaMgr.h.

Constructor & Destructor Documentation

UserSchemaMgr::UserSchemaMgr

(

Topology::partitionAddress *

myIdentityArg)

Definition at line 33 of file UserSchemaMgr.cc.

References addcolumn(), Topology::partitionAddress::address, argsize, MessageUserSchema::userschema_s::argsize, Topology::partitionAddress::argstring, MessageUserSchema::argstring, BOOL, BUILTINADDCOLUMN, MessageUserSchema::userschema_s::builtincmd, BUILTINCREATESCHEMA, BUILTINCREATETABLE, BUILTINDELETEINDEX, BUILTINDELETESCHEMA, BUILTINDELETETABLE, changepassword(), CHAR, CHARX, passwordStruct::clearpassword, createdomain(), createschema(), createtable(), createuser(), deletedomain(), deleteindex(), deleteschema(), deletetable(), deleteuser(), passwordStruct::digest, domainid, MessageUserSchema::userschema_s::domainid, domainIdToNextUserId, domainIdToUserIds, domainIdToUserNames, domainNameToDomainId, fieldTypeMap, FLOAT, GETMSG, indexTypeMap, MessageUserSchema::userschema_s::instance, INT, logfile, login(), Topology::partitionAddress::mbox, mboxes, Message::messageStruct, msgpack2Vector(), msgrcv, msgsnd, myIdentity, myTopology, nextdomainid, Topology::addressStruct::nodeid, Mboxes::nodeid, NONE, NONUNIQUE, NONUNIQUENOTNULL, operationHandler(), operationid, MessageUserSchema::userschema_s::operationid, pwdStruct, resultVector, Mboxes::sendObBatch(), STARTCMD, tainstance, Message::message_s::topic, TOPIC_CHANGEPASSWORD, TOPIC_CREATEDOMAIN, TOPIC_CREATEUSER, TOPIC_DELETEDOMAIN, TOPIC_DELETEUSER, TOPIC_LOGIN, TOPIC_NONE, TOPIC_OPERATION, TOPIC_SCHEMAREQUEST, TOPIC_TOPOLOGY, UINT, UNIQUE, UNIQUENOTNULL, UNORDERED, UNORDEREDNOTNULL, Mboxes::update(), userid, MessageUserSchema::userschema_s::userid, MessageUserSchema::userschemaStruct, and VARCHAR.

                                                                    :
    myIdentity(*myIdentityArg)
{
    delete myIdentityArg;
    mboxes.nodeid = myIdentity.address.nodeid;
    mboxes.update(myTopology);

    // these are incremented before being given out. domainid 1 is _global
    nextdomainid = 1;

    msgsnd = NULL;

    domainNameToDomainId["_global"] = 1;
    domainIdToUserNames[ domainNameToDomainId["_global"] ] =
        new userNameToUserIdMap;
    domainIdToNextUserId[ domainNameToDomainId["_global"] ] = 1;
    domainIdToUserNames[domainNameToDomainId["_global"]]->operator[]("admin") = 1;
    domainIdToUserIds[ domainNameToDomainId["_global"] ] =
        new userIdToPasswordMap;
    SHA512().CalculateDigest(pwdStruct.digest,
                             (const byte *)myIdentity.argstring.c_str(),
                             myIdentity.argstring.size());
    pwdStruct.clearpassword.assign(myIdentity.argstring.c_str(),
                                   myIdentity.argstring.size());
    domainIdToUserIds[ domainNameToDomainId["_global"] ]->operator[](1) =
        pwdStruct;

    fieldTypeMap["int"] = INT;
    fieldTypeMap["uint"] = UINT;
    fieldTypeMap["bool"] = BOOL;
    fieldTypeMap["float"] = FLOAT;
    fieldTypeMap["char"] = CHAR;
    fieldTypeMap["charx"] = CHARX;
    fieldTypeMap["varchar"] = VARCHAR;

    indexTypeMap["none"] = NONE;
    indexTypeMap["unique"] = UNIQUE;
    indexTypeMap["nonunique"] = NONUNIQUE;
    indexTypeMap["unordered"] = UNORDERED;
    indexTypeMap["uniquenotnull"] = UNIQUENOTNULL;
    indexTypeMap["nonuniquenotnull"] = NONUNIQUENOTNULL;
    indexTypeMap["unorderednotnull"] = UNORDEREDNOTNULL;

    while (1)
    {
        mboxes.sendObBatch();
        do
        {
            GETMSG(msgrcv, myIdentity.mbox, 1000)
                }
        while (msgrcv==NULL);

        class MessageUserSchema &msgrcvref =
            *(class MessageUserSchema *)msgrcv;

        if (msgrcvref.messageStruct.topic != TOPIC_TOPOLOGY &&
            msgrcvref.messageStruct.topic != TOPIC_OPERATION
            && msgrcvref.messageStruct.topic != TOPIC_NONE)
        {
            argsize = msgrcvref.userschemaStruct.argsize;
            tainstance = msgrcvref.userschemaStruct.instance;
            operationid = msgrcvref.userschemaStruct.operationid;
            domainid = msgrcvref.userschemaStruct.domainid;
            userid = msgrcvref.userschemaStruct.userid;
            resultVector = new vector<string>;
            msgpack2Vector(resultVector, (char *)msgrcvref.argstring.c_str(),
                           argsize);
        }

        switch (msgrcv->messageStruct.topic)
        {
        case TOPIC_LOGIN:
            login();
            break;

        case TOPIC_CHANGEPASSWORD:
            changepassword();
            break;

        case TOPIC_CREATEDOMAIN:
            createdomain();
            break;

        case TOPIC_CREATEUSER:
            createuser();
            break;

        case TOPIC_DELETEUSER:
            deleteuser();
            break;

        case TOPIC_DELETEDOMAIN:
            deletedomain();
            break;

        case TOPIC_SCHEMAREQUEST:
            switch (msgrcvref.userschemaStruct.builtincmd)
            {
            case BUILTINCREATESCHEMA:
            {
                createschema(STARTCMD);
            }
            break;

            case BUILTINCREATETABLE:
                createtable(STARTCMD);
                break;

            case BUILTINADDCOLUMN:
                addcolumn(STARTCMD);
                break;

            case BUILTINDELETEINDEX:
                deleteindex(STARTCMD);
                break;

            case BUILTINDELETETABLE:
                deletetable(STARTCMD);
                break;

            case BUILTINDELETESCHEMA:
                deleteschema(STARTCMD);
                break;

            default:
                fprintf(logfile, "UserSchemaMgr bad schema builtin %li\n",
                        msgrcvref.userschemaStruct.builtincmd);
            }

            break;

        case TOPIC_TOPOLOGY:
            mboxes.update(myTopology);
            break;

        case TOPIC_OPERATION:
            operationHandler(*((class MessageUserSchema *)msgrcv));
            break;

        default:
            fprintf(logfile, "UserSchemaMgr bad topic %i\n",
                    msgrcv->messageStruct.topic);
        }

        if (msgrcvref.messageStruct.topic != TOPIC_TOPOLOGY &&
            msgrcvref.messageStruct.topic != TOPIC_OPERATION &&
            msgrcvref.messageStruct.topic != TOPIC_NONE)
        {
            delete resultVector;
        }
    }
}

Here is the call graph for this function:

UserSchemaMgr::~UserSchemaMgr ( )

virtual

Definition at line 186 of file UserSchemaMgr.cc.

{
}

Member Function Documentation

void UserSchemaMgr::addcolumn ( builtincmds_e  cmd)

private

add column

Parameters

cmd	entry point for continuation

Definition at line 606 of file UserSchemaMgr.cc.

References ABORTCMD, BUILTIN_STATUS_NOTOK, BUILTIN_STATUS_OK, CHARX, domainid, domainidsToSchemata, fieldTypeMap, indexTypeMap, logfile, Message::messageStruct, msgrcv, Table::name, resultVector, Message::message_s::sourceAddr, STARTCMD, status, and TransactionAgent::usmReply().

Referenced by UserSchemaMgr().

{
    switch (cmd)
    {
    case STARTCMD:
    {
        /* either succeeds or fails :-) */
        // uses domainid, input tableid
        int64_t tid = boost::lexical_cast<int64_t>(resultVector->at(0));
        string stringtype = resultVector->at(1);
        int64_t len = boost::lexical_cast<int64_t>(resultVector->at(2));
        string name = resultVector->at(3);
        string stringidxtype = resultVector->at(4);
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_SCHEMAREPLY);
        class MessageUserSchema &msgref = *msg;

        if (!fieldTypeMap.count(stringtype))
        {
            // map string not found, doh!
            status = BUILTIN_STATUS_NOTOK;
            TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr,
                                       *msg);
            return;
        }

        fieldtype_e type = fieldTypeMap[stringtype];

        if (type != CHARX)
        {
            len = 0; // zero out the length unless it is charx
        }

        if (!indexTypeMap.count(stringidxtype))
        {
            status = BUILTIN_STATUS_NOTOK;
            TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr,
                                       *msg);
            return;
        }

        indextype_e idxtype = indexTypeMap[stringidxtype];

        if (!domainidsToSchemata.count(domainid))
        {
            status = BUILTIN_STATUS_NOTOK;
            TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr,
                                       *msg);
            return;
        }

        class Schema *schemaPtr = domainidsToSchemata[domainid];

        if (!schemaPtr->tables.count(tid))
        {
            status = BUILTIN_STATUS_NOTOK;
            TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr,
                                       *msg);
            return;
        }

        class Table *tablePtr = schemaPtr->tables[tid];

        if (tablePtr->columnaNameToFieldMap.count(name))
        {
            // column already exists
            status = BUILTIN_STATUS_NOTOK;
            TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr,
                                       *msg);
            return;
        }

        msgref.userschemaStruct.fieldid = tablePtr->addfield(type, len, name,
                                                             idxtype);
        schemaPtr->fieldNameToId[tid][name] = msgref.userschemaStruct.fieldid;
        status = BUILTIN_STATUS_OK;
        msgref.userschemaStruct.tableid = tid;
        msgref.userschemaStruct.fieldlen = len;
        msgref.userschemaStruct.fieldtype = type;
        msgref.userschemaStruct.indextype = idxtype;

        msgref.userschemaStruct.domainid = domainid;
        msgref.argstring = name;
        msgref.userschemaStruct.argsize = 0;

        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
    }
    break;

    case ABORTCMD:
        break;

    default:
        fprintf(logfile, "no such cmd %i %s %i\n", cmd, __FILE__, __LINE__);
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void UserSchemaMgr::changepassword ( )

private

change password

Definition at line 266 of file UserSchemaMgr.cc.

References domainid, domainIdToUserIds, domainIdToUserIdsIterator, Message::messageStruct, msgrcv, resultVector, Message::message_s::sourceAddr, userid, userIdToPassword, userIdToPasswordIterator, and TransactionAgent::usmReply().

Referenced by UserSchemaMgr().

{
    domainIdToUserIdsIterator = domainIdToUserIds.find(domainid);

    if (domainIdToUserIdsIterator == domainIdToUserIds.end())
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_CHANGEPASSWORDFAIL);
        //    replyTa(this, TOPIC_CHANGEPASSWORDFAIL, msg);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    userIdToPasswordIterator = userIdToPassword->find(userid);

    if (userIdToPasswordIterator == userIdToPassword->end())
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_CHANGEPASSWORDFAIL);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    SHA512().CalculateDigest(userIdToPasswordIterator->second.digest,
                             (const byte *)resultVector->at(0).c_str(),
                             resultVector->at(0).length());
    class MessageUserSchema *msg =
        new class MessageUserSchema(TOPIC_CHANGEPASSWORDOK);
    //  replyTa(this, TOPIC_CHANGEPASSWORDOK, msg);
    TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
}

Here is the call graph for this function:

Here is the caller graph for this function:

void UserSchemaMgr::createdomain ( )

private

create domain

Definition at line 298 of file UserSchemaMgr.cc.

References domainid, domainIdToNextUserId, domainIdToUserIds, domainIdToUserNames, domainNameToDomainId, domainNameToDomainIdIterator, getnextdomainid(), Message::messageStruct, msgrcv, resultVector, Message::message_s::sourceAddr, userid, and TransactionAgent::usmReply().

Referenced by UserSchemaMgr().

{
    // only _global admin user can do this
    if (domainid != 1 || userid != 1)
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_CREATEDOMAINFAIL);
        //    replyTa(this, TOPIC_CREATEDOMAINFAIL, msg);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    domainNameToDomainIdIterator = domainNameToDomainId.find(resultVector->at(0));

    if (domainNameToDomainIdIterator != domainNameToDomainId.end())
    {
        // domainname exists already
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_CREATEDOMAINFAIL);
        //    replyTa(this, TOPIC_CREATEDOMAINFAIL, msg);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    int64_t newdomainid = getnextdomainid();
    // make dname->did & did->usernamemap & did->useridmap & did->nextuserid
    domainNameToDomainId[resultVector->at(0)] = newdomainid;
    domainIdToUserNames[newdomainid] = new userNameToUserIdMap;
    domainIdToUserIds[newdomainid] = new userIdToPasswordMap;
    domainIdToNextUserId[newdomainid] = 0;

    domainid = newdomainid;
    class MessageUserSchema *msg =
        new class MessageUserSchema(TOPIC_CREATEDOMAINOK);
    //  replyTa(this, TOPIC_CREATEDOMAINOK, msg);
    TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
}

Here is the call graph for this function:

Here is the caller graph for this function:

void UserSchemaMgr::createschema ( builtincmds_e  cmd)

private

create schema

Parameters

cmd	entry point for continuation

Definition at line 528 of file UserSchemaMgr.cc.

References ABORTCMD, createSchema(), logfile, Message::messageStruct, msgrcv, Message::message_s::sourceAddr, STARTCMD, and TransactionAgent::usmReply().

Referenced by UserSchemaMgr().

{
    switch (cmd)
    {
    case STARTCMD:
    {
        createSchema(this);
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_SCHEMAREPLY);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        break;
    }

    case ABORTCMD:
        break;

    default:
        fprintf(logfile, "no such cmd %i %s %i\n", cmd, __FILE__, __LINE__);
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void UserSchemaMgr::createtable ( builtincmds_e  cmd)

private

create table

Parameters

cmd	entry point for continuation

Definition at line 549 of file UserSchemaMgr.cc.

References ABORTCMD, BUILTIN_STATUS_NOTOK, BUILTIN_STATUS_OK, Schema::createTable(), domainid, domainidsToSchemata, Schema::getnexttableid(), logfile, Message::messageStruct, msgrcv, resultVector, Message::message_s::sourceAddr, STARTCMD, status, Schema::tableNameToId, and TransactionAgent::usmReply().

Referenced by UserSchemaMgr().

{
    switch (cmd)
    {
    case STARTCMD:
    {
        class Schema *schemaPtr = NULL;
        int64_t tid = 0;

        if (domainidsToSchemata.count(domainid))
        {
            schemaPtr = domainidsToSchemata[domainid];

            // something to check table name exists:
            if (schemaPtr->tableNameToId.count(resultVector->at(0)))
            {
                //table name already exists
                status = BUILTIN_STATUS_NOTOK;
            }
            else
            {
                tid = schemaPtr->getnexttableid();
                status = schemaPtr->createTable(tid);
            }
        }
        else
        {
            status = BUILTIN_STATUS_NOTOK;
        }

        /* either succeeds or fails :-) */
        // table id & name mapping
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_SCHEMAREPLY);
        class MessageUserSchema &msgref = *msg;

        if (status==BUILTIN_STATUS_OK)
        {
            schemaPtr->tableNameToId[resultVector->at(0)] = tid;
            msgref.userschemaStruct.tableid = tid;

            msgref.userschemaStruct.domainid = domainid;
            msgref.argstring = resultVector->at(0);
        }

        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
    }
    break;

    case ABORTCMD:
        break;

    default:
        fprintf(logfile, "no such cmd %i %s %i\n", cmd, __FILE__, __LINE__);
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void UserSchemaMgr::createuser ( )

private

create user

Definition at line 337 of file UserSchemaMgr.cc.

References passwordStruct::digest, domainid, domainIdToUserIds, domainIdToUserNames, domainIdToUserNamesIterator, domainNameToDomainId, domainNameToDomainIdIterator, getnextuserid(), Message::messageStruct, msgrcv, pwdStruct, resultVector, Message::message_s::sourceAddr, userid, userIdToPassword, userNameToUserId, userNameToUserIdIterator, and TransactionAgent::usmReply().

Referenced by UserSchemaMgr().

{
    if (domainid != 1 || userid != 1)
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_CREATEUSERFAIL);
        //    replyTa(this, TOPIC_CREATEUSERFAIL, msg);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    domainNameToDomainIdIterator = domainNameToDomainId.find(resultVector->at(0));

    if (domainNameToDomainIdIterator == domainNameToDomainId.end())
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_CREATEUSERFAIL);
        //    replyTa(this, TOPIC_CREATEUSERFAIL, msg);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    int64_t did = domainNameToDomainIdIterator->second;
    domainIdToUserNamesIterator = domainIdToUserNames.find(did);

    if (domainIdToUserNamesIterator == domainIdToUserNames.end())
    {
        // no domainid to usernames entry, so it must have been deleted during
        // this session
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_CREATEUSERFAIL);
        //    replyTa(this, TOPIC_CREATEUSERFAIL, msg);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    // check for username already
    userNameToUserId = domainIdToUserNames[did];
    userNameToUserIdIterator = userNameToUserId->find(resultVector->at(1));

    if (userNameToUserIdIterator != userNameToUserId->end())
    {
        // username already exists
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_CREATEUSERFAIL);
        //    replyTa(this, TOPIC_CREATEUSERFAIL, msg);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    /* get next userid, then insert into things
     * domainIdToUserNames, domainIdToUserIds */
    int64_t newuserid = getnextuserid(did);
    userNameToUserId->operator[](resultVector->at(1)) = newuserid;
    userIdToPassword = domainIdToUserIds[did];
    SHA512().CalculateDigest(pwdStruct.digest,
                             (const byte *)resultVector->at(2).c_str(),
                             resultVector->at(2).length());
    userIdToPassword->operator[](newuserid) = pwdStruct;

    domainid = did;
    userid = newuserid;
    class MessageUserSchema *msg =
        new class MessageUserSchema(TOPIC_CREATEUSEROK);
    TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
}

Here is the call graph for this function:

Here is the caller graph for this function:

void UserSchemaMgr::deletedomain ( )

private

delete domain

Definition at line 485 of file UserSchemaMgr.cc.

References domainid, domainIdToNextUserId, domainIdToUserIds, domainIdToUserNames, domainNameToDomainId, domainNameToDomainIdIterator, Message::messageStruct, msgrcv, resultVector, Message::message_s::sourceAddr, userid, and TransactionAgent::usmReply().

Referenced by UserSchemaMgr().

{
    // only _global admin can do this
    if (domainid != 1 || userid != 1)
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_DELETEDOMAINFAIL);
        //    replyTa(this, TOPIC_DELETEDOMAINFAIL, msg);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    /* delete maps, always return ok if name exists. 3 user maps & domain entry
     * userIdToPassword,userNameToUserId
     * erase from: domainIdToUserIds, domainIdToUserNames, domainNameToDomainId
     * domainIdToNextUserId
     * just need the domainid (by way of the domain name
     */
    domainNameToDomainIdIterator = domainNameToDomainId.find(resultVector->at(0));

    if (domainNameToDomainIdIterator == domainNameToDomainId.end())
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_DELETEDOMAINFAIL);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    domainid = domainNameToDomainIdIterator->second;
    // assuming that deleting map that isn't there is ok, so no need to check
    delete domainIdToUserNames[domainid];
    delete domainIdToUserIds[domainid];
    domainIdToUserNames.erase(domainid);
    domainIdToUserIds.erase(domainid);
    domainIdToNextUserId.erase(domainid);
    domainNameToDomainId.erase(resultVector->at(0));

    class MessageUserSchema *msg =
        new class MessageUserSchema(TOPIC_DELETEDOMAINOK);
    TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
}

Here is the call graph for this function:

Here is the caller graph for this function:

void UserSchemaMgr::deleteindex ( builtincmds_e  cmd)

private

delete index

Parameters

cmd	entry point for continuation

Definition at line 703 of file UserSchemaMgr.cc.

References ABORTCMD, BUILTIN_STATUS_OK, logfile, Message::messageStruct, msgrcv, Message::message_s::sourceAddr, STARTCMD, status, and TransactionAgent::usmReply().

Referenced by UserSchemaMgr().

{
    switch (cmd)
    {
    case STARTCMD:
    {
        /* either succeeds or fails :-) */
        status = BUILTIN_STATUS_OK;
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_SCHEMAREPLY);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
    }
    break;

    case ABORTCMD:
        break;

    default:
        fprintf(logfile, "no such cmd %i %s %i\n", cmd, __FILE__, __LINE__);
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void UserSchemaMgr::deleteschema ( builtincmds_e  cmd)

private

delete schema

Parameters

cmd	entry point for continuation

Definition at line 747 of file UserSchemaMgr.cc.

References ABORTCMD, BUILTIN_STATUS_OK, logfile, Message::messageStruct, msgrcv, Message::message_s::sourceAddr, STARTCMD, status, and TransactionAgent::usmReply().

Referenced by UserSchemaMgr().

{
    switch (cmd)
    {
    case STARTCMD:
    {
        /* either succeeds or fails :-) */
        status = BUILTIN_STATUS_OK;
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_SCHEMAREPLY);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
    }
    break;

    case ABORTCMD:
        break;

    default:
        fprintf(logfile, "no such cmd %i %s %i\n", cmd, __FILE__, __LINE__);
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void UserSchemaMgr::deletetable ( builtincmds_e  cmd)

private

delete table

Parameters

cmd	entry point for continuation

Definition at line 725 of file UserSchemaMgr.cc.

References ABORTCMD, BUILTIN_STATUS_OK, logfile, Message::messageStruct, msgrcv, Message::message_s::sourceAddr, STARTCMD, status, and TransactionAgent::usmReply().

Referenced by UserSchemaMgr().

{
    switch (cmd)
    {
    case STARTCMD:
    {
        /* either succeeds or fails :-) */
        status = BUILTIN_STATUS_OK;
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_SCHEMAREPLY);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
    }
    break;

    case ABORTCMD:
        break;

    default:
        fprintf(logfile, "no such cmd %i %s %i\n", cmd, __FILE__, __LINE__);
    }
}

Here is the call graph for this function:

Here is the caller graph for this function:

void UserSchemaMgr::deleteuser ( )

private

delete user

Definition at line 405 of file UserSchemaMgr.cc.

References domainid, domainIdToUserIds, domainIdToUserIdsIterator, domainIdToUserNames, domainIdToUserNamesIterator, domainNameToDomainId, domainNameToDomainIdIterator, Message::messageStruct, msgrcv, resultVector, Message::message_s::sourceAddr, userid, userIdToPassword, userNameToUserId, userNameToUserIdIterator, and TransactionAgent::usmReply().

Referenced by UserSchemaMgr().

{
    if (domainid != 1 || userid != 1)
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_DELETEUSERFAIL);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    domainNameToDomainIdIterator = domainNameToDomainId.find(resultVector->at(0));

    if (domainNameToDomainIdIterator == domainNameToDomainId.end())
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_DELETEUSERFAIL);
        //    replyTa(this, TOPIC_DELETEUSERFAIL, msg);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    domainid = domainNameToDomainIdIterator->second;
    domainIdToUserNamesIterator = domainIdToUserNames.find(domainid);

    if (domainIdToUserNamesIterator == domainIdToUserNames.end())
    {
        // no domainid to usernames entry, so it must have been deleted during
        // this session
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_DELETEUSERFAIL);
        //    replyTa(this, TOPIC_DELETEUSERFAIL, msg);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    domainIdToUserNamesIterator = domainIdToUserNames.find(domainid);

    if (domainIdToUserNamesIterator == domainIdToUserNames.end())
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_DELETEUSERFAIL);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    userNameToUserId = domainIdToUserNamesIterator->second;
    // check for username already
    userNameToUserId = domainIdToUserNames[domainid];
    userNameToUserIdIterator = userNameToUserId->find(resultVector->at(1));

    if (userNameToUserIdIterator == userNameToUserId->end())
    {
        // username doesn't exist
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_DELETEUSERFAIL);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    userid = userNameToUserId->at(resultVector->at(1));
    userNameToUserId->erase(resultVector->at(1));

    domainIdToUserIdsIterator = domainIdToUserIds.find(domainid);

    if (domainIdToUserIdsIterator == domainIdToUserIds.end())
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_DELETEUSERFAIL);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    userIdToPassword = domainIdToUserIdsIterator->second;
    userIdToPassword->erase(userid);

    class MessageUserSchema *msg =
        new class MessageUserSchema(TOPIC_DELETEUSEROK);
    TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
}

Here is the call graph for this function:

Here is the caller graph for this function:

int64_t UserSchemaMgr::getnextdomainid ( )

private

generate unique, ever-increasing domain identifier

Returns

next domainid

Definition at line 769 of file UserSchemaMgr.cc.

References nextdomainid.

Referenced by createdomain().

{
    return ++nextdomainid;
}

Here is the caller graph for this function:

int64_t UserSchemaMgr::getnextuserid ( int64_t  argdomainid)

private

generate unique, ever-increasing user identifier

Returns

next userid

Definition at line 774 of file UserSchemaMgr.cc.

References domainIdToNextUserId, and domainIdToNextUserIdIterator.

Referenced by createuser().

{
    domainIdToNextUserIdIterator = domainIdToNextUserId.find(argdomainid);

    if (domainIdToNextUserIdIterator == domainIdToNextUserId.end())
    {
        return -1;
    }

    domainIdToNextUserIdIterator->second =
        domainIdToNextUserIdIterator->second + 1;
    return domainIdToNextUserIdIterator->second;
}

Here is the caller graph for this function:

void UserSchemaMgr::login ( )

private

login (raw interface)

Definition at line 197 of file UserSchemaMgr.cc.

References passwordStruct::digest, domainid, domainIdToUserIds, domainIdToUserNames, domainIdToUserNamesIterator, MessageUserSchema::domainname, domainNameToDomainId, domainNameToDomainIdIterator, Message::messageStruct, msgrcv, pwdStruct, resultVector, Message::message_s::sourceAddr, userid, userIdToPassword, userIdToPasswordIterator, userNameToUserId, userNameToUserIdIterator, and TransactionAgent::usmReply().

Referenced by UserSchemaMgr().

{
    // vector: 0,1,2: domainname,username,password
    domainNameToDomainIdIterator = domainNameToDomainId.find(resultVector->at(0));

    if (domainNameToDomainIdIterator == domainNameToDomainId.end())
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_LOGINFAIL);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    int64_t did = domainNameToDomainIdIterator->second;
    // check username against
    domainIdToUserNamesIterator = domainIdToUserNames.find(did);

    if (domainIdToUserNamesIterator == domainIdToUserNames.end())
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_LOGINFAIL);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    userNameToUserId = domainIdToUserNamesIterator->second;
    userNameToUserIdIterator = userNameToUserId->find(resultVector->at(1));

    if (userNameToUserIdIterator == userNameToUserId->end())
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_LOGINFAIL);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    int64_t uid = userNameToUserIdIterator->second;
    userIdToPassword = domainIdToUserIds[did];
    userIdToPasswordIterator = userIdToPassword->find(uid);

    if (userIdToPasswordIterator == userIdToPassword->end())
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_LOGINFAIL);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    pwdStruct = userIdToPasswordIterator->second;
    byte passworddigest[64];
    SHA512().CalculateDigest(passworddigest,
                             (const byte *)resultVector->at(2).c_str(),
                             resultVector->at(2).length());

    if (memcmp(pwdStruct.digest, passworddigest, 64))
    {
        class MessageUserSchema *msg =
            new class MessageUserSchema(TOPIC_LOGINFAIL);
        TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
        return;
    }

    userid=uid;
    domainid=did;
    class MessageUserSchema *msg = new class MessageUserSchema(TOPIC_LOGINOK);
    msg->domainname=resultVector->at(0);
    TransactionAgent::usmReply(this, msgrcv->messageStruct.sourceAddr, *msg);
}

Here is the call graph for this function:

Here is the caller graph for this function:

void UserSchemaMgr::operationHandler ( class MessageUserSchema &  msgrcvref)

private

perform operation (currently only login for SQL)

Parameters

msgrcvref

received MessageUserSchema

Definition at line 788 of file UserSchemaMgr.cc.

References Topology::partitionAddress::address, MessageUserSchema::userschema_s::caller, MessageUserSchema::userschema_s::callerstate, MessageUserSchema::domainname, mboxes, Message::messageStruct, myIdentity, OPERATION_LOGIN, MessageUserSchema::userschema_s::operationid, operationLogin(), MessageUserSchema::userschema_s::operationtype, MessageUserSchema::password, Message::message_s::sourceAddr, Mboxes::toActor(), MessageUserSchema::username, and MessageUserSchema::userschemaStruct.

Referenced by UserSchemaMgr().

{
    class MessageUserSchema *replyMsg =
        new class MessageUserSchema(TOPIC_OPERATION);
    class MessageUserSchema &replyMsgRef = *replyMsg;

    switch ((operationtype_e)msgrcvref.userschemaStruct.operationtype)
    {
    case OPERATION_LOGIN:
        replyMsgRef.userschemaStruct.status =
            operationLogin(msgrcvref.username,

                           msgrcvref.domainname, msgrcvref.password,
                           &replyMsgRef.userschemaStruct.userid,
                           &replyMsgRef.userschemaStruct.domainid);
        replyMsgRef.domainname=msgrcvref.domainname;
        break;

    default:
        printf("%s %i anomaly operationtype %i\n", __FILE__, __LINE__,
               msgrcvref.userschemaStruct.operationtype);
    }

    replyMsgRef.userschemaStruct.operationid =
        msgrcvref.userschemaStruct.operationid;
    replyMsgRef.userschemaStruct.caller = msgrcvref.userschemaStruct.caller;
    replyMsgRef.userschemaStruct.callerstate =
        msgrcvref.userschemaStruct.callerstate;
    mboxes.toActor(myIdentity.address, msgrcvref.messageStruct.sourceAddr,
                   replyMsgRef);
}

Here is the call graph for this function:

Here is the caller graph for this function:

int64_t UserSchemaMgr::operationLogin ( string &  username, string &  domainname, string &  password, int64_t *  uid, int64_t *  did  )

private

login for SQL session

Parameters

username	user name
domainname	domain name (PostgreSQL dbname)
password	password (clear)
uid	userid
did	domainid

Returns

status

Definition at line 820 of file UserSchemaMgr.cc.

References passwordStruct::digest, domainIdToUserIds, domainIdToUserNames, domainNameToDomainId, pwdStruct, STATUS_NOTOK, and STATUS_OK.

Referenced by operationHandler().

{
    boost::unordered_map<std::string, int64_t>::iterator itDname2Did;
    boost::unordered_map<int64_t, userNameToUserIdMap *>::iterator itDid2Unames;
    boost::unordered_map<string, int64_t>::iterator itUname2Uid;
    boost::unordered_map<int64_t, passwordStruct>::iterator itUid2Password;

    itDname2Did = domainNameToDomainId.find(domainname);

    if (itDname2Did == domainNameToDomainId.end())
    {
        return STATUS_NOTOK;
    }

    *did = itDname2Did->second;

    itDid2Unames = domainIdToUserNames.find(*did);

    if (itDid2Unames == domainIdToUserNames.end())
    {
        return STATUS_NOTOK;
    }

    userNameToUserIdMap &uname2Uid = *itDid2Unames->second;

    itUname2Uid = uname2Uid.find(username);

    if (itUname2Uid == uname2Uid.end())
    {
        return STATUS_NOTOK;
    }

    *uid = itUname2Uid->second;

    userIdToPasswordMap &uid2Password = *domainIdToUserIds[*did];
    itUid2Password = uid2Password.find(*uid);

    if (itUid2Password == uid2Password.end())
    {
        return STATUS_NOTOK;
    }

    passwordStruct pwd = itUid2Password->second;

    byte passworddigest[64];
    SHA512().CalculateDigest(passworddigest, (const byte *)password.c_str(),
                             password.length());

    if (memcmp(pwdStruct.digest, passworddigest, 64))
    {
        return STATUS_NOTOK;
    }

    // return vals did & uid have already been set
    return STATUS_OK;
}

Here is the caller graph for this function:

Member Data Documentation

int64_t UserSchemaMgr::argsize

private

Definition at line 186 of file UserSchemaMgr.h.

Referenced by UserSchemaMgr().

int64_t UserSchemaMgr::domainid

Definition at line 71 of file UserSchemaMgr.h.

Referenced by addcolumn(), changepassword(), createdomain(), createtable(), createuser(), deletedomain(), deleteuser(), login(), and UserSchemaMgr().

REUSEMESSAGES domainidToSchemaMap UserSchemaMgr::domainidsToSchemata

Definition at line 78 of file UserSchemaMgr.h.

Referenced by addcolumn(), and createtable().

domainidToSchemaMap::iterator UserSchemaMgr::domainidsToSchemataIterator

private

Definition at line 205 of file UserSchemaMgr.h.

domainIdToNextUserIdMap UserSchemaMgr::domainIdToNextUserId

private

Definition at line 195 of file UserSchemaMgr.h.

Referenced by createdomain(), deletedomain(), getnextuserid(), and UserSchemaMgr().

domainIdToNextUserIdMap::iterator UserSchemaMgr::domainIdToNextUserIdIterator

private

Definition at line 196 of file UserSchemaMgr.h.

Referenced by getnextuserid().

domainIdToUserIdsMap UserSchemaMgr::domainIdToUserIds

private

Definition at line 193 of file UserSchemaMgr.h.

Referenced by changepassword(), createdomain(), createuser(), deletedomain(), deleteuser(), login(), operationLogin(), and UserSchemaMgr().

domainIdToUserIdsMap::iterator UserSchemaMgr::domainIdToUserIdsIterator

private

Definition at line 194 of file UserSchemaMgr.h.

Referenced by changepassword(), and deleteuser().

domainIdToUserNamesMap UserSchemaMgr::domainIdToUserNames

private

Definition at line 191 of file UserSchemaMgr.h.

Referenced by createdomain(), createuser(), deletedomain(), deleteuser(), login(), operationLogin(), and UserSchemaMgr().

domainIdToUserNamesMap::iterator UserSchemaMgr::domainIdToUserNamesIterator

private

Definition at line 192 of file UserSchemaMgr.h.

Referenced by createuser(), deleteuser(), and login().

domainNameToDomainIdMap UserSchemaMgr::domainNameToDomainId

private

Definition at line 189 of file UserSchemaMgr.h.

Referenced by createdomain(), createuser(), deletedomain(), deleteuser(), login(), operationLogin(), and UserSchemaMgr().

domainNameToDomainIdMap::iterator UserSchemaMgr::domainNameToDomainIdIterator

private

Definition at line 190 of file UserSchemaMgr.h.

Referenced by createdomain(), createuser(), deletedomain(), deleteuser(), and login().

boost::unordered_map<std::string, fieldtype_e> UserSchemaMgr::fieldTypeMap

private

Definition at line 206 of file UserSchemaMgr.h.

Referenced by addcolumn(), and UserSchemaMgr().

boost::unordered_map<std::string, indextype_e> UserSchemaMgr::indexTypeMap

private

Definition at line 207 of file UserSchemaMgr.h.

Referenced by addcolumn(), and UserSchemaMgr().

int64_t UserSchemaMgr::instance

private

Definition at line 187 of file UserSchemaMgr.h.

class Mboxes UserSchemaMgr::mboxes

Definition at line 79 of file UserSchemaMgr.h.

Referenced by operationHandler(), and UserSchemaMgr().

class Message* UserSchemaMgr::msgrcv

Definition at line 76 of file UserSchemaMgr.h.

Referenced by addcolumn(), changepassword(), createdomain(), createschema(), createtable(), createuser(), deletedomain(), deleteindex(), deleteschema(), deletetable(), deleteuser(), login(), and UserSchemaMgr().

class Message* UserSchemaMgr::msgsnd

Definition at line 69 of file UserSchemaMgr.h.

Referenced by UserSchemaMgr().

Topology::partitionAddress UserSchemaMgr::myIdentity

Definition at line 80 of file UserSchemaMgr.h.

Referenced by operationHandler(), and UserSchemaMgr().

class Mbox* UserSchemaMgr::mymboxPtr

private

Definition at line 188 of file UserSchemaMgr.h.

class Topology UserSchemaMgr::myTopology

private

Definition at line 83 of file UserSchemaMgr.h.

Referenced by UserSchemaMgr().

int64_t UserSchemaMgr::nextdomainid

private

Definition at line 204 of file UserSchemaMgr.h.

Referenced by getnextdomainid(), and UserSchemaMgr().

int64_t UserSchemaMgr::operationid

Definition at line 70 of file UserSchemaMgr.h.

Referenced by UserSchemaMgr().

passwordStruct UserSchemaMgr::pwdStruct

private

Definition at line 201 of file UserSchemaMgr.h.

Referenced by createuser(), login(), operationLogin(), and UserSchemaMgr().

passwordStruct* UserSchemaMgr::pwdStructPtr

private

Definition at line 202 of file UserSchemaMgr.h.

std::vector<std::string>* UserSchemaMgr::resultVector

private

Definition at line 203 of file UserSchemaMgr.h.

Referenced by addcolumn(), changepassword(), createdomain(), createtable(), createuser(), deletedomain(), deleteuser(), login(), and UserSchemaMgr().

int64_t UserSchemaMgr::status

Definition at line 73 of file UserSchemaMgr.h.

Referenced by addcolumn(), createtable(), deleteindex(), deleteschema(), and deletetable().

int64_t UserSchemaMgr::tainstance

Definition at line 74 of file UserSchemaMgr.h.

Referenced by UserSchemaMgr().

int64_t UserSchemaMgr::userid

Definition at line 72 of file UserSchemaMgr.h.

Referenced by changepassword(), createdomain(), createuser(), deletedomain(), deleteuser(), login(), and UserSchemaMgr().

userIdToPasswordMap* UserSchemaMgr::userIdToPassword

private

Definition at line 199 of file UserSchemaMgr.h.

Referenced by changepassword(), createuser(), deleteuser(), and login().

userIdToPasswordMap::iterator UserSchemaMgr::userIdToPasswordIterator

private

Definition at line 200 of file UserSchemaMgr.h.

Referenced by changepassword(), and login().

userNameToUserIdMap* UserSchemaMgr::userNameToUserId

private

Definition at line 197 of file UserSchemaMgr.h.

Referenced by createuser(), deleteuser(), and login().

userNameToUserIdMap::iterator UserSchemaMgr::userNameToUserIdIterator

private

Definition at line 198 of file UserSchemaMgr.h.

Referenced by createuser(), deleteuser(), and login().

---

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

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