X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Fde%2Ftodesbaum%2Futil%2Ffreenet%2Ffcp2%2FConnection.java;h=848ee868e54b0666c9a0b5075f81ce1e5603ab4d;hb=refs%2Ftags%2F0.4.8;hp=15757d0d13f3852f92e0224bb96e3c9cc1b27f17;hpb=6f1a8216cfba28add0ef365b46a08d16d4eb87fe;p=jSite.git diff --git a/src/de/todesbaum/util/freenet/fcp2/Connection.java b/src/de/todesbaum/util/freenet/fcp2/Connection.java index 15757d0..848ee86 100644 --- a/src/de/todesbaum/util/freenet/fcp2/Connection.java +++ b/src/de/todesbaum/util/freenet/fcp2/Connection.java @@ -39,7 +39,7 @@ import de.todesbaum.util.io.TempFileInputStream; * A physical connection to a Freenet node. * * @author David Roden <droden@gmail.com> - * @version $Id: Connection.java 413 2006-03-29 12:22:31Z bombe $ + * @version $Id$ */ public class Connection { @@ -155,9 +155,6 @@ public class Connection { nodeSocket.setReceiveBufferSize(65535); nodeInputStream = nodeSocket.getInputStream(); nodeOutputStream = nodeSocket.getOutputStream(); - // nodeWriter = new TeeWriter(new - // OutputStreamWriter(nodeOutputStream, Charset.forName("UTF-8")), - // new PrintWriter(System.out)); nodeWriter = new OutputStreamWriter(nodeOutputStream, Charset.forName("UTF-8")); nodeReader = new NodeReader(nodeInputStream); Thread nodeReaderThread = new Thread(nodeReader); @@ -231,6 +228,9 @@ public class Connection { } nodeSocket = null; } + synchronized (this) { + notify(); + } fireConnectionTerminated(); } @@ -264,7 +264,7 @@ public class Connection { * listeners about the messages. * * @author David Roden <droden@gmail.com> - * @version $Id: Connection.java 413 2006-03-29 12:22:31Z bombe $ + * @version $Id$ */ private class NodeReader implements Runnable {