@@ -16,7 +16,7 @@ func (c *Client) BroadcastData(txId string, data []byte, numOfNodes int64, peers
16
16
}
17
17
18
18
count := int64 (0 )
19
- pNode := NewShortConn ()
19
+ pNode := NewTempConn ()
20
20
for _ , peer := range peers {
21
21
pNode .SetShortConnUrl ("http://" + peer )
22
22
uploader , err := CreateUploader (pNode , txId , data )
@@ -46,7 +46,7 @@ func (c *Client) GetTxDataFromPeers(txId string, peers ...string) ([]byte, error
46
46
}
47
47
}
48
48
49
- pNode := NewShortConn ()
49
+ pNode := NewTempConn ()
50
50
for _ , peer := range peers {
51
51
pNode .SetShortConnUrl ("http://" + peer )
52
52
data , err := pNode .DownloadChunkData (txId )
@@ -69,7 +69,7 @@ func (c *Client) GetBlockFromPeers(height int64, peers ...string) (*types.Block,
69
69
}
70
70
}
71
71
72
- pNode := NewShortConn ()
72
+ pNode := NewTempConn ()
73
73
for _ , peer := range peers {
74
74
pNode .SetShortConnUrl ("http://" + peer )
75
75
block , err := pNode .GetBlockByHeight (height )
@@ -93,7 +93,7 @@ func (c *Client) GetTxFromPeers(arId string, peers ...string) (*types.Transactio
93
93
}
94
94
}
95
95
96
- pNode := NewShortConn ()
96
+ pNode := NewTempConn ()
97
97
for _ , peer := range peers {
98
98
pNode .SetShortConnUrl ("http://" + peer )
99
99
tx , err := pNode .GetTransactionByID (arId )
@@ -117,7 +117,7 @@ func (c *Client) GetUnconfirmedTxFromPeers(arId string, peers ...string) (*types
117
117
}
118
118
}
119
119
120
- pNode := NewShortConn ()
120
+ pNode := NewTempConn ()
121
121
for _ , peer := range peers {
122
122
pNode .SetShortConnUrl ("http://" + peer )
123
123
tx , err := pNode .GetUnconfirmedTx (arId )
0 commit comments