lload.h 14.4 KB
Newer Older
1
/* lload.h - load balancer include file */
Ondřej Kuzník's avatar
Ondřej Kuzník committed
2
3
4
/* $OpenLDAP$ */
/* This work is part of OpenLDAP Software <http://www.openldap.org/>.
 *
Quanah Gibson-Mount's avatar
Quanah Gibson-Mount committed
5
 * Copyright 1998-2021 The OpenLDAP Foundation.
Ondřej Kuzník's avatar
Ondřej Kuzník committed
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted only as authorized by the OpenLDAP
 * Public License.
 *
 * A copy of this license is available in the file LICENSE in the
 * top-level directory of the distribution or, alternatively, at
 * <http://www.OpenLDAP.org/license.html>.
 */
/* Portions Copyright (c) 1995 Regents of the University of Michigan.
 * All rights reserved.
 *
 * Redistribution and use in source and binary forms are permitted
 * provided that this notice is preserved and that due credit is given
 * to the University of Michigan at Ann Arbor. The name of the University
 * may not be used to endorse or promote products derived from this
 * software without specific prior written permission. This software
 * is provided ``as is'' without express or implied warranty.
 */

27
28
#ifndef _LLOAD_H_
#define _LLOAD_H_
Ondřej Kuzník's avatar
Ondřej Kuzník committed
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

#include "ldap_defaults.h"

#include <stdio.h>
#include <ac/stdlib.h>

#include <sys/types.h>
#include <ac/syslog.h>
#include <ac/regex.h>
#include <ac/signal.h>
#include <ac/socket.h>
#include <ac/time.h>
#include <ac/param.h>

#include "avl.h"

45
#include "../servers/slapd/slap.h"
46
#include "../slapd/back-monitor/back-monitor.h"
47

Ondřej Kuzník's avatar
Ondřej Kuzník committed
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
#ifndef ldap_debug
#define ldap_debug slap_debug
#endif

#include "ldap_log.h"

#include <ldap.h>
#include <ldap_schema.h>

#include "lber_pvt.h"
#include "ldap_pvt.h"
#include "ldap_pvt_thread.h"
#include "ldap_queue.h"

#include <event2/event.h>

64
65
66
67
68
69
70
71
#ifdef HAVE_CYRUS_SASL
#ifdef HAVE_SASL_SASL_H
#include <sasl/sasl.h>
#else
#include <sasl.h>
#endif
#endif /* HAVE_CYRUS_SASL */

Ondřej Kuzník's avatar
Ondřej Kuzník committed
72
73
LDAP_BEGIN_DECL

74
75
76
#ifdef SERVICE_NAME
#undef SERVICE_NAME
#endif
Ondřej Kuzník's avatar
Ondřej Kuzník committed
77

78
#define SERVICE_NAME OPENLDAP_PACKAGE "-lloadd"
Ondřej Kuzník's avatar
Ondřej Kuzník committed
79

80
#define LLOAD_SB_MAX_INCOMING_CLIENT ( ( 1 << 24 ) - 1 )
81
#define LLOAD_SB_MAX_INCOMING_UPSTREAM ( ( 1 << 24 ) - 1 )
Ondřej Kuzník's avatar
Ondřej Kuzník committed
82

83
#define LLOAD_CONN_MAX_PDUS_PER_CYCLE_DEFAULT 10
Ondřej Kuzník's avatar
Ondřej Kuzník committed
84

85
86
#define BER_BV_OPTIONAL( bv ) ( BER_BVISNULL( bv ) ? NULL : ( bv ) )

87
88
#include <epoch.h>

Ondřej Kuzník's avatar
Ondřej Kuzník committed
89
90
91
92
93
#define checked_lock( mutex ) \
    if ( ldap_pvt_thread_mutex_lock( mutex ) != 0 ) assert(0)
#define checked_unlock( mutex ) \
    if ( ldap_pvt_thread_mutex_unlock( mutex ) != 0 ) assert(0)

Ondřej Kuzník's avatar
Ondřej Kuzník committed
94
95
96
97
98
99
100
#ifdef LDAP_THREAD_DEBUG
#define assert_locked( mutex ) \
    if ( ldap_pvt_thread_mutex_trylock( mutex ) == 0 ) assert(0)
