diff --git a/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/transactions/TransactionPool.java b/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/transactions/TransactionPool.java index 1d5e20de95..07fdf82d4d 100644 --- a/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/transactions/TransactionPool.java +++ b/ethereum/eth/src/main/java/tech/pegasys/pantheon/ethereum/eth/transactions/TransactionPool.java @@ -80,18 +80,10 @@ public TransactionPool( } private void handleConnect(final EthPeer peer) { - - System.out.println("- x - x - x -"); - List localTransactions = getLocalTransactions(); for (Transaction transaction : localTransactions) { peerTransactionTracker.addToPeerSendQueue(peer, transaction); } - // peerTransactionTracker.markTransactionsAsSeen(peer, localTransactions); - // Iterable localTransactionsX = getLocalTransactions(); - // try { - // peer.send(TransactionsMessage.create(localTransactionsX)); - // }catch (Exception ignored){} } public List getLocalTransactions() { diff --git a/ethereum/eth/src/test/java/tech/pegasys/pantheon/ethereum/eth/transactions/TransactionPoolTest.java b/ethereum/eth/src/test/java/tech/pegasys/pantheon/ethereum/eth/transactions/TransactionPoolTest.java index 445fe7c36e..f5c177a4ff 100644 --- a/ethereum/eth/src/test/java/tech/pegasys/pantheon/ethereum/eth/transactions/TransactionPoolTest.java +++ b/ethereum/eth/src/test/java/tech/pegasys/pantheon/ethereum/eth/transactions/TransactionPoolTest.java @@ -585,7 +585,7 @@ private void givenTransactionIsValid(final Transaction transaction) { } @Test - public void shouldX() { + public void shouldSendOnlyLocalTransactionToNewlyConnectedPeer() { SyncState syncState = mock(SyncState.class); when(syncState.isInSync(anyLong())).thenReturn(true); EthProtocolManager ethProtocolManager = EthProtocolManagerTestUtil.create();