Skip to content

Commit cb9e7b0

Browse files
author
Sunny Jiao
committed
fix grpc
1 parent 8404777 commit cb9e7b0

File tree

1 file changed

+16
-29
lines changed

1 file changed

+16
-29
lines changed

framework/src/test/java/org/tron/core/services/DelegationServiceTest.java

Lines changed: 16 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -31,35 +31,22 @@ public DelegationServiceTest(TronApplicationContext context) {
3131
}
3232

3333
public static void testGrpc() {
34-
io.grpc.ManagedChannel channel = ManagedChannelBuilder.forTarget(fullnode)
35-
.usePlaintext()
36-
.build();
37-
try {
38-
WalletBlockingStub walletStub = WalletGrpc.newBlockingStub(channel);
39-
BytesMessage.Builder builder = BytesMessage.newBuilder();
40-
builder.setValue(ByteString.copyFromUtf8("TLTDZBcPoJ8tZ6TTEeEqEvwYFk2wgotSfD"));
41-
System.out
42-
.println("getBrokerageInfo: " + walletStub.getBrokerageInfo(builder.build()).getNum());
43-
System.out.println("getRewardInfo: " + walletStub.getRewardInfo(builder.build()).getNum());
44-
UpdateBrokerageContract.Builder updateBrokerageContract = UpdateBrokerageContract.newBuilder();
45-
updateBrokerageContract.setOwnerAddress(
46-
ByteString.copyFrom(decodeFromBase58Check("TN3zfjYUmMFK3ZsHSsrdJoNRtGkQmZLBLz")))
47-
.setBrokerage(10);
48-
TransactionExtention transactionExtention = walletStub
49-
.updateBrokerage(updateBrokerageContract.build());
50-
System.out.println("UpdateBrokerage: " + transactionExtention);
51-
} finally {
52-
// Properly shutdown the gRPC channel to prevent resource leaks
53-
channel.shutdown();
54-
try {
55-
if (!channel.awaitTermination(5, java.util.concurrent.TimeUnit.SECONDS)) {
56-
channel.shutdownNow();
57-
}
58-
} catch (InterruptedException e) {
59-
channel.shutdownNow();
60-
Thread.currentThread().interrupt();
61-
}
62-
}
34+
WalletBlockingStub walletStub = WalletGrpc
35+
.newBlockingStub(ManagedChannelBuilder.forTarget(fullnode)
36+
.usePlaintext()
37+
.build());
38+
BytesMessage.Builder builder = BytesMessage.newBuilder();
39+
builder.setValue(ByteString.copyFromUtf8("TLTDZBcPoJ8tZ6TTEeEqEvwYFk2wgotSfD"));
40+
System.out
41+
.println("getBrokerageInfo: " + walletStub.getBrokerageInfo(builder.build()).getNum());
42+
System.out.println("getRewardInfo: " + walletStub.getRewardInfo(builder.build()).getNum());
43+
UpdateBrokerageContract.Builder updateBrokerageContract = UpdateBrokerageContract.newBuilder();
44+
updateBrokerageContract.setOwnerAddress(
45+
ByteString.copyFrom(decodeFromBase58Check("TN3zfjYUmMFK3ZsHSsrdJoNRtGkQmZLBLz")))
46+
.setBrokerage(10);
47+
TransactionExtention transactionExtention = walletStub
48+
.updateBrokerage(updateBrokerageContract.build());
49+
System.out.println("UpdateBrokerage: " + transactionExtention);
6350
}
6451

6552
private void testPay(int cycle) {

0 commit comments

Comments
 (0)