update and merge

Author: hypercube-lab

src/blob_fetch_stage.rs

@@ -45,4 +45,3 @@ impl Service for BlobFetchStage {
         Ok(())
     }
 }
-

src/blockthread.rs

@@ -2015,4 +2015,3 @@ mod tests {
         assert!(node.sockets.repair.local_addr().unwrap().port() < FULLNODE_PORT_RANGE.1);
     }
 }
-

src/broadcast_stage.rs

@@ -426,4 +426,3 @@ mod tests {
         assert_eq!(highest_index, 2 * leader_rotation_interval - 1);
     }
 }
-

src/builtin_pgm.rs

@@ -408,4 +408,3 @@ mod test {
         assert_eq!(tx.userdata, vec![2, 0, 0, 0, 123, 0, 0, 0, 0, 0, 0, 0]);
     }
 }
-

src/builtin_transaction.rs

@@ -183,4 +183,3 @@ mod tests {
         assert_ne!(sign_data0a, sign_data0b);
     }
 }
-

src/choose_gossip_peer_strategy.rs

@@ -332,4 +332,3 @@ mod tests {
         assert_eq!(result, DEFAULT_WEIGHT);
     }
 }
-

src/client.rs

@@ -18,4 +18,3 @@ pub fn mk_client(r: &NodeInfo) -> ThinClient {
         transactions_socket,
     )
 }
-

src/counter.rs

@@ -187,4 +187,3 @@ mod tests {
         }
     }
 }
-

src/drone.rs

@@ -410,4 +410,3 @@ mod tests {
         remove_dir_all(ledger_path).unwrap();
     }
 }
-

src/dynamic_program.rs

@@ -243,4 +243,3 @@ mod tests {
     // moving across the boundary correctly
 
 }
-

src/entry.rs

@@ -318,4 +318,3 @@ mod tests {
         next_entry(&zero, 0, vec![tx]);
     }
 }
-

src/entry_writer.rs

@@ -123,4 +123,3 @@ mod tests {
         assert_eq!(entries, mint.create_entries());
     }
 }
-

src/erasure.rs

@@ -938,4 +938,3 @@ mod test {
     //        );
     //    }
 }
-

src/fetch_stage.rs

@@ -46,4 +46,3 @@ impl Service for FetchStage {
         Ok(())
     }
 }
-

src/fin_plan.rs

@@ -228,4 +228,3 @@ mod tests {
         assert_eq!(fin_plan, Budget::new_authorized_payment(from1, 42, to));
     }
 }
-

src/fin_plan_instruction.rs

@@ -35,4 +35,3 @@ pub enum Instruction {
     /// Vote for a PoH that is equal to the lastid of this transaction
     NewVote(Vote),
 }
-

src/fin_plan_program.rs

@@ -568,4 +568,3 @@ mod test {
         assert_eq!(tx.userdata, vec![2, 0, 0, 0]);
     }
 }
-

src/fin_plan_transaction.rs

@@ -345,4 +345,3 @@ mod tests {
         assert!(!tx.verify_plan());
     }
 }
-

src/fullnode.rs

@@ -713,4 +713,3 @@ mod tests {
         remove_dir_all(&validator_ledger_path).unwrap();
     }
 }
-

src/hash.rs

@@ -73,4 +73,3 @@ pub fn extend_and_hash(id: &Hash, val: &[u8]) -> Hash {
     hash_data.extend_from_slice(val);
     hash(&hash_data)
 }
-

src/ledger.rs

@@ -870,4 +870,3 @@ mod tests {
     }
 
 }
-

src/lib.rs

@@ -114,4 +114,3 @@ extern crate matches;
 
 extern crate influx_db_client;
 extern crate rand;
-

src/logger.rs

@@ -14,4 +14,3 @@ pub fn setup() {
             .init();
     });
 }
-

src/metrics.rs

@@ -350,4 +350,3 @@ mod test {
     }
 
 }
-

src/mint.rs

@@ -90,4 +90,3 @@ mod tests {
         assert!(entries[..].verify(&entries[0].id));
     }
 }
-

src/ncp.rs

@@ -84,4 +84,3 @@ mod tests {
         d.close().expect("thread join");
     }
 }
-

src/netutil.rs

@@ -264,4 +264,3 @@ mod tests {
     }
 
 }
-

src/packet.rs

@@ -521,4 +521,3 @@ mod tests {
     }
 
 }
-

src/payment_plan.rs

@@ -25,4 +25,3 @@ pub struct Payment {
     /// The `Pubkey` that `tokens` should be paid to.
     pub to: Pubkey,
 }
-

src/pod.rs

@@ -96,4 +96,3 @@ mod tests {
         );
     }
 }
-

