mirror of
https://github.com/MarginaliaSearch/MarginaliaSearch.git
synced 2025-10-06 07:32:38 +02:00
Compare commits
1 Commits
deploy-022
...
deploy-022
Author | SHA1 | Date | |
---|---|---|---|
|
1ffaab2da6 |
@@ -85,6 +85,8 @@ public class PingJobScheduler {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public void pause(int nodeId) {
|
public void pause(int nodeId) {
|
||||||
|
logger.info("Pausing PingJobScheduler for nodeId: {}", nodeId);
|
||||||
|
|
||||||
if (this.nodeId != null && this.nodeId != nodeId) {
|
if (this.nodeId != null && this.nodeId != nodeId) {
|
||||||
logger.warn("Attempted to pause PingJobScheduler with mismatched nodeId: expected {}, got {}", this.nodeId, nodeId);
|
logger.warn("Attempted to pause PingJobScheduler with mismatched nodeId: expected {}, got {}", this.nodeId, nodeId);
|
||||||
return;
|
return;
|
||||||
@@ -98,6 +100,7 @@ public class PingJobScheduler {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public synchronized void resume(int nodeId) {
|
public synchronized void resume(int nodeId) {
|
||||||
|
logger.info("Resuming PingJobScheduler for nodeId: {}", nodeId);
|
||||||
if (this.nodeId != null) {
|
if (this.nodeId != null) {
|
||||||
logger.warn("Attempted to resume PingJobScheduler with mismatched nodeId: expected {}, got {}", this.nodeId, nodeId);
|
logger.warn("Attempted to resume PingJobScheduler with mismatched nodeId: expected {}, got {}", this.nodeId, nodeId);
|
||||||
return;
|
return;
|
||||||
@@ -139,24 +142,14 @@ public class PingJobScheduler {
|
|||||||
|
|
||||||
try {
|
try {
|
||||||
List<WritableModel> objects = switch (data) {
|
List<WritableModel> objects = switch (data) {
|
||||||
case HistoricalAvailabilityData.JustDomainReference(DomainReference reference) -> {
|
case HistoricalAvailabilityData.JustDomainReference(DomainReference reference)
|
||||||
logger.info("Processing availability job for domain: {}", reference.domainName());
|
-> httpPingService.pingDomain(reference, null, null);
|
||||||
yield httpPingService.pingDomain(reference, null, null);
|
case HistoricalAvailabilityData.JustAvailability(String domain, DomainAvailabilityRecord record)
|
||||||
}
|
-> httpPingService.pingDomain(
|
||||||
case HistoricalAvailabilityData.JustAvailability(String domain, DomainAvailabilityRecord record) -> {
|
new DomainReference(record.domainId(), record.nodeId(), domain), record, null);
|
||||||
logger.info("Availability check with no security info: {}", domain);
|
case HistoricalAvailabilityData.AvailabilityAndSecurity(String domain, DomainAvailabilityRecord availability, DomainSecurityRecord security)
|
||||||
yield httpPingService.pingDomain(
|
-> httpPingService.pingDomain(
|
||||||
new DomainReference(record.domainId(), record.nodeId(), domain),
|
new DomainReference(availability.domainId(), availability.nodeId(), domain), availability, security);
|
||||||
record,
|
|
||||||
null);
|
|
||||||
}
|
|
||||||
case HistoricalAvailabilityData.AvailabilityAndSecurity(String domain, DomainAvailabilityRecord availability, DomainSecurityRecord security) -> {
|
|
||||||
logger.info("Availability check with full historical data: {}", domain);
|
|
||||||
yield httpPingService.pingDomain(
|
|
||||||
new DomainReference(availability.domainId(), availability.nodeId(), domain),
|
|
||||||
availability,
|
|
||||||
security);
|
|
||||||
}
|
|
||||||
};
|
};
|
||||||
|
|
||||||
pingDao.write(objects);
|
pingDao.write(objects);
|
||||||
|
@@ -48,7 +48,6 @@ public class DnsPingService {
|
|||||||
switch (changes) {
|
switch (changes) {
|
||||||
case DnsRecordChange.None _ -> {}
|
case DnsRecordChange.None _ -> {}
|
||||||
case DnsRecordChange.Changed changed -> {
|
case DnsRecordChange.Changed changed -> {
|
||||||
logger.info("DNS record for {} changed: {}", newRecord.dnsRootDomainId(), changed);
|
|
||||||
generatedRecords.add(DomainDnsEvent.builder()
|
generatedRecords.add(DomainDnsEvent.builder()
|
||||||
.rootDomainId(newRecord.dnsRootDomainId())
|
.rootDomainId(newRecord.dnsRootDomainId())
|
||||||
.nodeId(newRecord.nodeAffinity())
|
.nodeId(newRecord.nodeAffinity())
|
||||||
|
Reference in New Issue
Block a user