fergalmoran/DnsServer
1
0
Fork 0
mirror of https://github.com/fergalmoran/DnsServer.git synced 2026-01-06 16:53:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

DnsServer: tcp send and receive timeout made configurable. added retries parameter for recursive resolution wait timeout.

Browse Source
This commit is contained in:
Shreyas Zare
2018-12-15 14:46:04 +05:30
parent a4b580917a
commit 55f56bd583
1 changed files with 19 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
DnsServerCore/DnsServer.cs
View File

@@ -47,8 +47,6 @@ namespace DnsServerCore
#region variables
const int UDP_LISTENER_THREAD_COUNT = 3;
const int TCP_SOCKET_SEND_TIMEOUT = 30000;
const int TCP_SOCKET_RECV_TIMEOUT = 120000;
readonly IPEndPoint _localEP;
@@ -79,6 +77,9 @@ namespace DnsServerCore
LogManager _queryLog;
StatsManager _stats;
int _tcpSendTimeout = 10000;
int _tcpReceiveTimeout = 10000;
readonly ConcurrentDictionary<DnsQuestionRecord, object> _recursiveQueryLocks = new ConcurrentDictionary<DnsQuestionRecord, object>();
volatile ServiceState _state = ServiceState.Stopped;
@@ -246,8 +247,8 @@ namespace DnsServerCore
{
Socket socket = _tcpListener.Accept();
socket.SendTimeout = TCP_SOCKET_SEND_TIMEOUT;
socket.ReceiveTimeout = TCP_SOCKET_RECV_TIMEOUT;
socket.SendTimeout = _tcpSendTimeout;
socket.ReceiveTimeout = _tcpReceiveTimeout;
ThreadPool.QueueUserWorkItem(ReadTcpRequestAsync, socket);
}
@@ -676,7 +677,7 @@ namespace DnsServerCore
//question already being recursively resolved by another thread, wait till timeout or pulse signal
lock (actualLockObj)
{
Monitor.Wait(actualLockObj, _timeout);
Monitor.Wait(actualLockObj, _timeout * _retries);
}
//query cache zone again to see if answer available
@@ -713,7 +714,7 @@ namespace DnsServerCore
try
{
return DnsClient.ResolveViaNameServers(request.Question[0], viaNameServers, _dnsCache, _proxy, _preferIPv6, protocol, _retries, _maxStackCount, _timeout, _recursiveResolveProtocol);
return DnsClient.ResolveViaNameServers(request.Question[0], viaNameServers, _dnsCache, _proxy, _preferIPv6, protocol, _retries, _timeout, _recursiveResolveProtocol, _maxStackCount);
}
finally
{
@@ -920,6 +921,18 @@ namespace DnsServerCore
set { _stats = value; }
}
public int TcpSendTimeout
{
get { return _tcpSendTimeout; }
set { _tcpSendTimeout = value; }
}
public int TcpReceiveTimeout
{
get { return _tcpReceiveTimeout; }
set { _tcpReceiveTimeout = value; }
}
#endregion
class DnsCache : IDnsCache