Filter needs to process the event of checkpoint/failover or other event passed by COLO frame. Signed-off-by: zhanghailiang <zhang.zhanghailiang@huawei.com> Signed-off-by: Zhang Chen <zhangckid@gmail.com> Signed-off-by: Zhang Chen <chen.zhang@intel.com> Signed-off-by: Jason Wang <jasowang@redhat.com>
86 lines
2.7 KiB
C
86 lines
2.7 KiB
C
/*
|
|
* Copyright (c) 2015 FUJITSU LIMITED
|
|
* Author: Yang Hongyang <yanghy@cn.fujitsu.com>
|
|
*
|
|
* This work is licensed under the terms of the GNU GPL, version 2 or
|
|
* later. See the COPYING file in the top-level directory.
|
|
*/
|
|
|
|
#ifndef QEMU_NET_FILTER_H
|
|
#define QEMU_NET_FILTER_H
|
|
|
|
#include "qapi/qapi-types-net.h"
|
|
#include "qom/object.h"
|
|
#include "qemu-common.h"
|
|
#include "net/queue.h"
|
|
|
|
#define TYPE_NETFILTER "netfilter"
|
|
#define NETFILTER(obj) \
|
|
OBJECT_CHECK(NetFilterState, (obj), TYPE_NETFILTER)
|
|
#define NETFILTER_GET_CLASS(obj) \
|
|
OBJECT_GET_CLASS(NetFilterClass, (obj), TYPE_NETFILTER)
|
|
#define NETFILTER_CLASS(klass) \
|
|
OBJECT_CLASS_CHECK(NetFilterClass, (klass), TYPE_NETFILTER)
|
|
|
|
typedef void (FilterSetup) (NetFilterState *nf, Error **errp);
|
|
typedef void (FilterCleanup) (NetFilterState *nf);
|
|
/*
|
|
* Return:
|
|
* 0: finished handling the packet, we should continue
|
|
* size: filter stolen this packet, we stop pass this packet further
|
|
*/
|
|
typedef ssize_t (FilterReceiveIOV)(NetFilterState *nc,
|
|
NetClientState *sender,
|
|
unsigned flags,
|
|
const struct iovec *iov,
|
|
int iovcnt,
|
|
NetPacketSent *sent_cb);
|
|
|
|
typedef void (FilterStatusChanged) (NetFilterState *nf, Error **errp);
|
|
|
|
typedef void (FilterHandleEvent) (NetFilterState *nf, int event, Error **errp);
|
|
|
|
typedef struct NetFilterClass {
|
|
ObjectClass parent_class;
|
|
|
|
/* optional */
|
|
FilterSetup *setup;
|
|
FilterCleanup *cleanup;
|
|
FilterStatusChanged *status_changed;
|
|
FilterHandleEvent *handle_event;
|
|
/* mandatory */
|
|
FilterReceiveIOV *receive_iov;
|
|
} NetFilterClass;
|
|
|
|
|
|
struct NetFilterState {
|
|
/* private */
|
|
Object parent;
|
|
|
|
/* protected */
|
|
char *netdev_id;
|
|
NetClientState *netdev;
|
|
NetFilterDirection direction;
|
|
bool on;
|
|
QTAILQ_ENTRY(NetFilterState) next;
|
|
};
|
|
|
|
ssize_t qemu_netfilter_receive(NetFilterState *nf,
|
|
NetFilterDirection direction,
|
|
NetClientState *sender,
|
|
unsigned flags,
|
|
const struct iovec *iov,
|
|
int iovcnt,
|
|
NetPacketSent *sent_cb);
|
|
|
|
/* pass the packet to the next filter */
|
|
ssize_t qemu_netfilter_pass_to_next(NetClientState *sender,
|
|
unsigned flags,
|
|
const struct iovec *iov,
|
|
int iovcnt,
|
|
void *opaque);
|
|
|
|
void colo_notify_filters_event(int event, Error **errp);
|
|
|
|
#endif /* QEMU_NET_FILTER_H */
|