1

server/stat/src/upstream/upstream.rs

@@ -1,6 +1,7 @@
 use std::sync::{Arc, Mutex};
 use r9;
-use crate::common::DownStreamPack;
+use crate::common::{DownStreamPack, UpStreamPack};
 pub struct UpStream {
     down_pack_queue: Arc<Mutex::<r9::QueueLock<DownStreamPack>>>,
+    up_pack_queue: Arc<Mutex::<r9::QueueLock<UpStreamPack>>>,
 }