#else
#define assert_locked( mutex ) ( (void)0 )
#endif

101
102
103
104
typedef struct LloadBackend LloadBackend;
typedef struct LloadPendingConnection LloadPendingConnection;
typedef struct LloadConnection LloadConnection;
typedef struct LloadOperation LloadOperation;
105
typedef struct LloadChange LloadChange;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
106
107
/* end of forward declarations */

108
109
typedef LDAP_CIRCLEQ_HEAD(BeSt, LloadBackend) lload_b_head;
typedef LDAP_CIRCLEQ_HEAD(ConnSt, LloadConnection) lload_c_head;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
110

111
112
LDAP_SLAPD_V (lload_b_head) backend;
LDAP_SLAPD_V (lload_c_head) clients;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
113
LDAP_SLAPD_V (ldap_pvt_thread_mutex_t) backend_mutex;
114
LDAP_SLAPD_V (LloadBackend *) current_backend;
115
LDAP_SLAPD_V (struct slap_bindconf) bindconf;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
116
LDAP_SLAPD_V (struct berval) lloadd_identity;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
117

Ondřej Kuzník's avatar
Ondřej Kuzník committed
118
119
120
121
122
/* Used to coordinate server (un)pause, shutdown */
LDAP_SLAPD_V (ldap_pvt_thread_mutex_t) lload_wait_mutex;
LDAP_SLAPD_V (ldap_pvt_thread_cond_t) lload_pause_cond;
LDAP_SLAPD_V (ldap_pvt_thread_cond_t) lload_wait_cond;

123
typedef int lload_cf_aux_table_parse_x( struct berval *val,
Ondřej Kuzník's avatar
Ondřej Kuzník committed
124
125
126
127
128
        void *bc,
        slap_cf_aux_table *tab0,
        const char *tabmsg,
        int unparse );

129
typedef struct LloadListener LloadListener;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
130

131
132
133
134
135
136
137
enum lc_type {
    LLOAD_CHANGE_UNDEFINED = 0,
    LLOAD_CHANGE_MODIFY,
    LLOAD_CHANGE_ADD,
    LLOAD_CHANGE_DEL,
};

138
139
140
enum lc_object {
    LLOAD_UNDEFINED = 0,
    LLOAD_DAEMON,
141
    /*
142
    LLOAD_BINDCONF,
143
    */
144
145
146
147
148
149
150
    LLOAD_BACKEND,
};

enum lcf_daemon {
    LLOAD_DAEMON_MOD_THREADS = 1 << 0,
    LLOAD_DAEMON_MOD_FEATURES = 1 << 1,
    LLOAD_DAEMON_MOD_TLS = 1 << 2,
151
152
    LLOAD_DAEMON_MOD_LISTENER_ADD = 1 << 3,
    LLOAD_DAEMON_MOD_LISTENER_REPLACE = 1 << 4,
153
    LLOAD_DAEMON_MOD_BINDCONF = 1 << 5,
154
155
156
157
158
159
160
161
};

enum lcf_backend {
    LLOAD_BACKEND_MOD_OTHER = 1 << 0,
    LLOAD_BACKEND_MOD_CONNS = 1 << 1,
};

struct LloadChange {
162
    enum lc_type type;
163
164
165
166
167
168
169
    enum lc_object object;
    union {
        int generic;
        enum lcf_daemon daemon;
        enum lcf_backend backend;
    } flags;
    void *target;
170
};
171

Ondřej Kuzník's avatar
Ondřej Kuzník committed
172
typedef enum {
173
#ifdef LDAP_API_FEATURE_VERIFY_CREDENTIALS
Ondřej Kuzník's avatar
Ondřej Kuzník committed
174
    LLOAD_FEATURE_VC = 1 << 0,
175
#endif /* LDAP_API_FEATURE_VERIFY_CREDENTIALS */
Ondřej Kuzník's avatar
Ondřej Kuzník committed
176
    LLOAD_FEATURE_PROXYAUTHZ = 1 << 1,
177
    LLOAD_FEATURE_PAUSE = 1 << 2,
Ondřej Kuzník's avatar
Ondřej Kuzník committed
178
179
} lload_features_t;

