Skip to content
This repository has been archived by the owner on Sep 26, 2019. It is now read-only.

Commit

Permalink
update
Browse files Browse the repository at this point in the history
  • Loading branch information
smatthewenglish committed Apr 16, 2019
1 parent 756a51f commit 736eb7d
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -80,18 +80,10 @@ public TransactionPool(
}

private void handleConnect(final EthPeer peer) {

System.out.println("- x - x - x -");

List<Transaction> localTransactions = getLocalTransactions();
for (Transaction transaction : localTransactions) {
peerTransactionTracker.addToPeerSendQueue(peer, transaction);
}
// peerTransactionTracker.markTransactionsAsSeen(peer, localTransactions);
// Iterable<Transaction> localTransactionsX = getLocalTransactions();
// try {
// peer.send(TransactionsMessage.create(localTransactionsX));
// }catch (Exception ignored){}
}

public List<Transaction> getLocalTransactions() {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand Down

0 comments on commit 736eb7d

Please sign in to comment.