CAAccountingDBInterface Class Reference

#include <CAAccountingDBInterface.hpp>

Collaboration diagram for CAAccountingDBInterface:

Public Member Functions
SINT32	storeCostConfirmation (CAXMLCostConfirmation &cc, UINT8 *ccCascade)
	Creates the tables we need in the DB. More...
SINT32	getCostConfirmation (UINT64 accountNumber, UINT8 *cascadeId, CAXMLCostConfirmation **pCC, bool &a_bSettled)
SINT32	getUnsettledCostConfirmations (CAXMLCostConfirmation ***resultCCs, UINT8 *cascadeId, UINT32 *nrOfCCs, UINT32 a_maxCCs)
	Fills the CAQueue with all non-settled cost confirmations. More...
SINT32	markAsSettled (UINT64 accountNumber, UINT8 *cascadeId, UINT64 a_transferredBytes)
	Marks this account as settled. More...
SINT32	deleteCC (UINT64 accountNumber, UINT8 *cascadeId)
	if the BI reports an error while trying to settle a CC, this will be called to delete it from the database (otherwise the AI would try forever in vain to settle the unusable CC) More...
SINT32	storePrepaidAmount (UINT64 accountNumber, SINT32 prepaidBytes, UINT8 *cascadeId)
SINT32	getPrepaidAmount (UINT64 accountNumber, UINT8 *cascadeId, bool a_bDelete)
SINT32	storeAccountStatus (UINT64 a_accountNumber, UINT32 a_statusCode)
SINT32	getAccountStatus (UINT64 a_accountNumber, UINT32 &a_statusCode)
SINT32	clearAccountStatus (UINT64 a_accountNumber)
SINT32	checkCountAllQuery (UINT8 *a_query, UINT32 &r_count)
	Takes and executes a query that counts databae records and tests if the result is valid. More...

Static Public Member Functions
static CAAccountingDBInterface *	getConnection ()
static SINT32	releaseConnection (CAAccountingDBInterface *dbIf)
static SINT32	init ()
static SINT32	cleanup ()

Private Member Functions
	CAAccountingDBInterface ()
	Constructor. More...
	~CAAccountingDBInterface ()
	Destructor. More...
SINT32	__storeCostConfirmation (CAXMLCostConfirmation &cc, UINT8 *ccCascade)
	stores a cost confirmation in the DB More...
SINT32	__getCostConfirmation (UINT64 accountNumber, UINT8 *cascadeId, CAXMLCostConfirmation **pCC, bool &a_bSettled)
	Gets the latest cost confirmation stored for the given user account. More...
SINT32	__getUnsettledCostConfirmations (CAXMLCostConfirmation ***resultCCs, UINT8 *cascadeId, UINT32 *nrOfCCs, UINT32 a_maxCCs)
	Fills the CAQueue with pointer to all non-settled cost confirmations. More...
SINT32	__markAsSettled (UINT64 accountNumber, UINT8 *cascadeId, UINT64 a_transferredBytes)
	Marks this account as settled. More...
SINT32	__deleteCC (UINT64 accountNumber, UINT8 *cascadeId)
SINT32	__storePrepaidAmount (UINT64 accountNumber, SINT32 prepaidBytes, UINT8 *cascadeId)
SINT32	__getPrepaidAmount (UINT64 accountNumber, UINT8 *cascadeId, bool a_bDelete)
SINT32	__storeAccountStatus (UINT64 a_accountNumber, UINT32 a_statusCode)
SINT32	__getAccountStatus (UINT64 a_accountNumber, UINT32 &a_statusCode)
SINT32	__clearAccountStatus (UINT64 a_accountNumber)
SINT32	__checkCountAllQuery (UINT8 *a_query, UINT32 &r_count)
SINT32	initDBConnection ()
	Initiates the database connection. More...
SINT32	terminateDBConnection ()
	Terminates the database connection. More...
bool	isDBConnected ()
bool	checkConnectionStatus ()
	Checks if the connection still exists and tries to reconnect if not. More...
bool	checkOwner ()
bool	testAndSetOwner ()
bool	testAndResetOwner ()
PGresult *	monitored_PQexec (PGconn *conn, const char *query)

Private Attributes
PGconn *	m_dbConn
	connection to postgreSQL database More...
bool	m_bConnected
volatile thread_id_t	m_owner
volatile bool	m_free
int	m_protocolVersion
CAMutex *	m_pConnectionMutex

Static Private Attributes
static CAConditionVariable *	ms_pConnectionAvailable = NULL
static volatile UINT64	ms_threadWaitNr = 0
static volatile UINT64	ms_nextThreadNr = 0
static CAAccountingDBInterface *	ms_pDBConnectionPool []

Friends
class	CAAccountingInstance

Detailed Description

Author

Bastian Voigt

This class is used to store cost confirmations in a postgresql database

Definition at line 54 of file CAAccountingDBInterface.hpp.

Constructor & Destructor Documentation

CAAccountingDBInterface()

CAAccountingDBInterface::CAAccountingDBInterface ( )

private

Constructor.

Definition at line 45 of file CAAccountingDBInterface.cpp.

  {
    m_bConnected = false;
    m_dbConn=NULL;/* The owner of the connection */
    m_owner = 0;
    /* indicates whether this connection is not owned by a thread.
     * (There is no reliable value of m_owner to indicate this).
     */
    m_free = true;
    /* to ensure atomic access to m_owner and m_free */
    m_pConnectionMutex = new CAMutex();
  }

References m_bConnected, m_dbConn, m_free, m_owner, and m_pConnectionMutex.

Referenced by init().

Here is the caller graph for this function:

~CAAccountingDBInterface()

CAAccountingDBInterface::~CAAccountingDBInterface ( )

private

Destructor.

Definition at line 62 of file CAAccountingDBInterface.cpp.

  {
    terminateDBConnection();
    delete m_pConnectionMutex;
    m_pConnectionMutex = NULL;
  }

References m_pConnectionMutex, and terminateDBConnection().

Here is the call graph for this function:

Member Function Documentation

__checkCountAllQuery()

SINT32 CAAccountingDBInterface::__checkCountAllQuery ( UINT8 *  a_query, UINT32 &  r_count  )

private

Definition at line 295 of file CAAccountingDBInterface.cpp.

{
  r_count = 0;
 
  if (!a_query)
  {
    return E_UNKNOWN;
  }
  /*
  if(!checkConnectionStatus())
  {
    MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionFailure);
    return E_NOT_CONNECTED;
  }
  MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionSuccess);
  */
  PGresult * pResult = monitored_PQexec(m_dbConn, (char*)a_query);
 
  if(PQresultStatus(pResult) != PGRES_TUPLES_OK)
  {
    CAMsg::printMsg(LOG_ERR,
            "CAAccountingDBInterface: Database Error '%s' while processing query '%s'\n",
            PQresultErrorMessage(pResult), a_query
            );
    PQclear(pResult);
    return E_UNKNOWN;
  }
 
  if ( (PQntuples(pResult) != 1) || (PQgetisnull(pResult, 0, 0)))
  {
    CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: Wrong number of tuples or null value\n");
    PQclear(pResult);
    return E_UNKNOWN;
  }
 
  r_count = atoi(PQgetvalue(pResult, 0, 0));
  PQclear(pResult);
  return E_SUCCESS;
}

References E_SUCCESS, E_UNKNOWN, m_dbConn, monitored_PQexec(), and CAMsg::printMsg().

Referenced by __storeAccountStatus(), __storeCostConfirmation(), __storePrepaidAmount(), and checkCountAllQuery().

Here is the call graph for this function:

Here is the caller graph for this function:

__clearAccountStatus()

SINT32 CAAccountingDBInterface::__clearAccountStatus ( UINT64  a_accountNumber )

private

