X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fnet%2Fpterodactylus%2Ffcp%2Fquelaton%2FClientPutCommandImpl.java;h=8a2ebfeac794f22ab1e84f29fae256f447d538c1;hb=bcbda1a1adef0a7848e87601a5dbf1741a63d1cb;hp=6e5f7e19dedaac2447fde0ee59a508a84538369d;hpb=9eb54fff8cfc8a6b8ecf89d49a9a9898ec8f0215;p=jFCPlib.git

diff --git a/src/main/java/net/pterodactylus/fcp/quelaton/ClientPutCommandImpl.java b/src/main/java/net/pterodactylus/fcp/quelaton/ClientPutCommandImpl.java
index 6e5f7e1..8a2ebfe 100644
--- a/src/main/java/net/pterodactylus/fcp/quelaton/ClientPutCommandImpl.java
+++ b/src/main/java/net/pterodactylus/fcp/quelaton/ClientPutCommandImpl.java
@@ -119,7 +119,6 @@ class ClientPutCommandImpl implements ClientPutCommand {
 	private class ClientPutReplySequence extends FcpReplySequence<Optional<Key>> {
 
 		private final AtomicReference<FcpMessage> originalClientPut = new AtomicReference<>();
-		private final AtomicReference<String> identifier = new AtomicReference<>();
 		private final AtomicReference<String> directory = new AtomicReference<>();
 		private final AtomicReference<Key> finalKey = new AtomicReference<>();
 		private final AtomicBoolean putFinished = new AtomicBoolean();
@@ -141,7 +140,6 @@ class ClientPutCommandImpl implements ClientPutCommand {
 		@Override
 		public ListenableFuture<Optional<Key>> send(FcpMessage fcpMessage) throws IOException {
 			originalClientPut.set(fcpMessage);
-			identifier.set(fcpMessage.getField("Identifier"));
 			String filename = fcpMessage.getField("Filename");
 			if (filename != null) {
 				directory.set(new File(filename).getParent());
@@ -151,49 +149,39 @@ class ClientPutCommandImpl implements ClientPutCommand {
 
 		@Override
 		protected void consumePutSuccessful(PutSuccessful putSuccessful) {
-			if (putSuccessful.getIdentifier().equals(identifier.get())) {
-				finalKey.set(new Key(putSuccessful.getURI()));
-				putFinished.set(true);
-			}
+			finalKey.set(new Key(putSuccessful.getURI()));
+			putFinished.set(true);
 		}
 
 		@Override
 		protected void consumePutFailed(PutFailed putFailed) {
-			if (putFailed.getIdentifier().equals(identifier.get())) {
-				putFinished.set(true);
-			}
+			putFinished.set(true);
 		}
 
 		@Override
 		protected void consumeProtocolError(ProtocolError protocolError) {
-			if (protocolError.getIdentifier().equals(identifier.get())) {
-				if (protocolError.getCode() == 25) {
-					setIdentifier(directory.get());
-					sendMessage(new TestDDARequest(directory.get(), true, false));
-				} else {
-					putFinished.set(true);
-				}
+			if (protocolError.getCode() == 25) {
+				setIdentifier(directory.get());
+				sendMessage(new TestDDARequest(directory.get(), true, false));
+			} else {
+				putFinished.set(true);
 			}
 		}
 
 		@Override
 		protected void consumeTestDDAReply(TestDDAReply testDDAReply) {
-			if (testDDAReply.getDirectory().equals(directory.get())) {
-				try {
-					String readContent = Files.readAllLines(new File(testDDAReply.getReadFilename()).toPath()).get(0);
-					sendMessage(new TestDDAResponse(directory.get(), readContent));
-				} catch (IOException e) {
-					sendMessage(new TestDDAResponse(directory.get(), "failed-to-read"));
-				}
+			try {
+				String readContent = Files.readAllLines(new File(testDDAReply.getReadFilename()).toPath()).get(0);
+				sendMessage(new TestDDAResponse(directory.get(), readContent));
+			} catch (IOException e) {
+				sendMessage(new TestDDAResponse(directory.get(), "failed-to-read"));
 			}
 		}
 
 		@Override
 		protected void consumeTestDDAComplete(TestDDAComplete testDDAComplete) {
-			if (testDDAComplete.getDirectory().equals(directory.get())) {
-				setIdentifier(originalClientPut.get().getField("Identifier"));
-				sendMessage(originalClientPut.get());
-			}
+			setIdentifier(originalClientPut.get().getField("Identifier"));
+			sendMessage(originalClientPut.get());
 		}
 
 		@Override