blob: ec8d5d081d405f25bac7afced5ca305b72c31c14 [file] [log] [blame]
Willy Tarreaucff64112008-11-03 06:26:53 +01001/*
Willy Tarreau8e89b842009-10-18 23:56:35 +02002 * include/proto/stream_interface.h
3 * This file contains stream_interface function prototypes
4 *
Willy Tarreaub24281b2011-02-13 13:16:36 +01005 * Copyright (C) 2000-2011 Willy Tarreau - w@1wt.eu
Willy Tarreau8e89b842009-10-18 23:56:35 +02006 *
7 * This library is free software; you can redistribute it and/or
8 * modify it under the terms of the GNU Lesser General Public
9 * License as published by the Free Software Foundation, version 2.1
10 * exclusively.
11 *
12 * This library is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * Lesser General Public License for more details.
16 *
17 * You should have received a copy of the GNU Lesser General Public
18 * License along with this library; if not, write to the Free Software
19 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
20 */
Willy Tarreaucff64112008-11-03 06:26:53 +010021
22#ifndef _PROTO_STREAM_INTERFACE_H
23#define _PROTO_STREAM_INTERFACE_H
24
25#include <stdlib.h>
26
27#include <common/config.h>
28#include <types/stream_interface.h>
29
30
31/* main event functions used to move data between sockets and buffers */
Willy Tarreau269358d2009-09-20 20:14:49 +020032int stream_int_check_timeouts(struct stream_interface *si);
Willy Tarreaucff64112008-11-03 06:26:53 +010033void stream_int_report_error(struct stream_interface *si);
Willy Tarreaudded32d2008-11-30 19:48:07 +010034void stream_int_retnclose(struct stream_interface *si, const struct chunk *msg);
Willy Tarreaucff64112008-11-03 06:26:53 +010035
Willy Tarreaufb90d942009-09-05 20:57:35 +020036/* functions used when running a stream interface as a task */
37void stream_int_update(struct stream_interface *si);
38void stream_int_update_embedded(struct stream_interface *si);
39void stream_int_shutr(struct stream_interface *si);
40void stream_int_shutw(struct stream_interface *si);
41void stream_int_chk_rcv(struct stream_interface *si);
42void stream_int_chk_snd(struct stream_interface *si);
43
44struct task *stream_int_register_handler(struct stream_interface *si,
Willy Tarreaub24281b2011-02-13 13:16:36 +010045 struct si_applet *app);
Willy Tarreaufb90d942009-09-05 20:57:35 +020046struct task *stream_int_register_handler_task(struct stream_interface *si,
47 struct task *(*fct)(struct task *));
48void stream_int_unregister_handler(struct stream_interface *si);
49
Willy Tarreau9e000c62011-03-10 14:03:36 +010050static inline void clear_target(struct target *dest)
51{
52 dest->type = TARG_TYPE_NONE;
53 dest->ptr.v = NULL;
54}
55
56static inline void set_target_server(struct target *dest, struct server *s)
57{
58 dest->type = TARG_TYPE_SERVER;
59 dest->ptr.s = s;
60}
61
62static inline void set_target_proxy(struct target *dest, struct proxy *p)
63{
64 dest->type = TARG_TYPE_PROXY;
65 dest->ptr.p = p;
66}
67
68static inline void set_target_applet(struct target *dest, struct si_applet *a)
69{
70 dest->type = TARG_TYPE_APPLET;
71 dest->ptr.a = a;
72}
73
74static inline void set_target_task(struct target *dest, struct task *t)
75{
76 dest->type = TARG_TYPE_TASK;
77 dest->ptr.t = t;
78}
79
80static inline struct target *copy_target(struct target *dest, struct target *src)
81{
82 *dest = *src;
83 return dest;
84}
85
86static inline int target_match(struct target *a, struct target *b)
87{
88 return a->type == b->type && a->ptr.v == b->ptr.v;
89}
90
Willy Tarreau827aee92011-03-10 16:55:02 +010091static inline struct server *target_srv(struct target *t)
92{
93 if (!t || t->type != TARG_TYPE_SERVER)
94 return NULL;
95 return t->ptr.s;
96}
97
Willy Tarreaucff64112008-11-03 06:26:53 +010098#endif /* _PROTO_STREAM_INTERFACE_H */
99
100/*
101 * Local variables:
102 * c-indent-level: 8
103 * c-basic-offset: 8
104 * End:
105 */