Merge pull request #1473 from 0chain/feat/init-free

Init free read

zboxcore/sdk/allocation.go

@@ -213,6 +213,7 @@ type Allocation struct {
 	repairRequestInProgress *RepairRequest
 	initialized             bool
 	checkStatus             bool
+	readFree                bool
 	// conseususes
 	consensusThreshold int
 	fullconsensus      int
@@ -315,6 +316,15 @@ func (a *Allocation) InitAllocation() {
 	for _, blobber := range a.Blobbers {
 		zboxutil.SetHostClient(blobber.ID, blobber.Baseurl)
 	}
+	a.readFree = true
+	if a.ReadPriceRange.Max > 0 {
+		for _, blobberDetail := range a.BlobberDetails {
+			if blobberDetail.Terms.ReadPrice > 0 {
+				a.readFree = false
+				break
+			}
+		}
+	}
 	a.startWorker(a.ctx)
 	InitCommitWorker(a.Blobbers)
 	InitBlockDownloader(a.Blobbers, downloadWorkerCount)
@@ -1170,17 +1180,13 @@ func (a *Allocation) processReadMarker(drs []*DownloadRequest) {
 	blobberMap := make(map[uint64]int64)
 	mpLock := sync.Mutex{}
 	wg := sync.WaitGroup{}
-	var isReadFree bool
-	if a.ReadPriceRange.Max == 0 && a.ReadPriceRange.Min == 0 {
-		isReadFree = true
-	}
 	now := time.Now()
 
 	for _, dr := range drs {
 		wg.Add(1)
 		go func(dr *DownloadRequest) {
 			defer wg.Done()
-			if isReadFree {
+			if a.readFree {
 				dr.freeRead = true
 			}
 			dr.processDownloadRequest()
@@ -1199,7 +1205,7 @@ func (a *Allocation) processReadMarker(drs []*DownloadRequest) {
 	elapsedProcessDownloadRequest := time.Since(now)
 
 	// Do not send readmarkers for free reads
-	if isReadFree {
+	if a.readFree {
 		for _, dr := range drs {
 			if dr.skip {
 				continue