aboutsummaryrefslogtreecommitdiff
path: root/test_p2p_stress
diff options
context:
space:
mode:
authorDeterminant <ted.sybil@gmail.com>2019-06-21 14:36:19 -0400
committerDeterminant <ted.sybil@gmail.com>2019-06-21 14:36:19 -0400
commit988748a02d39228017e36f7a5c3415b19b31657d (patch)
tree197a5758fc3a9e1ec00b88020d11a9d2dbbbe58b /test_p2p_stress
parent720096e3dcc84cc0ab821841fdae249a4a029758 (diff)
parentb58ed6653f5e9ccd2d52239e8a26bfc9ae4cb061 (diff)
Merge branch 'master' of github.com:Determinant/salticidae-go
Diffstat (limited to 'test_p2p_stress')
-rw-r--r--test_p2p_stress/main.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/test_p2p_stress/main.go b/test_p2p_stress/main.go
index 251f2e1..9e0757f 100644
--- a/test_p2p_stress/main.go
+++ b/test_p2p_stress/main.go
@@ -54,7 +54,7 @@ func msgRandSerialize(size int) (salticidae.Msg, salticidae.UInt256) {
}
func msgRandUnserialize(msg salticidae.Msg) salticidae.DataStream {
- return msg.ConsumePayload()
+ return msg.GetPayloadByMove()
}
func msgAckSerialize(hash salticidae.UInt256) salticidae.Msg {
@@ -66,7 +66,7 @@ func msgAckSerialize(hash salticidae.UInt256) salticidae.Msg {
}
func msgAckUnserialize(msg salticidae.Msg) salticidae.UInt256 {
- p := msg.ConsumePayload()
+ p := msg.GetPayloadByMove()
hash := salticidae.NewUInt256()
hash.Unserialize(p)
return hash
@@ -126,7 +126,7 @@ func sendRand(size int, app *AppContext, conn salticidae.MsgNetworkConn) {
msg, hash := msgRandSerialize(size)
tc := app.getTC(addr2id(conn.GetAddr()))
tc.hash = hash
- app.net.AsMsgNetwork().SendMsgByMove(msg, conn)
+ app.net.AsMsgNetwork().SendMsg(msg, conn)
}
var apps []AppContext
@@ -157,7 +157,7 @@ func onReceiveRand(_msg *C.struct_msg_t, _conn *C.struct_msgnetwork_conn_t, user
conn := salticidae.MsgNetworkConnFromC(salticidae.CMsgNetworkConn(_conn))
net := conn.GetNet()
ack := msgAckSerialize(msgRandUnserialize(msg).GetHash())
- net.SendMsgByMove(ack, conn)
+ net.SendMsg(ack, conn)
}
//export onReceiveAck