180
181
182
183
#define LLOAD_FEATURE_SUPPORTED_MASK ( \
    LLOAD_FEATURE_PROXYAUTHZ | \
    0 )

184
185
186
187
188
189
#ifdef BALANCER_MODULE
#define LLOAD_TLS_CTX ( lload_use_slap_tls_ctx ? slap_tls_ctx : lload_tls_ctx )
#else
#define LLOAD_TLS_CTX ( lload_tls_ctx )
#endif

Ondřej Kuzník's avatar
Ondřej Kuzník committed
190
191
192
enum lload_tls_type {
    LLOAD_CLEARTEXT = 0,
    LLOAD_LDAPS,
Ondřej Kuzník's avatar
Ondřej Kuzník committed
193
    LLOAD_STARTTLS_OPTIONAL,
Ondřej Kuzník's avatar
Ondřej Kuzník committed
194
    LLOAD_STARTTLS,
Ondřej Kuzník's avatar
Ondřej Kuzník committed
195
    LLOAD_TLS_ESTABLISHED,
Ondřej Kuzník's avatar
Ondřej Kuzník committed
196
197
};

198
199
struct LloadPendingConnection {
    LloadBackend *backend;
200
201
202
203

    struct event *event;
    ber_socket_t fd;

204
    LDAP_LIST_ENTRY(LloadPendingConnection) next;
205
206
};

207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
typedef struct lload_counters_t {
    ldap_pvt_mp_t lc_ops_completed;
    ldap_pvt_mp_t lc_ops_received;
    ldap_pvt_mp_t lc_ops_forwarded;
    ldap_pvt_mp_t lc_ops_rejected;
    ldap_pvt_mp_t lc_ops_failed;
} lload_counters_t;

enum {
    LLOAD_STATS_OPS_BIND = 0,
    LLOAD_STATS_OPS_OTHER,
    LLOAD_STATS_OPS_LAST
};

typedef struct lload_global_stats_t {
    ldap_pvt_mp_t global_incoming;
    ldap_pvt_mp_t global_outgoing;
    lload_counters_t counters[LLOAD_STATS_OPS_LAST];
} lload_global_stats_t;

Ondřej Kuzník's avatar
Ondřej Kuzník committed
227
/* Can hold mutex when locking a linked connection */
228
struct LloadBackend {
Ondřej Kuzník's avatar
Ondřej Kuzník committed
229
    ldap_pvt_thread_mutex_t b_mutex;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
230

Ondřej Kuzník's avatar
Ondřej Kuzník committed
231
    struct berval b_name, b_uri;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
232
    int b_proto, b_port;
233
    enum lload_tls_type b_tls, b_tls_conf;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
234
235
    char *b_host;

236
237
238
239
    int b_retry_timeout, b_failed;
    struct event *b_retry_event;
    struct timeval b_retry_tv;

Ondřej Kuzník's avatar
Ondřej Kuzník committed
240
    int b_numconns, b_numbindconns;
241
    int b_bindavail, b_active, b_opening;
242
243
244
    lload_c_head b_conns, b_bindconns, b_preparing;
    LDAP_LIST_HEAD(ConnectingSt, LloadPendingConnection) b_connecting;
    LloadConnection *b_last_conn, *b_last_bindconn;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
245

246
247
248
    long b_max_pending, b_max_conn_pending;
    long b_n_ops_executing;

249
250
    lload_counters_t b_counters[LLOAD_STATS_OPS_LAST];

251
252
253
254
#ifdef BALANCER_MODULE
    monitor_subsys_t *b_monitor;
#endif /* BALANCER_MODULE */

255
    struct evdns_getaddrinfo_request *b_dns_req;
256
    void *b_cookie;
257

258
    LDAP_CIRCLEQ_ENTRY(LloadBackend) b_next;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
259
260
};

261
262
263
typedef int (*LloadOperationHandler)( LloadConnection *client,
        LloadOperation *op,
        BerElement *ber );
264
typedef int (*RequestHandler)( LloadConnection *c, LloadOperation *op );
Ondřej Kuzník's avatar
Ondřej Kuzník committed
265
266
267
268
typedef struct lload_exop_handlers_t {
    struct berval oid;
    RequestHandler func;
} ExopHandler;
269