Definition at line 913 of file CAAccountingDBInterface.cpp.

  {
    SINT32 ret = E_SUCCESS;
    PGresult* result = NULL;
    size_t queryMaxLen = strlen(STMT_CLEAR_ACCOUNT_STATUS) + ACCOUNT_NUMBER_SIZE; //accountnumber has exactly 12 digits
    char* clearAccountStatusStmt=new char[queryMaxLen+1];
    memset(clearAccountStatusStmt, 0, queryMaxLen+1);
 
    if( (a_accountNumber > MAX_ACCOUNTNUMBER) &&
      (a_accountNumber < MIN_ACCOUNTNUMBER) )
    {
      CAMsg::printMsg(LOG_DEBUG, "Cannot clear account status: accountnumber &llu is invalid.\n",
          a_accountNumber);
      delete[] clearAccountStatusStmt;
      return E_UNKNOWN;
    }
    snprintf(clearAccountStatusStmt, queryMaxLen, STMT_CLEAR_ACCOUNT_STATUS, a_accountNumber);
    result = monitored_PQexec(m_dbConn, clearAccountStatusStmt);
    if(result != NULL)
    {
      if (PQresultStatus(result) != PGRES_COMMAND_OK)
      {
        CAMsg::printMsg(LOG_DEBUG, "Clearing accountstatus for account %llu failed.\n", a_accountNumber);
        ret = E_UNKNOWN;
      }
      PQclear(result);
      delete[] clearAccountStatusStmt;
      return ret;
    }
    delete[] clearAccountStatusStmt;
    CAMsg::printMsg(LOG_DEBUG, "Clearing accountstatus for account %llu failed.\n", a_accountNumber);
    return E_UNKNOWN;
  }

References ACCOUNT_NUMBER_SIZE, E_SUCCESS, E_UNKNOWN, m_dbConn, MAX_ACCOUNTNUMBER, MIN_ACCOUNTNUMBER, monitored_PQexec(), CAMsg::printMsg(), and STMT_CLEAR_ACCOUNT_STATUS.

Referenced by clearAccountStatus().

Here is the call graph for this function:

Here is the caller graph for this function:

__deleteCC()

SINT32 CAAccountingDBInterface::__deleteCC ( UINT64  accountNumber, UINT8 *  cascadeId  )

private

Definition at line 596 of file CAAccountingDBInterface.cpp.

{
  const char* deleteQuery = "DELETE FROM COSTCONFIRMATIONS WHERE ACCOUNTNUMBER = %s AND CASCADE='%s'";
  UINT8* finalQuery;
  PGresult* result;
  SINT32 ret;
  UINT8 temp[32];
  print64(temp,accountNumber);
 
  if (!checkConnectionStatus())
  {
    MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionFailure);
    ret = E_NOT_CONNECTED;
  }
  else
  {
    MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionSuccess);
 
    finalQuery = new UINT8[strlen(deleteQuery)+ 32 + strlen((char*)cascadeId)];
    sprintf((char *)finalQuery,deleteQuery,temp, cascadeId);
    result = monitored_PQexec(m_dbConn, (char*)finalQuery);
 
    //CAMsg::printMsg(LOG_DEBUG, "%s\n",finalQuery);
    delete[] finalQuery;
    finalQuery = NULL;
    if (PQresultStatus(result) != PGRES_COMMAND_OK)
    {
      PQclear(result);
      ret = E_UNKNOWN;
    }
    else
    {
      PQclear(result);
      ret = E_SUCCESS;
    }
  }
 
  if (ret == E_SUCCESS)
  {
    CAMsg::printMsg(LOG_INFO, "CAAccountingDBInterface: Costconfirmation for account %s was deleted!\n", temp);
  }
  else
  {
    CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: Could not delete account %s!\n", temp);
  }
 
  return ret;
}

References checkConnectionStatus(), E_NOT_CONNECTED, E_SUCCESS, E_UNKNOWN, m_dbConn, monitored_PQexec(), MONITORING_FIRE_PAY_EVENT, print64(), and CAMsg::printMsg().

Referenced by deleteCC().

Here is the call graph for this function:

Here is the caller graph for this function:

__getAccountStatus()

SINT32 CAAccountingDBInterface::__getAccountStatus ( UINT64  a_accountNumber, UINT32 &  a_statusCode  )

private

Definition at line 962 of file CAAccountingDBInterface.cpp.

  {
    const char* selectQuery = "SELECT STATUSCODE FROM ACCOUNTSTATUS WHERE ACCOUNTNUMBER = %s";
    PGresult* result;
    UINT8* finalQuery;
    UINT8 accountNumberAsString[32];
    print64(accountNumberAsString,accountNumber);
 
    if(!checkConnectionStatus())
    {
      MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionFailure);
      return E_NOT_CONNECTED;
    }
    MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionSuccess);
 
    a_statusCode =  CAXMLErrorMessage::ERR_OK;
 
    finalQuery = new UINT8[strlen(selectQuery) + 32];
    sprintf( (char *)finalQuery, selectQuery, accountNumberAsString);
    result = monitored_PQexec(m_dbConn, (char *)finalQuery);
 
    delete[] finalQuery;
    finalQuery = NULL;
    if(PQresultStatus(result)!=PGRES_TUPLES_OK)
    {
      CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: Database error while trying to read account status, Reason: %s\n", PQresultErrorMessage(result));
      PQclear(result);
      return E_UNKNOWN;
    }
 
    if(PQntuples(result) == 1)
    {
      int statusCodeIndex = PQfnumber(result,"STATUSCODE");
      //int expiresIndex = PQfnumber(result,"EXPIRES");
      if(statusCodeIndex != -1 )
      {
        a_statusCode = atoi(PQgetvalue(result, 0, statusCodeIndex)); //first row, first column
      }
      else
      {
        CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: no status code found while reading account status\n");
      }
 
      /*if(expiresIndex != -1)
      {
        expires = strncpy(expires, (const char*)PQgetvalue(result, 0, expiresIndex), 10);
      }
      else
      {
        CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: no expire date found while reading account status\n");
      }*/
    }
 
    PQclear(result);
 
    return E_SUCCESS;
  }

References checkConnectionStatus(), E_NOT_CONNECTED, E_SUCCESS, E_UNKNOWN, CAXMLErrorMessage::ERR_OK, m_dbConn, monitored_PQexec(), MONITORING_FIRE_PAY_EVENT, print64(), and CAMsg::printMsg().

Referenced by getAccountStatus().

Here is the call graph for this function:

Here is the caller graph for this function:

__getCostConfirmation()

SINT32 CAAccountingDBInterface::__getCostConfirmation ( UINT64  accountNumber, UINT8 *  cascadeId, CAXMLCostConfirmation **  pCC, bool &  a_bSettled  )

private

Gets the latest cost confirmation stored for the given user account.

Parameters

accountNumber	the account for which the cost confirmation is requested
pCC	on return contains a pointer to the Cost confirmation (the caller is responsible for deleting this object), NULL in case of an error

Return values

E_SUCCESS,if	everything is OK
E_NOT_CONNECTED,if	the DB query could not be executed
E_NOT_FOUND,if	there was no XMLCC found
E_UNKOWN	in case of a general error

Definition at line 218 of file CAAccountingDBInterface.cpp.

  {
    if(!checkConnectionStatus())
    {
      /* We assume, that the DB Connection was obtained by CAAccountingDBInterface::getConnnection
       *  which shall return an established DBConnection. Therefore this is an error event
       */
      MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionFailure);
      return E_NOT_CONNECTED;
    }
 
    const char* queryF = "SELECT XMLCC, SETTLED FROM COSTCONFIRMATIONS WHERE ACCOUNTNUMBER=%s AND CASCADE='%s'";
    UINT8* query;
    UINT8* xmlCC;
    PGresult* result;
    UINT8 tmp[32];
    print64(tmp,accountNumber);
 
    query = new UINT8[strlen(queryF) + 32 + strlen((char*)cascadeId)];
    sprintf( (char *)query, queryF, tmp, cascadeId);
    #ifdef DEBUG
      CAMsg::printMsg(LOG_DEBUG, "CAAccountingDBInterface: executing query %s\n", query);
    #endif
 
    result = monitored_PQexec(m_dbConn, (char *)query);
 
    delete[] query;
    query = NULL;
    if(PQresultStatus(result)!=PGRES_TUPLES_OK)
    {
      CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: Could not read XMLCC. Reason: %s\n",
      PQresultErrorMessage(result));
      PQclear(result);
      return E_UNKNOWN;
    }
 
    if(PQntuples(result)!=1)
    {
      #ifdef DEBUG
        CAMsg::printMsg(LOG_DEBUG, "CAAccountingDBInterface: XMLCC not found.\n");
      #endif
      PQclear(result);
      return E_NOT_FOUND;
    }
 
    xmlCC = (UINT8*) PQgetvalue(result, 0, 0);
    if (atoi(PQgetvalue(result, 0, 1)) == 0)
    {
      a_bSettled = false;
    }
    else
    {
      a_bSettled = true;
    }
 
    *pCC = CAXMLCostConfirmation::getInstance(xmlCC,strlen((char*)xmlCC));
    PQclear(result);
 
    if(*pCC==NULL)
    {
      return E_UNKNOWN;
    }
    return E_SUCCESS;
  }

