blob: c1c955cb03a2cb39da6919d4113a96f29274d5b7 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
package com.yahoo.search.cluster;
import com.yahoo.search.result.ErrorMessage;
/**
* This node monitor is responsible for maintaining the state of a monitored node.
* It has the following properties:
* <ul>
* <li>A node is taken out of operation if it gives no response in 10 s</li>
* <li>A node is put back in operation when it responds correctly again
* </ul>
*
* @author Steinar Knutsen
*/
public class TrafficNodeMonitor<T> extends BaseNodeMonitor<T> {
/** Creates a new node monitor for a node */
public TrafficNodeMonitor(T node, MonitorConfiguration configuration, boolean internal) {
super(internal);
this.node = node;
this.configuration = configuration;
}
/** Whether or not this has ever responded successfully */
private boolean atStartUp = true;
public T getNode() { return node; }
/**
* Called when this node fails.
*
* @param error a container which should contain a short description
*/
@Override
public void failed(ErrorMessage error) {
respondedAt = now();
switch (error.getCode()) {
// TODO: Remove hard coded error messages.
// Refer to docs/errormessages
case 10:
case 11:
// Only count not being able to talk to backend at all
// as errors we care about
if ((respondedAt-succeededAt) > 10000) {
setWorking(false, "Not working for 10 s: " + error.toString());
}
break;
default:
succeededAt = respondedAt;
break;
}
}
/**
* Called when a response is received from this node.
*/
public void responded() {
respondedAt=now();
succeededAt=respondedAt;
atStartUp = false;
if (!isWorking)
setWorking(true,"Responds correctly");
}
/** Thread-safely changes the state of this node if required */
protected synchronized void setWorking(boolean working,String explanation) {
if (this.isWorking==working) return; // Old news
if (explanation==null) {
explanation="";
} else {
explanation=": " + explanation;
}
if (working) {
log.info("Putting " + node + " in service" + explanation);
}
else {
if (!atStartUp || !isInternal())
log.warning("Taking " + node + " out of service" + explanation);
failedAt=now();
}
this.isWorking=working;
}
}
|
