mirror of
https://github.com/kaspanet/kaspad.git
synced 2026-03-01 22:53:19 +00:00
Compare commits
1 Commits
bignet-deb
...
bignet-deb
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
53706c2f9f |
@@ -26,7 +26,7 @@ func (f *FlowContext) AddTransaction(tx *util.Tx) error {
|
|||||||
|
|
||||||
f.transactionsToRebroadcast[*tx.ID()] = tx
|
f.transactionsToRebroadcast[*tx.ID()] = tx
|
||||||
inv := appmessage.NewMsgInvTransaction([]*daghash.TxID{tx.ID()})
|
inv := appmessage.NewMsgInvTransaction([]*daghash.TxID{tx.ID()})
|
||||||
log.Criticalf("~~~~~ FlowContext.AddTransaction() broadcasting", tx.ID())
|
log.Criticalf("~~~~~ FlowContext.AddTransaction() broadcasting %s", tx.ID())
|
||||||
return f.Broadcast(inv)
|
return f.Broadcast(inv)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -141,7 +141,7 @@ func (flow *handleRelayedTransactionsFlow) readInv() (*appmessage.MsgInvTransact
|
|||||||
func (flow *handleRelayedTransactionsFlow) broadcastAcceptedTransactions(acceptedTxs []*mempool.TxDesc) error {
|
func (flow *handleRelayedTransactionsFlow) broadcastAcceptedTransactions(acceptedTxs []*mempool.TxDesc) error {
|
||||||
idsToBroadcast := make([]*daghash.TxID, len(acceptedTxs))
|
idsToBroadcast := make([]*daghash.TxID, len(acceptedTxs))
|
||||||
for i, tx := range acceptedTxs {
|
for i, tx := range acceptedTxs {
|
||||||
log.Criticalf("~~~~~ broadcastAcceptedTransactions() broadcasting", tx.Tx.ID())
|
log.Criticalf("~~~~~ broadcastAcceptedTransactions() broadcasting %s", tx.Tx.ID())
|
||||||
idsToBroadcast[i] = tx.Tx.ID()
|
idsToBroadcast[i] = tx.Tx.ID()
|
||||||
}
|
}
|
||||||
inv := appmessage.NewMsgInvTransaction(idsToBroadcast)
|
inv := appmessage.NewMsgInvTransaction(idsToBroadcast)
|
||||||
|
|||||||
Reference in New Issue
Block a user