Skip to content

Commit abcbe43

Browse files
committed
Http,Network,Services.Utitlity: rename FSharpUtil
Renamed FSharpUtil module to AsyncUtil.
1 parent 35d2ec5 commit abcbe43

File tree

7 files changed

+16
-18
lines changed

7 files changed

+16
-18
lines changed

NOnion/Http/TorHttpClient.fs

+2-2
Original file line numberDiff line numberDiff line change
@@ -51,7 +51,7 @@ type TorHttpClient(stream: TorStream, host: string) =
5151

5252
do!
5353
ReceiveAll memStream
54-
|> FSharpUtil.WithTimeout Constants.HttpGetResponseTimeout
54+
|> AsyncUtil.WithTimeout Constants.HttpGetResponseTimeout
5555

5656
let httpResponse = memStream.ToArray()
5757

@@ -145,7 +145,7 @@ type TorHttpClient(stream: TorStream, host: string) =
145145

146146
do!
147147
ReceiveAll memStream
148-
|> FSharpUtil.WithTimeout Constants.HttpPostResponseTimeout
148+
|> AsyncUtil.WithTimeout Constants.HttpPostResponseTimeout
149149

150150
let httpResponse = memStream.ToArray()
151151

NOnion/NOnion.fsproj

+1-1
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
<Compile Include="RelayIntroduceStatus.fs" />
1919
<Compile Include="Exceptions.fs" />
2020
<Compile Include="HandshakeType.fs" />
21-
<Compile Include="Utility\FSharpUtil.fs" />
21+
<Compile Include="Utility\AsyncUtil.fs" />
2222
<Compile Include="Utility\ResultUtil.fs" />
2323
<Compile Include="Utility\MailboxUtil.fs" />
2424
<Compile Include="Utility\StreamUtil.fs" />

NOnion/Network/TorCircuit.fs

+6-6
Original file line numberDiff line numberDiff line change
@@ -1113,7 +1113,7 @@ and TorCircuit
11131113
completionTaskRes
11141114
|> UnwrapResult
11151115
|> Async.AwaitTask
1116-
|> FSharpUtil.WithTimeout Constants.CircuitOperationTimeout
1116+
|> AsyncUtil.WithTimeout Constants.CircuitOperationTimeout
11171117
}
11181118

11191119
member __.Extend(nodeDetail: CircuitNodeDetail) =
@@ -1130,7 +1130,7 @@ and TorCircuit
11301130
completionTaskRes
11311131
|> UnwrapResult
11321132
|> Async.AwaitTask
1133-
|> FSharpUtil.WithTimeout Constants.CircuitOperationTimeout
1133+
|> AsyncUtil.WithTimeout Constants.CircuitOperationTimeout
11341134
}
11351135

11361136
member __.RegisterAsIntroductionPoint
@@ -1156,7 +1156,7 @@ and TorCircuit
11561156
completionTaskRes
11571157
|> UnwrapResult
11581158
|> Async.AwaitTask
1159-
|> FSharpUtil.WithTimeout Constants.CircuitOperationTimeout
1159+
|> AsyncUtil.WithTimeout Constants.CircuitOperationTimeout
11601160
}
11611161

11621162
member __.RegisterAsRendezvousPoint(cookie: array<byte>) =
@@ -1177,7 +1177,7 @@ and TorCircuit
11771177
completionTaskRes
11781178
|> UnwrapResult
11791179
|> Async.AwaitTask
1180-
|> FSharpUtil.WithTimeout Constants.CircuitOperationTimeout
1180+
|> AsyncUtil.WithTimeout Constants.CircuitOperationTimeout
11811181
}
11821182

11831183
member self.ExtendAsync nodeDetail =
@@ -1203,7 +1203,7 @@ and TorCircuit
12031203
completionTaskRes
12041204
|> UnwrapResult
12051205
|> Async.AwaitTask
1206-
|> FSharpUtil.WithTimeout Constants.CircuitOperationTimeout
1206+
|> AsyncUtil.WithTimeout Constants.CircuitOperationTimeout
12071207
}
12081208