References checkConnectionStatus(), E_NOT_CONNECTED, E_NOT_FOUND, E_SUCCESS, E_UNKNOWN, m_dbConn, monitored_PQexec(), MONITORING_FIRE_PAY_EVENT, print64(), and CAMsg::printMsg().

Referenced by getCostConfirmation().

Here is the call graph for this function:

Here is the caller graph for this function:

__getPrepaidAmount()

SINT32 CAAccountingDBInterface::__getPrepaidAmount ( UINT64  accountNumber, UINT8 *  cascadeId, bool  a_bDelete  )

private

Definition at line 753 of file CAAccountingDBInterface.cpp.

  {
    //check for an entry for this accountnumber
    const char* selectQuery = "SELECT PREPAIDBYTES FROM PREPAIDAMOUNTS WHERE ACCOUNTNUMBER=%s AND CASCADE='%s'";
    PGresult* result;
    UINT8* finalQuery;
    UINT8 accountNumberAsString[32];
    print64(accountNumberAsString,accountNumber);
 
    if(!checkConnectionStatus())
    {
      MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionFailure);
      return E_NOT_CONNECTED;
    }
    MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionSuccess);
 
    finalQuery = new UINT8[strlen(selectQuery) + 32 + strlen((char*)cascadeId)];
    sprintf( (char *)finalQuery, selectQuery, accountNumberAsString, cascadeId);
    result = monitored_PQexec(m_dbConn, (char *)finalQuery);
 
    if(PQresultStatus(result)!=PGRES_TUPLES_OK)
    {
      CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: Database error while trying to read prepaid bytes, Reason: %s\n", PQresultErrorMessage(result));
      PQclear(result);
      delete[] finalQuery;
      finalQuery = NULL;
      return E_UNKNOWN;
    }
 
    if(PQntuples(result)!=1)
    {
      //perfectly normal, the user account simply hasnt been used with this cascade yet
      PQclear(result);
      delete[] finalQuery;
      finalQuery = NULL;
      return 0;
    }
    SINT32 nrOfBytes =  atoi(PQgetvalue(result, 0, 0)); //first row, first column
    PQclear(result);
 
    if (a_bDelete)
    {
      //delete entry from db
      const char* deleteQuery = "DELETE FROM PREPAIDAMOUNTS WHERE ACCOUNTNUMBER=%s AND CASCADE='%s' ";
      PGresult* result2;
      print64(accountNumberAsString,accountNumber);
      sprintf( (char *)finalQuery, deleteQuery, accountNumberAsString, cascadeId);
 
      result2 = monitored_PQexec(m_dbConn, (char *)finalQuery);
 
      if (PQresultStatus(result2) != PGRES_COMMAND_OK)
      {
        CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: Deleting read prepaidamount failed.");
      }
      PQclear(result2);
    }
 
    delete[] finalQuery;
    finalQuery = NULL;
 
    return nrOfBytes;
  }

References checkConnectionStatus(), E_NOT_CONNECTED, E_UNKNOWN, m_dbConn, monitored_PQexec(), MONITORING_FIRE_PAY_EVENT, print64(), and CAMsg::printMsg().

Referenced by getPrepaidAmount().

Here is the call graph for this function:

Here is the caller graph for this function:

__getUnsettledCostConfirmations()

SINT32 CAAccountingDBInterface::__getUnsettledCostConfirmations ( CAXMLCostConfirmation ***  resultCCs, UINT8 *  cascadeId, UINT32 *  nrOfCCs, UINT32  a_maxCCs  )

private

Fills the CAQueue with pointer to all non-settled cost confirmations.

The caller is responsible for deleating this cost confirmations.

Return values

E_NOT_CONNECTED	if a connection to the DB could not be established
E_UNKNOWN	in case of a general error
E_SUCCESS	: database operation completed successfully (but queue might still be empty if there were no unsettled cost confirmation to find). Param: cascadeId : String identifier of a cascade for which to return the cost confirmations (concatenated hashes of all the cascade's mixes' price certs)

Definition at line 471 of file CAAccountingDBInterface.cpp.

  {
    const char* query= "SELECT XMLCC FROM COSTCONFIRMATIONS WHERE SETTLED=0 AND CASCADE = '%s' LIMIT %u";
    UINT8* finalQuery;
    PGresult* result;
    SINT32 numTuples, i;
    UINT8* pTmpStr;
    CAXMLCostConfirmation* pCC;
 
    if(!checkConnectionStatus())
    {
      MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionFailure);
      return E_NOT_CONNECTED;
    }
    MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionSuccess);
 
    finalQuery = new UINT8[strlen(query)+strlen((char*)cascadeId)];
    sprintf( (char*)finalQuery, query, cascadeId, a_maxCCs);
 
#ifdef DEBUG
    CAMsg::printMsg(LOG_DEBUG, "Getting Cost confirmations for cascade: ");
    CAMsg::printMsg(LOG_DEBUG, (const char*) finalQuery);
#endif
 
    result = monitored_PQexec(m_dbConn, (char *)finalQuery);
 
    delete[] finalQuery;
    finalQuery = NULL;
    if(PQresultStatus(result) != PGRES_TUPLES_OK)
    {
      PQclear(result);
      return E_UNKNOWN;
    }
    numTuples = PQntuples(result);
    *nrOfCCs = numTuples;
 
    if(numTuples > 0)
    {
 
      *resultCCs = new CAXMLCostConfirmation *[numTuples];
      i = 0;
      while(i < *nrOfCCs)
      {
        pTmpStr = (UINT8*) PQgetvalue(result, i, 0);
        if( (pTmpStr!=NULL)&&
            ( (pCC = CAXMLCostConfirmation::getInstance(pTmpStr,strlen((char*)pTmpStr)) )!=NULL))
        {
          (*resultCCs)[i] = pCC;
          i++;
        }
        else
        {
          //ok, in this case we reserved a bit too much memory, but it is very unlikely and if it would happen
          //there is no need to worry about it.
          (*nrOfCCs)--;
        }
      }
    }
    PQclear(result);
 
    //CAMsg::printMsg(LOG_DEBUG, "Stop get unsettled CC\n");
    return E_SUCCESS;
  }

References checkConnectionStatus(), E_NOT_CONNECTED, E_SUCCESS, E_UNKNOWN, m_dbConn, monitored_PQexec(), MONITORING_FIRE_PAY_EVENT, and CAMsg::printMsg().

Referenced by getUnsettledCostConfirmations().

Here is the call graph for this function:

Here is the caller graph for this function:

__markAsSettled()

SINT32 CAAccountingDBInterface::__markAsSettled ( UINT64  accountNumber, UINT8 *  cascadeId, UINT64  a_transferredBytes  )

private

Marks this account as settled.

Todo:

what to do if there was a new CC stored while we were busy settling the old one?

Return values

E_NOT_CONNECTED	if a connection to the DB could not be established
E_UNKNOWN	in case of a general error

Definition at line 552 of file CAAccountingDBInterface.cpp.

  {
    const char* queryF = "UPDATE COSTCONFIRMATIONS SET SETTLED=1 WHERE ACCOUNTNUMBER=%s AND BYTES=%s AND CASCADE='%s'";
    UINT8 * query;
    PGresult * result;
 
    if(!checkConnectionStatus())
    {
      MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionFailure);
      return E_NOT_CONNECTED;
    }
    MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionSuccess);
 
    UINT8 tmp[32], tmp2[32];
    print64(tmp,accountNumber);
    print64(tmp2,a_transferredBytes);
    query = new UINT8[strlen(queryF) + 32 + 32 + strlen((char*)cascadeId)];
    sprintf((char *)query, queryF, tmp, tmp2, cascadeId);
    result = monitored_PQexec(m_dbConn, (char *)query);
 
    delete[] query;
    query = NULL;
    if(PQresultStatus(result) != PGRES_COMMAND_OK)
      {
        PQclear(result);
        return E_UNKNOWN;
      }
    PQclear(result);
 
    return E_SUCCESS;
  }

