Qortal/altcoinj
3
0
Fork 0
mirror of https://github.com/Qortal/altcoinj.git synced 2025-02-14 19:25:51 +00:00
Code Issues Projects Releases Wiki Activity

Use unconnected socket in BlockingClient as before

Browse Source
This commit is contained in:
Devrandom 2014-04-24 13:14:18 -04:00 committed by Mike Hearn
parent 23da335e57
commit 9cfb420cdb
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/src/main/java/com/google/bitcoin/net/BlockingClient.java
View File

@ -66,6 +66,7 @@ public class BlockingClient implements MessageWriteTarget {
// sure it doesnt get too large or have to call read too often. // sure it doesnt get too large or have to call read too often.
dbuf = ByteBuffer.allocateDirect(Math.min(Math.max(parser.getMaxMessageSize(), BUFFER_SIZE_LOWER_BOUND), BUFFER_SIZE_UPPER_BOUND)); dbuf = ByteBuffer.allocateDirect(Math.min(Math.max(parser.getMaxMessageSize(), BUFFER_SIZE_LOWER_BOUND), BUFFER_SIZE_UPPER_BOUND));
parser.setWriteTarget(this); parser.setWriteTarget(this);
socket = socketFactory.createSocket();
Thread t = new Thread() { Thread t = new Thread() {
@Override @Override
public void run() { public void run() {
@ -73,8 +74,7 @@ public class BlockingClient implements MessageWriteTarget {
clientSet.add(BlockingClient.this); clientSet.add(BlockingClient.this);
try { try {
InetSocketAddress iServerAddress = (InetSocketAddress)serverAddress; InetSocketAddress iServerAddress = (InetSocketAddress)serverAddress;
socket = socketFactory.createSocket(iServerAddress.getAddress(), iServerAddress.getPort()); socket.connect(serverAddress, connectTimeoutMillis);
//socket.connect(serverAddress, connectTimeoutMillis);
parser.connectionOpened(); parser.connectionOpened();
InputStream stream = socket.getInputStream(); InputStream stream = socket.getInputStream();
byte[] readBuff = new byte[dbuf.capacity()]; byte[] readBuff = new byte[dbuf.capacity()];