12091209
member __.WaitingForRendezvousJoin
@@ -1231,7 +1231,7 @@ and TorCircuit
12311231
completionTaskRes
12321232
|> UnwrapResult
12331233
|> Async.AwaitTask
1234-
|> FSharpUtil.WithTimeout Constants.CircuitRendezvousTimeout
1234+
|> AsyncUtil.WithTimeout Constants.CircuitRendezvousTimeout
12351235

12361236
}
12371237

NOnion/Network/TorGuard.fs

+3-3
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,7 @@ type TorGuard private (client: TcpClient, sslStream: SslStream) =
120120
do!
121121
client.ConnectAsync(ipEndpoint.Address, ipEndpoint.Port)
122122
|> Async.AwaitTask
123-
|> FSharpUtil.WithTimeout
123+
|> AsyncUtil.WithTimeout
124124
Constants.GuardConnectionTimeout
125125
}
126126

@@ -148,7 +148,7 @@ type TorGuard private (client: TcpClient, sslStream: SslStream) =
148148
false
149149
)
150150
|> Async.AwaitTask
151-
|> FSharpUtil.WithTimeout Constants.CircuitOperationTimeout
151+
|> AsyncUtil.WithTimeout Constants.CircuitOperationTimeout
152152

153153
do!
154154
ExceptionUtil.RunGuardJobWithExceptionHandling<unit>(
@@ -391,7 +391,7 @@ type TorGuard private (client: TcpClient, sslStream: SslStream) =
391391
TorLogger.Log "TorGuard: finished handshake process"
392392
//TODO: do security checks on handshake data
393393
}
394-
|> FSharpUtil.WithTimeout Constants.CircuitOperationTimeout
394+
|> AsyncUtil.WithTimeout Constants.CircuitOperationTimeout
395395

396396
member internal __.RegisterCircuit(circuit: ITorCircuit) : uint16 =
397397
let rec createCircuitId(retry: int) =

NOnion/Network/TorStream.fs

+2-2
Original file line numberDiff line numberDiff line change
@@ -460,7 +460,7 @@ type TorStream(circuit: TorCircuit) =
460460
completionTaskRes
461461
|> UnwrapResult
462462
|> Async.AwaitTask
463-
|> FSharpUtil.WithTimeout Constants.StreamCreationTimeout
463+
|> AsyncUtil.WithTimeout Constants.StreamCreationTimeout
464464
}
465465

466466
member self.ConnectToDirectory() =
@@ -480,7 +480,7 @@ type TorStream(circuit: TorCircuit) =
480480
completionTaskResult
481481
|> UnwrapResult
482482
|> Async.AwaitTask
483-
|> FSharpUtil.WithTimeout Constants.StreamCreationTimeout
483+
|> AsyncUtil.WithTimeout Constants.StreamCreationTimeout
484484
}
485485

486486
member self.ConnectToDirectoryAsync() =

NOnion/Services/TorServiceHost.fs

+1-1
Original file line numberDiff line numberDiff line change
@@ -247,7 +247,7 @@ type TorServiceHost
247247
introEncPubKey
248248

249249
do!
250-
FSharpUtil.Retry<NOnionException>
250+
AsyncUtil.Retry<NOnionException>
251251
connectToRendezvousJob
252252
maxRendezvousConnectRetryCount
253253

NOnion/Utility/FSharpUtil.fs NOnion/Utility/AsyncUtil.fs

+1-3
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,12 @@
11
namespace NOnion.Utility
22

33
open System
4-
open System.Runtime.ExceptionServices
54

6-
open FSharpx.Collections
75
open Fsdk
86

97
open NOnion
108

11-
module FSharpUtil =
9+
module AsyncUtil =
1210
let WithTimeout (timeSpan: TimeSpan) (job: Async<'R>) : Async<'R> =
1311
async {
1412
let! result = FSharpUtil.WithTimeout timeSpan job

0 commit comments

Comments
 (0)