aboutsummaryrefslogtreecommitdiff
path: root/src/hotstuff_client.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/hotstuff_client.cpp')
-rw-r--r--src/hotstuff_client.cpp181
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;
-}