References checkConnectionStatus(), E_NOT_CONNECTED, E_SUCCESS, E_UNKNOWN, m_dbConn, monitored_PQexec(), MONITORING_FIRE_PAY_EVENT, and print64().

Referenced by markAsSettled().

Here is the call graph for this function:

Here is the caller graph for this function:

__storeAccountStatus()

SINT32 CAAccountingDBInterface::__storeAccountStatus ( UINT64  a_accountNumber, UINT32  a_statusCode  )

private

Definition at line 830 of file CAAccountingDBInterface.cpp.

{
  const char* previousStatusQuery = "SELECT COUNT(*) FROM ACCOUNTSTATUS WHERE ACCOUNTNUMBER='%s' ";
  //reverse order of columns, so insertQuery and updateQuery can be used with the same sprintf parameters
  const char* insertQuery         = "INSERT INTO ACCOUNTSTATUS(STATUSCODE,ACCOUNTNUMBER) VALUES ('%u', '%s')";
  const char* updateQuery         = "UPDATE ACCOUNTSTATUS SET STATUSCODE=%u WHERE ACCOUNTNUMBER=%s";
  const char* query;
 
  PGresult* result;
  UINT8* finalQuery;
  UINT8 tmp[32];
  UINT32 len;
  UINT32 count;
  print64(tmp,accountNumber);
 
  if(!checkConnectionStatus())
  {
    MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionFailure);
    return E_NOT_CONNECTED;
  }
  MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionSuccess);
 
  len = max(strlen(previousStatusQuery), strlen(insertQuery));
  len = max(len, strlen(updateQuery));
  finalQuery = new UINT8[len + 32 + 32 + 32];
  sprintf( (char *)finalQuery, previousStatusQuery, tmp);
 
  if (__checkCountAllQuery(finalQuery, count) != E_SUCCESS)
  {
    delete[] finalQuery;
    finalQuery = NULL;
    return E_UNKNOWN;
  }
 
  // put query together (either insert or update)
  if(count == 0)
  {
    query = insertQuery;
  }
  else
  {
    query = updateQuery;
  }
  sprintf((char*)finalQuery, query, statuscode, tmp);
  result = monitored_PQexec(m_dbConn, (char *)finalQuery);
 
  if (PQresultStatus(result) != PGRES_COMMAND_OK) // || PQntuples(result) != 1)
  {
    CAMsg::printMsg(LOG_ERR, "CAAccountungDBInterface: Saving the account status failed!\n");
    //if (PQresultStatus(result) != PGRES_COMMAND_OK)
    {
      CAMsg::printMsg(LOG_ERR,
              "Database Error '%s' while processing query '%s'\n",
              PQresultErrorMessage(result), finalQuery
              );
    }
    delete[] finalQuery;
    finalQuery = NULL;
    if (result)
    {
      PQclear(result);
    }
    return E_UNKNOWN;
  }
  delete[] finalQuery;
  finalQuery = NULL;
  PQclear(result);
  CAMsg::printMsg(LOG_DEBUG, "Stored status code %u for account nr. %s \n",statuscode, tmp);
  return E_SUCCESS;
}

References __checkCountAllQuery(), checkConnectionStatus(), E_NOT_CONNECTED, E_SUCCESS, E_UNKNOWN, len, m_dbConn, max, monitored_PQexec(), MONITORING_FIRE_PAY_EVENT, print64(), and CAMsg::printMsg().

Referenced by storeAccountStatus().

Here is the call graph for this function:

Here is the caller graph for this function:

__storeCostConfirmation()

SINT32 CAAccountingDBInterface::__storeCostConfirmation ( CAXMLCostConfirmation &  cc, UINT8 *  ccCascade  )

private

stores a cost confirmation in the DB

Todo:

optimize - maybe do check and insert/update in one step??

Definition at line 352 of file CAAccountingDBInterface.cpp.

  {
    #ifndef HAVE_NATIVE_UINT64
      #warning Native UINT64 type not available - CostConfirmation Database might be non-functional
    #endif
    const char* previousCCQuery = "SELECT COUNT(*) FROM COSTCONFIRMATIONS WHERE ACCOUNTNUMBER='%s' AND CASCADE='%s'";
    const char* query2F =         "INSERT INTO COSTCONFIRMATIONS(BYTES, XMLCC, SETTLED, ACCOUNTNUMBER, CASCADE) VALUES ('%s', '%s', '%d', '%s', '%s')";
    const char* query3F =         "UPDATE COSTCONFIRMATIONS SET BYTES='%s', XMLCC='%s', SETTLED='%d' WHERE ACCOUNTNUMBER='%s' AND CASCADE='%s'";
    const char* tempQuery;
 
    UINT8 * query;
    UINT8 * pStrCC;
    UINT32 size;
    UINT32 len;
    UINT32 count;
    PGresult * pResult;
    UINT8 strAccountNumber[32];
    UINT8 tmp[32];
 
    if(!checkConnectionStatus())
    {
      MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionFailure);
      return E_NOT_CONNECTED;
    }
    MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionSuccess);
 
    pStrCC = new UINT8[8192];
    size=8192;
    if(cc.toXMLString(pStrCC, &size)!=E_SUCCESS)
    {
      CAMsg::printMsg(LOG_DEBUG, "CAAccountingInstanceDBInterface: Could not transform CC to XML string!\n");
      delete[] pStrCC;
      pStrCC = NULL;
      return E_UNKNOWN;
    }
 
#ifdef DEBUG
    CAMsg::printMsg(LOG_DEBUG, "cc to store in  db:%s\n",pStrCC);
#endif
 
    // Test: is there already an entry with this accountno. for the same cascade?
    len = max(strlen(previousCCQuery), strlen(query2F));
    len = max(len, strlen(query3F));
    query = new UINT8[len + 32 + 32 + 1 + size + strlen((char*)ccCascade)];
    print64(strAccountNumber,cc.getAccountNumber());
    sprintf( (char*)query, previousCCQuery, strAccountNumber, ccCascade);
 
    // to receive result in binary format...
    if (__checkCountAllQuery(query, count) != E_SUCCESS)
    {
      delete[] pStrCC;
      pStrCC = NULL;
      delete[] query;
      query = NULL;
      return E_UNKNOWN;
    }
 
    // put query together (either insert or update)
    print64(tmp,cc.getTransferredBytes());
    if(count == 0)
    {
      tempQuery = query2F; // do insert
    }
    else
    {
      tempQuery = query3F; // do update
    }
    sprintf((char*)query, tempQuery, tmp, pStrCC, 0, strAccountNumber, ccCascade);
 
    // issue query..
    pResult = monitored_PQexec(m_dbConn, (char*)query);
 
    delete[] pStrCC;
    pStrCC = NULL;
    if(PQresultStatus(pResult) != PGRES_COMMAND_OK) // || PQntuples(pResult) != 1)
    {
      CAMsg::printMsg(LOG_ERR, "Could not store CC!\n");
      //if (PQresultStatus(pResult) != PGRES_COMMAND_OK)
      {
        CAMsg::printMsg(LOG_ERR,
                "Database message '%s' while processing query '%s'\n",
                PQresultErrorMessage(pResult), query
                );
      }
      delete[] query;
      query = NULL;
      PQclear(pResult);
      return E_UNKNOWN;
    }
    delete[] query;
    query = NULL;
    PQclear(pResult);
 
    #ifdef DEBUG
    CAMsg::printMsg(LOG_DEBUG, "CAAccountingInstanceDBInterface: Finished storing CC in DB.\n");
    #endif
    return E_SUCCESS;
  }

