mirror/ternfs-XTXMarkets
1
0
Fork 0
mirror of https://github.com/XTXMarkets/ternfs.git synced 2026-01-06 02:49:45 -06:00
Code Issues Packages Projects Releases Wiki Activity

xmon: if too many alerts initialize appType to _parent

Browse Source
This commit is contained in:
Miroslav Crnic
2024-03-15 19:39:41 +00:00
parent 27faaa45ae
commit 72c1acaea8
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
cpp/core/Xmon.cpp
View File

@@ -252,7 +252,7 @@ void XmonBuf::readIn(int fd, size_t sz, std::string& errString) {
ensureUnpackSizeOrPanic(sz);
size_t readSoFar = 0;
while (readSoFar < sz) {
ssize_t r = read(fd, buf+cur+readSoFar, sz-readSoFar);
ssize_t r = read(fd, buf+cur+readSoFar, sz-readSoFar);
if (unlikely(r < 0)) {
errString = generateErrString("read in xmon buf", errno);
return;
@@ -290,7 +290,7 @@ EggsTime Xmon::_stepNextWakeup() {
_fds[SOCK_FD].fd = connectToHost(_xmonHost, _xmonPort, errString);
CHECK_ERR_STRING(errString);
LOG_INFO(_env, "connected to xmon %s:%s", _xmonHost, _xmonPort);
// Send logon message(s)
_packLogon(_buf);
errString = _buf.writeOut(_fds[SOCK_FD].fd);
@@ -455,7 +455,7 @@ EggsTime Xmon::_stepNextWakeup() {
.quietPeriod = 0,
.message = "too many alerts, alerts dropped",
.msgType = XmonRequestType::CREATE,
.appType = XmonAppType::DEFAULT,
.appType = _parent,
.binnable = true,
};
_packRequest(_buf, req);
@@ -483,7 +483,7 @@ EggsTime Xmon::_stepNextWakeup() {
LOG_INFO(_env, "skipping clear alertId=%s since it's still quiet", req.alertId);
_quietAlerts.erase(quiet);
goto skip_request;
}
}
LOG_INFO(_env, "clearing alert, aid=%s", req.alertId);
} else {
throw EGGS_EXCEPTION("bad req type %s", (int)req.msgType);
@@ -507,4 +507,4 @@ EggsTime Xmon::_stepNextWakeup() {
void Xmon::step() {
EggsTime nextTimer = _stepNextWakeup();
_ensureTimer(eggsNow(), nextTimer);
}
}