Some minor fixes on windows.

Author: brett-smith

cli/src/main/java/uk/co/bithatch/tnfs/cli/TNFSTP.java

@@ -487,39 +487,44 @@ public void complete(LineReader reader, ParsedLine line, List<Candidate> candida
 	private void spawn(String[] args, Object cmd) throws IOException, InterruptedException {
 		if(args[0].startsWith("!")) {
 			args[0] = args[0].substring(1);
-			var pb = new ProcessBuilder(Arrays.asList(args));
-			pb.directory(getLcwd().toFile());
-			pb.redirectErrorStream(true);
-			Process p = pb.start();
 			try {
-				var thread = new Thread() {
-					public void run() {
-						var b = new byte[256];
-						var in = terminal.input();
-						var out = p.getOutputStream();
-						int r;
-						try {
-							while( ( r = in.read(b)) != -1) {
-								out.write(b, 0, r);
-								out.flush();
+				var pb = new ProcessBuilder(Arrays.asList(args));
+				pb.directory(getLcwd().toFile());
+				pb.redirectErrorStream(true);
+				Process p = pb.start();
+				try {
+					var thread = new Thread() {
+						public void run() {
+							var b = new byte[256];
+							var in = terminal.input();
+							var out = p.getOutputStream();
+							int r;
+							try {
+								while( ( r = in.read(b)) != -1) {
+									out.write(b, 0, r);
+									out.flush();
+								}
+							}
+							catch(Exception ioe) {
 							}
 						}
-						catch(Exception ioe) {
-						}
+					};
+					thread.start();
+					try {
+						p.getInputStream().transferTo(System.out);
+					}
+					finally {
+						thread.interrupt();
 					}
-				};
-				thread.start();
-				try {
-					p.getInputStream().transferTo(System.out);
 				}
 				finally {
-					thread.interrupt();
+					if(p.waitFor() != 0) {
+						error(String.format("%s exited with error code %d.%n", args[0], p.exitValue()));
+					}
 				}
 			}
-			finally {
-				if(p.waitFor() != 0) {
-					error(String.format("%s exited with error code %d.", args[0], p.exitValue()));
-				}
+			catch(IOException ioe) { 
+				error(String.format("Command %s failed. %s%n", args[0], ioe.getMessage()));
 			}
 		}
 		else {

cli/src/main/java/uk/co/bithatch/tnfs/cli/commands/Bye.java

@@ -37,8 +37,12 @@ public Bye() {
 
 	@Override
 	protected Integer onCall() throws Exception {
-		getContainer().getMount().close();
-		System.exit(0);
+		try {
+			getContainer().getMount().close();
+		}
+		finally {
+			System.exit(0);
+		}
 		return 0;
 	}
 }

client/src/main/java/uk/co/bithatch/tnfs/client/AbstractTNFSMount.java

@@ -409,12 +409,27 @@ public void close() throws IOException {
 			@Override
 			public int write(ByteBuffer src) throws IOException {
 				var max = client.payloadSize - 3;
-				if(src.remaining() > max) {
-					throw new IllegalArgumentException("Source buffer must provider fewer than " + max + " bytes");
+				var wrtn = 0;
+				
+				while(src.hasRemaining()) {
+					var waslimit = -1;
+					if(src.remaining() > max) {
+						waslimit = src.limit();
+						src.limit(src.position() + max);
+	//					throw new IllegalArgumentException("Source buffer must provider fewer than " + max + " bytes");
+					}
+					
+					
+					var w = client.sendMessage(Command.WRITE,
+							Message.of(sessionId(), Command.WRITE, 
+									new Command.Write(fh.handle(), src)), path).written();
+					wrtn += w;
+					if(waslimit > -1) {
+						src.limit(waslimit);
+					}
 				}
-				var w = client.sendMessage(Command.WRITE, Message.of(sessionId(), Command.WRITE, new Command.Write(fh.handle(), src)), path).written();
-				position += w;
-				return w;
+				position += wrtn;
+				return wrtn;
 			}
 
 			@Override
@@ -517,8 +532,12 @@ public final void close() throws IOException {
 		for(var x : extensions.values()) {
 			x.close();
 		}
-		client.sendMessage(Command.UMOUNT, Message.of(sessionId(), Command.UMOUNT, new Command.HeaderOnly()));
-		onClose();
+		
+		try {
+			client.sendMessage(Command.UMOUNT, Message.of(sessionId(), Command.UMOUNT, new Command.HeaderOnly()));
+		} finally {
+			onClose();	
+		}
 	}
 
 	protected void beforeClose() throws IOException {