References __checkCountAllQuery(), checkConnectionStatus(), E_NOT_CONNECTED, E_SUCCESS, E_UNKNOWN, len, m_dbConn, max, monitored_PQexec(), MONITORING_FIRE_PAY_EVENT, print64(), and CAMsg::printMsg().

Referenced by storeCostConfirmation().

Here is the call graph for this function:

Here is the caller graph for this function:

__storePrepaidAmount()

SINT32 CAAccountingDBInterface::__storePrepaidAmount ( UINT64  accountNumber, SINT32  prepaidBytes, UINT8 *  cascadeId  )

private

Definition at line 659 of file CAAccountingDBInterface.cpp.

{
  const char* selectQuery = "SELECT COUNT(*) FROM PREPAIDAMOUNTS WHERE ACCOUNTNUMBER=%s AND CASCADE='%s'";
  const char* insertQuery = "INSERT INTO PREPAIDAMOUNTS(PREPAIDBYTES, ACCOUNTNUMBER, CASCADE) VALUES (%d, %s, '%s')";
  const char* updateQuery = "UPDATE PREPAIDAMOUNTS SET PREPAIDBYTES=%d WHERE ACCOUNTNUMBER=%s AND CASCADE='%s'";
  //const char* deleteQuery = "DELETE FROM PREPAIDAMOUNTS WHERE ACCOUNTNUMBER = %s AND CASCADE='%s'";
  const char* query;
 
  PGresult* result;
  UINT8* finalQuery;
  UINT8 tmp[32];
  UINT32 len;
  UINT32 count;
  print64(tmp,accountNumber);
 
  if(!checkConnectionStatus())
  {
    MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionFailure);
    return E_NOT_CONNECTED;
  }
 
  MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionSuccess);
 
  len = max(strlen(selectQuery), strlen(insertQuery));
  len = max(len, strlen(updateQuery));
  finalQuery = new UINT8[len + 32 + 32 + strlen((char*)cascadeId)];
  sprintf( (char *)finalQuery, selectQuery, tmp, cascadeId);
 
  if (__checkCountAllQuery(finalQuery, count) != E_SUCCESS)
  {
    delete[] finalQuery;
    finalQuery = NULL;
    /*if(!checkConnectionStatus())
    {
      MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionFailure);
      return E_NOT_CONNECTED;
    }*/
    return E_UNKNOWN;
  }
 
  // put query together (either insert or update)
  if(count == 0)
  {
    query = insertQuery;
  }
  else
  {
    query = updateQuery;
  }
  sprintf((char*)finalQuery, query, prepaidBytes, tmp, cascadeId);
  result = monitored_PQexec(m_dbConn, (char *)finalQuery);
 
  if (PQresultStatus(result) != PGRES_COMMAND_OK) // || PQntuples(result) != 1)
  {
    CAMsg::printMsg(LOG_ERR, "CAAccountungDBInterface: Saving to prepaidamounts failed!\n");
    //if (PQresultStatus(result) != PGRES_COMMAND_OK)
    {
      CAMsg::printMsg(LOG_ERR,
              "Database message '%s' while processing query '%s'\n",
              PQresultErrorMessage(result), finalQuery
              );
    }
    delete[] finalQuery;
    finalQuery = NULL;
    if (result)
    {
      PQclear(result);
    }
    return E_UNKNOWN;
  }
  delete[] finalQuery;
  finalQuery = NULL;
  PQclear(result);
  CAMsg::printMsg(LOG_DEBUG, "CAAccountingDBInterface: Stored %d prepaid bytes for account nr. %s \n",prepaidBytes, tmp);
  return E_SUCCESS;
}

References __checkCountAllQuery(), checkConnectionStatus(), E_NOT_CONNECTED, E_SUCCESS, E_UNKNOWN, len, m_dbConn, max, monitored_PQexec(), MONITORING_FIRE_PAY_EVENT, print64(), and CAMsg::printMsg().

Referenced by storePrepaidAmount().

Here is the call graph for this function:

Here is the caller graph for this function:

checkConnectionStatus()

bool CAAccountingDBInterface::checkConnectionStatus ( )

private

Checks if the connection still exists and tries to reconnect if not.

Returns

if the database connection is active after the call or not

Definition at line 134 of file CAAccountingDBInterface.cpp.

{
  if (!m_bConnected)
  {
    return false;
  }
 
  if (PQstatus(m_dbConn) != CONNECTION_OK)
  {
    CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: Connection to database lost! Reason: %s\n",
      PQerrorMessage(m_dbConn));
      PQreset(m_dbConn);
 
        if (PQstatus(m_dbConn) != CONNECTION_OK)
        {
          CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: Could not reset database connection! Reason: %s\n",
            PQerrorMessage(m_dbConn));
      terminateDBConnection();
        }
        else
        {
          CAMsg::printMsg(LOG_INFO, "CAAccountingDBInterface: Database connection has been reset successfully!");
        }
  }
  return m_bConnected;
}

References m_bConnected, m_dbConn, CAMsg::printMsg(), and terminateDBConnection().

Referenced by __deleteCC(), __getAccountStatus(), __getCostConfirmation(), __getPrepaidAmount(), __getUnsettledCostConfirmations(), __markAsSettled(), __storeAccountStatus(), __storeCostConfirmation(), __storePrepaidAmount(), getConnection(), and monitored_PQexec().

Here is the call graph for this function:

Here is the caller graph for this function:

checkCountAllQuery()

SINT32 CAAccountingDBInterface::checkCountAllQuery	(	UINT8 *	a_query,
		UINT32 &	r_count
	)

Takes and executes a query that counts databae records and tests if the result is valid.

Parameters

a_query	a query that should return the count of database rows
r_count	number of database rows; only valid if E_SUCCESS is returned

Definition at line 283 of file CAAccountingDBInterface.cpp.

{
  if(checkOwner())
  {
    return __checkCountAllQuery(a_query, r_count);
  }
  else
  {
    return E_UNKNOWN;
  }
}

References __checkCountAllQuery(), checkOwner(), and E_UNKNOWN.

Here is the call graph for this function:

checkOwner()

bool CAAccountingDBInterface::checkOwner ( )

private

Definition at line 182 of file CAAccountingDBInterface.cpp.

{
  bool isFree = false;
  thread_id_t owner = 0;
  m_pConnectionMutex->lock();
  owner = m_owner;
  isFree = m_free;
  m_pConnectionMutex->unlock();
 
  return ( (owner==CAThread::getSelfID()) && !isFree);
}

References CAThread::getSelfID(), CAMutex::lock(), m_free, m_owner, m_pConnectionMutex, and CAMutex::unlock().

Referenced by checkCountAllQuery(), clearAccountStatus(), deleteCC(), getAccountStatus(), getCostConfirmation(), getPrepaidAmount(), getUnsettledCostConfirmations(), markAsSettled(), storeAccountStatus(), storeCostConfirmation(), and storePrepaidAmount().

Here is the call graph for this function:

Here is the caller graph for this function:

cleanup()

SINT32 CAAccountingDBInterface::cleanup ( )

static

Definition at line 1212 of file CAAccountingDBInterface.cpp.

{
  UINT32 i;
  SINT32 dbConnStatus, ret = E_SUCCESS;
  if(ms_pDBConnectionPool != NULL)
  {
    for(i=0; i < MAX_DB_CONNECTIONS; i++)
    {
      if(ms_pDBConnectionPool[i] == NULL)
      {
        //CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: DBConnection: Already cleaned up.\n");
      }
      else
      {
        dbConnStatus = ms_pDBConnectionPool[i]->terminateDBConnection();
        delete ms_pDBConnectionPool[i];
        ms_pDBConnectionPool[i] = NULL;
      }
      if(dbConnStatus != E_SUCCESS)
      {
        CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: DBConnection cleanup: "
            "an error occured while closing DBConnection.\n");
        ret = dbConnStatus;
      }
    }
  }
  if(ms_pConnectionAvailable != NULL)
  {
    delete ms_pConnectionAvailable;
    ms_pConnectionAvailable = NULL;
  }
  return ret;
}

References E_SUCCESS, MAX_DB_CONNECTIONS, ms_pConnectionAvailable, ms_pDBConnectionPool, CAMsg::printMsg(), and terminateDBConnection().

