| | |
| | | |
| | | if (!it.next()) |
| | | { |
| | | it.releaseCursor(); |
| | | close(it); |
| | | return null; |
| | | } |
| | | |
| | |
| | | } |
| | | } |
| | | |
| | | private void sleep(int millis) |
| | | { |
| | | try { Thread.sleep(millis); } catch (InterruptedException e) {} |
| | | } |
| | | |
| | | /** |
| | | * Creates a TopologyMsg filled with information to be sent to a remote RS. |
| | | * We send remote RS the info of every DS that are directly connected to us |
| | |
| | | // there's no change older than eligibleCN (case of s3/cn31) |
| | | result.update(new ChangeNumber(0, 0, serverId)); |
| | | } finally { |
| | | if (ri != null) { |
| | | ri.releaseCursor(); |
| | | } |
| | | close(ri); |
| | | } |
| | | } else { |
| | | // for this serverId, all changes in the ChangelogDb are holder |