counted_mysql_session.cc File Reference

#include "collector/counted_mysql_session.h"
#include "mrs/router_observation_entities.h"
#include "mysql/harness/destination.h"

Classes
class	collector::GuardBoolSetFalse

Namespaces
namespace	collector

Macros
#define	CHECK_DISCONNECTION_RETURN(X)
#define	CHECK_DISCONNECTION_VOID(X)

Typedefs
using	collector::MySQLSession = mysqlrouter::MySQLSession

Functions
static bool	collector::did_server_disconnect (unsigned int code)

Macro Definition Documentation

CHECK_DISCONNECTION_RETURN

#define CHECK_DISCONNECTION_RETURN

(

X

)

Value:

  {                                                                         \
    GuardBoolSetFalse guard{reconnect_at_next_query_};                      \
    try {                                                                   \
      return X;                                                             \
    } catch (const CountedMySQLSession::Error &e) {                         \
      if (reconnect_at_next_query_ && did_server_disconnect(e.code())) {    \
        try {                                                               \
          connect_and_set_opts(get_connection_parameters(), initial_sqls_); \
        } catch (...) {                                                     \
          throw e;                                                          \
        }                                                                   \
        return X;                                                           \
      }                                                                     \
      throw;                                                                \
    }                                                                       \
  }

CHECK_DISCONNECTION_VOID

#define CHECK_DISCONNECTION_VOID

(

X

)

Value:

  {                                                                         \
    GuardBoolSetFalse guard{reconnect_at_next_query_};                      \
    try {                                                                   \
      X;                                                                    \
    } catch (const CountedMySQLSession::Error &e) {                         \
      if (reconnect_at_next_query_ && did_server_disconnect(e.code())) {    \
        try {                                                               \
          connect_and_set_opts(get_connection_parameters(), initial_sqls_); \
        } catch (...) {                                                     \
          throw e;                                                          \
        }                                                                   \
        X;                                                                  \
      }                                                                     \
      throw;                                                                \
    }                                                                       \
  }