Referenced by CAFirstMix::clean(), and CACmdLnOptions::setAccountingDatabase().

Here is the call graph for this function:

Here is the caller graph for this function:

clearAccountStatus()

SINT32 CAAccountingDBInterface::clearAccountStatus

(

UINT64

a_accountNumber

)

Definition at line 901 of file CAAccountingDBInterface.cpp.

  {
    if(checkOwner())
    {
      return __clearAccountStatus(a_accountNumber);
    }
    else
    {
      return E_UNKNOWN;
    }
  }

References __clearAccountStatus(), checkOwner(), and E_UNKNOWN.

Referenced by CAAccountingInstance::__commitSettlementToDatabase(), and CAAccountingInstance::settlementTransaction().

Here is the call graph for this function:

Here is the caller graph for this function:

deleteCC()

SINT32 CAAccountingDBInterface::deleteCC	(	UINT64	accountNumber,
		UINT8 *	cascadeId
	)

if the BI reports an error while trying to settle a CC, this will be called to delete it from the database (otherwise the AI would try forever in vain to settle the unusable CC)

Definition at line 584 of file CAAccountingDBInterface.cpp.

{
  if(checkOwner())
  {
    return __deleteCC(accountNumber, cascadeId);
  }
  else
  {
    return E_UNKNOWN;
  }
}

References __deleteCC(), checkOwner(), and E_UNKNOWN.

Referenced by CAAccountingInstance::__handleSettleResult(), and CAAccountingInstance::settlementTransaction().

Here is the call graph for this function:

Here is the caller graph for this function:

getAccountStatus()

SINT32 CAAccountingDBInterface::getAccountStatus	(	UINT64	a_accountNumber,
		UINT32 &	a_statusCode
	)

Definition at line 947 of file CAAccountingDBInterface.cpp.

  {
    if(checkOwner())
    {
      return __getAccountStatus(a_accountNumber, a_statusCode);
    }
    else
    {
      return E_UNKNOWN;
    }
  }

References __getAccountStatus(), checkOwner(), and E_UNKNOWN.

Referenced by CAAccountingInstance::__handleSettleResult(), CAAccountingInstance::finishLoginProcess(), CAAccountingInstance::handleChallengeResponse_internal(), and CAAccountingInstance::settlementTransaction().

Here is the call graph for this function:

Here is the caller graph for this function:

getConnection()

CAAccountingDBInterface * CAAccountingDBInterface::getConnection ( )

static

Definition at line 1020 of file CAAccountingDBInterface.cpp.

{
  UINT32 i;
  UINT64 myWaitNr;
  CAAccountingDBInterface *returnedConnection = NULL;
 
  if(ms_pDBConnectionPool == NULL)
  {
    CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: No DBConnection available. This should NEVER happen!\n");
    return NULL;
  }
  if(ms_pConnectionAvailable == NULL)
  {
    CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: DBConnections not initialized. This should NEVER happen!\n");
    return NULL;
  }
  ms_pConnectionAvailable->lock();
  for(i=0; 1; i++)
  {
    if(ms_pDBConnectionPool[(i%MAX_DB_CONNECTIONS)] != NULL)
    {
      if(ms_pDBConnectionPool[(i%MAX_DB_CONNECTIONS)]->testAndSetOwner())
      {
        returnedConnection = ms_pDBConnectionPool[(i%MAX_DB_CONNECTIONS)];
        break;
      }
    }
    if((i % MAX_DB_CONNECTIONS) == (MAX_DB_CONNECTIONS - 1)  )
    {
      //wait until connection is free
      ms_threadWaitNr++;
      myWaitNr = ms_threadWaitNr;
#ifdef DEBUG
      CAMsg::printMsg(LOG_DEBUG, "CAAccountingDBInterface: Thread %x waits for connection with waitNr %Lu and %Lu Threads waiting before\n",
          pthread_self(), myWaitNr, (myWaitNr - ms_nextThreadNr));
#endif
      while(ms_nextThreadNr != myWaitNr)
      {
        ms_pConnectionAvailable->wait();
      }
#ifdef DEBUG
      CAMsg::printMsg(LOG_DEBUG, "CAAccountingDBInterface: Thread %x with waitNr %Lu continues\n",
                pthread_self(), myWaitNr);
#endif
      if(ms_threadWaitNr == ms_nextThreadNr)
      {
        //was the last waiting thread: reset the variables
        ms_threadWaitNr = 0;
        ms_nextThreadNr = 0;
      }
      //next complete array loop turn
    }
  }
  ms_pConnectionAvailable->unlock();
  if(returnedConnection != NULL)
  {
    if(!(returnedConnection->checkConnectionStatus()))
    {
      if(returnedConnection->initDBConnection() != E_SUCCESS)
      {
        MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionFailure);
        CAMsg::printMsg(LOG_WARNING, "CAAccountingDBInterface: Warning requested DB connection can not be established\n");
        /*returnedConnection->testAndResetOwner();
        return NULL;*/
      }
      else
      {
        MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionSuccess);
      }
    }
    else
    {
      MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionSuccess);
    }
  }
  return returnedConnection;
}

References checkConnectionStatus(), E_SUCCESS, initDBConnection(), CAMutex::lock(), MAX_DB_CONNECTIONS, MONITORING_FIRE_PAY_EVENT, ms_nextThreadNr, ms_pConnectionAvailable, ms_pDBConnectionPool, ms_threadWaitNr, CAMsg::printMsg(), testAndSetOwner(), CAMutex::unlock(), and CAConditionVariable::wait().

Referenced by CAAccountingInstance::__newSettlementTransaction(), CAAccountingInstance::cleanupTableEntry(), CAAccountingInstance::finishLoginProcess(), CAAccountingInstance::handleAccountCertificate_internal(), CAAccountingInstance::handleChallengeResponse_internal(), CAAccountingInstance::handleCostConfirmation_internal(), CAAccountingInstance::handleJapPacket_internal(), and CAAccountingInstance::settlementTransaction().

Here is the call graph for this function:

Here is the caller graph for this function:

getCostConfirmation()

SINT32 CAAccountingDBInterface::getCostConfirmation	(	UINT64	accountNumber,
		UINT8 *	cascadeId,
		CAXMLCostConfirmation **	pCC,
		bool &	a_bSettled
	)

Definition at line 195 of file CAAccountingDBInterface.cpp.

{
  if(checkOwner())
  {
    return __getCostConfirmation(accountNumber, cascadeId, pCC, a_bSettled);
  }
  else
  {
    return E_UNKNOWN;
  }
}

References __getCostConfirmation(), checkOwner(), and E_UNKNOWN.

Referenced by CAAccountingInstance::handleChallengeResponse_internal(), and CAAccountingInstance::handleJapPacket_internal().

Here is the call graph for this function:

Here is the caller graph for this function:

getPrepaidAmount()

SINT32 CAAccountingDBInterface::getPrepaidAmount	(	UINT64	accountNumber,
		UINT8 *	cascadeId,
		bool	a_bDelete
	)

Definition at line 736 of file CAAccountingDBInterface.cpp.

{
  if(checkOwner())
  {
    return __getPrepaidAmount(accountNumber, cascadeId, a_bDelete);
  }
  else
  {
    return E_UNKNOWN;
  }
}

References __getPrepaidAmount(), checkOwner(), and E_UNKNOWN.

Referenced by CAAccountingInstance::__commitSettlementToDatabase(), CAAccountingInstance::handleAccountCertificate_internal(), CAAccountingInstance::handleChallengeResponse_internal(), and CAAccountingInstance::settlementTransaction().

Here is the call graph for this function:

Here is the caller graph for this function:

getUnsettledCostConfirmations()

SINT32 CAAccountingDBInterface::getUnsettledCostConfirmations	(	CAXMLCostConfirmation ***	resultCCs,
		UINT8 *	cascadeId,
		UINT32 *	nrOfCCs,
		UINT32	a_maxCCs
	)

Fills the CAQueue with all non-settled cost confirmations.

Definition at line 452 of file CAAccountingDBInterface.cpp.

{
  if(checkOwner())
  {
    return __getUnsettledCostConfirmations(resultCCs, cascadeId, nrOfCCs, a_maxCCs);
  }
  else
  {
    return E_UNKNOWN;
  }
}

