File broker_proxy_conn.c

FileList > broker > broker_proxy_conn.c

Go to the source code of this file

• #include <sys/types.h>
• #include <assert.h>
• #include <sys/time.h>
• #include <unistd.h>
• #include <pthread.h>
• #include "porting.h"
• #include "broker_proxy_conn.h"
• #include "shard_proxy_common.h"
• #include "shard_shm.h"

Public Attributes

Type	Name
T_PROXY_CONN	broker_Proxy_conn = /* multi line expression */
pthread_mutex_t	proxy_conn_mutex

Public Functions

Type	Name
int	broker_add_proxy_conn (SOCKET fd)
int	broker_delete_proxy_conn_by_fd (SOCKET fd)
int	broker_delete_proxy_conn_by_proxy_id (int proxy_id)
void	broker_destroy_proxy_conn (void)
SOCKET	broker_find_available_proxy (T_SHM_PROXY * shm_proxy_p)
SOCKET	broker_get_proxy_conn_maxfd (SOCKET proxy_sock_fd)
SOCKET	broker_get_readable_proxy_conn (fd_set * fds)
int	broker_init_proxy_conn (int max_proxy)
int	broker_register_proxy_conn (SOCKET fd, int proxy_id)
int	broker_set_proxy_fds (fd_set * fds)

Public Static Functions

Type	Name
T_PROXY_CONN_ENT *	broker_find_proxy_conn_by_fd (SOCKET fd)
T_PROXY_CONN_ENT *	broker_find_proxy_conn_by_id (int proxy_id)
void	broker_free_all_proxy_conn_ent (void)

Macros

Type	Name
define	PROXY_SVR_CON_RETRY_COUNT 3
define	PROXY_SVR_CON_RETRY_MSEC 400

Public Attributes Documentation

variable broker_Proxy_conn

T_PROXY_CONN broker_Proxy_conn;

---

variable proxy_conn_mutex

pthread_mutex_t proxy_conn_mutex;

---

Public Functions Documentation

function broker_add_proxy_conn

int broker_add_proxy_conn (
    SOCKET fd
) 

---

function broker_delete_proxy_conn_by_fd

int broker_delete_proxy_conn_by_fd (
    SOCKET fd
) 

---

function broker_delete_proxy_conn_by_proxy_id

int broker_delete_proxy_conn_by_proxy_id (
    int proxy_id
) 

---

function broker_destroy_proxy_conn

void broker_destroy_proxy_conn (
    void
) 

---

function broker_find_available_proxy

SOCKET broker_find_available_proxy (
    T_SHM_PROXY * shm_proxy_p
) 

---

function broker_get_proxy_conn_maxfd

SOCKET broker_get_proxy_conn_maxfd (
    SOCKET proxy_sock_fd
) 

---

function broker_get_readable_proxy_conn

SOCKET broker_get_readable_proxy_conn (
    fd_set * fds
) 

---

function broker_init_proxy_conn

int broker_init_proxy_conn (
    int max_proxy
) 

---

function broker_register_proxy_conn

int broker_register_proxy_conn (
    SOCKET fd,
    int proxy_id
) 

---

function broker_set_proxy_fds

int broker_set_proxy_fds (
    fd_set * fds
) 

---

Public Static Functions Documentation

function broker_find_proxy_conn_by_fd

static T_PROXY_CONN_ENT * broker_find_proxy_conn_by_fd (
    SOCKET fd
) 

---

function broker_find_proxy_conn_by_id

static T_PROXY_CONN_ENT * broker_find_proxy_conn_by_id (
    int proxy_id
) 

---

function broker_free_all_proxy_conn_ent

static void broker_free_all_proxy_conn_ent (
    void
) 

---

Macro Definition Documentation

define PROXY_SVR_CON_RETRY_COUNT

#define PROXY_SVR_CON_RETRY_COUNT `3`

---

define PROXY_SVR_CON_RETRY_MSEC

#define PROXY_SVR_CON_RETRY_MSEC `400`

---

---

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