projects
/
ldk-java
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
92e57fa
)
[Java] Use ProbabilisticScorer in HumanObjectPeerTest
author
Matt Corallo
<git@bluematt.me>
Wed, 23 Mar 2022 03:08:51 +0000
(
03:08
+0000)
committer
Matt Corallo
<git@bluematt.me>
Wed, 23 Mar 2022 18:44:52 +0000
(18:44 +0000)
src/test/java/org/ldk/HumanObjectPeerTest.java
patch
|
blob
|
history
diff --git
a/src/test/java/org/ldk/HumanObjectPeerTest.java
b/src/test/java/org/ldk/HumanObjectPeerTest.java
index 64ec216277ec7d42ec631bd881ed157bf472d28b..3297d8b8ccf76edd4f5baf40e698994001333c92 100644
(file)
--- a/
src/test/java/org/ldk/HumanObjectPeerTest.java
+++ b/
src/test/java/org/ldk/HumanObjectPeerTest.java
@@
-357,9
+357,12
@@
class HumanObjectPeerTestInstance {
this.constructor = new ChannelManagerConstructor(Network.LDKNetwork_Bitcoin, UserConfig.with_default(), new byte[32], 0,
this.keys_interface, this.fee_estimator, this.chain_monitor, this.router, this.tx_broadcaster, this.logger);
}
this.constructor = new ChannelManagerConstructor(Network.LDKNetwork_Bitcoin, UserConfig.with_default(), new byte[32], 0,
this.keys_interface, this.fee_estimator, this.chain_monitor, this.router, this.tx_broadcaster, this.logger);
}
- Result_ScorerDecodeErrorZ score_res = Scorer.read(Scorer.with_default().write());
+ ProbabilisticScoringParameters params = ProbabilisticScoringParameters.with_default();
+ ProbabilisticScorer default_scorer = ProbabilisticScorer.of(params, this.router);
+ Result_ProbabilisticScorerDecodeErrorZ score_res = ProbabilisticScorer.read(default_scorer.write(),
+ TwoTuple_ProbabilisticScoringParametersNetworkGraphZ.of(params, this.router));
assert score_res.is_ok();
assert score_res.is_ok();
- Score score = ((Result_
ScorerDecodeErrorZ.Result_
ScorerDecodeErrorZ_OK) score_res).res.as_Score();
+ Score score = ((Result_
ProbabilisticScorerDecodeErrorZ.Result_Probabilistic
ScorerDecodeErrorZ_OK) score_res).res.as_Score();
MultiThreadedLockableScore scorer = null;
if (use_invoice_payer) { scorer = MultiThreadedLockableScore.of(score); }
constructor.chain_sync_completed(new ChannelManagerConstructor.EventHandler() {
MultiThreadedLockableScore scorer = null;
if (use_invoice_payer) { scorer = MultiThreadedLockableScore.of(score); }
constructor.chain_sync_completed(new ChannelManagerConstructor.EventHandler() {
@@
-442,7
+445,7
@@
class HumanObjectPeerTestInstance {
} catch (ChannelManagerConstructor.InvalidSerializedDataException e) {}
}
MultiThreadedLockableScore scorer = null;
} catch (ChannelManagerConstructor.InvalidSerializedDataException e) {}
}
MultiThreadedLockableScore scorer = null;
- if (use_invoice_payer) { scorer = MultiThreadedLockableScore.of(
Scorer.with_default(
).as_Score()); }
+ if (use_invoice_payer) { scorer = MultiThreadedLockableScore.of(
ProbabilisticScorer.of(ProbabilisticScoringParameters.with_default(), this.router
).as_Score()); }
constructor.chain_sync_completed(new ChannelManagerConstructor.EventHandler() {
@Override public void handle_event(Event event) {
synchronized (pending_manager_events) {
constructor.chain_sync_completed(new ChannelManagerConstructor.EventHandler() {
@Override public void handle_event(Event event) {
synchronized (pending_manager_events) {