summaryrefslogtreecommitdiffstats
path: root/src/kernel/sysfs.c
diff options
context:
space:
mode:
authorFrederic Robra2019-09-17 16:18:41 +0200
committerFrederic Robra2019-09-17 16:18:41 +0200
commita6ddfe1212a2df72cacb0f44cc872b1bd0363c38 (patch)
treeb4cb6ffcfa7b21dbc9a4e901a4de7be971cf74a8 /src/kernel/sysfs.c
parentremoved initial server and removed replacement of alt servers (diff)
downloaddnbd3-ng-a6ddfe1212a2df72cacb0f44cc872b1bd0363c38.tar.gz
dnbd3-ng-a6ddfe1212a2df72cacb0f44cc872b1bd0363c38.tar.xz
dnbd3-ng-a6ddfe1212a2df72cacb0f44cc872b1bd0363c38.zip
added client configuration for number connections
Diffstat (limited to 'src/kernel/sysfs.c')
-rw-r--r--src/kernel/sysfs.c20
1 files changed, 12 insertions, 8 deletions
diff --git a/src/kernel/sysfs.c b/src/kernel/sysfs.c
index a780a21..4d5a87d 100644
--- a/src/kernel/sysfs.c
+++ b/src/kernel/sysfs.c
@@ -35,18 +35,20 @@ ssize_t show_connected_servers(char *buf, struct dnbd3_device *dev)
for (i = 0; i < dev->number_connections; ++i) {
if (dev->socks[i].sock) {
if (dev->socks[i].server->host.type == HOST_IP4) {
- ret = MIN(snprintf(buf, size, "%pI4,%d,%llu,%d\n",
+ ret = MIN(snprintf(buf, size, "%pI4,%d,%llu,%llu,%d\n",
dev->socks[i].server->host.addr,
(int)ntohs(dev->socks[i].server->host.port),
- dev->socks[i].server->avg_rtt,
+ dndb3_average_rtt(dev->socks[i].server),
+ dev->socks[i].server->rating,
(int)dev->socks[i].server->failures)
, size);
} else {
- ret = MIN(snprintf(buf, size, "%pI6,%d,%llu,%d\n",
+ ret = MIN(snprintf(buf, size, "%pI6,%d,%llu,%llu,%d\n",
dev->socks[i].server->host.addr,
(int)ntohs(dev->socks[i].server->host.port),
- dev->socks[i].server->avg_rtt,
+ dndb3_average_rtt(dev->socks[i].server),
+ dev->socks[i].server->rating,
(int)dev->socks[i].server->failures)
, size);
@@ -84,17 +86,19 @@ ssize_t show_alt_servers(char *buf, struct dnbd3_device *dev)
int i, size = PAGE_SIZE, ret;
for (i = 0; i < NUMBER_SERVERS; ++i) {
if (dev->alt_servers[i].host.type == HOST_IP4) {
- ret = MIN(snprintf(buf, size, "%pI4,%d,%llu,%d\n",
+ ret = MIN(snprintf(buf, size, "%pI4,%d,%llu,%llu,%d\n",
dev->alt_servers[i].host.addr,
(int)ntohs(dev->alt_servers[i].host.port),
- dev->alt_servers[i].avg_rtt,
+ dndb3_average_rtt(&dev->alt_servers[i]),
+ dev->alt_servers[i].rating,
(int)dev->alt_servers[i].failures)
, size);
} else if (dev->alt_servers[i].host.type == HOST_IP6) {
- ret = MIN(snprintf(buf, size, "%pI6,%d,%llu,%d\n",
+ ret = MIN(snprintf(buf, size, "%pI6,%d,,%llu%llu,%d\n",
dev->alt_servers[i].host.addr,
(int)ntohs(dev->alt_servers[i].host.port),
- dev->alt_servers[i].avg_rtt,
+ dndb3_average_rtt(&dev->alt_servers[i]),
+ dev->alt_servers[i].rating,
(int)dev->alt_servers[i].failures)
, size);
} else {