fix(p2p): temporary workaround to reduce pressure on task heap (this sucks)

Author: superp00t

faws/repo/p2p/pull_job.go

@@ -60,7 +60,7 @@ func (pull_job *pull_job) worker() (err error) {
 			return
 		}
 
-		load_scale := float64(1) / float64(subscription.object_wishlist.Len())
+		load_scale := float64(1) / float64(subscription.object_wishlist.AvailableLen())
 		duration := time.Duration(float64(1500)*load_scale) * time.Millisecond
 		time.Sleep(duration)
 

faws/repo/p2p/tracker/manifest.go

@@ -173,6 +173,7 @@ func DecodeManifestInfo(b []byte, topic Topic, out *ManifestInfo) (err error) {
 			return
 		}
 		tag_names[i] = tag_name
+		cleartext = cleartext[tag_name_lengths[i]:]
 	}
 	// tie hashes and tags together
 	out.Tags = make([]revision.Tag, num_tags)

faws/repo/queue/task_heap.go

@@ -84,3 +84,10 @@ func (task_heap *TaskHeap[T]) Len() (n int) {
 	task_heap.guard_items.Unlock()
 	return
 }
+
+func (task_heap *TaskHeap[T]) AvailableLen() (n int) {
+	task_heap.guard_items.Lock()
+	n = task_heap.available_items.Len()
+	task_heap.guard_items.Unlock()
+	return
+}