Merge pull request #498 from weibocom/vector_continue

vector聚合访问，中间某轮返回空，不提前终止后续轮次的访问

Author: parabala

protocol/src/vector/attachment.rs

@@ -368,6 +368,7 @@ impl RetrieveAttach {
         self.body.push(body_data);
         self.body_token_count += rows * columns;
         self.left_count = self.left_count.saturating_sub(rows);
+        log::debug!("left_count: {}", self.left_count);
     }
 
     #[inline]
@@ -413,6 +414,7 @@ impl RetrieveAttach {
                 }
             }
         }
+        log::debug!("si len: {},content: {:?}", self.si.len(), self.si);
         self.si.len() > 0
     }
     #[inline]

protocol/src/vector/mod.rs

@@ -199,13 +199,18 @@ impl Protocol for Vector {
 
         match vec_attach.attch_type() {
             AttachType::Retrieve => {
-                // 如果header为none，说明查询结果为空，直接返回false
+                let attach = vec_attach.retrieve_attach_mut();
+                // 如果header为none，说明当前查询结果为空
+                // 如果有si，则看是否还有后续请求
+                // 如果没有si，直接返回false
                 if response.header.is_none() {
+                    if attach.has_si() {
+                        return attach.left_count != 0;
+                    }
                     return false;
                 }
 
                 assert!(response.header.is_some(), "rsp:{}", response);
-                let attach = vec_attach.retrieve_attach_mut();
                 let body_data = response.data().0.to_vec();
                 let header = response.header.as_mut().expect("rsp header");