commit 0c62d806a4352c054f80bb0f604eb7de7f1430e0
Author: Shelikhoo <[email protected]>
Date:   Tue Nov 16 19:25:27 2021 +0000

    Represent NATTypeMeasurementInterval in time.Duration
    
    Adopted the change in according to the recommendation from
    
    
https://gitlab.torproject.org/tpo/anti-censorship/pluggable-transports/snowflake/-/merge_requests/62#note_2761566
---
 proxy/lib/snowflake.go | 10 +++++-----
 proxy/main.go          |  2 +-
 2 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/proxy/lib/snowflake.go b/proxy/lib/snowflake.go
index df6a256..a9ac399 100644
--- a/proxy/lib/snowflake.go
+++ b/proxy/lib/snowflake.go
@@ -112,9 +112,9 @@ type SnowflakeProxy struct {
        RelayURL string
        // NATProbeURL is the URL of the probe service we use for NAT checks
        NATProbeURL string
-       // NATTypeMeasurementIntervalSecond is time in second before NAT type 
is retested
-       NATTypeMeasurementIntervalSecond uint
-       shutdown                         chan struct{}
+       // NATTypeMeasurementInterval is time before NAT type is retested
+       NATTypeMeasurementInterval time.Duration
+       shutdown                   chan struct{}
 }
 
 // Checks whether an IP address is a remote address for the client
@@ -550,14 +550,14 @@ func (sf *SnowflakeProxy) Start() error {
        log.Printf("NAT type: %s", currentNATTypeLoaded)
 
        NatRetestTask := task.Periodic{
-               Interval: time.Second * 
time.Duration(sf.NATTypeMeasurementIntervalSecond),
+               Interval: sf.NATTypeMeasurementInterval,
                Execute: func() error {
                        sf.checkNATType(config, sf.NATProbeURL)
                        return nil
                },
        }
 
-       if sf.NATTypeMeasurementIntervalSecond != 0 {
+       if sf.NATTypeMeasurementInterval != 0 {
                NatRetestTask.Start()
                defer NatRetestTask.Close()
        }
diff --git a/proxy/main.go b/proxy/main.go
index de33d42..b85dde0 100644
--- a/proxy/main.go
+++ b/proxy/main.go
@@ -31,7 +31,7 @@ func main() {
                KeepLocalAddresses: *keepLocalAddresses,
                RelayURL:           *relayURL,
 
-               NATTypeMeasurementIntervalSecond: 
uint(NATTypeMeasurementInterval.Seconds()),
+               NATTypeMeasurementInterval: *NATTypeMeasurementInterval,
        }
 
        var logOutput io.Writer = os.Stderr

_______________________________________________
tor-commits mailing list
[email protected]
https://lists.torproject.org/cgi-bin/mailman/listinfo/tor-commits

Reply via email to