From c2cc08852bcbd94bad5c15c39e7145c0496d7241 Mon Sep 17 00:00:00 2001
From: Alex Auvolat <alex@adnab.me>
Date: Tue, 6 Sep 2022 19:31:42 +0200
Subject: [PATCH] Reenable node ordering

---
 src/block/manager.rs | 10 ++++------
 1 file changed, 4 insertions(+), 6 deletions(-)

diff --git a/src/block/manager.rs b/src/block/manager.rs
index a9def3b0..66a454b0 100644
--- a/src/block/manager.rs
+++ b/src/block/manager.rs
@@ -9,7 +9,7 @@ use async_trait::async_trait;
 use bytes::Bytes;
 use serde::{Deserialize, Serialize};
 
-use futures::{Stream, TryStreamExt};
+use futures::Stream;
 use futures_util::stream::StreamExt;
 use tokio::fs;
 use tokio::io::{AsyncReadExt, AsyncWriteExt, BufReader};
@@ -191,7 +191,7 @@ impl BlockManager {
 		order_tag: Option<OrderTag>,
 	) -> Result<(DataBlockHeader, ByteStream), Error> {
 		let who = self.replication.read_nodes(hash);
-		//let who = self.system.rpc.request_order(&who);
+		let who = self.system.rpc.request_order(&who);
 
 		for node in who.iter() {
 			let node_id = NodeID::from(*node);
@@ -238,7 +238,7 @@ impl BlockManager {
 		order_tag: Option<OrderTag>,
 	) -> Result<DataBlock, Error> {
 		let who = self.replication.read_nodes(hash);
-		//let who = self.system.rpc.request_order(&who);
+		let who = self.system.rpc.request_order(&who);
 
 		for node in who.iter() {
 			let node_id = NodeID::from(*node);
@@ -296,9 +296,7 @@ impl BlockManager {
 	> {
 		let (header, stream) = self.rpc_get_raw_block_streaming(hash, order_tag).await?;
 		match header {
-			DataBlockHeader::Plain => Ok(Box::pin(stream.map_err(|_| {
-				std::io::Error::new(std::io::ErrorKind::Other, "netapp stream error")
-			}))),
+			DataBlockHeader::Plain => Ok(Box::pin(stream)),
 			DataBlockHeader::Compressed => {
 				// Too many things, I hate it.
 				let reader = stream_asyncread(stream);