Commit 01570f85 authored by Loïck Bonniot's avatar Loïck Bonniot

Merge branch '451_slowdown_flag' into 'master'

[c] Add slowdown flag



See merge request !78
parents fd636e3f d4de2685
Pipeline #1865 passed with stages
...@@ -3,7 +3,6 @@ package cmd ...@@ -3,7 +3,6 @@ package cmd
import ( import (
"dfss" "dfss"
dapi "dfss/dfssd/api" dapi "dfss/dfssd/api"
"github.com/spf13/cobra" "github.com/spf13/cobra"
"github.com/spf13/viper" "github.com/spf13/viper"
...@@ -31,7 +30,7 @@ A tool to sign multiparty contract using a secure cryptographic protocol`, ...@@ -31,7 +30,7 @@ A tool to sign multiparty contract using a secure cryptographic protocol`,
// All of the flags will be gathered by viper, this is why // All of the flags will be gathered by viper, this is why
// we do not store their values // we do not store their values
func init() { func init() {
// Bind flags to the dfsst command // Bind flags to the dfssc command
RootCmd.PersistentFlags().BoolP("verbose", "v", false, "print verbose messages") RootCmd.PersistentFlags().BoolP("verbose", "v", false, "print verbose messages")
RootCmd.PersistentFlags().String("ca", "ca.pem", "path to the root certificate") RootCmd.PersistentFlags().String("ca", "ca.pem", "path to the root certificate")
RootCmd.PersistentFlags().String("cert", "cert.pem", "path to the user's certificate") RootCmd.PersistentFlags().String("cert", "cert.pem", "path to the user's certificate")
...@@ -40,6 +39,8 @@ func init() { ...@@ -40,6 +39,8 @@ func init() {
RootCmd.PersistentFlags().String("host", "localhost:9000", "host of the dfss platform") RootCmd.PersistentFlags().String("host", "localhost:9000", "host of the dfss platform")
RootCmd.PersistentFlags().IntP("port", "p", 9005, "port to use for P2P communication between clients") RootCmd.PersistentFlags().IntP("port", "p", 9005, "port to use for P2P communication between clients")
signCmd.Flags().Duration("slowdown", 0, "Delay between each promises round")
// Store flag values into viper // Store flag values into viper
_ = viper.BindPFlag("verbose", RootCmd.PersistentFlags().Lookup("verbose")) _ = viper.BindPFlag("verbose", RootCmd.PersistentFlags().Lookup("verbose"))
_ = viper.BindPFlag("file_ca", RootCmd.PersistentFlags().Lookup("ca")) _ = viper.BindPFlag("file_ca", RootCmd.PersistentFlags().Lookup("ca"))
......
...@@ -6,6 +6,7 @@ import ( ...@@ -6,6 +6,7 @@ import (
"dfss/dfssc/sign" "dfss/dfssc/sign"
"github.com/spf13/cobra" "github.com/spf13/cobra"
"github.com/spf13/viper"
) )
var signCmd = &cobra.Command{ var signCmd = &cobra.Command{
...@@ -17,6 +18,8 @@ var signCmd = &cobra.Command{ ...@@ -17,6 +18,8 @@ var signCmd = &cobra.Command{
os.Exit(1) os.Exit(1)
} }
_ = viper.BindPFlag("slowdown", cmd.Flags().Lookup("slowdown"))
filename := args[0] filename := args[0]
fmt.Println("You are going to sign the following contract:") fmt.Println("You are going to sign the following contract:")
showContract(cmd, args) showContract(cmd, args)
......
...@@ -8,6 +8,7 @@ import ( ...@@ -8,6 +8,7 @@ import (
cAPI "dfss/dfssc/api" cAPI "dfss/dfssc/api"
"dfss/dfssc/common" "dfss/dfssc/common"
dAPI "dfss/dfssd/api" dAPI "dfss/dfssd/api"
"github.com/spf13/viper"
) )
// Sign performs all the message exchanges for the contract to be signed // Sign performs all the message exchanges for the contract to be signed
...@@ -42,6 +43,7 @@ func (m *SignatureManager) Sign() error { ...@@ -42,6 +43,7 @@ func (m *SignatureManager) Sign() error {
// Follow the sequence until there is no next occurence of me // Follow the sequence until there is no next occurence of me
for m.currentIndex >= 0 { for m.currentIndex >= 0 {
m.OnProgressUpdate(m.currentIndex, seqLen+1) m.OnProgressUpdate(m.currentIndex, seqLen+1)
time.Sleep(viper.GetDuration("slowdown"))
dAPI.DLog("starting round at index [" + fmt.Sprintf("%d", m.currentIndex) + "] with nextIndex=" + fmt.Sprintf("%d", nextIndex)) dAPI.DLog("starting round at index [" + fmt.Sprintf("%d", m.currentIndex) + "] with nextIndex=" + fmt.Sprintf("%d", nextIndex))
// Set of promises we are waiting for // Set of promises we are waiting for
......
Markdown is supported
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