diff --git a/Rpc/BindingProtocols/TaskBuilders/BaseTaskBuilder.vb b/Rpc/BindingProtocols/TaskBuilders/BaseTaskBuilder.vb index 5c2f655..3b4b45a 100644 --- a/Rpc/BindingProtocols/TaskBuilders/BaseTaskBuilder.vb +++ b/Rpc/BindingProtocols/TaskBuilders/BaseTaskBuilder.vb @@ -83,10 +83,10 @@ Namespace Rpc.BindingProtocols.TaskBuilders ''' ''' The queued task. ''' - ''' + ''' ''' procedure number ''' - ''' + ''' ''' instance of arguments of request ''' ''' diff --git a/Rpc/BindingProtocols/TaskBuilders/PortMapper.vb b/Rpc/BindingProtocols/TaskBuilders/PortMapper.vb index 1e85bc1..c000cce 100644 --- a/Rpc/BindingProtocols/TaskBuilders/PortMapper.vb +++ b/Rpc/BindingProtocols/TaskBuilders/PortMapper.vb @@ -62,9 +62,9 @@ Namespace Rpc.BindingProtocols.TaskBuilders ''' number 111 (SUNRPC) on either of these protocols. ''' http://tools.ietf.org/html/rfc1833#section-3.2 ''' - ''' instance of connector - ''' cancellation token - ''' attache created task to parent task + ''' instance of connector + ''' cancellation token + ''' attache created task to parent task Public Sub New(ByVal conn As IRpcClient, ByVal token As CancellationToken, ByVal attachedToParent As Boolean) MyBase.New(conn, token, attachedToParent) End Sub diff --git a/Rpc/BindingProtocols/TaskBuilders/RpcBindV3.vb b/Rpc/BindingProtocols/TaskBuilders/RpcBindV3.vb index 53b4428..8a00456 100644 --- a/Rpc/BindingProtocols/TaskBuilders/RpcBindV3.vb +++ b/Rpc/BindingProtocols/TaskBuilders/RpcBindV3.vb @@ -63,9 +63,9 @@ Namespace Rpc.BindingProtocols.TaskBuilders ''' For TCP/IP and UDP/IP, for example, it is port number 111. Each transport has such an assigned, well-known address. ''' http://tools.ietf.org/html/rfc1833#section-2.2.1 ''' - ''' instance of connector - ''' cancellation token - ''' attache created task to parent task + ''' instance of connector + ''' cancellation token + ''' attache created task to parent task Public Sub New(ByVal conn As IRpcClient, ByVal token As CancellationToken, ByVal attachedToParent As Boolean) MyBase.New(conn, token, attachedToParent) End Sub diff --git a/Rpc/BindingProtocols/TaskBuilders/RpcBindV4.vb b/Rpc/BindingProtocols/TaskBuilders/RpcBindV4.vb index 0abc8ff..7a03fc5 100644 --- a/Rpc/BindingProtocols/TaskBuilders/RpcBindV4.vb +++ b/Rpc/BindingProtocols/TaskBuilders/RpcBindV4.vb @@ -64,9 +64,9 @@ Namespace Rpc.BindingProtocols.TaskBuilders ''' For TCP/IP and UDP/IP, for example, it is port number 111. Each transport has such an assigned, well-known address. ''' http://tools.ietf.org/html/rfc1833#section-2.2.1 ''' - ''' instance of connector - ''' cancellation token - ''' attache created task to parent task + ''' instance of connector + ''' cancellation token + ''' attache created task to parent task Public Sub New(ByVal conn As IRpcClient, ByVal token As CancellationToken, ByVal attachedToParent As Boolean) MyBase.New(conn, token, attachedToParent) End Sub diff --git a/Rpc/Exceptions/AuthenticateException.vb b/Rpc/Exceptions/AuthenticateException.vb index f4f8abd..8053418 100644 --- a/Rpc/Exceptions/AuthenticateException.vb +++ b/Rpc/Exceptions/AuthenticateException.vb @@ -52,7 +52,7 @@ Namespace Rpc ''' ''' Authenticate error ''' - ''' + ''' Public Sub New(ByVal replyBody As reply_body) MyBase.New(replyBody) End Sub @@ -60,8 +60,8 @@ Namespace Rpc ''' ''' Authenticate error ''' - ''' - ''' + ''' + ''' Public Sub New(ByVal replyBody As reply_body, ByVal message As String) MyBase.New(replyBody, message) End Sub @@ -69,9 +69,9 @@ Namespace Rpc ''' ''' Authenticate error ''' - ''' - ''' - ''' + ''' + ''' + ''' Public Sub New(ByVal replyBody As reply_body, ByVal message As String, ByVal innerEx As Exception) MyBase.New(replyBody, message, innerEx) End Sub diff --git a/Rpc/Exceptions/ReplyException.vb b/Rpc/Exceptions/ReplyException.vb index 211df2b..9d09ed6 100644 --- a/Rpc/Exceptions/ReplyException.vb +++ b/Rpc/Exceptions/ReplyException.vb @@ -68,7 +68,7 @@ Namespace Rpc ''' ''' Error received in response RPC message ''' - ''' + ''' Public Sub New(ByVal replyBody As reply_body) Me.ReplyBody = replyBody End Sub @@ -76,8 +76,8 @@ Namespace Rpc ''' ''' Error received in response RPC message ''' - ''' - ''' + ''' + ''' Public Sub New(ByVal replyBody As reply_body, ByVal message As String) MyBase.New(message) Me.ReplyBody = replyBody @@ -86,9 +86,9 @@ Namespace Rpc ''' ''' Error received in response RPC message ''' - ''' - ''' - ''' + ''' + ''' + ''' Public Sub New(ByVal replyBody As reply_body, ByVal message As String, ByVal innerEx As Exception) MyBase.New(message, innerEx) Me.ReplyBody = replyBody diff --git a/Rpc/Exceptions/RpcException.vb b/Rpc/Exceptions/RpcException.vb index 003fc5d..2895a77 100644 --- a/Rpc/Exceptions/RpcException.vb +++ b/Rpc/Exceptions/RpcException.vb @@ -57,7 +57,7 @@ Namespace Rpc ''' ''' Error associated with work on RPC protocol ''' - ''' + ''' Public Sub New(ByVal message As String) MyBase.New(message) End Sub @@ -65,8 +65,8 @@ Namespace Rpc ''' ''' Error associated with work on RPC protocol ''' - ''' - ''' + ''' + ''' Public Sub New(ByVal message As String, ByVal innerEx As Exception) MyBase.New(message, innerEx) End Sub diff --git a/Rpc/IRpcClient.vb b/Rpc/IRpcClient.vb index 9fc18b1..5680d14 100644 --- a/Rpc/IRpcClient.vb +++ b/Rpc/IRpcClient.vb @@ -57,10 +57,10 @@ Namespace Rpc ''' ''' the runned task ''' - ''' call body structure - ''' instance of request arguments - ''' task creation options - ''' cancellation token + ''' call body structure + ''' instance of request arguments + ''' task creation options + ''' cancellation token ''' type of request ''' type of response Function CreateTask(Of TReq, TResp)(ByVal callBody As call_body, ByVal reqArgs As TReq, ByVal options As TaskCreationOptions, ByVal token As CancellationToken) As Task(Of TResp) diff --git a/Rpc/RpcClient.vb b/Rpc/RpcClient.vb index 068bac9..fc04596 100644 --- a/Rpc/RpcClient.vb +++ b/Rpc/RpcClient.vb @@ -77,8 +77,8 @@ Namespace Rpc ''' ''' Create RPC client from TCP protocol. ''' - ''' server address - ''' block size + ''' server address + ''' block size Public Shared Function FromTcp(ByVal ep As IPEndPoint, ByVal Optional blockSize As Integer = 1024 * 4) As RpcClient Log.Debug("Create RPC client for TCP server:{0}", ep) Return New RpcClient(Function() New TcpSession(ep, blockSize)) @@ -87,7 +87,7 @@ Namespace Rpc ''' ''' Create RPC client from UDP protocol. ''' - ''' server address + ''' server address Public Shared Function FromUdp(ByVal ep As IPEndPoint) As RpcClient Log.Debug("Create RPC client for UDP server:{0}", ep) Return New RpcClient(Function() New UdpSession(ep)) diff --git a/Rpc/TcpStreaming/TcpReader.vb b/Rpc/TcpStreaming/TcpReader.vb index 8eb775f..65924d9 100644 --- a/Rpc/TcpStreaming/TcpReader.vb +++ b/Rpc/TcpStreaming/TcpReader.vb @@ -95,7 +95,7 @@ Namespace Rpc.TcpStreaming ''' ''' read an array of length 'count' bytes ''' - ''' required bytes + ''' required bytes ''' Public Function Read(ByVal count As UInteger) As Byte() Implements IByteReader.Read Dim buffer = New Byte(count - 1) {} diff --git a/Rpc/TcpStreaming/TcpWriter.vb b/Rpc/TcpStreaming/TcpWriter.vb index 3525308..4937b95 100644 --- a/Rpc/TcpStreaming/TcpWriter.vb +++ b/Rpc/TcpStreaming/TcpWriter.vb @@ -64,7 +64,7 @@ Namespace Rpc.TcpStreaming ''' ''' generator TCP messages with record mark ''' - ''' maximum block size in the TCP message + ''' maximum block size in the TCP message Public Sub New(ByVal maxBlock As Integer) _maxBlock = maxBlock _pos = 4 @@ -75,7 +75,7 @@ Namespace Rpc.TcpStreaming ''' ''' write array of bytes ''' - ''' + ''' Public Sub Write(ByVal buffer As Byte()) Implements IByteWriter.Write Dim offset As Long = 0 @@ -98,7 +98,7 @@ Namespace Rpc.TcpStreaming ''' ''' write byte ''' - ''' + ''' Public Sub Write(ByVal b As Byte) Implements IByteWriter.Write _currentBlock(_pos) = b _pos += 1 diff --git a/Rpc/Toolkit.vb b/Rpc/Toolkit.vb index 288eaa5..14ff409 100644 --- a/Rpc/Toolkit.vb +++ b/Rpc/Toolkit.vb @@ -66,7 +66,7 @@ Namespace Rpc ''' ''' create writer configured for RPC protocol ''' - ''' + ''' ''' Public Function CreateWriter(ByVal writer As IByteWriter) As Writer Return _wb.Create(writer) @@ -75,7 +75,7 @@ Namespace Rpc ''' ''' create reader configured for RPC protocol ''' - ''' + ''' ''' Public Function CreateReader(ByVal reader As IByteReader) As Reader Return _rb.Create(reader) @@ -91,7 +91,7 @@ Namespace Rpc ''' ''' convert byte array to text ''' - ''' + ''' ''' Public Function ToDisplay(ByVal buffer As Byte()) As String @@ -119,7 +119,7 @@ Namespace Rpc ''' ''' returns the description of the RPC message ''' - ''' + ''' ''' Public Sub ReplyMessageValidate(ByVal msg As rpc_msg) Try diff --git a/Rpc/UdpDatagrams/UdpReader.vb b/Rpc/UdpDatagrams/UdpReader.vb index 34d3bec..7d1c252 100644 --- a/Rpc/UdpDatagrams/UdpReader.vb +++ b/Rpc/UdpDatagrams/UdpReader.vb @@ -62,7 +62,7 @@ Namespace Rpc.UdpDatagrams ''' ''' parser of RPC message received from UDP protocol ''' - ''' UDP datagram + ''' UDP datagram Public Sub New(ByVal bytes As Byte()) _pos = 0 _leftToRead = bytes.Length @@ -72,7 +72,7 @@ Namespace Rpc.UdpDatagrams ''' ''' read an array of length 'count' bytes ''' - ''' required bytes + ''' required bytes ''' Public Function Read(ByVal count As UInteger) As Byte() Implements IByteReader.Read If _leftToRead < count Then Throw UnexpectedEnd() diff --git a/Rpc/UdpDatagrams/UdpWriter.vb b/Rpc/UdpDatagrams/UdpWriter.vb index 8e7c630..80695bd 100644 --- a/Rpc/UdpDatagrams/UdpWriter.vb +++ b/Rpc/UdpDatagrams/UdpWriter.vb @@ -75,7 +75,7 @@ Namespace Rpc.UdpDatagrams ''' ''' write array of bytes ''' - ''' + ''' Public Sub Write(ByVal buffer As Byte()) Implements IByteWriter.Write _totalSize += buffer.Length If _totalSize > _max Then Throw SizeIsExceeded() @@ -100,7 +100,7 @@ Namespace Rpc.UdpDatagrams ''' ''' write byte ''' - ''' + ''' Public Sub Write(ByVal b As Byte) Implements IByteWriter.Write _totalSize += 1 If _totalSize > _max Then Throw SizeIsExceeded()