1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
|
using System;
using System.IO;
#if !PORTABLE || DOTNET
using System.Net.Sockets;
#endif
namespace Org.BouncyCastle.Tls
{
public class DtlsTransport
: DatagramTransport
{
private readonly DtlsRecordLayer m_recordLayer;
internal DtlsTransport(DtlsRecordLayer recordLayer)
{
this.m_recordLayer = recordLayer;
}
/// <exception cref="IOException"/>
public virtual int GetReceiveLimit()
{
return m_recordLayer.GetReceiveLimit();
}
/// <exception cref="IOException"/>
public virtual int GetSendLimit()
{
return m_recordLayer.GetSendLimit();
}
/// <exception cref="IOException"/>
public virtual int Receive(byte[] buf, int off, int len, int waitMillis)
{
if (null == buf)
throw new ArgumentNullException("buf");
if (off < 0 || off >= buf.Length)
throw new ArgumentException("invalid offset: " + off, "off");
if (len < 0 || len > buf.Length - off)
throw new ArgumentException("invalid length: " + len, "len");
if (waitMillis < 0)
throw new ArgumentException("cannot be negative", "waitMillis");
try
{
return m_recordLayer.Receive(buf, off, len, waitMillis);
}
catch (TlsFatalAlert fatalAlert)
{
m_recordLayer.Fail(fatalAlert.AlertDescription);
throw fatalAlert;
}
catch (TlsTimeoutException e)
{
throw e;
}
#if !PORTABLE || DOTNET
catch (SocketException e)
{
if (TlsUtilities.IsTimeout(e))
throw e;
m_recordLayer.Fail(AlertDescription.internal_error);
throw new TlsFatalAlert(AlertDescription.internal_error, e);
}
#endif
// TODO[tls-port] Can we support interrupted IO on .NET?
//catch (InterruptedIOException e)
//{
// throw e;
//}
catch (IOException e)
{
m_recordLayer.Fail(AlertDescription.internal_error);
throw e;
}
catch (Exception e)
{
m_recordLayer.Fail(AlertDescription.internal_error);
throw new TlsFatalAlert(AlertDescription.internal_error, e);
}
}
/// <exception cref="IOException"/>
public virtual void Send(byte[] buf, int off, int len)
{
if (null == buf)
throw new ArgumentNullException("buf");
if (off < 0 || off >= buf.Length)
throw new ArgumentException("invalid offset: " + off, "off");
if (len < 0 || len > buf.Length - off)
throw new ArgumentException("invalid length: " + len, "len");
try
{
m_recordLayer.Send(buf, off, len);
}
catch (TlsFatalAlert fatalAlert)
{
m_recordLayer.Fail(fatalAlert.AlertDescription);
throw fatalAlert;
}
catch (TlsTimeoutException e)
{
throw e;
}
#if !PORTABLE || DOTNET
catch (SocketException e)
{
if (TlsUtilities.IsTimeout(e))
throw e;
m_recordLayer.Fail(AlertDescription.internal_error);
throw new TlsFatalAlert(AlertDescription.internal_error, e);
}
#endif
// TODO[tls-port] Can we support interrupted IO on .NET?
//catch (InterruptedIOException e)
//{
// throw e;
//}
catch (IOException e)
{
m_recordLayer.Fail(AlertDescription.internal_error);
throw e;
}
catch (Exception e)
{
m_recordLayer.Fail(AlertDescription.internal_error);
throw new TlsFatalAlert(AlertDescription.internal_error, e);
}
}
/// <exception cref="IOException"/>
public virtual void Close()
{
m_recordLayer.Close();
}
}
}
|
