blob: 3e00c4559d8a0cf314747a5fdf4650336f0e044e (
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
|
#ifndef _OSMO_CONN_H
#define _OSMO_CONN_H
#include <osmocom/core/select.h>
#include <osmocom/core/linuxlist.h>
#include <osmocom/core/socket.h>
#include <osmocom/core/write_queue.h>
struct osmo_conn;
struct osmo_link {
struct llist_head list;
struct osmo_fd ofd;
const char *addr;
uint16_t port;
struct llist_head conns;
int slave_max_qlen;
void (*accept_cb)(struct osmo_conn *conn);
int (*slave_read_cb)(struct osmo_conn *conn);
};
struct osmo_conn {
struct llist_head list;
struct osmo_link *link;
struct osmo_wqueue queue;
struct {
const char *host;
uint16_t port;
} remote;
void *priv;
};
int osmo_conn_enqueue(struct osmo_conn *conn, struct msgb *msg);
void osmo_conn_close(struct osmo_conn *conn);
struct osmo_link *osmo_link_create(void *ctx, const char *addr, uint16_t port,
int (*read_cb)(struct osmo_conn *),
int slave_max_qlen);
int osmo_link_listen(struct osmo_link *link,
void (*accept_cb)(struct osmo_conn *));
int osmo_link_close(struct osmo_link *link);
#endif
|
