1 files changed, 0 insertions, 181 deletions
diff --git a/src/hotstuff_client.cpp b/src/hotstuff_client.cpp
deleted file mode 100644
index 831b7ff..0000000
--- a/src/hotstuff_client.cpp
+++ /dev/null
@@ -1,181 +0,0 @@
-/**
- * Copyright 2018 VMware
- * Copyright 2018 Ted Yin
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#include <cassert>
-#include <random>
-#include <signal.h>
-#include <sys/time.h>
-
-#include "salticidae/type.h"
-#include "salticidae/netaddr.h"
-#include "salticidae/network.h"
-#include "salticidae/util.h"
-
-#include "hotstuff/util.h"
-#include "hotstuff/type.h"
-#include "hotstuff/client.h"
-
-using salticidae::Config;
-
-using hotstuff::ReplicaID;
-using hotstuff::NetAddr;
-using hotstuff::EventContext;
-using hotstuff::MsgReqCmd;
-using hotstuff::MsgRespCmd;
-using hotstuff::CommandDummy;
-using hotstuff::HotStuffError;
-using hotstuff::uint256_t;
-using hotstuff::opcode_t;
-using hotstuff::command_t;
-
-EventContext ec;
-ReplicaID proposer;
-size_t max_async_num;
-int max_iter_num;
-uint32_t cid;
-uint32_t cnt = 0;
-uint32_t nfaulty;
-
-struct Request {
-    command_t cmd;
-    size_t confirmed;
-    salticidae::ElapsedTime et;
-    Request(const command_t &cmd): cmd(cmd), confirmed(0) { et.start(); }
-};
-
-using Net = salticidae::MsgNetwork<opcode_t>;
-
-std::unordered_map<ReplicaID, Net::conn_t> conns;
-std::unordered_map<const uint256_t, Request> waiting;
-std::vector<NetAddr> replicas;
-std::vector<std::pair<struct timeval, double>> elapsed;
-Net mn(ec, Net::Config());
-
-void connect_all() {
-    for (size_t i = 0; i < replicas.size(); i++)
-        conns.insert(std::make_pair(i, mn.connect_sync(replicas[i])));
-}
-
-bool try_send(bool check = true) {
-    if ((!check || waiting.size() < max_async_num) && max_iter_num)
-    {
-        auto cmd = new CommandDummy(cid, cnt++);
-        MsgReqCmd msg(*cmd);
-        for (auto &p: conns) mn.send_msg(msg, p.second);
-#ifndef HOTSTUFF_ENABLE_BENCHMARK
-        HOTSTUFF_LOG_INFO("send new cmd %.10s",
-                            get_hex(cmd->get_hash()).c_str());
-#endif
-        waiting.insert(std::make_pair(
-            cmd->get_hash(), Request(cmd)));
-        if (max_iter_num > 0)
-            max_iter_num--;
-        return true;
-    }
-    return false;
-}
-
-void client_resp_cmd_handler(MsgRespCmd &&msg, const Net::conn_t &) {
-    auto &fin = msg.fin;
-    HOTSTUFF_LOG_DEBUG("got %s", std::string(msg.fin).c_str());
-    const uint256_t &cmd_hash = fin.cmd_hash;
-    auto it = waiting.find(cmd_hash);
-    auto &et = it->second.et;
-    if (it == waiting.end()) return;
-    et.stop();
-    if (++it->second.confirmed <= nfaulty) return; // wait for f + 1 ack
-#ifndef HOTSTUFF_ENABLE_BENCHMARK
-    HOTSTUFF_LOG_INFO("got %s, wall: %.3f, cpu: %.3f",
-                        std::string(fin).c_str(),
-                        et.elapsed_sec, et.cpu_elapsed_sec);
-#else
-    struct timeval tv;
-    gettimeofday(&tv, nullptr);
-    elapsed.push_back(std::make_pair(tv, et.elapsed_sec));
-#endif
-    waiting.erase(it);
-    while (try_send());
-}
-
-std::pair<std::string, std::string> split_ip_port_cport(const std::string &s) {
-    auto ret = salticidae::trim_all(salticidae::split(s, ";"));
-    return std::make_pair(ret[0], ret[1]);
-}
-
-int main(int argc, char **argv) {
-    Config config("hotstuff.conf");
-
-    auto opt_idx = Config::OptValInt::create(0);
-    auto opt_replicas = Config::OptValStrVec::create();
-    auto opt_max_iter_num = Config::OptValInt::create(100);
-    auto opt_max_async_num = Config::OptValInt::create(10);
-    auto opt_cid = Config::OptValInt::create(-1);
-
-    auto shutdown = [&](int) { ec.stop(); };
-    salticidae::SigEvent ev_sigint(ec, shutdown);
-    salticidae::SigEvent ev_sigterm(ec, shutdown);
-    ev_sigint.add(SIGINT);
-    ev_sigterm.add(SIGTERM);
-
-    mn.reg_handler(client_resp_cmd_handler);
-    mn.start();
-
-    config.add_opt("idx", opt_idx, Config::SET_VAL);
-    config.add_opt("cid", opt_cid, Config::SET_VAL);
-    config.add_opt("replica", opt_replicas, Config::APPEND);
-    config.add_opt("iter", opt_max_iter_num, Config::SET_VAL);
-    config.add_opt("max-async", opt_max_async_num, Config::SET_VAL);
-    config.parse(argc, argv);
-    auto idx = opt_idx->get();
-    max_iter_num = opt_max_iter_num->get();
-    max_async_num = opt_max_async_num->get();
-    std::vector<std::string> raw;
-    for (const auto &s: opt_replicas->get())
-    {
-        auto res = salticidae::trim_all(salticidae::split(s, ","));
-        if (res.size() < 1)
-            throw HotStuffError("format error");
-        raw.push_back(res[0]);
-    }
-
-    if (!(0 <= idx && (size_t)idx < raw.size() && raw.size() > 0))
-        throw std::invalid_argument("out of range");
-    cid = opt_cid->get() != -1 ? opt_cid->get() : idx;
-    for (const auto &p: raw)
-    {
-        auto _p = split_ip_port_cport(p);
-        size_t _;
-        replicas.push_back(NetAddr(NetAddr(_p.first).ip, htons(stoi(_p.second, &_))));
-    }
-
-    nfaulty = (replicas.size() - 1) / 3;
-    HOTSTUFF_LOG_INFO("nfaulty = %zu", nfaulty);
-    connect_all();
-    while (try_send());
-    ec.dispatch();
-
-#ifdef HOTSTUFF_ENABLE_BENCHMARK
-    for (const auto &e: elapsed)
-    {
-        char fmt[64];
-        struct tm *tmp = localtime(&e.first.tv_sec);
-        strftime(fmt, sizeof fmt, "%Y-%m-%d %H:%M:%S.%%06u [hotstuff info] %%.6f\n", tmp);
-        fprintf(stderr, fmt, e.first.tv_usec, e.second);
-    }
-#endif
-    return 0;
-}