270
271
typedef int (*CONNECTION_PDU_CB)( LloadConnection *c );
typedef void (*CONNECTION_DESTROY_CB)( LloadConnection *c );
Ondřej Kuzník's avatar
Ondřej Kuzník committed
272

Ondřej Kuzník's avatar
Ondřej Kuzník committed
273
/* connection state (protected by c_mutex) */
274
enum sc_state {
275
276
277
278
279
    LLOAD_C_INVALID = 0, /* MUST BE ZERO (0) */
    LLOAD_C_READY,       /* ready */
    LLOAD_C_CLOSING,     /* closing */
    LLOAD_C_ACTIVE,      /* exclusive operation (tls setup, ...) in progress */
    LLOAD_C_BINDING,     /* binding */
280
281
    LLOAD_C_DYING,       /* part-processed dead waiting to be freed, someone
                          * might still be observing it */
Ondřej Kuzník's avatar
Ondřej Kuzník committed
282
};
283
enum sc_type {
284
285
286
287
    LLOAD_C_OPEN = 0,  /* regular connection */
    LLOAD_C_PREPARING, /* upstream connection not assigned yet */
    LLOAD_C_BIND, /* connection used to handle bind client requests if VC not enabled */
    LLOAD_C_PRIVILEGED, /* connection can override proxyauthz control */
288
};
289
290
291
292
293
294
295
296
297
enum sc_io_state {
    LLOAD_C_OPERATIONAL = 0,        /* all is good */
    LLOAD_C_READ_HANDOVER = 1 << 0, /* A task to process PDUs is scheduled or
                                     * running, do not re-enable c_read_event */
    LLOAD_C_READ_PAUSE = 1 << 1,    /* We want to pause reading until the client
                                     * has sufficiently caught up with what we
                                     * sent */
};

298
299
300
/*
 * represents a connection from an ldap client/to ldap server
 */
301
struct LloadConnection {
302
    enum sc_state c_state; /* connection state */
303
    enum sc_type c_type;
304
    enum sc_io_state c_io_state;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
305
    ber_socket_t c_fd;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
306

307
/*
308
 * LloadConnection reference counting:
309
310
 * - connection has a reference counter in c_refcnt
 * - also a liveness/validity token is added to c_refcnt during
311
 *   lload_connection_init, its existence is tracked in c_live and is usually the
312
 *   only one that prevents it from being destroyed
313
314
315
 * - anyone who needs to be able to relock the connection after unlocking it has
 *   to use acquire_ref(), they need to make sure a matching
 *   RELEASE_REF( c, c_refcnt, c->c_destroy ); is run eventually
316
 * - when a connection is considered dead, use CONNECTION_DESTROY on a locked
317
318
319
320
321
 *   connection, it will be made unreachable from normal places and either
 *   scheduled for reclamation when safe to do so or if anyone still holds a
 *   reference, it just gets unlocked and reclaimed after the last ref is
 *   released
 * - CONNECTION_LOCK_DESTROY is a shorthand for locking and CONNECTION_DESTROY
322
 */
Ondřej Kuzník's avatar
Ondřej Kuzník committed
323
    ldap_pvt_thread_mutex_t c_mutex; /* protect the connection */
324
325
    uintptr_t c_refcnt, c_live;
    CONNECTION_DESTROY_CB c_unlink;
326
327
    CONNECTION_DESTROY_CB c_destroy;
    CONNECTION_PDU_CB c_pdu_cb;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
328
#define CONNECTION_ASSERT_LOCKED(c) assert_locked( &(c)->c_mutex )
Ondřej Kuzník's avatar
Ondřej Kuzník committed
329
330
331
332
333
334
335
336
#define CONNECTION_LOCK(c) \
    do { \
        checked_lock( &(c)->c_mutex ); \
    } while (0)
#define CONNECTION_UNLOCK(c) \
    do { \
        checked_unlock( &(c)->c_mutex ); \
    } while (0)
337
#define CONNECTION_UNLINK_(c) \
338
    do { \
339
        if ( __atomic_exchange_n( &(c)->c_live, 0, __ATOMIC_ACQ_REL ) ) { \
340
341
            RELEASE_REF( (c), c_refcnt, c->c_destroy ); \
            (c)->c_unlink( (c) ); \
342
343
        } \
    } while (0)
344
#define CONNECTION_DESTROY(c) \
345
    do { \
346
347
        CONNECTION_UNLINK_(c); \
        CONNECTION_UNLOCK(c); \
348
    } while (0)
349
#define CONNECTION_LOCK_DESTROY(c) \
350
    do { \
351
        CONNECTION_LOCK(c); \
352
        CONNECTION_DESTROY(c); \
353
354
355
    } while (0);

