system/NetworkManager
system/NetworkManager
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/NetworkManager/NetworkManager synced 2024-10-04 15:21:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

device: always expose device statistics information

Browse source 
Instead of updating the device-statistic counters only periodically as
we refresh the link, update them on every link-changed event from
platform.

That means, also for devices that have RefreshRateMs at zero, the values
will be updated at random times when the link information changes.
The difference is, that previously the counters would be zero unless
RefreshRateMs was set. Now, they have some (probably stale) values
which however are not guaranteed to be kept up-to-date.

Also, now we refresh more often then promised by RefreshRateMs. But the API
technically doesn't specify that, so if we find there is a problem with
this, we may revert it later.
This commit is contained in:
Thomas Haller 2016-08-16 15:55:04 +02:00
parent c16e14c71c
commit fbbebc2123
2 changed files with 31 additions and 32 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
introspection/nm-device-statistics.xml
View file

@ -5,10 +5,10 @@
<!--
RefreshRateMs:
Rate of change of the rest of properties of this interface. If zero, the
properties do not change. Otherwise, the properties are refreshed each
RefreshRateMs milliseconds in case the underlying counter has changed
too.
Refresh rate of the rest of properties of this interface. The properties
are guaranteed to be refreshed each RefreshRateMs milliseconds in case
the underlying counter has changed too.
If zero, there is no guaranteed refresh rate of the properties.
-->
<property name="RefreshRateMs" type="u" access="readwrite"/>

55
src/devices/nm-device.c
View file

@ -803,30 +803,24 @@ _stats_update_counters (NMDevice *self,
}
static void
_stats_refresh (NMDevice *self)
_stats_update_counters_from_pllink (NMDevice *self, const NMPlatformLink *pllink)
{
const NMPlatformLink *pllink;
int ifindex;
ifindex = nm_device_get_ip_ifindex (self);
if (ifindex > 0) {
nm_platform_link_refresh (NM_PLATFORM_GET, ifindex);
pllink = nm_platform_link_get (NM_PLATFORM_GET, ifindex);
if (pllink) {
_stats_update_counters (self, pllink->tx_bytes, pllink->rx_bytes);
return;
}
}
_stats_update_counters (self, 0, 0);
_stats_update_counters (self, pllink->tx_bytes, pllink->rx_bytes);
}
static gboolean
_stats_timeout_cb (gpointer user_data)
{
NMDevice *self = user_data;
int ifindex;
ifindex = nm_device_get_ip_ifindex (self);
_LOGT (LOGD_DEVICE, "stats: refresh %d", ifindex);
if (ifindex > 0)
nm_platform_link_refresh (NM_PLATFORM_GET, ifindex);
_LOGT (LOGD_DEVICE, "stats: refresh");
_stats_refresh (self);
return G_SOURCE_CONTINUE;
}
@ -851,6 +845,7 @@ static void
_stats_set_refresh_rate (NMDevice *self, guint refresh_rate_ms)
{
NMDevicePrivate *priv;
int ifindex;
guint old_rate;
priv = NM_DEVICE_GET_PRIVATE (self);
@ -871,16 +866,17 @@ _stats_set_refresh_rate (NMDevice *self, guint refresh_rate_ms)
if (_stats_refresh_rate_real (old_rate) == refresh_rate_ms)
return;
if (!refresh_rate_ms) {
nm_clear_g_source (&priv->stats.timeout_id);
_stats_update_counters (self, 0, 0);
return;
}
nm_clear_g_source (&priv->stats.timeout_id);
/* trigger an inital refresh of the data when the refresh-rate changes */
_stats_refresh (self);
if (!refresh_rate_ms)
return;
/* trigger an inital refresh of the data whenever the refresh-rate changes.
* As we process the result in an idle handler with device_link_changed(),
* we don't get the result right away. */
ifindex = nm_device_get_ip_ifindex (self);
if (ifindex > 0)
nm_platform_link_refresh (NM_PLATFORM_GET, ifindex);
priv->stats.timeout_id = g_timeout_add (refresh_rate_ms, _stats_timeout_cb, self);
}
@ -1830,6 +1826,9 @@ device_link_changed (NMDevice *self)
_notify (self, PROP_DRIVER);
}
if (ifindex == nm_device_get_ip_ifindex (self))
_stats_update_counters_from_pllink (self, &info);
had_hw_addr = (priv->hw_addr != NULL);
nm_device_update_hw_address (self);
got_hw_addr = (!had_hw_addr && priv->hw_addr);
@ -1958,6 +1957,8 @@ device_ip_link_changed (NMDevice *self)
if (!pllink)
return G_SOURCE_REMOVE;
_stats_update_counters_from_pllink (self, pllink);
if (pllink->name[0] && g_strcmp0 (priv->ip_iface, pllink->name)) {
_LOGI (LOGD_DEVICE, "interface index %d renamed ip_iface (%d) from '%s' to '%s'",
priv->ifindex, nm_device_get_ip_ifindex (self),
@ -2251,6 +2252,7 @@ realize_start_setup (NMDevice *self, const NMPlatformLink *plink)
if (plink) {
g_return_if_fail (link_type_compatible (self, plink->type, NULL, NULL));
update_device_from_platform_link (self, plink);
_stats_update_counters_from_pllink (self, plink);
}
if (priv->ifindex > 0) {
@ -2321,11 +2323,8 @@ realize_start_setup (NMDevice *self, const NMPlatformLink *plink)
nm_assert (!priv->stats.timeout_id);
real_rate = _stats_refresh_rate_real (priv->stats.refresh_rate_ms);
if (real_rate) {
if (plink)
_stats_update_counters (self, plink->tx_bytes, plink->rx_bytes);
if (real_rate)
priv->stats.timeout_id = g_timeout_add (real_rate, _stats_timeout_cb, self);
}
klass->realize_start_notify (self, plink);