References __getUnsettledCostConfirmations(), checkOwner(), and E_UNKNOWN.

Referenced by CAAccountingInstance::__newSettlementTransaction(), and CAAccountingInstance::settlementTransaction().

Here is the call graph for this function:

Here is the caller graph for this function:

init()

SINT32 CAAccountingDBInterface::init ( )

static

Definition at line 1174 of file CAAccountingDBInterface.cpp.

{
  UINT32 i;
  SINT32 dbConnStatus;
 
  ms_pConnectionAvailable = new CAConditionVariable();
 
  ms_threadWaitNr = 0;
  ms_nextThreadNr = 0;
 
  if(ms_pDBConnectionPool != NULL)
  {
    for(i=0; i < MAX_DB_CONNECTIONS; i++)
    {
      if(ms_pDBConnectionPool[i] != NULL)
      {
        //CAMsg::printMsg(LOG_WARNING, "CAAccountingDBInterface: DBConnection: "
        //    "Already initialized connection.\n");
      }
      ms_pDBConnectionPool[i] = new CAAccountingDBInterface();
      dbConnStatus = ms_pDBConnectionPool[i]->initDBConnection();
 
      if(dbConnStatus != E_SUCCESS)
      {
        CAMsg::printMsg(LOG_CRIT, "CAAccountingDBInterface: DBConnection initialization: "
            "could not connect to Database.\n");
        return E_UNKNOWN;
      }
    }
  }
  else
  { //should never happen
    CAMsg::printMsg(LOG_CRIT, "CAAccountingDBInterface: DBConnection initialization failed.\n");
    return E_UNKNOWN;
  }
  return E_SUCCESS;
}

References CAAccountingDBInterface(), E_SUCCESS, E_UNKNOWN, initDBConnection(), MAX_DB_CONNECTIONS, ms_nextThreadNr, ms_pConnectionAvailable, ms_pDBConnectionPool, ms_threadWaitNr, and CAMsg::printMsg().

Referenced by CAFirstMix::init(), and CACmdLnOptions::setAccountingDatabase().

Here is the call graph for this function:

Here is the caller graph for this function:

initDBConnection()

SINT32 CAAccountingDBInterface::initDBConnection ( )

private

Initiates the database connection.

This function is called inside the aiThread

Returns

E_NOT_CONNECTED if the connection could not be established

E_UNKNOWN if we are already connected

E_SUCCESS if all is OK

Definition at line 78 of file CAAccountingDBInterface.cpp.

  {
    if(m_bConnected)
    {
      return E_UNKNOWN;
    }
 
    // Get database connection info from configfile and/or commandline
    UINT8 host[255];
    if(CALibProxytest::getOptions()->getDatabaseHost(host, 255) != E_SUCCESS)
    {
      CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: Error, no Database Host!\n");
      return E_UNKNOWN;
    }
    UINT32 tcp_port = CALibProxytest::getOptions()->getDatabasePort();
    UINT8 dbName[255];
    if(CALibProxytest::getOptions()->getDatabaseName(dbName, 255) != E_SUCCESS)
    {
      CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: Error, no Database Name!\n");
      return E_UNKNOWN;
    }
    UINT8 userName[255];
    if(CALibProxytest::getOptions()->getDatabaseUsername(userName, 255) != E_SUCCESS)
    {
      CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: Error, no Database Username!\n");
      return E_UNKNOWN;
    }
    UINT8 password[255];
    if(CALibProxytest::getOptions()->getDatabasePassword(password, 255) != E_SUCCESS)
    {
      CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: Error, no Database Password!\n");
      return E_UNKNOWN;
    }
 
 
    char port[20];
    sprintf(port, "%i", tcp_port);
    m_dbConn = PQsetdbLogin(
        (char*)host, port, "", "",
        (char*)dbName, (char*)userName, (char*)password
      );
    if(m_dbConn==NULL||PQstatus(m_dbConn) == CONNECTION_BAD)
    {
      CAMsg::printMsg(
        LOG_ERR, "CAAccountingDBInterface: Could not connect to Database. Reason: %s\n",
        PQerrorMessage(m_dbConn)
      );
      PQfinish(m_dbConn);
      m_dbConn = NULL;
      m_bConnected = false;
      return E_NOT_CONNECTED;
    }
    m_bConnected = true;
    return E_SUCCESS;
  }

References E_NOT_CONNECTED, E_SUCCESS, E_UNKNOWN, CACmdLnOptions::getDatabasePort(), CALibProxytest::getOptions(), m_bConnected, m_dbConn, and CAMsg::printMsg().

Referenced by getConnection(), and init().

Here is the call graph for this function:

Here is the caller graph for this function:

isDBConnected()

bool CAAccountingDBInterface::isDBConnected ( )

private

Definition at line 161 of file CAAccountingDBInterface.cpp.

{
  return m_bConnected;
}

References m_bConnected.

markAsSettled()

SINT32 CAAccountingDBInterface::markAsSettled	(	UINT64	accountNumber,
		UINT8 *	cascadeId,
		UINT64	a_transferredBytes
	)

Marks this account as settled.

Todo:

what to do if there was a new CC stored while we were busy settling the old one?

Definition at line 535 of file CAAccountingDBInterface.cpp.

{
  if(checkOwner())
  {
    return __markAsSettled(accountNumber, cascadeId, a_transferredBytes);
  }
  else
  {
    return E_UNKNOWN;
  }
}

References __markAsSettled(), checkOwner(), and E_UNKNOWN.

Referenced by CAAccountingInstance::__handleSettleResult(), and CAAccountingInstance::settlementTransaction().

Here is the call graph for this function:

Here is the caller graph for this function:

monitored_PQexec()

PGresult * CAAccountingDBInterface::monitored_PQexec ( PGconn *  conn, const char *  query  )

private

Definition at line 1246 of file CAAccountingDBInterface.cpp.

{
  PGresult* result = NULL;
  result = PQexec(conn, query);
  if(!checkConnectionStatus())
  {
    MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionFailure);
  }
  else
  {
    MONITORING_FIRE_PAY_EVENT(ev_pay_dbConnectionSuccess);
  }
  return result;
}

References checkConnectionStatus(), and MONITORING_FIRE_PAY_EVENT.

Referenced by __checkCountAllQuery(), __clearAccountStatus(), __deleteCC(), __getAccountStatus(), __getCostConfirmation(), __getPrepaidAmount(), __getUnsettledCostConfirmations(), __markAsSettled(), __storeAccountStatus(), __storeCostConfirmation(), and __storePrepaidAmount().

Here is the call graph for this function:

Here is the caller graph for this function:

releaseConnection()

SINT32 CAAccountingDBInterface::releaseConnection ( CAAccountingDBInterface *  dbIf )

static

Definition at line 1104 of file CAAccountingDBInterface.cpp.

{
  SINT32 ret;
  //@todo: implementation
  if(dbIf == NULL)
  {
    return E_UNKNOWN;
  }
  if(dbIf->m_pConnectionMutex == NULL)
  {
    CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: DBConnection structure corrupt!\n");
    return E_UNKNOWN;
  }
  if(ms_pConnectionAvailable == NULL)
  {
    CAMsg::printMsg(LOG_ERR, "CAAccountingDBInterface: DBConnections not initialized. This should NEVER happen!\n");
    return E_UNKNOWN;
  }
 
  ms_pConnectionAvailable->lock();
  if(dbIf->testAndResetOwner())
  {
    if(ms_threadWaitNr != ms_nextThreadNr)
    {
      ms_nextThreadNr++;
#ifdef DEBUG
      CAMsg::printMsg(LOG_DEBUG, "CAAccountingDBInterface: There are %Lu Threads waiting. Waking up thread with waitNr. %Lu\n",
                       (ms_threadWaitNr - ms_nextThreadNr), ms_nextThreadNr);
#endif
      //There are threads waiting
      ms_pConnectionAvailable->broadcast();
    }
    ret = E_SUCCESS;
  }
  else
  {
    ret = E_UNKNOWN;
  }
  ms_pConnectionAvailable->unlock();
  return ret;
}