    Sockbuf *c_sb; /* ber connection stuff */
Ondřej Kuzník's avatar
Ondřej Kuzník committed
356
357
358
359
360
361

    /* set by connection_init */
    unsigned long c_connid;    /* unique id of this connection */
    struct berval c_peer_name; /* peer name (trans=addr:port) */
    time_t c_starttime;        /* when the connection was opened */

Ondřej Kuzník's avatar
Ondřej Kuzník committed
362
363
    time_t c_activitytime;  /* when the connection was last used */
    ber_int_t c_next_msgid; /* msgid of the next message */
Ondřej Kuzník's avatar
Ondřej Kuzník committed
364

365
    /* must not be used while holding either mutex */
Ondřej Kuzník's avatar
Ondřej Kuzník committed
366
    struct event *c_read_event, *c_write_event;
367
    struct timeval *c_read_timeout;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
368
369
370

    /* can only be changed by binding thread */
    struct berval c_sasl_bind_mech; /* mech in progress */
Ondřej Kuzník's avatar
Ondřej Kuzník committed
371
372
    struct berval c_auth;           /* authcDN (possibly in progress) */

Ondřej Kuzník's avatar
Ondřej Kuzník committed
373
374
    unsigned long c_pin_id;

375
376
377
#ifdef HAVE_CYRUS_SASL
    sasl_conn_t *c_sasl_authctx;
    void *c_sasl_defaults;
378
379
380
381
#ifdef SASL_CHANNEL_BINDING /* 2.1.25+ */
    sasl_channel_binding_t *c_sasl_cbinding; /* Else cyrus-sasl would happily
                                              * leak it on sasl_dispose */
#endif /* SASL_CHANNEL_BINDING */
382
383
#endif /* HAVE_CYRUS_SASL */

Ondřej Kuzník's avatar
Ondřej Kuzník committed
384
#ifdef LDAP_API_FEATURE_VERIFY_CREDENTIALS
Ondřej Kuzník's avatar
Ondřej Kuzník committed
385
    struct berval c_vc_cookie;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
386
#endif /* LDAP_API_FEATURE_VERIFY_CREDENTIALS */
Ondřej Kuzník's avatar
Ondřej Kuzník committed
387

Ondřej Kuzník's avatar
Ondřej Kuzník committed
388
389
    /* Can be held while acquiring c_mutex to inject things into c_ops or
     * destroy the connection */
Ondřej Kuzník's avatar
Ondřej Kuzník committed
390
391
    ldap_pvt_thread_mutex_t c_io_mutex; /* only one pdu written at a time */

Ondřej Kuzník's avatar
Ondřej Kuzník committed
392
393
    BerElement *c_currentber; /* ber we're attempting to read */
    BerElement *c_pendingber; /* ber we're attempting to write */
Ondřej Kuzník's avatar
Ondřej Kuzník committed
394

Ondřej Kuzník's avatar
Ondřej Kuzník committed
395
396
    TAvlnode *c_ops; /* Operations pending on the connection */

Ondřej Kuzník's avatar
Ondřej Kuzník committed
397
#ifdef HAVE_TLS
Ondřej Kuzník's avatar
Ondřej Kuzník committed
398
    enum lload_tls_type c_is_tls; /* true if this LDAP over raw TLS */
Ondřej Kuzník's avatar
Ondřej Kuzník committed
399
400
#endif

401
402
403
    long c_n_ops_executing;      /* num of ops currently executing */
    long c_n_ops_completed;      /* num of ops completed */
    lload_counters_t c_counters; /* per connection operation counters */
Ondřej Kuzník's avatar
Ondřej Kuzník committed
404

405
406
407
408
409
    /*
     * Protected by the CIRCLEQ mutex:
     * - Client: clients_mutex
     * - Upstream: b->b_mutex
     */
410
    LDAP_CIRCLEQ_ENTRY(LloadConnection) c_next;
411

Ondřej Kuzník's avatar
Ondřej Kuzník committed
412
413
414
    void *c_private;
};

