Commit f7963756 authored by Weixin Deng's avatar Weixin Deng
Browse files

Set timeout

parent e92f1c3a
......@@ -13,6 +13,11 @@ wget https://bootstrap.pypa.io/get-pip.py
python3 get-pip.py
python3 -m pip install pytz
git clone https://github.com/magnific0/wondershaper.git
cd wondershaper
sudo make install
sudo wondershaper -a eno50 -d 1000
curl -s https://packagecloud.io/install/repositories/github/git-lfs/script.deb.sh | sudo bash
sudo apt install git-lfs
git config --global user.name "Weixin Deng"
......
......@@ -57,8 +57,11 @@ def main():
)
exps.append(exp)
exps.sort(key=lambda exp: (exp.data_size, exp.servers, exp.ports))
print("backends,data_size,ports,server_delay,servers,goodput_mean,goodput_std")
for exp in exps:
print(exp)
print(
f"{exp.backends},{exp.data_size},{exp.ports},{exp.server_delay},{exp.servers},{exp.goodput_mean},{exp.goodput_std}"
)
if __name__ == "__main__":
......
......@@ -119,8 +119,9 @@ func (c *Client) SendRequest(
wgStart *sync.WaitGroup,
wgFinish *sync.WaitGroup) {
defer wgFinish.Done()
client, err := rpc.Dial("tcp", request.DstAddr)
conn, err := net.DialTimeout("tcp", request.DstAddr, time.Hour)
Assert(err == nil, "[Client error] ", err)
client := rpc.NewClient(conn)
defer client.Close()
var reply Reply
wgInit.Done()
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment