1 // SPDX-License-Identifier: BSD-2-Clause
3 * Copyright (C) 2020 Andre Heider <a.heider@gmail.com>
16 #include "dsl_cpe_control.h"
17 #include <drv_dsl_cpe_api_ioctl.h>
18 #ifdef INCLUDE_DSL_CPE_API_VRX
19 #include <drv_mei_cpe_interface.h>
22 #define U16(v1, v2) ( \
23 ((uint16_t)(v1) << 8) | \
26 #define U32(v1, v2, v3, v4) ( \
27 ((uint32_t)(v1) << 24) | \
28 ((uint32_t)(v2) << 16) | \
29 ((uint32_t)(v3) << 8) | \
32 #define STR_CASE(id, text) \
37 #define STR_CASE_MAP(id, text, number) \
43 #define IOCTL(type, request) \
45 memset(&out, 0, sizeof(type)); \
46 if (ioctl(fd, request, &out)) \
49 #define IOCTL_DIR(type, request, dir) \
51 memset(&out, 0, sizeof(type)); \
52 out.nDirection = dir; \
53 if (ioctl(fd, request, &out)) \
56 #define IOCTL_DIR_DELT(type, request, dir, delt) \
58 memset(&out, 0, sizeof(type)); \
59 out.nDirection = dir; \
60 out.nDeltDataType = delt; \
61 if (ioctl(fd, request, &out)) \
108 /* These values are exported via ubus and backwards compability
112 LSTATE_MAP_UNKNOWN
= -1,
113 LSTATE_MAP_NOT_INITIALIZED
,
114 LSTATE_MAP_EXCEPTION
,
117 LSTATE_MAP_HANDSHAKE
,
118 LSTATE_MAP_FULL_INIT
,
119 LSTATE_MAP_SHOWTIME_NO_SYNC
,
120 LSTATE_MAP_SHOWTIME_TC_SYNC
,
124 /* These values are exported via ubus and backwards compability
128 PSTATE_MAP_UNKNOWN
= -2,
136 static DSL_CPE_ThreadCtrl_t thread
;
137 static struct ubus_context
*ctx
;
138 static struct blob_buf b
;
140 static inline void m_null() {
141 blobmsg_add_field(&b
, BLOBMSG_TYPE_UNSPEC
, "", NULL
, 0);
144 static inline void m_double(const char *id
, double value
) {
145 blobmsg_add_double(&b
, id
, value
);
148 static inline void m_bool(const char *id
, bool value
) {
149 blobmsg_add_u8(&b
, id
, value
);
152 static inline void m_u32(const char *id
, uint32_t value
) {
153 blobmsg_add_u64(&b
, id
, value
);
156 static inline void m_str(const char *id
, const char *value
) {
157 blobmsg_add_string(&b
, id
, value
);
160 static inline void m_db(const char *id
, int value
, int invalid
) {
161 if (value
!= invalid
)
162 m_double(id
, (double)value
/ 10);
165 static inline void m_array(const char *id
, const uint8_t *value
, size_t len
) {
166 void *c
= blobmsg_open_array(&b
, id
);
168 for (size_t i
= 0; i
< len
; ++i
)
169 blobmsg_add_u16(&b
, "", value
[i
]);
171 blobmsg_close_array(&b
, c
);
174 static void m_vendor(const char *id
, const uint8_t *value
) {
176 if (U16(value
[0], value
[1]) != 0xb500)
179 const char *str
= NULL
;
180 switch (U32(value
[2], value
[3], value
[4], value
[5])) {
181 STR_CASE(0x414C4342, "Alcatel")
182 STR_CASE(0x414E4456, "Analog Devices")
183 STR_CASE(0x4244434D, "Broadcom")
184 STR_CASE(0x43454E54, "Centillium")
185 STR_CASE(0x4753504E, "Globespan")
186 STR_CASE(0x494B4E53, "Ikanos")
187 STR_CASE(0x4946544E, "Infineon")
188 STR_CASE(0x54535443, "Texas Instruments")
189 STR_CASE(0x544D4D42, "Thomson MultiMedia Broadband")
190 STR_CASE(0x5443544E, "Trend Chip Technologies")
191 STR_CASE(0x53544D49, "ST Micro")
197 if ((value
[6] == 0) && (value
[7] == 0)) {
203 sprintf(buf
, "%s %d.%d", str
, value
[6], value
[7]);
209 annex_t
get_annex(const uint8_t *xtse
) {
210 if ((xtse
[0] & XTSE_1_01_A_T1_413
) ||
211 (xtse
[0] & XTSE_1_03_A_1_NO
) ||
212 (xtse
[0] & XTSE_1_04_A_1_O
) ||
213 (xtse
[1] & XTSE_2_01_A_2_NO
) ||
214 (xtse
[2] & XTSE_3_03_A_3_NO
) ||
215 (xtse
[2] & XTSE_3_04_A_3_O
) ||
216 (xtse
[3] & XTSE_4_01_A_4_NO
) ||
217 (xtse
[3] & XTSE_4_02_A_4_O
) ||
218 (xtse
[5] & XTSE_6_01_A_5_NO
) ||
219 (xtse
[5] & XTSE_6_02_A_5_O
) ||
220 (xtse
[7] & XTSE_8_01_A
))
223 if ((xtse
[0] & XTSE_1_05_B_1_NO
) ||
224 (xtse
[0] & XTSE_1_06_B_1_O
) ||
225 (xtse
[1] & XTSE_2_02_B_2_O
) ||
226 (xtse
[2] & XTSE_3_05_B_3_NO
) ||
227 (xtse
[2] & XTSE_3_06_B_3_O
) ||
228 (xtse
[5] & XTSE_6_03_B_5_NO
) ||
229 (xtse
[5] & XTSE_6_04_B_5_O
) ||
230 (xtse
[7] & XTSE_8_02_B
))
233 if ((xtse
[0] & XTSE_1_02_C_TS_101388
) ||
234 (xtse
[0] & XTSE_1_07_C_1_NO
) ||
235 (xtse
[0] & XTSE_1_08_C_1_O
) ||
236 (xtse
[1] & XTSE_2_03_C_2_NO
) ||
237 (xtse
[1] & XTSE_2_04_C_2_O
) ||
238 (xtse
[7] & XTSE_8_03_C
))
241 if ((xtse
[3] & XTSE_4_05_I_3_NO
) ||
242 (xtse
[3] & XTSE_4_06_I_3_O
) ||
243 (xtse
[4] & XTSE_5_01_I_4_NO
) ||
244 (xtse
[4] & XTSE_5_02_I_4_O
) ||
245 (xtse
[5] & XTSE_6_07_I_5_NO
) ||
246 (xtse
[5] & XTSE_6_08_I_5_O
))
249 if ((xtse
[3] & XTSE_4_07_J_3_NO
) ||
250 (xtse
[3] & XTSE_4_08_J_3_O
) ||
251 (xtse
[6] & XTSE_7_01_J_5_NO
) ||
252 (xtse
[6] & XTSE_7_02_J_5_O
))
255 if ((xtse
[4] & XTSE_5_03_L_3_NO
) ||
256 (xtse
[4] & XTSE_5_04_L_3_NO
) ||
257 (xtse
[4] & XTSE_5_05_L_3_O
) ||
258 (xtse
[4] & XTSE_5_06_L_3_O
))
261 if ((xtse
[4] & XTSE_5_07_M_3_NO
) ||
262 (xtse
[4] & XTSE_5_08_M_3_O
) ||
263 (xtse
[6] & XTSE_7_03_M_5_NO
) ||
264 (xtse
[6] & XTSE_7_04_M_5_O
))
267 return ANNEX_UNKNOWN
;
270 static standard_t
get_standard(const uint8_t *xtse
) {
271 if (xtse
[0] & XTSE_1_01_A_T1_413
)
274 if (xtse
[0] & XTSE_1_02_C_TS_101388
)
275 return STD_TS_101_388
;
277 if ((xtse
[0] & XTSE_1_03_A_1_NO
) ||
278 (xtse
[0] & XTSE_1_04_A_1_O
) ||
279 (xtse
[0] & XTSE_1_05_B_1_NO
) ||
280 (xtse
[0] & XTSE_1_06_B_1_O
) ||
281 (xtse
[0] & XTSE_1_07_C_1_NO
) ||
282 (xtse
[0] & XTSE_1_08_C_1_O
))
285 if ((xtse
[1] & XTSE_2_01_A_2_NO
) ||
286 (xtse
[1] & XTSE_2_02_B_2_O
) ||
287 (xtse
[1] & XTSE_2_03_C_2_NO
) ||
288 (xtse
[1] & XTSE_2_04_C_2_O
))
291 if ((xtse
[2] & XTSE_3_03_A_3_NO
) ||
292 (xtse
[2] & XTSE_3_04_A_3_O
) ||
293 (xtse
[2] & XTSE_3_05_B_3_NO
) ||
294 (xtse
[2] & XTSE_3_06_B_3_O
) ||
295 (xtse
[3] & XTSE_4_05_I_3_NO
) ||
296 (xtse
[3] & XTSE_4_06_I_3_O
) ||
297 (xtse
[3] & XTSE_4_07_J_3_NO
) ||
298 (xtse
[3] & XTSE_4_08_J_3_O
) ||
299 (xtse
[4] & XTSE_5_03_L_3_NO
) ||
300 (xtse
[4] & XTSE_5_04_L_3_NO
) ||
301 (xtse
[4] & XTSE_5_05_L_3_O
) ||
302 (xtse
[4] & XTSE_5_06_L_3_O
) ||
303 (xtse
[4] & XTSE_5_07_M_3_NO
) ||
304 (xtse
[4] & XTSE_5_08_M_3_O
))
307 if ((xtse
[3] & XTSE_4_01_A_4_NO
) ||
308 (xtse
[3] & XTSE_4_02_A_4_O
) ||
309 (xtse
[4] & XTSE_5_01_I_4_NO
) ||
310 (xtse
[4] & XTSE_5_02_I_4_O
))
313 if ((xtse
[5] & XTSE_6_01_A_5_NO
) ||
314 (xtse
[5] & XTSE_6_02_A_5_O
) ||
315 (xtse
[5] & XTSE_6_03_B_5_NO
) ||
316 (xtse
[5] & XTSE_6_04_B_5_O
) ||
317 (xtse
[5] & XTSE_6_07_I_5_NO
) ||
318 (xtse
[5] & XTSE_6_08_I_5_O
) ||
319 (xtse
[6] & XTSE_7_01_J_5_NO
) ||
320 (xtse
[6] & XTSE_7_02_J_5_O
) ||
321 (xtse
[6] & XTSE_7_03_M_5_NO
) ||
322 (xtse
[6] & XTSE_7_04_M_5_O
))
325 if (xtse
[7] & XTSE_8_08
)
328 if ((xtse
[7] & XTSE_8_01_A
) ||
329 (xtse
[7] & XTSE_8_02_B
) ||
330 (xtse
[7] & XTSE_8_03_C
))
336 static void version_information(int fd
) {
337 IOCTL(DSL_VersionInformation_t
, DSL_FIO_VERSION_INFORMATION_GET
)
339 m_str("api_version", out
.data
.DSL_DriverVersionApi
);
340 m_str("firmware_version", out
.data
.DSL_ChipSetFWVersion
);
341 m_str("chipset", out
.data
.DSL_ChipSetType
);
342 m_str("driver_version", out
.data
.DSL_DriverVersionMeiBsp
);
345 static void line_state(int fd
) {
346 IOCTL(DSL_LineState_t
, DSL_FIO_LINE_STATE_GET
)
348 int map
= LSTATE_MAP_UNKNOWN
;
350 switch (out
.data
.nLineState
) {
351 STR_CASE_MAP(DSL_LINESTATE_NOT_INITIALIZED
, "Not initialized", LSTATE_MAP_NOT_INITIALIZED
)
352 STR_CASE_MAP(DSL_LINESTATE_EXCEPTION
, "Exception", LSTATE_MAP_EXCEPTION
)
353 STR_CASE(DSL_LINESTATE_NOT_UPDATED
, "Not updated")
354 STR_CASE(DSL_LINESTATE_IDLE_REQUEST
, "Idle request")
355 STR_CASE_MAP(DSL_LINESTATE_IDLE
, "Idle", LSTATE_MAP_IDLE
)
356 STR_CASE(DSL_LINESTATE_SILENT_REQUEST
, "Silent request")
357 STR_CASE_MAP(DSL_LINESTATE_SILENT
, "Silent", LSTATE_MAP_SILENT
)
358 STR_CASE_MAP(DSL_LINESTATE_HANDSHAKE
, "Handshake", LSTATE_MAP_HANDSHAKE
)
359 STR_CASE(DSL_LINESTATE_BONDING_CLR
, "Bonding CLR")
360 STR_CASE_MAP(DSL_LINESTATE_FULL_INIT
, "Full init", LSTATE_MAP_FULL_INIT
)
361 STR_CASE(DSL_LINESTATE_SHORT_INIT_ENTRY
, "Short init entry")
362 STR_CASE(DSL_LINESTATE_DISCOVERY
, "Discovery")
363 STR_CASE(DSL_LINESTATE_TRAINING
, "Training")
364 STR_CASE(DSL_LINESTATE_ANALYSIS
, "Analysis")
365 STR_CASE(DSL_LINESTATE_EXCHANGE
, "Exchange")
366 STR_CASE_MAP(DSL_LINESTATE_SHOWTIME_NO_SYNC
, "Showtime without TC-Layer sync", LSTATE_MAP_SHOWTIME_NO_SYNC
)
367 STR_CASE_MAP(DSL_LINESTATE_SHOWTIME_TC_SYNC
, "Showtime with TC-Layer sync", LSTATE_MAP_SHOWTIME_TC_SYNC
)
368 STR_CASE(DSL_LINESTATE_FASTRETRAIN
, "Fastretrain")
369 STR_CASE(DSL_LINESTATE_LOWPOWER_L2
, "Lowpower L2")
370 STR_CASE(DSL_LINESTATE_LOOPDIAGNOSTIC_ACTIVE
, "Loopdiagnostic active")
371 STR_CASE(DSL_LINESTATE_LOOPDIAGNOSTIC_DATA_EXCHANGE
, "Loopdiagnostic data exchange")
372 STR_CASE(DSL_LINESTATE_LOOPDIAGNOSTIC_DATA_REQUEST
, "Loopdiagnostic data request")
373 STR_CASE(DSL_LINESTATE_LOOPDIAGNOSTIC_COMPLETE
, "Loopdiagnostic complete")
374 STR_CASE_MAP(DSL_LINESTATE_RESYNC
, "Resync", LSTATE_MAP_RESYNC
)
375 STR_CASE(DSL_LINESTATE_TEST
, "Test")
376 STR_CASE(DSL_LINESTATE_TEST_LOOP
, "Test loop")
377 STR_CASE(DSL_LINESTATE_TEST_REVERB
, "Test reverb")
378 STR_CASE(DSL_LINESTATE_TEST_MEDLEY
, "Test medley")
379 STR_CASE(DSL_LINESTATE_TEST_SHOWTIME_LOCK
, "Showtime lock")
380 STR_CASE(DSL_LINESTATE_TEST_QUIET
, "Quiet")
381 STR_CASE(DSL_LINESTATE_LOWPOWER_L3
, "Lowpower L3")
382 #ifndef INCLUDE_DSL_CPE_API_DANUBE
383 STR_CASE(DSL_LINESTATE_DISABLED
, "Disabled")
384 STR_CASE(DSL_LINESTATE_T1413
, "T1413")
385 STR_CASE(DSL_LINESTATE_ORDERLY_SHUTDOWN_REQUEST
, "Orderly shutdown request")
386 STR_CASE(DSL_LINESTATE_ORDERLY_SHUTDOWN
, "Orderly shutdown")
387 STR_CASE(DSL_LINESTATE_TEST_FILTERDETECTION_ACTIVE
, "Test filterdetection active")
388 STR_CASE(DSL_LINESTATE_TEST_FILTERDETECTION_COMPLETE
, "Test filterdetection complete")
398 if (map
!= LSTATE_MAP_UNKNOWN
)
399 m_u32("state_num", map
);
401 m_bool("up", out
.data
.nLineState
== DSL_LINESTATE_SHOWTIME_TC_SYNC
);
404 static void pm_channel_counters_showtime(int fd
) {
405 IOCTL_DIR(DSL_PM_ChannelCounters_t
, DSL_FIO_PM_CHANNEL_COUNTERS_SHOWTIME_GET
, DSL_NEAR_END
);
407 m_u32("uptime", out
.interval
.nElapsedTime
);
410 static void g997_line_inventory(int fd
) {
411 IOCTL_DIR(DSL_G997_LineInventory_t
, DSL_FIO_G997_LINE_INVENTORY_GET
, DSL_DOWNSTREAM
)
413 m_array("vendor_id", out
.data
.G994VendorID
, DSL_G997_LI_MAXLEN_VENDOR_ID
);
414 m_vendor("vendor", out
.data
.G994VendorID
);
415 m_array("system_vendor_id", out
.data
.SystemVendorID
, DSL_G997_LI_MAXLEN_VENDOR_ID
);
416 m_vendor("system_vendor", out
.data
.SystemVendorID
);
417 m_array("version", out
.data
.VersionNumber
, DSL_G997_LI_MAXLEN_VERSION
);
418 m_array("serial", out
.data
.SerialNumber
, DSL_G997_LI_MAXLEN_SERIAL
);
421 static void g977_get_bit_allocation(int fd
, DSL_AccessDir_t direction
) {
422 IOCTL_DIR(DSL_G997_BitAllocationNsc_t
, DSL_FIO_G997_BIT_ALLOCATION_NSC_GET
, direction
);
424 // create default value to obtain consistent JSON structure
425 m_u32("groupsize", 1);
426 m_u32("groups", out
.data
.bitAllocationNsc
.nNumData
);
427 m_array("data", out
.data
.bitAllocationNsc
.nNSCData
, out
.data
.bitAllocationNsc
.nNumData
);
430 static void g977_get_snr(int fd
, DSL_AccessDir_t direction
) {
431 IOCTL_DIR_DELT(DSL_G997_DeltSnr_t
, DSL_FIO_G997_DELT_SNR_GET
, direction
, DSL_DELT_DATA_SHOWTIME
);
433 m_u32("groupsize", out
.data
.nGroupSize
);
434 m_u32("groups", out
.data
.deltSnr
.nNumData
);
436 void *c
= blobmsg_open_array(&b
, "data");
439 for (uint16_t i
= 0 ; i
< out
.data
.deltSnr
.nNumData
; i
++)
440 if (out
.data
.deltSnr
.nNSCData
[i
] != 255 && out
.data
.deltSnr
.nNSCData
[i
] != 0)
441 m_double("", -32 + (double)out
.data
.deltSnr
.nNSCData
[i
] / 2);
445 blobmsg_close_array(&b
, c
);
448 static void g977_get_qln(int fd
, DSL_AccessDir_t direction
) {
449 IOCTL_DIR_DELT(DSL_G997_DeltQln_t
, DSL_FIO_G997_DELT_QLN_GET
, direction
, DSL_DELT_DATA_SHOWTIME
);
451 m_u32("groupsize", out
.data
.nGroupSize
);
452 m_u32("groups", out
.data
.deltQln
.nNumData
);
454 void *c
= blobmsg_open_array(&b
, "data");
456 // QLN -150 ... -23 dBm/Hz
457 for (uint16_t i
= 0 ; i
< out
.data
.deltQln
.nNumData
; i
++)
458 if (out
.data
.deltQln
.nNSCData
[i
] != 255 && out
.data
.deltQln
.nNSCData
[i
] != 0)
459 m_double("", -23 - (double)out
.data
.deltQln
.nNSCData
[i
] / 2);
463 blobmsg_close_array(&b
, c
);
466 static void g977_get_hlog(int fd
, DSL_AccessDir_t direction
) {
467 IOCTL_DIR_DELT(DSL_G997_DeltHlog_t
, DSL_FIO_G997_DELT_HLOG_GET
, direction
, DSL_DELT_DATA_SHOWTIME
);
469 m_u32("groupsize", out
.data
.nGroupSize
);
470 m_u32("groups", out
.data
.deltHlog
.nNumData
);
472 void *c
= blobmsg_open_array(&b
, "data");
474 // HLOG +6 ... -96 dB
475 for (uint16_t i
= 0 ; i
< out
.data
.deltHlog
.nNumData
; i
++)
476 if (out
.data
.deltHlog
.nNSCData
[i
] != 1023 && out
.data
.deltHlog
.nNSCData
[i
] != 0)
477 m_double("", 6 - (double)out
.data
.deltHlog
.nNSCData
[i
] / 10);
481 blobmsg_close_array(&b
, c
);
484 static void g997_power_management_status(int fd
) {
485 IOCTL(DSL_G997_PowerManagementStatus_t
, DSL_FIO_G997_POWER_MANAGEMENT_STATUS_GET
)
487 int map
= PSTATE_MAP_UNKNOWN
;
489 switch (out
.data
.nPowerManagementStatus
) {
490 STR_CASE_MAP(DSL_G997_PMS_NA
, "Power management state is not available", PSTATE_MAP_NA
)
491 STR_CASE_MAP(DSL_G997_PMS_L0
, "L0 - Synchronized", PSTATE_MAP_L0
)
492 STR_CASE_MAP(DSL_G997_PMS_L1
, "L1 - Power Down Data transmission (G.992.2)", PSTATE_MAP_L1
)
493 STR_CASE_MAP(DSL_G997_PMS_L2
, "L2 - Power Down Data transmission (G.992.3 and G.992.4)", PSTATE_MAP_L2
)
494 STR_CASE_MAP(DSL_G997_PMS_L3
, "L3 - No power", PSTATE_MAP_L3
)
501 m_str("power_state", str
);
503 if (map
!= PSTATE_MAP_UNKNOWN
)
504 m_u32("power_state_num", map
);
507 static void g997_xtu_system_enabling(int fd
, standard_t
*standard
) {
508 IOCTL(DSL_G997_XTUSystemEnabling_t
, DSL_FIO_G997_XTU_SYSTEM_ENABLING_STATUS_GET
)
510 m_array("xtse", out
.data
.XTSE
, DSL_G997_NUM_XTSE_OCTETS
);
513 switch (get_annex(out
.data
.XTSE
)) {
514 STR_CASE(ANNEX_A
, "A")
515 STR_CASE(ANNEX_B
, "B")
516 STR_CASE(ANNEX_C
, "C")
517 STR_CASE(ANNEX_I
, "I")
518 STR_CASE(ANNEX_J
, "J")
519 STR_CASE(ANNEX_L
, "L")
520 STR_CASE(ANNEX_M
, "M")
528 *standard
= get_standard(out
.data
.XTSE
);
531 STR_CASE(STD_T1_413
, "T1.413")
532 STR_CASE(STD_TS_101_388
, "TS 101 388")
533 STR_CASE(STD_G_992_1
, "G.992.1")
534 STR_CASE(STD_G_992_2
, "G.992.2")
535 STR_CASE(STD_G_992_3
, "G.992.3")
536 STR_CASE(STD_G_992_4
, "G.992.4")
537 STR_CASE(STD_G_992_5
, "G.992.5")
538 STR_CASE(STD_G_993_1
, "G.993.1")
539 STR_CASE(STD_G_993_2
, "G.993.2")
545 m_str("standard", str
);
548 static void get_vector_status(int fd
, vector_t
*status
) {
549 *status
= VECTOR_UNKNOWN
;
551 #ifdef INCLUDE_DSL_CPE_API_VRX
555 IOCTL(IOCTL_MEI_dsmStatus_t
, FIO_MEI_DSM_STATUS_GET
);
557 switch (out
.eVectorStatus
) {
558 case e_MEI_VECTOR_STAT_OFF
:
559 *status
= VECTOR_OFF
;
561 case e_MEI_VECTOR_STAT_ON_DS
:
562 *status
= VECTOR_ON_DS
;
564 case e_MEI_VECTOR_STAT_ON_DS_US
:
565 *status
= VECTOR_ON_DS_US
;
573 static void vector_erb(int fd
) {
574 #ifdef INCLUDE_DSL_CPE_API_VRX
578 IOCTL(IOCTL_MEI_dsmStatistics_t
, FIO_MEI_DSM_STATISTICS_GET
);
580 m_u32("sent", out
.n_processed
);
581 m_u32("discarded", out
.n_fw_dropped_size
+ out
.n_mei_dropped_size
+ out
.n_mei_dropped_no_pp_cb
+ out
.n_pp_dropped
);
585 static void band_plan_status(int fd
, profile_t
*profile
) {
586 #if (INCLUDE_DSL_CPE_API_VDSL_SUPPORT == 1)
587 IOCTL(DSL_BandPlanStatus_t
, DSL_FIO_BAND_PLAN_STATUS_GET
)
589 switch (out
.data
.nProfile
) {
591 *profile
= PROFILE_8A
;
594 *profile
= PROFILE_8B
;
597 *profile
= PROFILE_8C
;
600 *profile
= PROFILE_8D
;
602 case DSL_PROFILE_12A
:
603 *profile
= PROFILE_12A
;
605 case DSL_PROFILE_12B
:
606 *profile
= PROFILE_12B
;
608 case DSL_PROFILE_17A
:
609 *profile
= PROFILE_17A
;
611 case DSL_PROFILE_30A
:
612 *profile
= PROFILE_30A
;
614 case DSL_PROFILE_35B
:
615 *profile
= PROFILE_35B
;
618 *profile
= PROFILE_UNKNOWN
;
624 STR_CASE(PROFILE_8A
, "8a")
625 STR_CASE(PROFILE_8B
, "8b")
626 STR_CASE(PROFILE_8C
, "8c")
627 STR_CASE(PROFILE_8D
, "8d")
628 STR_CASE(PROFILE_12A
, "12a")
629 STR_CASE(PROFILE_12B
, "12b")
630 STR_CASE(PROFILE_17A
, "17a")
631 STR_CASE(PROFILE_30A
, "30a")
632 STR_CASE(PROFILE_35B
, "35b")
638 m_str("profile", str
);
642 static void line_feature_config(int fd
, DSL_AccessDir_t direction
) {
643 IOCTL_DIR(DSL_LineFeature_t
, DSL_FIO_LINE_FEATURE_STATUS_GET
, direction
)
645 m_bool("trellis", out
.data
.bTrellisEnable
);
646 m_bool("bitswap", out
.data
.bBitswapEnable
);
647 m_bool("retx", out
.data
.bReTxEnable
);
648 m_bool("virtual_noise", out
.data
.bVirtualNoiseSupport
);
651 static void g997_channel_status(int fd
, DSL_AccessDir_t direction
) {
652 IOCTL_DIR(DSL_G997_ChannelStatus_t
, DSL_FIO_G997_CHANNEL_STATUS_GET
, direction
);
654 m_u32("interleave_delay", out
.data
.ActualInterleaveDelay
* 10);
655 #ifndef INCLUDE_DSL_CPE_API_DANUBE
656 // prefer ACTNDR, see comments in drv_dsl_cpe_api_g997.h
657 m_u32("data_rate", out
.data
.ActualNetDataRate
);
659 m_u32("data_rate", out
.data
.ActualDataRate
);
663 static void g997_line_status(int fd
, DSL_AccessDir_t direction
) {
664 IOCTL_DIR_DELT(DSL_G997_LineStatus_t
, DSL_FIO_G997_LINE_STATUS_GET
, direction
, DSL_DELT_DATA_SHOWTIME
);
666 // invalid value indicators taken from drv_dsl_cpe_api_g997.h
667 m_db("latn", out
.data
.LATN
, 1271);
668 m_db("satn", out
.data
.SATN
, 1271);
669 m_db("snr", out
.data
.SNR
, -641);
670 m_db("actps", out
.data
.ACTPS
, -901);
671 m_db("actatp", out
.data
.ACTATP
, -512);
672 m_u32("attndr", out
.data
.ATTNDR
);
675 static void pm_line_sec_counters_total(int fd
, DSL_XTUDir_t direction
) {
676 IOCTL_DIR(DSL_PM_LineSecCountersTotal_t
, DSL_FIO_PM_LINE_SEC_COUNTERS_TOTAL_GET
, direction
)
678 m_u32("es", out
.data
.nES
);
679 m_u32("ses", out
.data
.nSES
);
680 m_u32("loss", out
.data
.nLOSS
);
681 m_u32("uas", out
.data
.nUAS
);
682 m_u32("lofs", out
.data
.nLOFS
);
683 #ifndef INCLUDE_DSL_CPE_API_DANUBE
684 m_u32("fecs", out
.data
.nFECS
);
688 static void pm_data_path_counters_total(int fd
, DSL_XTUDir_t direction
) {
689 IOCTL_DIR(DSL_PM_DataPathCountersTotal_t
, DSL_FIO_PM_DATA_PATH_COUNTERS_TOTAL_GET
, direction
);
691 m_u32("hec", out
.data
.nHEC
);
692 m_u32("ibe", out
.data
.nIBE
);
693 m_u32("crc_p", out
.data
.nCRC_P
);
694 m_u32("crcp_p", out
.data
.nCRCP_P
);
695 m_u32("cv_p", out
.data
.nCV_P
);
696 m_u32("cvp_p", out
.data
.nCVP_P
);
699 static void retx_statistics(int fd
, DSL_XTUDir_t direction
) {
700 #ifdef INCLUDE_DSL_CPE_PM_RETX_COUNTERS
701 #ifdef INCLUDE_DSL_CPE_PM_RETX_THRESHOLDS
702 IOCTL_DIR(DSL_ReTxStatistics_t
, DSL_FIO_RETX_STATISTICS_GET
, direction
);
704 m_u32("rx_corrupted", out
.data
.nRxCorruptedTotal
);
705 m_u32("rx_uncorrected_protected", out
.data
.nRxUncorrectedProtected
);
706 m_u32("rx_retransmitted", out
.data
.nRxRetransmitted
);
707 m_u32("rx_corrected", out
.data
.nRxCorrected
);
708 m_u32("tx_retransmitted", out
.data
.nTxRetransmitted
);
713 static void describe_mode(standard_t standard
, profile_t profile
, vector_t vector
) {
718 strcpy(buf
, "T1.413");
721 strcpy(buf
, "TS 101 388");
724 strcpy(buf
, "G.992.1 (ADSL)");
727 strcpy(buf
, "G.992.2 (ADSL lite)");
730 strcpy(buf
, "G.992.3 (ADSL2)");
733 strcpy(buf
, "G.992.4 (ADSL2 lite)");
736 strcpy(buf
, "G.992.5 (ADSL2+)");
739 strcpy(buf
, "G.993.1 (VDSL)");
742 strcpy(buf
, "G.993.2 (VDSL2");
746 strcat(buf
, ", Profile 8a");
749 strcat(buf
, ", Profile 8b");
752 strcat(buf
, ", Profile 8c");
755 strcat(buf
, ", Profile 8d");
758 strcat(buf
, ", Profile 12a");
761 strcat(buf
, ", Profile 12b");
764 strcat(buf
, ", Profile 17a");
767 strcat(buf
, ", Profile 30a");
770 strcat(buf
, ", Profile 35b");
778 strcat(buf
, ", with downstream vectoring");
780 case VECTOR_ON_DS_US
:
781 strcat(buf
, ", with down- and upstream vectoring");
796 static int line_statistics(struct ubus_context
*ctx
, struct ubus_object
*obj
,
797 struct ubus_request_data
*req
, const char *method
,
798 struct blob_attr
*msg
)
803 #ifndef INCLUDE_DSL_CPE_API_DANUBE
804 fd
= open(DSL_CPE_DEVICE_NAME
"/0", O_RDWR
, 0644);
806 fd
= open(DSL_CPE_DEVICE_NAME
, O_RDWR
, 0644);
809 return UBUS_STATUS_UNKNOWN_ERROR
;
811 blob_buf_init(&b
, 0);
813 c
= blobmsg_open_table(&b
, "bits");
814 c2
= blobmsg_open_table(&b
, "downstream");
815 g977_get_bit_allocation(fd
, DSL_DOWNSTREAM
);
816 blobmsg_close_table(&b
, c2
);
817 c2
= blobmsg_open_table(&b
, "upstream");
818 g977_get_bit_allocation(fd
, DSL_UPSTREAM
);
819 blobmsg_close_table(&b
, c2
);
820 blobmsg_close_table(&b
, c
);
822 c
= blobmsg_open_table(&b
, "snr");
823 c2
= blobmsg_open_table(&b
, "downstream");
824 g977_get_snr(fd
, DSL_DOWNSTREAM
);
825 blobmsg_close_table(&b
, c2
);
826 c2
= blobmsg_open_table(&b
, "upstream");
827 g977_get_snr(fd
, DSL_UPSTREAM
);
828 blobmsg_close_table(&b
, c2
);
829 blobmsg_close_table(&b
, c
);
831 c
= blobmsg_open_table(&b
, "qln");
832 c2
= blobmsg_open_table(&b
, "downstream");
833 g977_get_qln(fd
, DSL_DOWNSTREAM
);
834 blobmsg_close_table(&b
, c2
);
835 c2
= blobmsg_open_table(&b
, "upstream");
836 g977_get_qln(fd
, DSL_UPSTREAM
);
837 blobmsg_close_table(&b
, c2
);
838 blobmsg_close_table(&b
, c
);
840 c
= blobmsg_open_table(&b
, "hlog");
841 c2
= blobmsg_open_table(&b
, "downstream");
842 g977_get_hlog(fd
, DSL_DOWNSTREAM
);
843 blobmsg_close_table(&b
, c2
);
844 c2
= blobmsg_open_table(&b
, "upstream");
845 g977_get_hlog(fd
, DSL_UPSTREAM
);
846 blobmsg_close_table(&b
, c2
);
847 blobmsg_close_table(&b
, c
);
849 ubus_send_reply(ctx
, req
, b
.head
);
856 static int metrics(struct ubus_context
*ctx
, struct ubus_object
*obj
,
857 struct ubus_request_data
*req
, const char *method
,
858 struct blob_attr
*msg
)
862 standard_t standard
= STD_UNKNOWN
;
863 profile_t profile
= PROFILE_UNKNOWN
;
864 vector_t vector
= VECTOR_UNKNOWN
;
866 #ifndef INCLUDE_DSL_CPE_API_DANUBE
867 fd
= open(DSL_CPE_DEVICE_NAME
"/0", O_RDWR
, 0644);
869 fd
= open(DSL_CPE_DEVICE_NAME
, O_RDWR
, 0644);
872 return UBUS_STATUS_UNKNOWN_ERROR
;
874 #ifdef INCLUDE_DSL_CPE_API_VRX
875 fd_mei
= open(DSL_CPE_DSL_LOW_DEV
"/0", O_RDWR
, 0644);
880 blob_buf_init(&b
, 0);
882 version_information(fd
);
884 pm_channel_counters_showtime(fd
);
886 c
= blobmsg_open_table(&b
, "atu_c");
887 g997_line_inventory(fd
);
888 blobmsg_close_table(&b
, c
);
890 g997_power_management_status(fd
);
891 g997_xtu_system_enabling(fd
, &standard
);
893 if (standard
== STD_G_993_2
) {
894 band_plan_status(fd
, &profile
);
895 get_vector_status(fd_mei
, &vector
);
898 describe_mode(standard
, profile
, vector
);
900 c
= blobmsg_open_table(&b
, "upstream");
903 m_bool("vector", false);
905 case VECTOR_ON_DS_US
:
906 m_bool("vector", true);
911 line_feature_config(fd
, DSL_UPSTREAM
);
912 g997_channel_status(fd
, DSL_UPSTREAM
);
913 g997_line_status(fd
, DSL_UPSTREAM
);
914 blobmsg_close_table(&b
, c
);
916 c
= blobmsg_open_table(&b
, "downstream");
919 m_bool("vector", false);
922 case VECTOR_ON_DS_US
:
923 m_bool("vector", true);
928 line_feature_config(fd
, DSL_DOWNSTREAM
);
929 g997_channel_status(fd
, DSL_DOWNSTREAM
);
930 g997_line_status(fd
, DSL_DOWNSTREAM
);
931 blobmsg_close_table(&b
, c
);
933 c
= blobmsg_open_table(&b
, "errors");
934 c2
= blobmsg_open_table(&b
, "near");
935 pm_line_sec_counters_total(fd
, DSL_NEAR_END
);
936 pm_data_path_counters_total(fd
, DSL_NEAR_END
);
937 retx_statistics(fd
, DSL_NEAR_END
);
938 blobmsg_close_table(&b
, c2
);
940 c2
= blobmsg_open_table(&b
, "far");
941 pm_line_sec_counters_total(fd
, DSL_FAR_END
);
942 pm_data_path_counters_total(fd
, DSL_FAR_END
);
943 retx_statistics(fd
, DSL_FAR_END
);
944 blobmsg_close_table(&b
, c2
);
945 blobmsg_close_table(&b
, c
);
949 case VECTOR_ON_DS_US
:
950 c
= blobmsg_open_table(&b
, "erb");
952 blobmsg_close_table(&b
, c
);
958 ubus_send_reply(ctx
, req
, b
.head
);
967 static const struct ubus_method dsl_methods
[] = {
968 UBUS_METHOD_NOARG("metrics", metrics
),
969 UBUS_METHOD_NOARG("statistics", line_statistics
)
972 static struct ubus_object_type dsl_object_type
=
973 UBUS_OBJECT_TYPE("dsl", dsl_methods
);
975 static struct ubus_object dsl_object
= {
977 .type
= &dsl_object_type
,
978 .methods
= dsl_methods
,
979 .n_methods
= ARRAY_SIZE(dsl_methods
),
982 static DSL_int_t
ubus_main(DSL_CPE_Thread_Params_t
*params
) {
990 ctx
= ubus_connect(NULL
);
994 if (ubus_add_object(ctx
, &dsl_object
)) {
1000 ubus_add_uloop(ctx
);
1002 DSL_CPE_ThreadInit(&thread
, "ubus", ubus_main
, DSL_CPE_PIPE_STACK_SIZE
, DSL_CPE_PIPE_PRIORITY
, 0, 0);
1005 void ubus_deinit() {
1012 DSL_CPE_ThreadShutdown(&thread
, 1000);