broker_proxy_conn.h File Reference

#include "porting.h"
#include "broker_shm.h"

Include dependency graph for broker_proxy_conn.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	t_proxy_conn_ent
struct	t_proxy_conn

Typedefs
typedef struct t_proxy_conn_ent	T_PROXY_CONN_ENT
typedef struct t_proxy_conn	T_PROXY_CONN

Enumerations
enum	T_BROKER_PROXY_CONN_STATUS { PROXY_CONN_NOT_CONNECTED = 0, PROXY_CONN_CONNECTED = 1, PROXY_CONN_AVAILABLE = 2 }

Functions
int	broker_set_proxy_fds (fd_set *fds)
SOCKET	broker_get_readable_proxy_conn (fd_set *fds)
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)
int	broker_register_proxy_conn (SOCKET fd, int proxy_id)
SOCKET	broker_get_proxy_conn_maxfd (SOCKET proxy_sock_fd)
int	broker_init_proxy_conn (int max_proxy)
void	broker_destroy_proxy_conn (void)
SOCKET	broker_find_available_proxy (T_SHM_PROXY *shm_proxy_p)

Variables
T_PROXY_CONN	broker_Proxy_conn

Typedef Documentation

typedef struct t_proxy_conn T_PROXY_CONN

Definition at line 51 of file broker_proxy_conn.h.

typedef struct t_proxy_conn_ent T_PROXY_CONN_ENT

Definition at line 41 of file broker_proxy_conn.h.

Enumeration Type Documentation

enum T_BROKER_PROXY_CONN_STATUS

Enumerator
PROXY_CONN_NOT_CONNECTED
PROXY_CONN_CONNECTED
PROXY_CONN_AVAILABLE

Definition at line 35 of file broker_proxy_conn.h.

Function Documentation

int broker_add_proxy_conn

(

SOCKET

fd

)

Definition at line 158 of file broker_proxy_conn.c.

References assert, t_proxy_conn::cur_num_proxy, t_proxy_conn_ent::fd, t_proxy_conn::max_num_proxy, t_proxy_conn_ent::next, NULL, PROXY_CONN_CONNECTED, t_proxy_conn::proxy_conn_ent, proxy_conn_mutex, t_proxy_conn_ent::proxy_id, PROXY_INVALID_ID, pthread_mutex_lock, pthread_mutex_unlock, and t_proxy_conn_ent::status.

Referenced by proxy_listener_thr_f().

Here is the caller graph for this function:

int broker_delete_proxy_conn_by_fd

(

SOCKET

fd

)

Definition at line 201 of file broker_proxy_conn.c.

References assert, t_proxy_conn::cur_num_proxy, t_proxy_conn_ent::fd, FREE_MEM, t_proxy_conn_ent::next, NULL, t_proxy_conn::proxy_conn_ent, proxy_conn_mutex, pthread_mutex_lock, and pthread_mutex_unlock.

Referenced by proxy_listener_thr_f(), and shard_dispatch_thr_f().

Here is the caller graph for this function:

int broker_delete_proxy_conn_by_proxy_id

(

int

proxy_id

)

Definition at line 238 of file broker_proxy_conn.c.

References assert, t_proxy_conn::cur_num_proxy, FREE_MEM, t_proxy_conn_ent::next, NULL, t_proxy_conn::proxy_conn_ent, proxy_conn_mutex, t_proxy_conn_ent::proxy_id, PROXY_INVALID_ID, pthread_mutex_lock, and pthread_mutex_unlock.

Referenced by stop_proxy_server().

Here is the caller graph for this function:

void broker_destroy_proxy_conn

(

void

)

Definition at line 428 of file broker_proxy_conn.c.

References broker_free_all_proxy_conn_ent(), t_proxy_conn::cur_num_proxy, t_proxy_conn::max_num_proxy, proxy_conn_mutex, pthread_mutex_destroy, pthread_mutex_lock, and pthread_mutex_unlock.

Referenced by main().

Here is the caller graph for this function:

SOCKET broker_find_available_proxy

(

T_SHM_PROXY *

shm_proxy_p

)

Definition at line 315 of file broker_proxy_conn.c.

References assert, broker_find_proxy_conn_by_id(), t_proxy_info::cur_client, t_proxy_conn_ent::fd, INVALID_SOCKET, t_proxy_info::max_context, t_proxy_conn::max_num_proxy, NULL, t_shm_proxy::num_proxy, t_proxy_info::pid, PROXY_CONN_AVAILABLE, proxy_conn_mutex, t_proxy_info::proxy_id, proxy_info_p, pthread_mutex_lock, pthread_mutex_unlock, shard_shm_find_proxy_info(), and t_proxy_conn_ent::status.

Referenced by broker_register_proxy_conn(), and shard_dispatch_thr_f().

Here is the caller graph for this function:

SOCKET broker_get_proxy_conn_maxfd

(

SOCKET

proxy_sock_fd

)

Definition at line 387 of file broker_proxy_conn.c.

References t_proxy_conn_ent::fd, t_proxy_conn_ent::next, t_proxy_conn::proxy_conn_ent, proxy_conn_mutex, PROXY_CONN_NOT_CONNECTED, proxy_sock_fd, pthread_mutex_lock, pthread_mutex_unlock, and t_proxy_conn_ent::status.

Referenced by proxy_listener_thr_f().

Here is the caller graph for this function:

SOCKET broker_get_readable_proxy_conn

(

fd_set *

fds

)

Definition at line 88 of file broker_proxy_conn.c.

References t_proxy_conn_ent::fd, INVALID_SOCKET, t_proxy_conn_ent::next, PROXY_CONN_CONNECTED, t_proxy_conn::proxy_conn_ent, proxy_conn_mutex, pthread_mutex_lock, pthread_mutex_unlock, and t_proxy_conn_ent::status.

Referenced by proxy_listener_thr_f().

Here is the caller graph for this function:

int broker_init_proxy_conn

(

int

max_proxy

)

Definition at line 411 of file broker_proxy_conn.c.

References t_proxy_conn::cur_num_proxy, t_proxy_conn::max_num_proxy, NULL, t_proxy_conn::proxy_conn_ent, proxy_conn_mutex, and pthread_mutex_init.

Referenced by main().

Here is the caller graph for this function:

int broker_register_proxy_conn	(	SOCKET	fd,
		int	proxy_id
	)

Definition at line 281 of file broker_proxy_conn.c.

References assert, broker_find_available_proxy(), broker_find_proxy_conn_by_fd(), NULL, PROXY_CONN_AVAILABLE, proxy_conn_mutex, proxy_id, t_proxy_conn_ent::proxy_id, PROXY_INVALID_ID, pthread_mutex_lock, pthread_mutex_unlock, shm_proxy_p, and t_proxy_conn_ent::status.

Referenced by proxy_listener_thr_f().

Here is the caller graph for this function:

int broker_set_proxy_fds

(

fd_set *

fds

)

Definition at line 69 of file broker_proxy_conn.c.

References t_proxy_conn_ent::fd, INVALID_SOCKET, t_proxy_conn_ent::next, PROXY_CONN_CONNECTED, t_proxy_conn::proxy_conn_ent, proxy_conn_mutex, pthread_mutex_lock, pthread_mutex_unlock, and t_proxy_conn_ent::status.

Referenced by proxy_listener_thr_f().

Here is the caller graph for this function:

Variable Documentation

T_PROXY_CONN broker_Proxy_conn

Definition at line 40 of file broker_proxy_conn.c.