Run bringup and takedown for every test.
[beanstalkd.git] / tube.h
blobccd78d3e318544fac05e6c9d4026ff6e8c77466d
1 /* tube.h - tubes header */
3 /* Copyright (C) 2008 Keith Rarick and Philotic Inc.
5 * This program is free software: you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation, either version 3 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
15 * You should have received a copy of the GNU General Public License
16 * along with this program. If not, see <http://www.gnu.org/licenses/>.
19 #ifndef tube_h
20 #define tube_h
22 typedef struct tube *tube;
24 typedef void(*evh)(int, short, void *);
26 #include "stat.h"
27 #include "job.h"
28 #include "pq.h"
29 #include "ms.h"
31 #define MAX_TUBE_NAME_LEN 201
33 struct tube {
34 unsigned int refs;
35 char name[MAX_TUBE_NAME_LEN];
36 struct pq ready;
37 struct pq delay;
38 struct job buried;
39 struct ms waiting; /* set of conns */
40 struct stats stat;
41 unsigned int using_ct;
42 unsigned int watching_ct;
45 extern struct ms tubes;
47 tube make_tube(const char *name);
48 void tube_dref(tube t);
49 void tube_iref(tube t);
50 tube tube_find(const char *name);
51 tube tube_find_or_make(const char *name);
52 #define TUBE_ASSIGN(a,b) (tube_dref(a), (a) = (b), tube_iref(a))
54 #endif /*tube_h*/