File shard_proxy_common.h¶

FileList > broker > shard_proxy_common.h

#include "porting.h"
#include "broker_shm.h"
#include "shard_proxy_queue.h"
#include "shard_proxy_log.h"
#include "memory_hash.h"
#include "shard_statement.h"

Classes¶

Type	Name
struct	t_cas_io
struct	t_client_io
struct	t_client_io_global
struct	t_context_stmt
struct	t_io_buffer
struct	t_proxy_context
struct	t_proxy_context_global
struct	t_proxy_event
struct	t_proxy_handler
struct	t_shard_io
struct	t_shard_io_global
struct	t_socket_io
struct	t_socket_io_global
struct	t_wait_context

Public Types¶

Type	Name
enum	E_PROXY_EVENT
typedef struct t_cas_io	T_CAS_IO
enum	T_CAS_IO_STATUS
typedef struct t_client_io	T_CLIENT_IO
typedef struct t_client_io_global	T_CLIENT_IO_GLOBAL
typedef struct t_context_stmt	T_CONTEXT_STMT
typedef struct t_io_buffer	T_IO_BUFFER
typedef struct t_proxy_context	T_PROXY_CONTEXT
typedef struct t_proxy_context_global	T_PROXY_CONTEXT_GLOBAL
typedef struct t_proxy_event	T_PROXY_EVENT
typedef struct t_proxy_handler	T_PROXY_HANDLER
typedef struct t_shard_io	T_SHARD_IO
typedef struct t_shard_io_global	T_SHARD_IO_GLOBAL
typedef struct t_socket_io	T_SOCKET_IO
typedef struct t_socket_io_global	T_SOCKET_IO_GLOBAL
enum	T_SOCKET_IO_STATUS
typedef struct t_wait_context	T_WAIT_CONTEXT

Macros¶

Type	Name
define	MAX_FD `[FD\_SETSIZE](broker__monitor_8c.md#function-timeout)`
define	PROXY_EVENT_FROM_CAS `([true](broker__monitor_8c.md#function-timeout))`
define	PROXY_EVENT_FROM_CLIENT `([false](broker__monitor_8c.md#function-timeout))`
define	PROXY_EVENT_NULL_BUFFER `([NULL](freelistheap_8h.md#define-null))`
define	PROXY_INVALID_CAS `([PROXY\_INVALID\_ID](broker__util_8h.md#define-proxy_invalid_id))`
define	PROXY_INVALID_CLIENT `([PROXY\_INVALID\_ID](broker__util_8h.md#define-proxy_invalid_id))`
define	PROXY_INVALID_CONTEXT `(-1)`
define	PROXY_INVALID_FUNC_CODE `(-1)`
define	PROXY_INVALID_ID `(-1)`
define	PROXY_INVALID_SHARD `([PROXY\_INVALID\_ID](broker__util_8h.md#define-proxy_invalid_id))`

Public Types Documentation¶

enum E_PROXY_EVENT¶

enum E_PROXY_EVENT {
    PROXY_EVENT_IO_READ = 0,
    PROXY_EVENT_IO_WRITE = 1,
    PROXY_EVENT_CLIENT_REQUEST = 2,
    PROXY_EVENT_CAS_RESPONSE = 3,
    PROXY_EVENT_CLIENT_CONN_ERROR = 4,
    PROXY_EVENT_CAS_CONN_ERROR = 5,
    PROXY_EVENT_CLIENT_WAKEUP_BY_SHARD = 6,
    PROXY_EVENT_CLIENT_WAKEUP_BY_STATEMENT = 7
};

typedef T_CAS_IO¶

typedef struct t_cas_io T_CAS_IO;

enum T_CAS_IO_STATUS¶

enum T_CAS_IO_STATUS {
    CAS_IO_NOT_CONNECTED = 0,
    CAS_IO_CONNECTED = 1,
    CAS_IO_CLOSE_WAIT = 2
};

typedef T_CLIENT_IO¶

typedef struct t_client_io T_CLIENT_IO;

typedef T_CLIENT_IO_GLOBAL¶

typedef struct t_client_io_global T_CLIENT_IO_GLOBAL;

typedef T_CONTEXT_STMT¶

typedef struct t_context_stmt T_CONTEXT_STMT;

typedef T_IO_BUFFER¶

typedef struct t_io_buffer T_IO_BUFFER;

typedef T_PROXY_CONTEXT¶

typedef struct t_proxy_context T_PROXY_CONTEXT;

typedef T_PROXY_CONTEXT_GLOBAL¶

typedef struct t_proxy_context_global T_PROXY_CONTEXT_GLOBAL;

typedef T_PROXY_EVENT¶

typedef struct t_proxy_event T_PROXY_EVENT;

typedef T_PROXY_HANDLER¶

typedef struct t_proxy_handler T_PROXY_HANDLER;

typedef T_SHARD_IO¶

typedef struct t_shard_io T_SHARD_IO;

typedef T_SHARD_IO_GLOBAL¶

typedef struct t_shard_io_global T_SHARD_IO_GLOBAL;

typedef T_SOCKET_IO¶

typedef struct t_socket_io T_SOCKET_IO;

typedef T_SOCKET_IO_GLOBAL¶

typedef struct t_socket_io_global T_SOCKET_IO_GLOBAL;

enum T_SOCKET_IO_STATUS¶

enum T_SOCKET_IO_STATUS {
    SOCK_IO_IDLE = 0,
    SOCK_IO_REG_WAIT = 1,
    SOCK_IO_ESTABLISHED = 2,
    SOCK_IO_CLOSE_WAIT = 3
};

typedef T_WAIT_CONTEXT¶

typedef struct t_wait_context T_WAIT_CONTEXT;

Macro Definition Documentation¶

define MAX_FD¶

#define MAX_FD `FD_SETSIZE`

define PROXY_EVENT_FROM_CAS¶

#define PROXY_EVENT_FROM_CAS `( true )`

define PROXY_EVENT_FROM_CLIENT¶

#define PROXY_EVENT_FROM_CLIENT `( false )`

define PROXY_EVENT_NULL_BUFFER¶

#define PROXY_EVENT_NULL_BUFFER `( NULL )`

define PROXY_INVALID_CAS¶

#define PROXY_INVALID_CAS `( PROXY_INVALID_ID )`

define PROXY_INVALID_CLIENT¶

#define PROXY_INVALID_CLIENT `( PROXY_INVALID_ID )`

define PROXY_INVALID_CONTEXT¶

#define PROXY_INVALID_CONTEXT `(-1)`

define PROXY_INVALID_FUNC_CODE¶

#define PROXY_INVALID_FUNC_CODE `(-1)`

define PROXY_INVALID_ID¶

#define PROXY_INVALID_ID `(-1)`

define PROXY_INVALID_SHARD¶

#define PROXY_INVALID_SHARD `( PROXY_INVALID_ID )`

The documentation for this class was generated from the following file cubrid/src/broker/shard_proxy_common.h