aboutsummaryrefslogtreecommitdiffstats
path: root/node-admin
diff options
context:
space:
mode:
authorvalerijf <valerijf@yahoo-inc.com>2016-07-21 16:30:49 +0200
committervalerijf <valerijf@yahoo-inc.com>2016-07-22 12:14:03 +0200
commita90d0951aaf52b1efdf31a97a476e31194a0b08c (patch)
tree0007c37f62042ff4be9cb592b051395e74a88dad /node-admin
parent292988ab73e7beb5133d574bf3426303e18e5525 (diff)
Changed PrefixLogger constructor to take in Class instead of String as logger name
Diffstat (limited to 'node-admin')
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/docker/DockerImpl.java4
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/maintenance/MaintenanceSchedulerImpl.java6
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminImpl.java2
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminStateUpdater.java2
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/DockerOperations.java12
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java2
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/noderepository/NodeRepositoryImpl.java5
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/orchestrator/OrchestratorImpl.java6
-rw-r--r--node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/util/PrefixLogger.java12
9 files changed, 25 insertions, 26 deletions
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/docker/DockerImpl.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/docker/DockerImpl.java
index 8148c1ad13e..e286dff43ca 100644
--- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/docker/DockerImpl.java
+++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/docker/DockerImpl.java
@@ -58,7 +58,7 @@ import java.util.stream.Stream;
* @author stiankri
*/
public class DockerImpl implements Docker {
- private static final PrefixLogger NODE_ADMIN_LOGGER = PrefixLogger.getNodeAdminLogger(DockerImpl.class.getName());
+ private static final PrefixLogger NODE_ADMIN_LOGGER = PrefixLogger.getNodeAdminLogger(DockerImpl.class);
private static final int SECONDS_TO_WAIT_BEFORE_KILLING = 10;
private static final String FRAMEWORK_CONTAINER_PREFIX = "/";
@@ -281,7 +281,7 @@ public class DockerImpl implements Docker {
private void setupContainerNetworking(ContainerName containerName,
HostName hostName,
int containerPid) throws UnknownHostException {
- PrefixLogger logger = PrefixLogger.getNodeAgentLogger(DockerImpl.class.getName(), containerName);
+ PrefixLogger logger = PrefixLogger.getNodeAgentLogger(DockerImpl.class, containerName);
InetAddress inetAddress = InetAddress.getByName(hostName.s());
String ipAddress = inetAddress.getHostAddress();
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/maintenance/MaintenanceSchedulerImpl.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/maintenance/MaintenanceSchedulerImpl.java
index dd5d2c5a411..b8f76632202 100644
--- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/maintenance/MaintenanceSchedulerImpl.java
+++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/maintenance/MaintenanceSchedulerImpl.java
@@ -19,13 +19,13 @@ import java.util.logging.Level;
* @author valerijf
*/
public class MaintenanceSchedulerImpl implements MaintenanceScheduler {
- private static final PrefixLogger NODE_ADMIN_LOGGER = PrefixLogger.getNodeAdminLogger(MaintenanceSchedulerImpl.class.getName());
+ private static final PrefixLogger NODE_ADMIN_LOGGER = PrefixLogger.getNodeAdminLogger(MaintenanceSchedulerImpl.class);
private static final String[] baseArguments = {"sudo", "/home/y/libexec/vespa/node-admin/maintenance.sh"};
@Override
public void removeOldFilesFromNode(ContainerName containerName) {
- PrefixLogger logger = PrefixLogger.getNodeAgentLogger(MaintenanceSchedulerImpl.class.getName(), containerName);
+ PrefixLogger logger = PrefixLogger.getNodeAgentLogger(MaintenanceSchedulerImpl.class, containerName);
String[] pathsToClean = {"/home/y/logs/elasticsearch2", "/home/y/logs/logstash2",
"/home/y/logs/daemontools_y", "/home/y/logs/nginx", "/home/y/logs/vespa"};
@@ -58,7 +58,7 @@ public class MaintenanceSchedulerImpl implements MaintenanceScheduler {
@Override
public void deleteContainerStorage(ContainerName containerName) throws IOException {
- PrefixLogger logger = PrefixLogger.getNodeAgentLogger(MaintenanceSchedulerImpl.class.getName(), containerName);
+ PrefixLogger logger = PrefixLogger.getNodeAgentLogger(MaintenanceSchedulerImpl.class, containerName);
File yVarDir = Maintainer.pathInNodeAdminFromPathInNode(containerName, "/home/y/var").toFile();
if (yVarDir.exists()) {
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminImpl.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminImpl.java
index 93ce96fecbd..6d941f0be52 100644
--- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminImpl.java
+++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminImpl.java
@@ -33,7 +33,7 @@ import java.util.stream.Stream;
* @author stiankri
*/
public class NodeAdminImpl implements NodeAdmin {
- private static final PrefixLogger logger = PrefixLogger.getNodeAdminLogger(NodeAdmin.class.getName());
+ private static final PrefixLogger logger = PrefixLogger.getNodeAdminLogger(NodeAdmin.class);
private static final long MIN_AGE_IMAGE_GC_MILLIS = Duration.ofMinutes(15).toMillis();
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminStateUpdater.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminStateUpdater.java
index b6e2cc741ba..4b7ba4fc540 100644
--- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminStateUpdater.java
+++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeadmin/NodeAdminStateUpdater.java
@@ -29,7 +29,7 @@ import static java.util.concurrent.TimeUnit.MILLISECONDS;
* @author dybis, stiankri
*/
public class NodeAdminStateUpdater extends AbstractComponent {
- private final PrefixLogger logger = PrefixLogger.getNodeAdminLogger(NodeAdminStateUpdater.class.getName());
+ private final PrefixLogger logger = PrefixLogger.getNodeAdminLogger(NodeAdminStateUpdater.class);
private final ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
private final NodeAdmin nodeAdmin;
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/DockerOperations.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/DockerOperations.java
index f02c8503038..c2e9f3cc14a 100644
--- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/DockerOperations.java
+++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/DockerOperations.java
@@ -42,7 +42,7 @@ public class DockerOperations {
try {
return docker.getVespaVersion(containerName);
} catch (RuntimeException e) {
- PrefixLogger logger = PrefixLogger.getNodeAgentLogger(DockerOperations.class.getName(), containerName);
+ PrefixLogger logger = PrefixLogger.getNodeAgentLogger(DockerOperations.class, containerName);
logger.log(Level.WARNING, "Ignoring failure", e);
return null;
}
@@ -72,7 +72,7 @@ public class DockerOperations {
}
Optional<String> removeReason = shouldRemoveContainer(nodeSpec, existingContainer);
if (removeReason.isPresent()) {
- PrefixLogger logger = PrefixLogger.getNodeAgentLogger(DockerOperations.class.getName(), nodeSpec.containerName);
+ PrefixLogger logger = PrefixLogger.getNodeAgentLogger(DockerOperations.class, nodeSpec.containerName);
logger.log(LogLevel.INFO, "Will remove container " + existingContainer.get() + ": " + removeReason.get());
removeContainer(nodeSpec, existingContainer.get(), orchestrator);
return true;
@@ -124,7 +124,7 @@ public class DockerOperations {
* Any failures are logged and ignored.
*/
private void trySuspendNode(ContainerName containerName) {
- PrefixLogger logger = PrefixLogger.getNodeAgentLogger(DockerOperations.class.getName(), containerName);
+ PrefixLogger logger = PrefixLogger.getNodeAgentLogger(DockerOperations.class, containerName);
Optional<ProcessResult> result;
try {
@@ -145,7 +145,7 @@ public class DockerOperations {
}
void startContainer(final ContainerNodeSpec nodeSpec) {
- PrefixLogger logger = PrefixLogger.getNodeAgentLogger(DockerOperations.class.getName(), nodeSpec.containerName);
+ PrefixLogger logger = PrefixLogger.getNodeAgentLogger(DockerOperations.class, nodeSpec.containerName);
logger.log(Level.INFO, "Starting container " + nodeSpec.containerName);
// TODO: Properly handle absent min* values
@@ -159,7 +159,7 @@ public class DockerOperations {
}
void scheduleDownloadOfImage(final ContainerNodeSpec nodeSpec, Runnable callback) {
- PrefixLogger logger = PrefixLogger.getNodeAgentLogger(DockerOperations.class.getName(), nodeSpec.containerName);
+ PrefixLogger logger = PrefixLogger.getNodeAgentLogger(DockerOperations.class, nodeSpec.containerName);
logger.log(LogLevel.INFO, "Schedule async download of Docker image " + nodeSpec.wantedDockerImage.get());
final CompletableFuture<DockerImage> asyncPullResult = docker.pullImageAsync(nodeSpec.wantedDockerImage.get());
@@ -177,7 +177,7 @@ public class DockerOperations {
private void removeContainer(final ContainerNodeSpec nodeSpec, final Container existingContainer, Orchestrator orchestrator)
throws Exception {
- PrefixLogger logger = PrefixLogger.getNodeAgentLogger(DockerOperations.class.getName(), nodeSpec.containerName);
+ PrefixLogger logger = PrefixLogger.getNodeAgentLogger(DockerOperations.class, nodeSpec.containerName);
final ContainerName containerName = existingContainer.name;
if (existingContainer.isRunning) {
// If we're stopping the node only to upgrade or restart the node or similar, we need to suspend
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java
index 3f4f91c2df0..ca2feb4b1a5 100644
--- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java
+++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/nodeagent/NodeAgentImpl.java
@@ -80,7 +80,7 @@ public class NodeAgentImpl implements NodeAgent {
this.hostname = hostName;
this.dockerOperations = dockerOperations;
this.maintenanceScheduler = maintenanceScheduler;
- this.logger = PrefixLogger.getNodeAgentLogger(NodeAgentImpl.class.getName(),
+ this.logger = PrefixLogger.getNodeAgentLogger(NodeAgentImpl.class,
NodeRepositoryImpl.containerNameFromHostName(hostName.toString()));
}
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/noderepository/NodeRepositoryImpl.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/noderepository/NodeRepositoryImpl.java
index e7e2168a8be..c2c95e7260a 100644
--- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/noderepository/NodeRepositoryImpl.java
+++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/noderepository/NodeRepositoryImpl.java
@@ -6,7 +6,6 @@ import com.yahoo.vespa.applicationmodel.HostName;
import com.yahoo.vespa.hosted.node.admin.ContainerNodeSpec;
import com.yahoo.vespa.hosted.node.admin.docker.ContainerName;
import com.yahoo.vespa.hosted.node.admin.docker.DockerImage;
-import com.yahoo.vespa.hosted.node.admin.nodeagent.DockerOperations;
import com.yahoo.vespa.hosted.node.admin.noderepository.bindings.GetNodesResponse;
import com.yahoo.vespa.hosted.node.admin.noderepository.bindings.NodeRepositoryApi;
import com.yahoo.vespa.hosted.node.admin.noderepository.bindings.UpdateNodeAttributesRequestBody;
@@ -29,7 +28,7 @@ import java.util.Set;
* @author stiankri
*/
public class NodeRepositoryImpl implements NodeRepository {
- private static final PrefixLogger NODE_ADMIN_LOGGER = PrefixLogger.getNodeAdminLogger(NodeRepositoryImpl.class.getName());
+ private static final PrefixLogger NODE_ADMIN_LOGGER = PrefixLogger.getNodeAdminLogger(NodeRepositoryImpl.class);
private static final String NODEREPOSITORY_PATH_PREFIX_NODES_API = "/";
private JaxRsStrategy<NodeRepositoryApi> nodeRepositoryClient;
@@ -129,7 +128,7 @@ public class NodeRepositoryImpl implements NodeRepository {
} catch (javax.ws.rs.WebApplicationException e) {
final Response response = e.getResponse();
UpdateNodeAttributesResponse updateResponse = response.readEntity(UpdateNodeAttributesResponse.class);
- PrefixLogger logger = PrefixLogger.getNodeAgentLogger(NodeRepositoryImpl.class.getName(),
+ PrefixLogger logger = PrefixLogger.getNodeAgentLogger(NodeRepositoryImpl.class,
containerNameFromHostName(hostName.toString()));
logger.log(LogLevel.ERROR, "Response code " + response.getStatus() + ": " + updateResponse.message);
throw new RuntimeException("Failed to update node attributes for " + hostName.s() + ":" + updateResponse.message);
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/orchestrator/OrchestratorImpl.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/orchestrator/OrchestratorImpl.java
index ef41b39316b..5d92bfe5cca 100644
--- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/orchestrator/OrchestratorImpl.java
+++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/orchestrator/OrchestratorImpl.java
@@ -30,7 +30,7 @@ import java.util.logging.Level;
* @author dybis
*/
public class OrchestratorImpl implements Orchestrator {
- private static final PrefixLogger NODE_ADMIN_LOGGER = PrefixLogger.getNodeAdminLogger(OrchestratorImpl.class.getName());
+ private static final PrefixLogger NODE_ADMIN_LOGGER = PrefixLogger.getNodeAdminLogger(OrchestratorImpl.class);
// TODO: Figure out the port dynamically.
private static final int HARDCODED_ORCHESTRATOR_PORT = 19071;
// TODO: Find a way to avoid duplicating this (present in orchestrator's services.xml also).
@@ -53,7 +53,7 @@ public class OrchestratorImpl implements Orchestrator {
@Override
public boolean suspend(final HostName hostName) {
- PrefixLogger logger = PrefixLogger.getNodeAgentLogger(OrchestratorImpl.class.getName(),
+ PrefixLogger logger = PrefixLogger.getNodeAgentLogger(OrchestratorImpl.class,
NodeRepositoryImpl.containerNameFromHostName(hostName.toString()));
try {
@@ -97,7 +97,7 @@ public class OrchestratorImpl implements Orchestrator {
@Override
public boolean resume(final HostName hostName) {
- PrefixLogger logger = PrefixLogger.getNodeAgentLogger(OrchestratorImpl.class.getName(),
+ PrefixLogger logger = PrefixLogger.getNodeAgentLogger(OrchestratorImpl.class,
NodeRepositoryImpl.containerNameFromHostName(hostName.toString()));
try {
diff --git a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/util/PrefixLogger.java b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/util/PrefixLogger.java
index b94ad4192d0..8e84c21f3de 100644
--- a/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/util/PrefixLogger.java
+++ b/node-admin/src/main/java/com/yahoo/vespa/hosted/node/admin/util/PrefixLogger.java
@@ -12,17 +12,17 @@ public class PrefixLogger {
private String prefix;
private Logger logger;
- private PrefixLogger(String className, String prefix) {
- this.logger = Logger.getLogger(className);
+ private PrefixLogger(Class clazz, String prefix) {
+ this.logger = Logger.getLogger(clazz.getName());
this.prefix = prefix + ": ";
}
- public static PrefixLogger getNodeAdminLogger(String className) {
- return new PrefixLogger(className, "NodeAdmin");
+ public static PrefixLogger getNodeAdminLogger(Class clazz) {
+ return new PrefixLogger(clazz, "NodeAdmin");
}
- public static PrefixLogger getNodeAgentLogger(String className, ContainerName containerName) {
- return new PrefixLogger(className, "NodeAgent-" + containerName.asString());
+ public static PrefixLogger getNodeAgentLogger(Class clazz, ContainerName containerName) {
+ return new PrefixLogger(clazz, "NodeAgent-" + containerName.asString());
}
public void log(Level level, String msg, Throwable thrown) {