diff options
| author | Sam Anthony <sam@samanthony.xyz> | 2024-11-28 10:42:31 -0500 |
|---|---|---|
| committer | Sam Anthony <sam@samanthony.xyz> | 2024-11-28 10:42:31 -0500 |
| commit | 6a710c3943f2350f4575f8cb1898129ef3c7dfdd (patch) | |
| tree | dc20bc0480e77a74f2176e5f0fed02ad2251a2cd /src/main/java/derms/replica/replica2/FindResource.java | |
| parent | 0cae203edc71b0285d2971f9124f24cb543b8e39 (diff) | |
| download | soen423-6a710c3943f2350f4575f8cb1898129ef3c7dfdd.zip | |
rename assignment code replica package
Diffstat (limited to 'src/main/java/derms/replica/replica2/FindResource.java')
| -rw-r--r-- | src/main/java/derms/replica/replica2/FindResource.java | 160 |
1 files changed, 160 insertions, 0 deletions
diff --git a/src/main/java/derms/replica/replica2/FindResource.java b/src/main/java/derms/replica/replica2/FindResource.java new file mode 100644 index 0000000..be2eed9 --- /dev/null +++ b/src/main/java/derms/replica/replica2/FindResource.java @@ -0,0 +1,160 @@ +package derms.replica.replica2; + +import java.io.IOException; +import java.io.Serializable; +import java.net.*; +import java.util.Collection; +import java.util.List; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import java.util.logging.Logger; + +public class FindResource { + public static final int port = 5558; + + public static class Client implements Runnable { + private InetAddress serverAddr; + private Request request; + private Collection<Resource> response; + private Logger log; + + public Client(Request request, InetAddress serverAddr, Collection<Resource> response) throws IOException { + this.serverAddr = serverAddr; + this.request = request; + this.response = response; + this.log = DermsLogger.getLogger(this.getClass()); + } + + @Override + public void run() { + DatagramSocket sock; + try { + sock = new DatagramSocket(); + } catch (Exception e) { + log.severe("Failed to open socket: "+e.getMessage()); + return; + } + + DatagramPacket requestPkt; + try { + requestPkt = ObjectPacket.create(request, new InetSocketAddress(serverAddr, port)); + } catch (IOException e) { + log.severe("Failed to create request packet: "+e.getMessage()); + sock.close(); + return; + } + + try { + sock.send(requestPkt); + } catch (Exception e) { + log.severe("Failed to send request: "+e.getMessage()); + sock.close(); + return; + } + + Resource[] resources; + try { + resources = ResourceTransfer.receive(sock); + } catch (IOException e) { + log.severe(e.getMessage()); + return; + } finally { + sock.close(); + } + + for (Resource r : resources) { + response.add(r); + } + } + } + + public static class Server implements Runnable { + private static final int bufsize = 4096; + + private InetAddress localAddr; + private Resources resources; + private ExecutorService pool; + private Logger log; + + public Server(InetAddress localAddr, Resources resources) throws IOException { + this.localAddr = localAddr; + this.resources = resources; + this.pool = Executors.newWorkStealingPool(); + this.log = DermsLogger.getLogger(this.getClass()); + } + + @Override + public void run() { + DatagramSocket sock = null; + try { + sock = new DatagramSocket(port, localAddr); + } catch (Exception e) { + log.severe("Failed to bind socket: "+e.getMessage()); + return; + } + + log.info("Running on "+localAddr.toString()+":"+port); + + DatagramPacket requestPkt = new DatagramPacket(new byte[bufsize], bufsize); + try { + for (;;) { + try { + sock.receive(requestPkt); + } catch (Exception e) { + log.warning("Error receiving from socket: "+e.getMessage()); + continue; + } + log.info("Got request"); + + Request request; + try { + request = ObjectPacket.deserialize(requestPkt, Request.class); + } catch (IOException e) { + log.warning("Failed to deserialize request: "+e.getMessage()); + continue; + } + + pool.execute(new RequestHandler(request, requestPkt.getSocketAddress(), resources, log)); + } + } finally { + sock.close(); + } + } + } + + public static class Request implements Serializable { + private CoordinatorID cid; + private ResourceName rname; + + public Request(CoordinatorID cid, ResourceName rname) { + this.cid = cid; + this.rname = rname; + } + } + + private static class RequestHandler implements Runnable { + private Request request; + private SocketAddress client; + private Resources resources; + private Logger log; + + private RequestHandler(Request request, SocketAddress client, Resources resources, Logger log) { + this.request = request; + this.client = client; + this.resources = resources; + this.log = log; + } + + @Override + public void run() { + List<Resource> borrowedResources = resources.borrowed(request.cid, request.rname); + log.info(""+borrowedResources.size()+" "+request.rname+" resources borrowed by "+request.cid); + try { + Resource[] arr = new Resource[0]; + ResourceTransfer.send(borrowedResources.toArray(arr), client); + } catch (IOException e) { + log.severe("Failed to send response: "+e.getMessage()); + } + } + } +}
\ No newline at end of file |