l0-server.h

Go to the documentation of this file.

#ifndef L0_SERVER_H
#define L0_SERVER_H

#include <ev.h>
#include <pbl.h>
#include "modules/cque.h"
#include "net_com.h"
#include "subscribe.h"
#include "teonet_l0_client.h"

typedef struct ksnLNullData { // \TODO: will be renamed to teoL0Data
    ev_io   w;                 
    char   *name;              
    size_t  name_length;       
    void   *read_buffer;       
    size_t  read_buffer_ptr;   
    size_t  read_buffer_size;  
    
    char   *t_addr;            
    int     t_port;            
    int     t_channel;         
    double  last_time;

    teoLNullEncryptionContext *server_crypt; // \TODO: will be renamed to teoL0EncryptionContext
} ksnLNullData;

typedef struct  ksnLNullClass { // \TODO: will be renamed to teoL0Class
    void           *ke;         
    PblMap         *map;        
    PblMap         *map_n;      
    int             fd;         
    ksnLNullSStat   stat;       
    int             fd_trudp;   
    ksnCQueClass   *cque;       
} ksnLNullClass;

#pragma pack(push)
#pragma pack(1)

typedef struct ksnLNullSPacket { // \TODO: will be renamed to teoL0SPacket
    uint8_t     cmd;                
    uint8_t     client_name_length; 
    uint16_t    data_length;        
    char        payload[];          
} ksnLNullSPacket;

#pragma pack(pop)

#ifdef  __cplusplus
extern "C" {
#endif

ksnLNullClass *ksnLNullInit(void *ke);
void ksnLNullDestroy(ksnLNullClass *kl);
int ksnLNullSendToL0(void *ke, char *addr, int port, char *cname, 
        size_t cname_length, uint8_t cmd, void *data, size_t data_len);
int ksnLNullSendEchoToL0(void *ke, char *addr, int port, char *cname,
        size_t cname_length, void *data, size_t data_len);
int ksnLNullSendEchoToL0A(void *ke, char *addr, int port, char *cname,
        size_t cname_length, void *data, size_t data_len);
int ksnLNullClientIsConnected(ksnLNullClass *kl, char *client_name);
teonet_client_data_ar *ksnLNullClientsList(ksnLNullClass *kl);
size_t ksnLNullClientsListLength(teonet_client_data_ar *clients_data);
ksnLNullSStat *ksnLNullStat(ksnLNullClass *kl);
int ksnLNulltrudpCheckPaket(ksnLNullClass *kl, ksnCorePacketData *rd);
ssize_t ksnLNullPacketSend(ksnLNullClass *kl, int fd, void *pkg, size_t pkg_length);
void ksnLNullClientDisconnect(ksnLNullClass *kl, int fd, int remove_f);

teoLNullEncryptionContext *ksnLNullClientGetCrypto(ksnLNullClass *kl, int fd);

#ifdef  __cplusplus
}
#endif

#endif  /* L0_SERVER_H */