blob: f84a7d632e2876d1bf3e5e6c7e9450bd95501e6a (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
/* Monkey HTTP Server
* ==================
* Copyright 2001-2017 Eduardo Silva <eduardo@monkey.io>
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef MK_SERVER_H
#define MK_SERVER_H
#define _GNU_SOURCE
#include <monkey/mk_socket.h>
#include <monkey/mk_config.h>
#include <monkey/mk_core.h>
#define MK_SERVER_SIGNAL_START 0xEEEEEEEE
#define MK_SERVER_SIGNAL_STOP 0xDDDDDDDD
struct mk_server_listen
{
struct mk_event event;
int server_fd;
struct mk_plugin *network;
struct mk_sched_handler *protocol;
struct mk_config_listener *listen;
struct mk_list _head;
};
struct mk_server_timeout {
struct mk_event event;
};
extern pthread_key_t mk_server_fifo_key;
#ifdef MK_HAVE_C_TLS
extern __thread struct mk_list *server_listen;
extern __thread struct mk_server_timeout *server_timeout;
#endif
struct mk_sched_worker;
int mk_socket_set_cork_flag(int fd, int state);
static inline int mk_server_cork_flag(int fd, int state)
{
return mk_socket_set_cork_flag(fd, state);
}
struct mk_server *mk_server_create();
int mk_server_listen_check(struct mk_server_listen *listen, int server_fd);
void mk_server_listen_free();
struct mk_list *mk_server_listen_init(struct mk_server *server);
unsigned int mk_server_capacity(struct mk_server *server);
void mk_server_launch_workers(struct mk_server *server);
void mk_server_worker_loop(struct mk_server *server);
void mk_server_loop_balancer(struct mk_server *server);
void mk_server_worker_loop(struct mk_server *server);
void mk_server_loop(struct mk_server *server);
#endif
|