src/pod_recorder.rs

@@ -93,4 +93,3 @@ mod tests {
         assert!(pod_recorder.tick().is_err());
     }
 }
-

src/recvmmsg.rs

@@ -182,4 +182,3 @@ mod tests {
         }
     }
 }
-

src/replicate_stage.rs

@@ -147,4 +147,3 @@ impl Service for ReplicateStage {
         Ok(())
     }
 }
-

src/replicator.rs

@@ -199,4 +199,3 @@ mod tests {
         let _ignored = remove_dir_all(&replicator_ledger_path);
     }
 }
-

src/request.rs

@@ -41,4 +41,3 @@ pub enum Response {
         time: usize,
     },
 }
-

src/request_processor.rs

@@ -64,4 +64,3 @@ impl RequestProcessor {
             .collect()
     }
 }
-

src/request_stage.rs

@@ -117,4 +117,3 @@ impl Service for RequestStage {
         self.thread_hdl.join()
     }
 }
-

src/result.rs

@@ -158,4 +158,3 @@ mod tests {
         ).unwrap();
     }
 }
-

src/retransmit_stage.rs

@@ -116,4 +116,3 @@ impl Service for RetransmitStage {
         }
     }
 }
-

src/rpc.rs

@@ -389,4 +389,3 @@ mod tests {
         assert_eq!(expected, result);
     }
 }
-

src/rpu.rs

@@ -61,4 +61,3 @@ impl Service for Rpu {
         Ok(())
     }
 }
-

src/service.rs

@@ -5,4 +5,3 @@ pub trait Service {
 
     fn join(self) -> Result<Self::JoinReturnType>;
 }
-

src/signature.rs

@@ -138,4 +138,3 @@ mod tests {
         assert_eq!(gen_n_pubkeys(seed, 50), gen_n_pubkeys(seed, 50));
     }
 }
-

src/sigverify.rs

@@ -282,4 +282,3 @@ mod tests {
         test_verify_n(5, true);
     }
 }
-

src/sigverify_stage.rs

@@ -154,4 +154,3 @@ impl Service for SigVerifyStage {
         Ok(())
     }
 }
-

src/storage_program.rs

@@ -50,4 +50,3 @@ impl StorageProgram {
 
 #[cfg(test)]
 mod test {}
-

src/store_ledger_stage.rs

@@ -70,4 +70,3 @@ impl Service for StoreLedgerStage {
         Ok(())
     }
 }
-

src/streamer.rs

@@ -195,4 +195,3 @@ mod test {
         t_responder.join().expect("join");
     }
 }
-

src/thin_client.rs

@@ -679,4 +679,3 @@ mod tests {
         remove_dir_all(ledger_path).unwrap();
     }
 }
-

src/tictactoe_dashboard_program.rs

@@ -163,4 +163,3 @@ mod test {
 
     // TODO: add tests for business logic
 }
-

src/tictactoe_program.rs

@@ -479,4 +479,3 @@ mod test {
         assert_eq!(g.state, State::XMove);
     }
 }
-

src/timing.rs

@@ -20,4 +20,3 @@ pub fn timestamp() -> u64 {
         .expect("create timestamp in timing");
     duration_as_ms(&now)
 }
-

src/transaction.rs

@@ -160,4 +160,3 @@ mod tests {
         );
     }
 }
-

src/transaction_processor.rs

@@ -1147,4 +1147,3 @@ mod tests {
         assert!(transaction_processor.process_transaction(&tx).is_err());
     }
 }
-

src/transaction_processoring_stage.rs

@@ -412,4 +412,3 @@ mod tests {
         assert_eq!(transaction_processor.get_balance(&alice.pubkey()), 1);
     }
 }
-

src/tx_creator.rs

@@ -88,4 +88,3 @@ impl Service for TxCreator {
         }
     }
 }
-

src/tx_signer.rs

@@ -282,4 +282,3 @@ pub mod tests {
         t_responder.join().expect("join");
     }
 }
-

src/vote_stage.rs

@@ -340,4 +340,3 @@ pub mod tests {
         }
     }
 }
-

src/wallet.rs

@@ -1479,4 +1479,3 @@ mod tests {
         remove_dir_all(ledger_path).unwrap();
     }
 }
-

src/window.rs

@@ -563,4 +563,3 @@ mod test {
         assert_eq!(wrap_blob_idx_in_window(&id, 101, 90, 100), (true, 101));
     }
 }
-

src/window_service.rs

@@ -666,4 +666,3 @@ mod test {
         t_receiver.join().expect("receiver thread join");
     }
 }
-

src/write_stage.rs

@@ -544,4 +544,3 @@ mod tests {
         assert_eq!(result, (vec![], true));
     }
 }
-