References CAConditionVariable::broadcast(), E_SUCCESS, E_UNKNOWN, CAMutex::lock(), m_pConnectionMutex, ms_nextThreadNr, ms_pConnectionAvailable, ms_threadWaitNr, CAMsg::printMsg(), testAndResetOwner(), and CAMutex::unlock().

Referenced by CAAccountingInstance::__newSettlementTransaction(), CAAccountingInstance::cleanupTableEntry(), CAAccountingInstance::finishLoginProcess(), CAAccountingInstance::handleAccountCertificate_internal(), CAAccountingInstance::handleChallengeResponse_internal(), CAAccountingInstance::handleCostConfirmation_internal(), CAAccountingInstance::handleJapPacket_internal(), and CAAccountingInstance::settlementTransaction().

Here is the call graph for this function:

Here is the caller graph for this function:

storeAccountStatus()

SINT32 CAAccountingDBInterface::storeAccountStatus	(	UINT64	a_accountNumber,
		UINT32	a_statusCode
	)

Definition at line 816 of file CAAccountingDBInterface.cpp.

{
  if(checkOwner())
  {
    return __storeAccountStatus(a_accountNumber, a_statusCode);
  }
  else
  {
    return E_UNKNOWN;
  }
}

References __storeAccountStatus(), checkOwner(), and E_UNKNOWN.

Referenced by CAAccountingInstance::__handleSettleResult(), and CAAccountingInstance::settlementTransaction().

Here is the call graph for this function:

Here is the caller graph for this function:

storeCostConfirmation()

SINT32 CAAccountingDBInterface::storeCostConfirmation	(	CAXMLCostConfirmation &	cc,
		UINT8 *	ccCascade
	)

Creates the tables we need in the DB.

Returns

E_SUCCESS if all is OK

E_UNKNOWN if the query could not be executed

E_NOT_CONNECTED if we are not connected to the DB

Definition at line 337 of file CAAccountingDBInterface.cpp.

{
  if(checkOwner())
  {
    return __storeCostConfirmation(cc, ccCascade);
  }
  else
  {
    return E_UNKNOWN;
  }
}

References __storeCostConfirmation(), checkOwner(), and E_UNKNOWN.

Referenced by CAAccountingInstance::__handleSettleResult(), CAAccountingInstance::handleCostConfirmation_internal(), and CAAccountingInstance::settlementTransaction().

Here is the call graph for this function:

Here is the caller graph for this function:

storePrepaidAmount()

SINT32 CAAccountingDBInterface::storePrepaidAmount	(	UINT64	accountNumber,
		SINT32	prepaidBytes,
		UINT8 *	cascadeId
	)

Definition at line 645 of file CAAccountingDBInterface.cpp.

{
  if(checkOwner())
  {
    return __storePrepaidAmount(accountNumber, prepaidBytes, cascadeId);
  }
  else
  {
    return E_UNKNOWN;
  }
}

References __storePrepaidAmount(), checkOwner(), and E_UNKNOWN.

Referenced by CAAccountingInstance::__commitSettlementToDatabase(), CAAccountingInstance::cleanupTableEntry(), and CAAccountingInstance::settlementTransaction().

Here is the call graph for this function:

Here is the caller graph for this function:

terminateDBConnection()

SINT32 CAAccountingDBInterface::terminateDBConnection ( )

private

Terminates the database connection.

Returns

E_SUCCESS

Definition at line 170 of file CAAccountingDBInterface.cpp.

{
  if(m_bConnected)
  {
    PQfinish(m_dbConn);
  }
  m_dbConn=NULL;
  m_bConnected = false;
  return E_SUCCESS;
}

References E_SUCCESS, m_bConnected, and m_dbConn.

Referenced by checkConnectionStatus(), cleanup(), and ~CAAccountingDBInterface().

Here is the caller graph for this function:

testAndResetOwner()

bool CAAccountingDBInterface::testAndResetOwner ( )

private

Definition at line 1160 of file CAAccountingDBInterface.cpp.

{
  bool success = false;
  m_pConnectionMutex->lock();
  if(!m_free && (m_owner == CAThread::getSelfID()))
  {
    m_free = true;
    m_owner = 0;
    success = true;
  }
  m_pConnectionMutex->unlock();
  return success;
}

References CAThread::getSelfID(), CAMutex::lock(), m_free, m_owner, m_pConnectionMutex, and CAMutex::unlock().

Referenced by releaseConnection().

Here is the call graph for this function:

Here is the caller graph for this function:

testAndSetOwner()

bool CAAccountingDBInterface::testAndSetOwner ( )

private

Definition at line 1146 of file CAAccountingDBInterface.cpp.

{
  bool success = false;
  m_pConnectionMutex->lock();
  if(m_free)
  {
    m_free = false;
    m_owner = CAThread::getSelfID();
    success = true;
  }
  m_pConnectionMutex->unlock();
  return success;
}

References CAThread::getSelfID(), CAMutex::lock(), m_free, m_owner, m_pConnectionMutex, and CAMutex::unlock().

Referenced by getConnection().

Here is the call graph for this function:

Here is the caller graph for this function:

Friends And Related Function Documentation

CAAccountingInstance

friend class CAAccountingInstance

friend

Definition at line 169 of file CAAccountingDBInterface.hpp.

Member Data Documentation

m_bConnected

bool CAAccountingDBInterface::m_bConnected

private

Definition at line 188 of file CAAccountingDBInterface.hpp.

Referenced by CAAccountingDBInterface(), checkConnectionStatus(), initDBConnection(), isDBConnected(), and terminateDBConnection().

m_dbConn

PGconn* CAAccountingDBInterface::m_dbConn

private

connection to postgreSQL database

Definition at line 187 of file CAAccountingDBInterface.hpp.

Referenced by __checkCountAllQuery(), __clearAccountStatus(), __deleteCC(), __getAccountStatus(), __getCostConfirmation(), __getPrepaidAmount(), __getUnsettledCostConfirmations(), __markAsSettled(), __storeAccountStatus(), __storeCostConfirmation(), __storePrepaidAmount(), CAAccountingDBInterface(), checkConnectionStatus(), initDBConnection(), and terminateDBConnection().

m_free

volatile bool CAAccountingDBInterface::m_free

private

Definition at line 195 of file CAAccountingDBInterface.hpp.

Referenced by CAAccountingDBInterface(), checkOwner(), testAndResetOwner(), and testAndSetOwner().

m_owner

volatile thread_id_t CAAccountingDBInterface::m_owner

private

Definition at line 191 of file CAAccountingDBInterface.hpp.

Referenced by CAAccountingDBInterface(), checkOwner(), testAndResetOwner(), and testAndSetOwner().

m_pConnectionMutex

CAMutex* CAAccountingDBInterface::m_pConnectionMutex

private

Definition at line 201 of file CAAccountingDBInterface.hpp.

Referenced by CAAccountingDBInterface(), checkOwner(), releaseConnection(), testAndResetOwner(), testAndSetOwner(), and ~CAAccountingDBInterface().

m_protocolVersion

int CAAccountingDBInterface::m_protocolVersion

private

Definition at line 196 of file CAAccountingDBInterface.hpp.

ms_nextThreadNr

volatile UINT64 CAAccountingDBInterface::ms_nextThreadNr = 0

staticprivate

Definition at line 210 of file CAAccountingDBInterface.hpp.

Referenced by getConnection(), init(), and releaseConnection().

ms_pConnectionAvailable

CAConditionVariable * CAAccountingDBInterface::ms_pConnectionAvailable = NULL

staticprivate

Definition at line 204 of file CAAccountingDBInterface.hpp.

Referenced by cleanup(), getConnection(), init(), and releaseConnection().

ms_pDBConnectionPool

CAAccountingDBInterface * CAAccountingDBInterface::ms_pDBConnectionPool

staticprivate

Definition at line 212 of file CAAccountingDBInterface.hpp.

Referenced by cleanup(), getConnection(), and init().

ms_threadWaitNr

volatile UINT64 CAAccountingDBInterface::ms_threadWaitNr = 0

staticprivate

Definition at line 208 of file CAAccountingDBInterface.hpp.

Referenced by getConnection(), init(), and releaseConnection().

---

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

• CAAccountingDBInterface.hpp
• CAAccountingDBInterface.cpp