2022-01-24 03:28:16 +00:00
|
|
|
#ifndef LAIKA_PEER_H
|
|
|
|
#define LAIKA_PEER_H
|
|
|
|
|
|
|
|
#include "laika.h"
|
|
|
|
#include "lsocket.h"
|
|
|
|
#include "lpacket.h"
|
|
|
|
#include "lpolllist.h"
|
|
|
|
|
2022-01-27 19:36:36 +00:00
|
|
|
typedef enum {
|
|
|
|
PEER_BOT,
|
|
|
|
PEER_CNC, /* cnc 2 cnc communication */
|
|
|
|
PEER_AUTH /* authorized peers can send commands to cnc */
|
|
|
|
} PEERTYPE;
|
|
|
|
|
2022-01-24 03:28:16 +00:00
|
|
|
struct sLaika_peer {
|
2022-01-25 02:50:14 +00:00
|
|
|
struct sLaika_socket sock; /* DO NOT MOVE THIS. this member HAS TO BE FIRST so that typecasting sLaika_peer* to sLaika_sock* works as intended */
|
2022-01-24 03:28:16 +00:00
|
|
|
struct sLaika_pollList *pList; /* pollList we're active in */
|
2022-01-25 03:46:29 +00:00
|
|
|
void (*pktHandler)(struct sLaika_peer *peer, uint8_t id, void *uData);
|
2022-01-25 02:57:54 +00:00
|
|
|
void *uData; /* data to be passed to pktHandler */
|
2022-01-25 19:53:17 +00:00
|
|
|
LAIKAPKT_SIZE *pktSizeTable; /* const table to pull pkt size data from */
|
|
|
|
LAIKAPKT_SIZE pktSize; /* current pkt size */
|
|
|
|
LAIKAPKT_ID pktID; /* current pkt ID */
|
2022-01-27 19:36:36 +00:00
|
|
|
PEERTYPE type;
|
2022-01-25 02:50:14 +00:00
|
|
|
bool setPollOut; /* is EPOLLOUT/POLLOUT is set on sock's pollfd ? */
|
2022-01-24 03:28:16 +00:00
|
|
|
};
|
|
|
|
|
2022-01-25 19:53:17 +00:00
|
|
|
struct sLaika_peer *laikaS_newPeer(void (*pktHandler)(struct sLaika_peer *peer, LAIKAPKT_ID id, void *uData), LAIKAPKT_SIZE *pktSizeTable, struct sLaika_pollList *pList, void *uData);
|
2022-01-24 03:28:16 +00:00
|
|
|
void laikaS_freePeer(struct sLaika_peer *peer);
|
|
|
|
|
|
|
|
bool laikaS_handlePeerIn(struct sLaika_peer *peer);
|
|
|
|
bool laikaS_handlePeerOut(struct sLaika_peer *peer);
|
|
|
|
|
|
|
|
#endif
|