@Test
public void testExecute() throws Exception
{

    doReturn( true ).when( peerTaskResult ).hasSucceeded();
    step.execute();
    verify( trackerOperation ).addLog( anyString() );
    doReturn( false ).when( peerTaskResult ).hasSucceeded();
    step.execute();
    verify( trackerOperation, times( 2 ) ).addLog( anyString() );
    doReturn( Sets.newHashSet() ).when( environment ).getPeers();
    reset( trackerOperation );
    step.execute();
    verify( trackerOperation, never() ).addLog( anyString() );
}