Ondřej Kuzník's avatar
Ondřej Kuzník committed
415
enum op_state {
416
    LLOAD_OP_NOT_FREEING = 0,
417
418
    LLOAD_OP_DETACHING_CLIENT = 1 << 1,
    LLOAD_OP_DETACHING_UPSTREAM = 1 << 0,
Ondřej Kuzník's avatar
Ondřej Kuzník committed
419
};
420

421
422
423
#define LLOAD_OP_DETACHING_MASK \
    ( LLOAD_OP_DETACHING_UPSTREAM | LLOAD_OP_DETACHING_CLIENT )

424
425
426
427
428
429
430
/* operation result for monitoring purposes */
enum op_result {
    LLOAD_OP_REJECTED,  /* operation was not forwarded */
    LLOAD_OP_COMPLETED, /* operation sent and response received */
    LLOAD_OP_FAILED, /* operation was forwarded, but no response was received */
};

431
432
433
434
435
436
/*
 * Operation reference tracking:
 * - o_refcnt is set to 1, never incremented
 * - operation_unlink sets it to 0 and on transition from 1 clears both
 *   connection links (o_client, o_upstream)
 */
437
struct LloadOperation {
438
439
    uintptr_t o_refcnt;

440
    LloadConnection *o_client;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
441
442
    unsigned long o_client_connid;
    ber_int_t o_client_msgid;
443
    ber_int_t o_saved_msgid;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
444

445
    LloadConnection *o_upstream;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
446
447
    unsigned long o_upstream_connid;
    ber_int_t o_upstream_msgid;
448
    time_t o_last_response;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
449

450
    /* Protects o_client, o_upstream links */
Ondřej Kuzník's avatar
Ondřej Kuzník committed
451
    ldap_pvt_thread_mutex_t o_link_mutex;
452

Ondřej Kuzník's avatar
Ondřej Kuzník committed
453
    ber_tag_t o_tag;
454
    time_t o_start;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
455
    unsigned long o_pin_id;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
456

457
    enum op_result o_res;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
458
459
460
461
    BerElement *o_ber;
    BerValue o_request, o_ctrls;
};

Ondřej Kuzník's avatar
Ondřej Kuzník committed
462
463
464
/*
 * listener; need to access it from monitor backend
 */
465
struct LloadListener {
Ondřej Kuzník's avatar
Ondřej Kuzník committed
466
467
468
469
470
471
    struct berval sl_url;
    struct berval sl_name;
    mode_t sl_perms;
#ifdef HAVE_TLS
    int sl_is_tls;
#endif
472
    int sl_is_proxied;
Ondřej Kuzník's avatar
Ondřej Kuzník committed
473
474
475
476
477
478
479
480
481
482
483
484
485
486
    struct event_base *base;
    struct evconnlistener *listener;
    int sl_mute; /* Listener is temporarily disabled due to emfile */
    int sl_busy; /* Listener is busy (accept thread activated) */
    ber_socket_t sl_sd;
    Sockaddr sl_sa;
#define sl_addr sl_sa.sa_in_addr
#define LDAP_TCP_BUFFER
#ifdef LDAP_TCP_BUFFER
    int sl_tcp_rmem; /* custom TCP read buffer size */
    int sl_tcp_wmem; /* custom TCP write buffer size */
#endif
};

Ondřej Kuzník's avatar
Ondřej Kuzník committed
487
typedef int (*CONNCB)( LloadConnection *c, void *arg );
488
489
490
491
492
493

struct lload_monitor_conn_arg {
    Operation *op;
    monitor_subsys_t *ms;
    Entry **ep;
};
494
495
496
497
498

/* config requires a bi_private with configuration data - dummy for now */
struct lload_conf_info {
    int dummy;
};
Ondřej Kuzník's avatar
Ondřej Kuzník committed
499
500
LDAP_END_DECL

501
502
#include "proto-lload.h"
#endif /* _LLOAD_H_ */