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
152
153
154
155
156
157
158
159
160
161
162
|
#ifndef HYBBX_CIRCUIT_TCP_H
#define HYBBX_CIRCUIT_TCP_H
/**
* HBX/Circuit TCP hub on Main (Circuit = TCP listener :7323; HBX = framed
* payloads on that stream). Remote Secondary processes connect via LINK_AUTH.
* Secondaries are separate edge machines (extenders/repeaters), not telnet users
* or local [transport.*] adapters on Main.
* Hub: [circuit] bind/port. Client: hybbx_circuit_link_* + LINK_AUTH.
* All inter-node paths (Secondary, mains_proxy mesh, future relays) use this
* client pattern only — never a direct socket to a remote HyBBX Main.
* Formal name: HBX — Hybrid Bridge eXchange (v1); see docs/TOPOLOGY.md.
*/
#include "hybbx/circuit.h"
#include "hybbx/circuit_balance.h"
#include "hybbx/circuit_bridge.h"
#include "hybbx/service.h"
#include "hybbx/types.h"
#include "hybbx/limits.h"
#ifdef __cplusplus
extern "C" {
#endif
typedef struct hybbx_circuit_hub hybbx_circuit_hub_t;
typedef struct hybbx_circuit_config {
char bind4[64];
char bind6[64];
unsigned port;
int ipv4;
int ipv6;
char link_password[128];
unsigned link_stale_days;
int link_auth;
char data_path[HYBBX_PATH_MAX];
char config_path[HYBBX_PATH_MAX];
unsigned max_links;
hybbx_circuit_bridge_registry_t bridge;
hybbx_circuit_balance_config_t balance;
} hybbx_circuit_config_t;
/** Internal transport plugin used for sessions bridged over the circuit hub. */
extern const hybbx_transport_plugin_t hybbx_plugin_circuit;
void hybbx_circuit_config_defaults(hybbx_circuit_config_t *cfg);
hybbx_circuit_hub_t *hybbx_circuit_hub_create(hybbx_service_t *service);
void hybbx_circuit_hub_destroy(hybbx_circuit_hub_t *hub);
hybbx_result_t hybbx_circuit_hub_start(hybbx_circuit_hub_t *hub,
const hybbx_circuit_config_t *cfg);
void hybbx_circuit_hub_stop(hybbx_circuit_hub_t *hub);
int hybbx_circuit_hub_running(const hybbx_circuit_hub_t *hub);
unsigned hybbx_circuit_hub_port(const hybbx_circuit_hub_t *hub);
/**
* Send a pre-encoded HBX frame to the attached link adapter.
*/
hybbx_result_t hybbx_circuit_hub_send_raw(hybbx_circuit_hub_t *hub,
const uint8_t *frame, size_t len);
hybbx_result_t hybbx_circuit_hub_send_hbx(hybbx_circuit_hub_t *hub,
const uint8_t *frame, size_t len);
unsigned hybbx_circuit_hub_active_link_count(const hybbx_circuit_hub_t *hub);
/**
* Send HBX to all active links. @p frequency_mhz 0 = any MHz.
* @p require_broadcast_qos filters to low-bandwidth + half-duplex links.
* Returns OK when at least one link accepted the frame.
*/
hybbx_result_t hybbx_circuit_hub_multicast_hbx(hybbx_circuit_hub_t *hub,
const uint8_t *frame, size_t len,
double frequency_mhz,
int require_broadcast_qos,
unsigned *sent_out);
/**
* Send HBX to one circuit slot (sequential AX.25 broadcast).
* @p slot_index must be an active broadcast-QoS link when @p require_broadcast_qos.
*/
hybbx_result_t hybbx_circuit_hub_send_hbx_slot(hybbx_circuit_hub_t *hub,
unsigned slot_index,
const uint8_t *frame, size_t len,
int require_broadcast_qos);
double hybbx_circuit_hub_link_frequency_mhz(const hybbx_circuit_hub_t *hub);
/** Non-zero when link QoS is low-bandwidth and half-duplex (AX.25 broadcast allowed). */
int hybbx_circuit_hub_link_broadcast_qos(const hybbx_circuit_hub_t *hub);
typedef struct hybbx_circuit_broadcast_link {
double frequency_mhz;
unsigned slot_index;
char link_id[HYBBX_LINK_ID_MAX];
} hybbx_circuit_broadcast_link_t;
/**
* Active broadcast-QoS links sorted by MHz (then link_id).
* Returns count written to @p out (may be 0).
*/
unsigned hybbx_circuit_hub_broadcast_links(const hybbx_circuit_hub_t *hub,
hybbx_circuit_broadcast_link_t *out,
unsigned out_max);
void hybbx_circuit_hub_prune_links(hybbx_circuit_hub_t *hub);
/** Record RF activity on a link adapter (RX or TX). */
void hybbx_circuit_hub_note_rf_activity(hybbx_circuit_hub_t *hub,
const char *link_id);
/** Non-zero when @p slot_index has had no RF activity for @p min_idle_sec. */
int hybbx_circuit_hub_link_band_idle(const hybbx_circuit_hub_t *hub,
unsigned slot_index,
unsigned min_idle_sec);
/**
* Earliest time a broadcast may TX on @p slot_index (now if already idle).
* Returns (time_t)-1 when the slot is unavailable.
*/
time_t hybbx_circuit_hub_link_band_ready_at(const hybbx_circuit_hub_t *hub,
unsigned slot_index,
unsigned min_idle_sec);
/** Link adapter: connect to the internal circuit hub (TCP client). */
hybbx_result_t hybbx_circuit_link_connect(const char *host, unsigned port,
int *out_fd);
hybbx_result_t hybbx_circuit_link_write(int fd, const uint8_t *frame,
size_t len);
hybbx_result_t hybbx_circuit_link_read(int fd, uint8_t *buf, size_t buf_len,
size_t *read_len);
/**
* Send LINK_AUTH HBX frame after TCP connect (link/repeater edge daemon
* toward the centralized daemon). Password only — no heartbeat/ping.
*/
hybbx_result_t hybbx_circuit_link_authenticate(int fd,
const char *password,
const char *role,
const char *id);
/**
* LINK_AUTH with optional QoS (baud, duplex, bandwidth) for auto load-balancing.
*/
hybbx_result_t hybbx_circuit_link_authenticate_ex(int fd,
const char *password,
const char *role,
const char *id,
const hybbx_circuit_link_qos_t *qos);
#ifdef __cplusplus
}
#endif
#endif /* HYBBX_CIRCUIT_TCP_H */
|
