blob: b101026b2e472cd9016aed2e9c30a6ef70178ad8 (
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
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
// Copyright (C) 2003 Davis E. King (davis@dlib.net)
// License: Boost Software License See LICENSE.txt for the full license.
#ifndef DLIB_LINKER_KERNEl_1_
#define DLIB_LINKER_KERNEl_1_
#include "linker_kernel_abstract.h"
#include "../threads.h"
#include "../sockets.h"
#include "../algs.h"
namespace dlib
{
class linker
{
/*!
INITIAL VALUE
running == false
A == 0
B == 0
running_mutex == a mutex
running_signaler == a signaler associated with running_mutex
cons_mutex == a mutex
service_connection_running == false
service_connection_running_mutex == a mutex
service_connection_running_signaler == a signaler associated with
service_connection_running_mutex
service_connection_error == false
service_connection_error_mutex == a mutex
CONVENTION
running == is_running()
running_mutex == a mutex for running
running_signaler == a signaler for signaling when
running becomes false and is associated with
running_mutex
cons_mutex == a mutex for A and B
service_connection_running == true when service_connection() is
running or is about to run else
false
service_connection_running_mutex == a mutex for service_connection_running
service_connection_running_signaler == a signaler associated with
service_connection_running_mutex
if (running) then
A == address of a from link()
B == address of b from link()
else
A == 0
B == 0
service_connection_error == service_connection uses this bool
to indicate if it terminated due to
an error or not
service_connection_error_mutex == a mutex for service_connection_error
!*/
public:
// These two typedefs are here for backwards compatibility with previous
// versions of dlib.
typedef linker kernel_1a;
typedef linker kernel_1a_c;
linker(
);
linker (
connection& a,
connection& b
);
virtual ~linker(
);
void clear(
);
bool is_running(
) const;
void link (
connection& a,
connection& b
);
private:
static void service_connection (
void* param
);
/*!
requires
param == pointer to a linker object
ensures
waits for data from b and forwards it to a and
if (b closes normally or is shutdown()) service_connection ends and
if (b closes normally) then a.shutdown_outgoing() is called and
if (a or b returns an error) then a and b are shutdown()
!*/
// data members
bool running;
mutex running_mutex;
signaler running_signaler;
connection* A;
connection* B;
mutex cons_mutex;
bool service_connection_running;
mutex service_connection_running_mutex;
signaler service_connection_running_signaler;
bool service_connection_error;
mutex service_connection_error_mutex;
// restricted functions
linker(linker&); // copy constructor
linker& operator=(linker&); // assignment operator
};
}
#ifdef NO_MAKEFILE
#include "linker_kernel_1.cpp"
#endif
#endif // DLIB_LINKER_KERNEl_1_
|
