Fixed NullPointerException when minecraftArguments=null

This commit is contained in:
huangyuhui
2016-05-23 13:09:30 +08:00
parent 75e0fa2def
commit ab1ca18488
12 changed files with 67 additions and 53 deletions

View File

@@ -51,21 +51,21 @@ public class DoubleOutputStream extends OutputStream {
}
@Override
public final void write(byte[] paramArrayOfByte) throws IOException {
public final void write(byte[] arr) throws IOException {
if (this.a != null)
this.a.write(paramArrayOfByte);
this.a.write(arr);
if (this.b != null)
this.b.write(paramArrayOfByte);
this.b.write(arr);
if (this.c)
flush();
}
@Override
public final void write(int paramInt) throws IOException {
public final void write(int i) throws IOException {
if (this.a != null)
this.a.write(paramInt);
this.a.write(i);
if (this.b != null)
this.b.write(paramInt);
this.b.write(i);
if (this.c)
flush();
}

View File

@@ -37,13 +37,10 @@ import org.jackhuang.hellominecraft.util.system.IOUtils;
public final class NetUtils {
public static byte[] getBytesFromStream(InputStream is) throws IOException {
ByteArrayOutputStream localByteArrayOutputStream = new ByteArrayOutputStream();
byte[] arrayOfByte1 = new byte[1024];
int i;
while ((i = is.read(arrayOfByte1)) >= 0)
localByteArrayOutputStream.write(arrayOfByte1, 0, i);
ByteArrayOutputStream out = new ByteArrayOutputStream();
IOUtils.copyStream(is, out);
is.close();
return localByteArrayOutputStream.toByteArray();
return out.toByteArray();
}
public static String getStreamContent(InputStream is) throws IOException {
@@ -83,12 +80,8 @@ public final class NetUtils {
public static String post(URL u, Map<String, String> params) throws IOException {
StringBuilder sb = new StringBuilder();
if (params != null) {
for (Map.Entry<String, String> e : params.entrySet()) {
sb.append(e.getKey());
sb.append("=");
sb.append(e.getValue());
sb.append("&");
}
for (Map.Entry<String, String> e : params.entrySet())
sb.append(e.getKey()).append("=").append(e.getValue()).append("&");
sb.deleteCharAt(sb.length() - 1);
}
return post(u, sb.toString());
@@ -150,9 +143,9 @@ public final class NetUtils {
public static URL concatenateURL(URL url, String query) {
try {
if ((url.getQuery() != null) && (url.getQuery().length() > 0))
return new URL(url.getProtocol(), url.getHost(), url.getPort(), new StringBuilder().append(url.getFile()).append("&").append(query).toString());
return new URL(url.getProtocol(), url.getHost(), url.getPort(), new StringBuilder().append(url.getFile()).append("?").append(query).toString());
if (url.getQuery() != null && url.getQuery().length() > 0)
return new URL(url.getProtocol(), url.getHost(), url.getPort(), url.getFile() + "&" + query);
return new URL(url.getProtocol(), url.getHost(), url.getPort(), url.getFile() + "?" + query);
} catch (MalformedURLException ex) {
throw new IllegalArgumentException("Could not concatenate given URL with GET arguments!", ex);
}

View File

@@ -109,7 +109,6 @@ public class Compressor {
}
String pathName;//存相对路径(相对于待压缩的根目录)
byte[] buf = new byte[1024];
int length;
for (File file : files)
if (file.isDirectory()) {
pathName = file.getPath().substring(basePath.length() + 1)
@@ -129,8 +128,7 @@ public class Compressor {
try (InputStream is = new FileInputStream(file)) {
BufferedInputStream bis = new BufferedInputStream(is);
zos.putNextEntry(new ZipEntry(pathName));
while ((length = bis.read(buf)) > 0)
zos.write(buf, 0, length);
IOUtils.copyStream(bis, zos, buf);
}
}
}
@@ -154,6 +152,7 @@ public class Compressor {
* @throws java.io.IOException 解压失败或无法写入
*/
public static void unzip(File zipFileName, File extPlace, Predicate<String> callback, boolean ignoreExistsFile) throws IOException {
byte[] buf = new byte[1024];
extPlace.mkdirs();
try (ZipInputStream zipFile = new ZipInputStream(new FileInputStream(zipFileName))) {
if (zipFileName.exists()) {
@@ -184,10 +183,8 @@ public class Compressor {
}
if (ignoreExistsFile && new File(strtemp).exists())
continue;
try (FileOutputStream fos = new FileOutputStream(strtemp); BufferedOutputStream bos = new BufferedOutputStream(fos)) {
int c;
while ((c = zipFile.read()) != -1)
bos.write((byte) c);
try (FileOutputStream fos = new FileOutputStream(strtemp)) {
IOUtils.copyStream(zipFile, fos, buf);
}
}
}

View File

@@ -288,4 +288,14 @@ public class IOUtils {
}
return lines;
}
public static void copyStream(InputStream input, OutputStream output) throws IOException {
copyStream(input, output, new byte[1024]);
}
public static void copyStream(InputStream input, OutputStream output, byte[] buf) throws IOException {
int length;
while ((length = input.read(buf)) != -1)
output.write(buf, 0, length);
}
}

View File

@@ -121,11 +121,9 @@ public class ZipEngine {
}
public void putStream(InputStream is, String pathName) throws IOException {
int length;
try (BufferedInputStream bis = new BufferedInputStream(is)) {
put(new ZipEntry(pathName));
while ((length = bis.read(buf)) > 0)
zos.write(buf, 0, length);
IOUtils.copyStream(bis, zos, buf);
}
}

View File

@@ -62,12 +62,12 @@ public class HTTPGetTask extends TaskInfo implements PreviousResult<String> {
URLConnection conn = new URL(url).openConnection();
InputStream is = conn.getInputStream();
ByteArrayOutputStream baos = new ByteArrayOutputStream();
int i;
int size = conn.getContentLength(), read = 0;
byte[] buf = new byte[1024];
int size = conn.getContentLength(), read = 0, len;
long lastTime = System.currentTimeMillis();
while ((i = is.read()) != -1) {
baos.write(i);
++read;
while ((len = is.read(buf)) != -1) {
baos.write(buf, 0, len);
read += len;
long now = System.currentTimeMillis();
if (ppl != null && (now - lastTime) >= 1000) {
ppl.setProgress(this, read, size);

View File

@@ -18,6 +18,7 @@
package org.jackhuang.hellominecraft.util.ui;
import java.io.OutputStream;
import java.util.Objects;
import java.util.Timer;
import javax.swing.SwingUtilities;
import org.jackhuang.hellominecraft.util.logging.Level;
@@ -34,24 +35,26 @@ public class LogWindowOutputStream extends OutputStream {
private final Level sas;
public LogWindowOutputStream(LogWindow logWindow, Level l) {
Objects.nonNull(logWindow);
Objects.nonNull(l);
txt = logWindow;
this.sas = l;
sas = l;
}
@Override
public final void write(byte[] paramArrayOfByte) {
write(paramArrayOfByte, 0, paramArrayOfByte.length);
public final void write(byte[] arr) {
write(arr, 0, arr.length);
}
@Override
public final void write(byte[] paramArrayOfByte, int off, int len) {
append(new String(paramArrayOfByte, off, len));
public final void write(byte[] arr, int off, int len) {
append(new String(arr, off, len));
}
private void append(final String newString) {
private void append(final String str) {
try {
SwingUtilities.invokeLater(() -> {
txt.log(newString, Level.guessLevel(newString, sas));
txt.log(str, Level.guessLevel(str, sas));
});
} catch (Throwable e) {
e.printStackTrace();
@@ -59,8 +62,8 @@ public class LogWindowOutputStream extends OutputStream {
}
@Override
public final void write(int paramInt) {
append(new String(new byte[] { (byte) paramInt }));
public final void write(int i) {
append(new String(new byte[] { (byte) i }));
}
public static void dispose() {