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
142
143
144
145
146
147
148
149
150
151
|
#
# Ouroboros - Copyright (C) 2016 - 2026
#
# Python API for Ouroboros
#
# Dimitri Staessens <dimitri@ouroboros.rocks>
#
# This library is free software; you can redistribute it and/or
# modify it under the terms of the GNU Lesser General Public License
# version 2.1 as published by the Free Software Foundation.
#
# This library is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
# Lesser General Public License for more details.
#
# You should have received a copy of the GNU Lesser General Public
# License along with this library; if not, write to the Free Software
# Foundation, Inc., http://www.fsf.org/about/contact/.
#
from cffi import FFI
ffibuilder: FFI = FFI()
ffibuilder.cdef("""
/* System types */
typedef long... time_t;
struct timespec {
time_t tv_sec;
long tv_nsec;
...;
};
/* OUROBOROS QOS.H */
typedef struct qos_spec {
uint32_t delay;
uint64_t bandwidth;
uint8_t availability;
uint32_t loss;
uint32_t ber;
uint8_t in_order;
uint32_t max_gap;
uint32_t timeout; /* Timeout in ms */
} qosspec_t;
/* OUROBOROS DEV.H */
/* Returns flow descriptor, qs updates to supplied QoS. */
int flow_alloc(const char * dst_name,
qosspec_t * qs,
const struct timespec * timeo);
/* Returns flow descriptor, qs updates to supplied QoS. */
int flow_accept(qosspec_t * qs,
const struct timespec * timeo);
/* Returns flow descriptor. */
int flow_join(const char * bc,
const struct timespec * timeo);
int flow_dealloc(int fd);
ssize_t flow_write(int fd,
const void * buf,
size_t count);
ssize_t flow_read(int fd,
void * buf,
size_t count);
/* OUROBOROS FCCNTL.H, VIA WRAPPER */
int flow_set_snd_timeout(int fd, struct timespec * ts);
int flow_set_rcv_timeout(int fd, struct timespec * ts);
int flow_get_snd_timeout(int fd, struct timespec * ts);
int flow_get_rcv_timeout(int fd, struct timespec * ts);
int flow_get_qos(int fd, qosspec_t * qs);
int flow_get_rx_qlen(int fd, size_t * sz);
int flow_get_tx_qlen(int fd, size_t * sz);
int flow_set_flags(int fd, uint32_t flags);
int flow_get_flags(int fd);
int flow_set_frct_flags(int fd, uint16_t flags);
int flow_get_frct_flags(int fd);
/* OUROBOROS FQUEUE.H */
enum fqtype {
FLOW_PKT = ...,
FLOW_DOWN = ...,
FLOW_UP = ...,
FLOW_ALLOC = ...,
FLOW_DEALLOC = ...,
FLOW_PEER = ...
};
struct flow_set;
struct fqueue;
typedef struct flow_set fset_t;
typedef struct fqueue fqueue_t;
fset_t * fset_create(void);
void fset_destroy(fset_t * set);
fqueue_t * fqueue_create(void);
void fqueue_destroy(struct fqueue * fq);
void fset_zero(fset_t * set);
int fset_add(fset_t * set,
int fd);
bool fset_has(const fset_t * set,
int fd);
void fset_del(fset_t * set,
int fd);
int fqueue_next(fqueue_t * fq);
enum fqtype fqueue_type(fqueue_t * fq);
ssize_t fevent(fset_t * set,
fqueue_t * fq,
const struct timespec * timeo);
""")
ffibuilder.set_source("_ouroboros_dev_cffi",
"""
#include "ouroboros/qos.h"
#include "ouroboros/dev.h"
#include "fccntl_wrap.h"
#include "ouroboros/fqueue.h"
""",
libraries=['ouroboros-dev'],
extra_compile_args=["-I./ffi/"])
if __name__ == "__main__":
ffibuilder.compile(verbose=True)
|
