mirror of
https://github.com/haiwen/ccnet-server.git
synced 2025-04-28 10:33:20 +00:00
85 lines
2.2 KiB
C
85 lines
2.2 KiB
C
|
/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
|
||
|
|
|
||
|
|
#ifndef CCNET_PACKET_IO_H
|
||
|
|
#define CCNET_PACKET_IO_H
|
||
|
|
|
||
|
|
#include "packet.h"
|
||
|
|
|
||
|
|
#if defined(__FreeBSD__) || defined(__NetBSD__) || defined(__OpenBSD__)
|
||
|
|
#include <event2/util.h>
|
||
|
|
#include <event2/buffer.h>
|
||
|
|
#include <event2/buffer_compat.h>
|
||
|
|
#else
|
||
|
|
#include <evutil.h>
|
||
|
|
#endif
|
||
|
|
|
||
|
|
/* struct evbuffer; */
|
||
|
|
/* for libevent2 */
|
||
|
|
struct evbuffer;
|
||
|
|
|
||
|
|
struct bufferevent;
|
||
|
|
struct CcnetSession;
|
||
|
|
struct ccnet_packet;
|
||
|
|
|
||
|
|
typedef void (*ccnet_can_read_cb)(struct ccnet_packet *, void* user_data);
|
||
|
|
typedef void (*ccnet_did_write_cb)(struct bufferevent *, void *);
|
||
|
|
typedef void (*ccnet_net_error_cb)(struct bufferevent *, short what, void *);
|
||
|
|
|
||
|
|
typedef struct CcnetPacketIO CcnetPacketIO;
|
||
|
|
|
||
|
|
struct CcnetPacketIO
|
||
|
|
{
|
||
|
|
unsigned int is_incoming : 1;
|
||
|
|
unsigned int handling : 1; /* handling event from this IO */
|
||
|
|
unsigned int schedule_free : 1;
|
||
|
|
|
||
|
|
int timeout;
|
||
|
|
|
||
|
|
struct sockaddr *addr;
|
||
|
|
evutil_socket_t socket;
|
||
|
|
|
||
|
|
struct CcnetSession *session;
|
||
|
|
|
||
|
|
struct bufferevent *bufev;
|
||
|
|
|
||
|
|
ccnet_can_read_cb canRead;
|
||
|
|
ccnet_did_write_cb didWrite;
|
||
|
|
ccnet_net_error_cb gotError;
|
||
|
|
void *user_data;
|
||
|
|
};
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
CcnetPacketIO*
|
||
|
|
ccnet_packet_io_new_outgoing (struct CcnetSession *session,
|
||
|
|
const char *addr_str, uint16_t port);
|
||
|
|
|
||
|
|
|
||
|
|
CcnetPacketIO*
|
||
|
|
ccnet_packet_io_new_incoming (struct CcnetSession *session,
|
||
|
|
struct sockaddr_storage *addr,
|
||
|
|
evutil_socket_t socket);
|
||
|
|
|
||
|
|
|
||
|
|
void ccnet_packet_io_free (CcnetPacketIO *io);
|
||
|
|
|
||
|
|
struct CcnetSession* ccnet_packet_io_get_session (CcnetPacketIO *io);
|
||
|
|
|
||
|
|
|
||
|
|
int ccnet_packet_io_reconnect (CcnetPacketIO *io);
|
||
|
|
|
||
|
|
int ccnet_packet_io_is_incoming (const CcnetPacketIO *io);
|
||
|
|
|
||
|
|
void ccnet_packet_io_set_timeout_secs (CcnetPacketIO *io, int secs);
|
||
|
|
|
||
|
|
|
||
|
|
void ccnet_packet_io_write_packet (CcnetPacketIO *io, ccnet_packet *packet);
|
||
|
|
|
||
|
|
void ccnet_packet_io_set_iofuncs (CcnetPacketIO *io,
|
||
|
|
ccnet_can_read_cb readcb,
|
||
|
|
ccnet_did_write_cb writecb,
|
||
|
|
ccnet_net_error_cb errcb,
|
||
|
|
void *user_data);
|
||
|
|
|
||
|
|
#endif
|