From 6654546671eea9f9becd32b3160a134802659cbc Mon Sep 17 00:00:00 2001 From: Sam Anthony Date: Thu, 28 Nov 2024 17:26:19 -0500 Subject: Replica2: restrict scope --- .../derms/replica/replica2/RequestResource.java | 22 +++++++++++----------- 1 file changed, 11 insertions(+), 11 deletions(-) (limited to 'src/main/java/derms/replica/replica2/RequestResource.java') diff --git a/src/main/java/derms/replica/replica2/RequestResource.java b/src/main/java/derms/replica/replica2/RequestResource.java index 44d85be..7388aa8 100644 --- a/src/main/java/derms/replica/replica2/RequestResource.java +++ b/src/main/java/derms/replica/replica2/RequestResource.java @@ -8,22 +8,22 @@ import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.logging.Logger; -public class RequestResource { - public static final int port = 5557; - public static final int bufsize = 4096; +class RequestResource { + static final int port = 5557; + static final int bufsize = 4096; - public static class Client { + static class Client { private CoordinatorID coordinatorID; private ResourceID resourceID; private int duration; - public Client(CoordinatorID coordinatorID, ResourceID resourceID, int duration) { + Client(CoordinatorID coordinatorID, ResourceID resourceID, int duration) { this.coordinatorID = coordinatorID; this.resourceID = resourceID; this.duration = duration; } - public Response sendRequest(InetAddress serverAddr) throws IOException { + Response sendRequest(InetAddress serverAddr) throws IOException { Request request = new Request(coordinatorID, resourceID, duration); DatagramSocket sock; try { @@ -61,13 +61,13 @@ public class RequestResource { } } - public static class Server implements Runnable { + static class Server implements Runnable { private InetAddress localAddr; private Resources resources; private ExecutorService pool; private Logger log; - public Server(InetAddress localAddr, Resources resources) throws IOException { + Server(InetAddress localAddr, Resources resources) throws IOException { this.localAddr = localAddr; this.resources = resources; pool = Executors.newWorkStealingPool(); @@ -202,9 +202,9 @@ public class RequestResource { } } - public static class Response implements Serializable { - public Status status; - public String message; + static class Response implements Serializable { + Status status; + String message; private Response(Status status, String message) { this.status = status; -- cgit v1.2.3