refactor(network): code cleaning
parent
ffadd5c1a7
commit
07147878a9
|
@ -27,22 +27,23 @@ class Network : public ALabel {
|
||||||
static int handleEvents(struct nl_msg*, void*);
|
static int handleEvents(struct nl_msg*, void*);
|
||||||
static int handleScan(struct nl_msg*, void*);
|
static int handleScan(struct nl_msg*, void*);
|
||||||
|
|
||||||
void worker();
|
void worker();
|
||||||
void createInfoSocket();
|
void createInfoSocket();
|
||||||
void createEventSocket();
|
void createEventSocket();
|
||||||
int getExternalInterface(int skip_idx = -1) const;
|
int getExternalInterface(int skip_idx = -1) const;
|
||||||
void getInterfaceAddress();
|
void getInterfaceAddress();
|
||||||
int netlinkRequest(void*, uint32_t, uint32_t groups = 0) const;
|
int netlinkRequest(void*, uint32_t, uint32_t groups = 0) const;
|
||||||
int netlinkResponse(void*, uint32_t, uint32_t groups = 0) const;
|
int netlinkResponse(void*, uint32_t, uint32_t groups = 0) const;
|
||||||
void parseEssid(struct nlattr**);
|
void parseEssid(struct nlattr**);
|
||||||
void parseSignal(struct nlattr**);
|
void parseSignal(struct nlattr**);
|
||||||
void parseFreq(struct nlattr**);
|
void parseFreq(struct nlattr**);
|
||||||
bool associatedOrJoined(struct nlattr**);
|
bool associatedOrJoined(struct nlattr**);
|
||||||
bool checkInterface(struct ifinfomsg* rtif, std::string name);
|
bool checkInterface(struct ifinfomsg* rtif, std::string name);
|
||||||
int getPreferredIface(int skip_idx = -1) const;
|
int getPreferredIface(int skip_idx = -1) const;
|
||||||
auto getInfo() -> void;
|
auto getInfo() -> void;
|
||||||
void clearIface();
|
const std::string getNetworkState() const;
|
||||||
bool wildcardMatch(const std::string& pattern, const std::string& text) const;
|
void clearIface();
|
||||||
|
bool wildcardMatch(const std::string& pattern, const std::string& text) const;
|
||||||
|
|
||||||
waybar::util::SleeperThread thread_;
|
waybar::util::SleeperThread thread_;
|
||||||
waybar::util::SleeperThread thread_timer_;
|
waybar::util::SleeperThread thread_timer_;
|
||||||
|
@ -60,6 +61,7 @@ class Network : public ALabel {
|
||||||
unsigned long long bandwidth_down_total_;
|
unsigned long long bandwidth_down_total_;
|
||||||
unsigned long long bandwidth_up_total_;
|
unsigned long long bandwidth_up_total_;
|
||||||
|
|
||||||
|
std::string state_;
|
||||||
std::string essid_;
|
std::string essid_;
|
||||||
std::string ifname_;
|
std::string ifname_;
|
||||||
std::string ipaddr_;
|
std::string ipaddr_;
|
||||||
|
|
|
@ -211,10 +211,16 @@ void waybar::modules::Network::worker() {
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
const std::string waybar::modules::Network::getNetworkState() const {
|
||||||
|
if (ifid_ == -1 || !linked_) return "disconnected";
|
||||||
|
if (ipaddr_.empty()) return "linked";
|
||||||
|
if (essid_.empty()) return "ethernet";
|
||||||
|
return "wifi";
|
||||||
|
}
|
||||||
|
|
||||||
auto waybar::modules::Network::update() -> void {
|
auto waybar::modules::Network::update() -> void {
|
||||||
std::string connectiontype;
|
|
||||||
std::string tooltip_format;
|
|
||||||
std::lock_guard<std::mutex> lock(mutex_);
|
std::lock_guard<std::mutex> lock(mutex_);
|
||||||
|
std::string tooltip_format;
|
||||||
auto down_octets = read_netstat(BANDWIDTH_CATEGORY, BANDWIDTH_DOWN_TOTAL_KEY);
|
auto down_octets = read_netstat(BANDWIDTH_CATEGORY, BANDWIDTH_DOWN_TOTAL_KEY);
|
||||||
auto up_octets = read_netstat(BANDWIDTH_CATEGORY, BANDWIDTH_UP_TOTAL_KEY);
|
auto up_octets = read_netstat(BANDWIDTH_CATEGORY, BANDWIDTH_UP_TOTAL_KEY);
|
||||||
|
|
||||||
|
@ -229,45 +235,22 @@ auto waybar::modules::Network::update() -> void {
|
||||||
bandwidth_up = *up_octets - bandwidth_up_total_;
|
bandwidth_up = *up_octets - bandwidth_up_total_;
|
||||||
bandwidth_up_total_ = *up_octets;
|
bandwidth_up_total_ = *up_octets;
|
||||||
}
|
}
|
||||||
if (ifid_ <= 0 || !linked_) {
|
|
||||||
if (config_["format-disconnected"].isString()) {
|
|
||||||
default_format_ = config_["format-disconnected"].asString();
|
|
||||||
}
|
|
||||||
if (config_["tooltip-format-disconnected"].isString()) {
|
|
||||||
tooltip_format = config_["tooltip-format-disconnected"].asString();
|
|
||||||
}
|
|
||||||
label_.get_style_context()->add_class("disconnected");
|
|
||||||
connectiontype = "disconnected";
|
|
||||||
} else {
|
|
||||||
if (essid_.empty()) {
|
|
||||||
if (config_["format-ethernet"].isString()) {
|
|
||||||
default_format_ = config_["format-ethernet"].asString();
|
|
||||||
}
|
|
||||||
if (config_["tooltip-format-ethernet"].isString()) {
|
|
||||||
tooltip_format = config_["tooltip-format-ethernet"].asString();
|
|
||||||
}
|
|
||||||
connectiontype = "ethernet";
|
|
||||||
} else if (ipaddr_.empty()) {
|
|
||||||
if (config_["format-linked"].isString()) {
|
|
||||||
default_format_ = config_["format-linked"].asString();
|
|
||||||
}
|
|
||||||
if (config_["tooltip-format-linked"].isString()) {
|
|
||||||
tooltip_format = config_["tooltip-format-linked"].asString();
|
|
||||||
}
|
|
||||||
connectiontype = "linked";
|
|
||||||
} else {
|
|
||||||
if (config_["format-wifi"].isString()) {
|
|
||||||
default_format_ = config_["format-wifi"].asString();
|
|
||||||
}
|
|
||||||
if (config_["tooltip-format-wifi"].isString()) {
|
|
||||||
tooltip_format = config_["tooltip-format-wifi"].asString();
|
|
||||||
}
|
|
||||||
connectiontype = "wifi";
|
|
||||||
}
|
|
||||||
label_.get_style_context()->remove_class("disconnected");
|
|
||||||
}
|
|
||||||
if (!alt_) {
|
if (!alt_) {
|
||||||
|
auto state = getNetworkState();
|
||||||
|
if (!state_.empty() && label_.get_style_context()->has_class(state_)) {
|
||||||
|
label_.get_style_context()->remove_class(state_);
|
||||||
|
}
|
||||||
|
if (config_["format-" + state].isString()) {
|
||||||
|
default_format_ = config_["format-" + state].asString();
|
||||||
|
}
|
||||||
|
if (config_["tooltip-format-" + state].isString()) {
|
||||||
|
tooltip_format = config_["tooltip-format-" + state].asString();
|
||||||
|
}
|
||||||
|
if (!label_.get_style_context()->has_class(state)) {
|
||||||
|
label_.get_style_context()->add_class(state);
|
||||||
|
}
|
||||||
format_ = default_format_;
|
format_ = default_format_;
|
||||||
|
state_ = state;
|
||||||
}
|
}
|
||||||
getState(signal_strength_);
|
getState(signal_strength_);
|
||||||
|
|
||||||
|
@ -301,7 +284,7 @@ auto waybar::modules::Network::update() -> void {
|
||||||
fmt::arg("ipaddr", ipaddr_),
|
fmt::arg("ipaddr", ipaddr_),
|
||||||
fmt::arg("cidr", cidr_),
|
fmt::arg("cidr", cidr_),
|
||||||
fmt::arg("frequency", frequency_),
|
fmt::arg("frequency", frequency_),
|
||||||
fmt::arg("icon", getIcon(signal_strength_, connectiontype)),
|
fmt::arg("icon", getIcon(signal_strength_, state_)),
|
||||||
fmt::arg("bandwidthDownBits", pow_format(bandwidth_down * 8ull / interval_.count(), "b/s")),
|
fmt::arg("bandwidthDownBits", pow_format(bandwidth_down * 8ull / interval_.count(), "b/s")),
|
||||||
fmt::arg("bandwidthUpBits", pow_format(bandwidth_up * 8ull / interval_.count(), "b/s")),
|
fmt::arg("bandwidthUpBits", pow_format(bandwidth_up * 8ull / interval_.count(), "b/s")),
|
||||||
fmt::arg("bandwidthDownOctets", pow_format(bandwidth_down / interval_.count(), "o/s")),
|
fmt::arg("bandwidthDownOctets", pow_format(bandwidth_down / interval_.count(), "o/s")),
|
||||||
|
@ -324,7 +307,7 @@ auto waybar::modules::Network::update() -> void {
|
||||||
fmt::arg("ipaddr", ipaddr_),
|
fmt::arg("ipaddr", ipaddr_),
|
||||||
fmt::arg("cidr", cidr_),
|
fmt::arg("cidr", cidr_),
|
||||||
fmt::arg("frequency", frequency_),
|
fmt::arg("frequency", frequency_),
|
||||||
fmt::arg("icon", getIcon(signal_strength_, connectiontype)),
|
fmt::arg("icon", getIcon(signal_strength_, state_)),
|
||||||
fmt::arg("bandwidthDownBits",
|
fmt::arg("bandwidthDownBits",
|
||||||
pow_format(bandwidth_down * 8ull / interval_.count(), "b/s")),
|
pow_format(bandwidth_down * 8ull / interval_.count(), "b/s")),
|
||||||
fmt::arg("bandwidthUpBits", pow_format(bandwidth_up * 8ull / interval_.count(), "b/s")),
|
fmt::arg("bandwidthUpBits", pow_format(bandwidth_up * 8ull / interval_.count(), "b/s")),
|
||||||
|
@ -617,6 +600,10 @@ int waybar::modules::Network::handleEvents(struct nl_msg *msg, void *data) {
|
||||||
auto rtif = static_cast<struct ifinfomsg *>(NLMSG_DATA(nh));
|
auto rtif = static_cast<struct ifinfomsg *>(NLMSG_DATA(nh));
|
||||||
// Check for valid interface
|
// Check for valid interface
|
||||||
if (rtif->ifi_index == net->ifid_) {
|
if (rtif->ifi_index == net->ifid_) {
|
||||||
|
// Down state can be detected here
|
||||||
|
if (!(rtif->ifi_flags & IFF_UP)) {
|
||||||
|
net->ifid_ = -1;
|
||||||
|
}
|
||||||
net->ipaddr_.clear();
|
net->ipaddr_.clear();
|
||||||
net->netmask_.clear();
|
net->netmask_.clear();
|
||||||
net->cidr_ = 0;
|
net->cidr_ = 0;
|
||||||
|
@ -634,7 +621,6 @@ int waybar::modules::Network::handleEvents(struct nl_msg *msg, void *data) {
|
||||||
net->dp.emit();
|
net->dp.emit();
|
||||||
} else if (rtif->ifi_index == net->ifid_) {
|
} else if (rtif->ifi_index == net->ifid_) {
|
||||||
net->clearIface();
|
net->clearIface();
|
||||||
net->ifid_ = -1;
|
|
||||||
// Check for a new interface and get info
|
// Check for a new interface and get info
|
||||||
auto new_iface = net->getPreferredIface(rtif->ifi_index);
|
auto new_iface = net->getPreferredIface(rtif->ifi_index);
|
||||||
if (new_iface != -1) {
|
if (new_iface != -1) {
|
||||||
|
@ -645,6 +631,10 @@ int waybar::modules::Network::handleEvents(struct nl_msg *msg, void *data) {
|
||||||
net->getInterfaceAddress();
|
net->getInterfaceAddress();
|
||||||
net->thread_timer_.wake_up();
|
net->thread_timer_.wake_up();
|
||||||
} else {
|
} else {
|
||||||
|
// Down state can be detected here
|
||||||
|
if (!(rtif->ifi_flags & IFF_UP)) {
|
||||||
|
net->ifid_ = -1;
|
||||||
|
}
|
||||||
net->dp.emit();
|
net->dp.emit();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -688,7 +678,6 @@ int waybar::modules::Network::handleScan(struct nl_msg *msg, void *data) {
|
||||||
}
|
}
|
||||||
|
|
||||||
void waybar::modules::Network::parseEssid(struct nlattr **bss) {
|
void waybar::modules::Network::parseEssid(struct nlattr **bss) {
|
||||||
essid_.clear();
|
|
||||||
if (bss[NL80211_BSS_INFORMATION_ELEMENTS] != nullptr) {
|
if (bss[NL80211_BSS_INFORMATION_ELEMENTS] != nullptr) {
|
||||||
auto ies = static_cast<char *>(nla_data(bss[NL80211_BSS_INFORMATION_ELEMENTS]));
|
auto ies = static_cast<char *>(nla_data(bss[NL80211_BSS_INFORMATION_ELEMENTS]));
|
||||||
auto ies_len = nla_len(bss[NL80211_BSS_INFORMATION_ELEMENTS]);
|
auto ies_len = nla_len(bss[NL80211_BSS_INFORMATION_ELEMENTS]);
|
||||||
|
|
Loading…
Reference in New Issue