@@ -148,9 +148,11 @@ func main() {
148
148
149
149
chain .SetServerChain (serverChain )
150
150
151
- if err := SetupValidatorOnBC (* logDir ); err != nil {
152
- Logger .Info ("error setting up validator on blockchain" , zap .Any ("err" , err ))
153
- }
151
+ go func () {
152
+ if err := SetupValidatorOnBC (* logDir ); err != nil {
153
+ Logger .Info ("error setting up validator on blockchain" , zap .Any ("err" , err ))
154
+ }
155
+ }()
154
156
155
157
fmt .Printf ("[+] %-24s %s\n " , "register on chain" , "[OK]" )
156
158
@@ -191,9 +193,6 @@ func main() {
191
193
}
192
194
193
195
func RegisterValidator () {
194
- registrationRetries := 0
195
- //ctx := badgerdbstore.GetStorageProvider().WithConnection(common.GetRootContext())
196
-
197
196
_ , err := sdk .GetValidator (node .Self .ID )
198
197
199
198
if err == nil {
@@ -202,11 +201,10 @@ func RegisterValidator() {
202
201
return
203
202
}
204
203
205
- for registrationRetries < 10 {
204
+ for {
206
205
txn , err := storage .GetProtocolImpl ().RegisterValidator (common .GetRootContext ())
207
206
if err != nil {
208
207
Logger .Error ("Error registering validator" , zap .Any ("err" , err ))
209
- registrationRetries ++
210
208
continue
211
209
}
212
210
time .Sleep (transaction .SLEEP_FOR_TXN_CONFIRMATION * time .Second )
@@ -226,7 +224,6 @@ func RegisterValidator() {
226
224
if ! txnVerified {
227
225
Logger .Error ("Add validator transaction could not be verified" , zap .Any ("err" , err ), zap .String ("txn.Hash" , txn .Hash ))
228
226
}
229
- registrationRetries ++
230
227
}
231
228
232
229
}
@@ -291,4 +288,4 @@ func readKeysFromFile(keysFile *string) error {
291
288
defer reader .Close ()
292
289
publicKey , privateKey , _ , _ = encryption .ReadKeys (reader )
293
290
return nil
294
- }
291
+ }
0 commit comments