feat(): fix concurrent get chunks bug

Author: zyjblockchain

client.go

@@ -596,13 +596,13 @@ func (c *Client) ConcurrentDownloadChunkData(id string, concurrentNum int) ([]by
 		chunkData, err := c.getChunkData(oss.Offset)
 		if err != nil {
 			count := 0
-			for count < 3 {
-				time.Sleep(2 * time.Second)
+			for count < 2 {
+				time.Sleep(1 * time.Second)
 				chunkData, err = c.getChunkData(oss.Offset)
 				if err == nil {
 					break
 				}
-				log.Error("retry getChunkData failed and try again...", "err", err, "offset", oss.Offset, "retryCount", count, "arId", id)
+				log.Error("retry getChunkData failed and try again...", "err", err, "idx", oss.Idx, "offset", oss.Offset, "retryCount", count, "arId", id)
 				if err != ErrRequestLimit {
 					count++
 				}
@@ -630,18 +630,21 @@ func (c *Client) ConcurrentDownloadChunkData(id string, concurrentNum int) ([]by
 		chunkData, err := c.getChunkData(int64(i) + start)
 		if err != nil {
 			count := 0
-			for count < 3 {
-				time.Sleep(2 * time.Second)
+			for count < 2 {
+				time.Sleep(1 * time.Second)
 				chunkData, err = c.getChunkData(int64(i) + start)
 				if err == nil {
 					break
 				}
-				log.Error("retry getChunkData failed and try again...", "err", err, "offset", int64(i)+start, "retryCount", count, "arId", id)
+				log.Error("latest two chunks retry getChunkData failed and try again...", "err", err, "offset", int64(i)+start, "retryCount", count, "arId", id)
 				if err != ErrRequestLimit {
 					count++
 				}
 			}
 		}
+		if err != nil {
+			return nil, errors.New("concurrent get latest two chunks failed")
+		}
 		chunkArr = append(chunkArr, chunkData)
 		i += len(chunkData)
 	}

client_test.go

@@ -309,7 +309,7 @@ func TestClient_GetBlockHashList2(t *testing.T) {
 
 func TestClient_ConcurrentDownloadChunkData(t *testing.T) {
 	c := NewClient("https://arweave.net")
-	arId := "6G_gCR5ZlFzg5Ek3DDTgwFFJhOKEowKJjHaA6Bt48VA"
+	arId := "trMxnk1aVVb_Nafg18tstoLS6SvUOpNcoSQ2qFazWio"
 	data, err := c.ConcurrentDownloadChunkData(arId, 0)
 	// data , err := c.DownloadChunkData(arId)
 	assert.NoError(t, err)
@@ -322,7 +322,7 @@ func TestClient_ConcurrentDownloadChunkData(t *testing.T) {
 
 func TestClient_ExistTxData(t *testing.T) {
 	c := NewClient("https://arweave.net")
-	arId := "cAC7ave2lo3aixlC1wdvRBpGa3ELX_s2M2zJ03u0AwI"
+	arId := "trMxnk1aVVb_Nafg18tstoLS6SvUOpNcoSQ2qFazWio"
 	exist, err := c.ExistTxData(arId)
 	assert.NoError(t, err)
 	t.Log(exist)