mirror of
				https://github.com/0glabs/0g-storage-node.git
				synced 2025-11-04 08:37:27 +00:00 
			
		
		
		
	Compare commits
	
		
			3 Commits
		
	
	
		
			25107647c2
			...
			351a8ae34b
		
	
	| Author | SHA1 | Date | |
|---|---|---|---|
| 
						 | 
					351a8ae34b | ||
| 
						 | 
					40092ca7fe | ||
| 
						 | 
					4d16866b91 | 
@ -358,7 +358,7 @@ mod tests {
 | 
				
			|||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    #[test]
 | 
					    #[test]
 | 
				
			||||||
    fn test_annoucement_cache_peek_priority() {
 | 
					    fn test_announcement_cache_peek_priority() {
 | 
				
			||||||
        let mut cache = AnnouncementCache::new(100, 3600);
 | 
					        let mut cache = AnnouncementCache::new(100, 3600);
 | 
				
			||||||
        let now = timestamp_now();
 | 
					        let now = timestamp_now();
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@ -382,7 +382,7 @@ mod tests {
 | 
				
			|||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    #[test]
 | 
					    #[test]
 | 
				
			||||||
    fn test_annoucement_cache_pop_len() {
 | 
					    fn test_announcement_cache_pop_len() {
 | 
				
			||||||
        let mut cache = AnnouncementCache::new(100, 3600);
 | 
					        let mut cache = AnnouncementCache::new(100, 3600);
 | 
				
			||||||
        let now = timestamp_now();
 | 
					        let now = timestamp_now();
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@ -404,7 +404,7 @@ mod tests {
 | 
				
			|||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    #[test]
 | 
					    #[test]
 | 
				
			||||||
    fn test_annoucement_cache_garbage_collect() {
 | 
					    fn test_announcement_cache_garbage_collect() {
 | 
				
			||||||
        let mut cache = AnnouncementCache::new(100, 3600);
 | 
					        let mut cache = AnnouncementCache::new(100, 3600);
 | 
				
			||||||
        let now = timestamp_now();
 | 
					        let now = timestamp_now();
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@ -422,7 +422,7 @@ mod tests {
 | 
				
			|||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    #[test]
 | 
					    #[test]
 | 
				
			||||||
    fn test_annoucement_cache_insert_gc() {
 | 
					    fn test_announcement_cache_insert_gc() {
 | 
				
			||||||
        let mut cache = AnnouncementCache::new(100, 3600);
 | 
					        let mut cache = AnnouncementCache::new(100, 3600);
 | 
				
			||||||
        let now = timestamp_now();
 | 
					        let now = timestamp_now();
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@ -438,7 +438,7 @@ mod tests {
 | 
				
			|||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    #[test]
 | 
					    #[test]
 | 
				
			||||||
    fn test_annoucement_cache_insert_ignore_older() {
 | 
					    fn test_announcement_cache_insert_ignore_older() {
 | 
				
			||||||
        let mut cache = AnnouncementCache::new(100, 3600);
 | 
					        let mut cache = AnnouncementCache::new(100, 3600);
 | 
				
			||||||
        let now = timestamp_now();
 | 
					        let now = timestamp_now();
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@ -461,7 +461,7 @@ mod tests {
 | 
				
			|||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    #[test]
 | 
					    #[test]
 | 
				
			||||||
    fn test_annoucement_cache_insert_overwrite() {
 | 
					    fn test_announcement_cache_insert_overwrite() {
 | 
				
			||||||
        let mut cache = AnnouncementCache::new(100, 3600);
 | 
					        let mut cache = AnnouncementCache::new(100, 3600);
 | 
				
			||||||
        let now = timestamp_now();
 | 
					        let now = timestamp_now();
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@ -479,7 +479,7 @@ mod tests {
 | 
				
			|||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    #[test]
 | 
					    #[test]
 | 
				
			||||||
    fn test_annoucement_cache_insert_cap_exceeded() {
 | 
					    fn test_announcement_cache_insert_cap_exceeded() {
 | 
				
			||||||
        let mut cache = AnnouncementCache::new(3, 3600);
 | 
					        let mut cache = AnnouncementCache::new(3, 3600);
 | 
				
			||||||
        let now = timestamp_now();
 | 
					        let now = timestamp_now();
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@ -499,7 +499,7 @@ mod tests {
 | 
				
			|||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    #[test]
 | 
					    #[test]
 | 
				
			||||||
    fn test_annoucement_cache_random() {
 | 
					    fn test_announcement_cache_random() {
 | 
				
			||||||
        let mut cache = AnnouncementCache::new(100, 3600);
 | 
					        let mut cache = AnnouncementCache::new(100, 3600);
 | 
				
			||||||
        let now = timestamp_now();
 | 
					        let now = timestamp_now();
 | 
				
			||||||
 | 
					
 | 
				
			||||||
@ -515,7 +515,7 @@ mod tests {
 | 
				
			|||||||
    }
 | 
					    }
 | 
				
			||||||
 | 
					
 | 
				
			||||||
    #[test]
 | 
					    #[test]
 | 
				
			||||||
    fn test_annoucement_cache_all() {
 | 
					    fn test_announcement_cache_all() {
 | 
				
			||||||
        let mut cache = AnnouncementCache::new(100, 3600);
 | 
					        let mut cache = AnnouncementCache::new(100, 3600);
 | 
				
			||||||
        let now = timestamp_now();
 | 
					        let now = timestamp_now();
 | 
				
			||||||
 | 
					
 | 
				
			||||||
 | 
				
			|||||||
@ -95,7 +95,7 @@ impl<'a> Miner<'a> {
 | 
				
			|||||||
            .enumerate()
 | 
					            .enumerate()
 | 
				
			||||||
            .zip(scratch_pad.iter().cycle())
 | 
					            .zip(scratch_pad.iter().cycle())
 | 
				
			||||||
            .zip(availabilities.into_iter())
 | 
					            .zip(availabilities.into_iter())
 | 
				
			||||||
            .filter_map(|(data, availiable)| availiable.then_some(data))
 | 
					            .filter_map(|(data, available)| available.then_some(data))
 | 
				
			||||||
        {
 | 
					        {
 | 
				
			||||||
            inc_counter(&PAD_MIX_COUNT);
 | 
					            inc_counter(&PAD_MIX_COUNT);
 | 
				
			||||||
            // Rust can optimize this loop well.
 | 
					            // Rust can optimize this loop well.
 | 
				
			||||||
 | 
				
			|||||||
		Loading…
	
		Reference in New Issue
	
	Block a user