Skip to content
Snippets Groups Projects
Commit 1c4e25d1 authored by armatusmiles's avatar armatusmiles
Browse files

[*] Fix compile errors

parent 7bdaeb20
No related branches found
No related tags found
No related merge requests found
......@@ -53,7 +53,7 @@ uint64_t get_key(unsigned long host,unsigned short port){
* @param port Client port
* @return Pointer to the new list's node
*/
dap_server_client_t * dap_udp_client_create(dap_server_t * sh, ev_io* w_client, unsigned long host, unsigned short port)
dap_client_remote_t * dap_udp_client_create(dap_server_t * sh, ev_io* w_client, unsigned long host, unsigned short port)
{
dap_udp_server_t* udp_server = DAP_UDP_SERVER(sh);
log_it(L_DEBUG,"Client structure create");
......@@ -61,7 +61,7 @@ dap_server_client_t * dap_udp_client_create(dap_server_t * sh, ev_io* w_client,
dap_udp_client_t * inh=DAP_NEW_Z(dap_udp_client_t);
inh->host_key = get_key(host,port);
dap_server_client_t * ret=DAP_NEW_Z(dap_server_client_t);
dap_client_remote_t * ret=DAP_NEW_Z(dap_client_remote_t);
inh->client = ret;
ret->server = sh;
ret->watcher_client = w_client;
......@@ -87,7 +87,7 @@ dap_server_client_t * dap_udp_client_create(dap_server_t * sh, ev_io* w_client,
* @param host Variable for host address
* @param host Variable for port
*/
void dap_udp_client_get_address(dap_server_client_t *client, unsigned int* host,unsigned short* port){
void dap_udp_client_get_address(dap_client_remote_t *client, unsigned int* host,unsigned short* port){
dap_udp_client_t* udp_client = DAP_UDP_CLIENT(client);
*host = udp_client->host_key >> 32;
*port = udp_client->host_key - (*host<<32);
......@@ -100,7 +100,7 @@ void dap_udp_client_get_address(dap_server_client_t *client, unsigned int* host,
* @param port Source port
* @return Pointer to client or NULL if not found
*/
dap_server_client_t * dap_udp_client_find(dap_server_t * sh, unsigned long host,unsigned short port)
dap_client_remote_t * dap_udp_client_find(dap_server_t * sh, unsigned long host,unsigned short port)
{
dap_udp_server_t* udp_server = DAP_UDP_SERVER(sh);
pthread_mutex_lock(&udp_server->mutex_on_list);
......@@ -121,7 +121,7 @@ dap_server_client_t * dap_udp_client_find(dap_server_t * sh, unsigned long host,
* @param sc Client structure
* @param is_ready Flag value
*/
void dap_udp_client_ready_to_read(dap_server_client_t * sc,bool is_ready)
void dap_udp_client_ready_to_read(dap_client_remote_t * sc,bool is_ready)
{
if(is_ready != sc->_ready_to_read) {
......@@ -145,7 +145,7 @@ void dap_udp_client_ready_to_read(dap_server_client_t * sc,bool is_ready)
* @param sc Client structure
* @param is_ready Flag value
*/
void dap_udp_client_ready_to_write(dap_server_client_t * sc,bool is_ready)
void dap_udp_client_ready_to_write(dap_client_remote_t * sc,bool is_ready)
{
// if(is_ready)
// add_waiting_client(sc); // Add client to writing queue
......@@ -169,7 +169,7 @@ void dap_udp_client_ready_to_write(dap_server_client_t * sc,bool is_ready)
* @brief add_waiting_client Add Client to write queue
* @param client Client instance
*/
void add_waiting_client(dap_server_client_t* client){
void add_waiting_client(dap_client_remote_t* client){
dap_server_t* sh = client->server;
dap_udp_server_t* udp_server = DAP_UDP_SERVER(sh);
dap_udp_client_t* udp_client = DAP_UDP_CLIENT(client);
......@@ -187,13 +187,13 @@ void add_waiting_client(dap_server_client_t* client){
}
size_t dap_udp_client_write(dap_server_client_t *sc, const void * data, size_t data_size){
size_t dap_udp_client_write(dap_client_remote_t *sc, const void * data, size_t data_size){
size_t size = dap_client_write(sc,data,data_size);
add_waiting_client(sc);
return size;
}
size_t dap_udp_client_write_f(dap_server_client_t *a_client, const char * a_format,...){
size_t dap_udp_client_write_f(dap_client_remote_t *a_client, const char * a_format,...){
size_t size = 0;
va_list ap;
va_start(ap,a_format);
......
......@@ -37,7 +37,7 @@ struct dap_udp_client;
#define UDP_CLIENT_BUF 100000
typedef struct dap_udp_client{
dap_server_client_t* client;
dap_client_remote_t* client;
uint64_t host_key; //key contains host address in first 4 bytes and port in last 4 bytes
UT_hash_handle hh;
......@@ -50,17 +50,17 @@ typedef struct dap_udp_client{
#define DAP_UDP_CLIENT(a) ((dap_udp_client_t *) (a)->_inheritor)
dap_server_client_t * dap_udp_client_create(dap_server_t * sh, ev_io* w_client, unsigned long host, unsigned short port); // Create new client and add it to the list
dap_server_client_t * dap_udp_client_find(dap_server_t * sh, unsigned long host, unsigned short port); // Find client by host and port
dap_client_remote_t * dap_udp_client_create(dap_server_t * sh, ev_io* w_client, unsigned long host, unsigned short port); // Create new client and add it to the list
dap_client_remote_t * dap_udp_client_find(dap_server_t * sh, unsigned long host, unsigned short port); // Find client by host and port
void dap_udp_client_ready_to_read(dap_server_client_t * sc,bool is_ready);
void dap_udp_client_ready_to_write(dap_server_client_t * sc,bool is_ready);
void dap_udp_client_ready_to_read(dap_client_remote_t * sc,bool is_ready);
void dap_udp_client_ready_to_write(dap_client_remote_t * sc,bool is_ready);
size_t dap_udp_client_write(dap_server_client_t *sc, const void * data, size_t data_size);
size_t dap_udp_client_write_f(dap_server_client_t *a_client, const char * a_format,...);
size_t dap_udp_client_write(dap_client_remote_t *sc, const void * data, size_t data_size);
size_t dap_udp_client_write_f(dap_client_remote_t *a_client, const char * a_format,...);
void add_waiting_client(dap_server_client_t* client); // Add client to writing queue
void add_waiting_client(dap_client_remote_t* client); // Add client to writing queue
void dap_udp_client_get_address(dap_server_client_t *client, unsigned int* host,unsigned short* port);
void dap_udp_client_get_address(dap_client_remote_t *client, unsigned int* host,unsigned short* port);
#endif
......@@ -51,7 +51,7 @@ typedef struct dap_udp_server{
} dap_udp_server_t;
#define DAP_UDP_SERVER(a) ((dap_udp_server_t *) (a)->_inheritor)
OD
extern void dap_udp_server_delete(dap_server_t * sh);
extern void dap_udp_server_loop(dap_server_t* udp_server); // Start server event loop
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment