@@ -83,6 +83,7 @@ func (cr *ChallengeEntity) LoadValidationTickets(ctx context.Context) error {
83
83
// unlocking it as it will be locked for longer time and handler.CommitWrite
84
84
// will fail.
85
85
allocMu := lock .GetMutex (allocation.Allocation {}.TableName (), cr .AllocationID )
86
+ logging .Logger .Debug ("[challenge]load: " , zap .String ("challenge_id" , cr .ChallengeID ), zap .String ("allocation_id" , cr .AllocationID ))
86
87
allocMu .RLock ()
87
88
88
89
allocationObj , err := allocation .Repo .GetAllocationFromDB (ctx , cr .AllocationID )
@@ -105,15 +106,15 @@ func (cr *ChallengeEntity) LoadValidationTickets(ctx context.Context) error {
105
106
var (
106
107
postData map [string ]any
107
108
)
108
-
109
+ logging . Logger . Debug ( "[challenge]getPost" , zap . String ( "allocation_id" , cr . AllocationID ))
109
110
if allocationObj .IsStorageV2 () {
110
111
postData , err = cr .getPostDataV2 (ctx , allocationObj )
111
112
} else {
112
113
postData , err = cr .getPostData (ctx , allocationObj )
113
114
}
114
115
allocMu .RUnlock ()
115
116
if err != nil {
116
- logging .Logger .Error ("[challenge]load: " , zap .String ("challenge_id" , cr .ChallengeID ), zap .Error (err ))
117
+ logging .Logger .Error ("[challenge]load: " , zap .String ("challenge_id" , cr .ChallengeID ), zap .String ( "allocation_id" , cr . AllocationID ), zap . Error (err ))
117
118
cr .CancelChallenge (ctx , err )
118
119
return err
119
120
}
@@ -294,7 +295,7 @@ func (cr *ChallengeEntity) SaveChallengeResult(ctx context.Context, t *coreTxn.T
294
295
func (cr * ChallengeEntity ) getPostDataV2 (ctx context.Context , allocationObj * allocation.Allocation ) (map [string ]any , error ) {
295
296
trie := allocationObj .GetTrie ()
296
297
copyTrie := wmpt .New (trie .CopyRoot (filestore .COLLAPSE_DEPTH ), datastore .GetBlockStore ())
297
-
298
+ logging . Logger . Info ( "[challenge]getPostDataV2: " , zap . String ( "allocation_id" , cr . AllocationID ))
298
299
var (
299
300
blockNum = int64 (0 )
300
301
postData = make (map [string ]interface {})
@@ -307,7 +308,7 @@ func (cr *ChallengeEntity) getPostDataV2(ctx context.Context, allocationObj *all
307
308
blockNum = r .Int63n (int64 (copyTrie .Weight ()))
308
309
blockNum ++
309
310
cr .BlockNum = blockNum
310
- logging .Logger .Info ("[challenge]rand: " , zap .Uint64 ("trie.NumBlocks" , trie .Weight ()), zap .Any ("blockNum" , blockNum ), zap .Any ("challenge_id" , cr .ChallengeID ), zap .Any ("random_seed" , cr .RandomNumber ))
311
+ logging .Logger .Info ("[challenge]rand: " , zap .Uint64 ("trie.NumBlocks" , trie .Weight ()), zap .Any ("blockNum" , blockNum ), zap .Any ("challenge_id" , cr .ChallengeID ), zap .Any ("random_seed" , cr .RandomNumber ), zap . String ( "allocation_id" , cr . AllocationID ) )
311
312
key , objectProof , err := copyTrie .GetBlockProof (uint64 (blockNum ))
312
313
if err != nil {
313
314
return nil , err
@@ -330,6 +331,7 @@ func (cr *ChallengeEntity) getPostDataV2(ctx context.Context, allocationObj *all
330
331
return nil , common .NewError ("root_mismatch" , "File meta root mismatch" )
331
332
}
332
333
}
334
+ logging .Logger .Debug ("[challenge]getPostDataV2Block: " , zap .Any ("blockNum" , blockNum ), zap .String ("allocation_id" , cr .AllocationID ))
333
335
cr .RespondedAllocationRoot = allocationObj .AllocationRoot
334
336
if blockNum > 0 {
335
337
r := rand .New (rand .NewSource (cr .RandomNumber ))
@@ -385,6 +387,7 @@ func (cr *ChallengeEntity) getPostDataV2(ctx context.Context, allocationObj *all
385
387
386
388
return nil , err
387
389
}
390
+ logging .Logger .Debug ("[challenge]getPostDataV2Return " , zap .Any ("blockNum" , blockNum ), zap .String ("allocation_id" , cr .AllocationID ))
388
391
return postData , nil
389
392
}
390
393
0 commit comments