From 49a9e0c5f7331d52996da5d802b98f1dd8d3417e Mon Sep 17 00:00:00 2001 From: Christian Basler Date: Tue, 16 Jun 2015 07:08:33 +0200 Subject: [PATCH] Fixed test --- .../ch/dissem/bitmessage/repository/JdbcNodeRegistry.java | 4 ++-- .../ch/dissem/bitmessage/repository/JdbcNodeRegistryTest.java | 3 ++- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/repositories/src/main/java/ch/dissem/bitmessage/repository/JdbcNodeRegistry.java b/repositories/src/main/java/ch/dissem/bitmessage/repository/JdbcNodeRegistry.java index df209eb..9ad8329 100644 --- a/repositories/src/main/java/ch/dissem/bitmessage/repository/JdbcNodeRegistry.java +++ b/repositories/src/main/java/ch/dissem/bitmessage/repository/JdbcNodeRegistry.java @@ -76,7 +76,7 @@ public class JdbcNodeRegistry extends JdbcHelper implements NodeRegistry { ResultSet lastConnectionTime = exists.executeQuery(); if (lastConnectionTime.next()) { long time = lastConnectionTime.getLong("time"); - if (time < node.getTime() && node.getTime() < UnixTime.now()) { + if (time < node.getTime() && node.getTime() <= UnixTime.now()) { time = node.getTime(); update.setLong(1, node.getServices()); update.setLong(2, time); @@ -86,7 +86,7 @@ public class JdbcNodeRegistry extends JdbcHelper implements NodeRegistry { update.setLong(5, node.getStream()); update.executeUpdate(); } - } else if (node.getTime() < UnixTime.now()) { + } else if (node.getTime() <= UnixTime.now()) { insert.setBytes(1, node.getIPv6()); insert.setInt(2, node.getPort()); insert.setLong(3, node.getServices()); diff --git a/repositories/src/test/java/ch/dissem/bitmessage/repository/JdbcNodeRegistryTest.java b/repositories/src/test/java/ch/dissem/bitmessage/repository/JdbcNodeRegistryTest.java index faa3797..8bfda1e 100644 --- a/repositories/src/test/java/ch/dissem/bitmessage/repository/JdbcNodeRegistryTest.java +++ b/repositories/src/test/java/ch/dissem/bitmessage/repository/JdbcNodeRegistryTest.java @@ -40,7 +40,8 @@ public class JdbcNodeRegistryTest { registry.offerAddresses(Arrays.asList( createAddress(1, 8444, 1, now()), createAddress(2, 8444, 1, now()), - createAddress(3, 8444, 1, now()) + createAddress(3, 8444, 1, now()), + createAddress(4, 8444, 2, now()) )); }