Skip to content

Commit 51903e6

Browse files
committed
Merge CheckPacket
1 parent 1ee1a14 commit 51903e6

File tree

4 files changed

+10
-9
lines changed

4 files changed

+10
-9
lines changed

src/Microsoft.Data.SqlClient/netcore/src/Microsoft/Data/SqlClient/TdsParserStateObject.netcore.cs

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -400,8 +400,6 @@ public void ReadAsyncCallback(IntPtr key, PacketHandle packet, uint error)
400400
}
401401
}
402402

403-
protected abstract bool CheckPacket(PacketHandle packet, TaskCompletionSource<object> source);
404-
405403
public void WriteAsyncCallback(PacketHandle packet, uint sniError) =>
406404
WriteAsyncCallback(IntPtr.Zero, packet, sniError);
407405

src/Microsoft.Data.SqlClient/netfx/src/Microsoft/Data/SqlClient/TdsParserStateObject.netfx.cs

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -460,13 +460,6 @@ public void ReadAsyncCallback(IntPtr key, PacketHandle packet, uint error)
460460
}
461461
}
462462

463-
private bool CheckPacket(PacketHandle packet, TaskCompletionSource<object> source)
464-
{
465-
Debug.Assert(packet.Type == PacketHandle.NativePointerType, "unexpected packet type when requiring NativePointer");
466-
IntPtr ptr = packet.NativePointer;
467-
return IntPtr.Zero == ptr || IntPtr.Zero != ptr && source != null;
468-
}
469-
470463
#pragma warning disable 420 // a reference to a volatile field will not be treated as volatile
471464

472465
public void WriteAsyncCallback(IntPtr key, PacketHandle packet, uint sniError)

src/Microsoft.Data.SqlClient/netfx/src/Microsoft/Data/SqlClient/TdsParserStateObjectNative.cs

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@
44

55
using System;
66
using System.Diagnostics;
7+
using System.Threading.Tasks;
78
using Interop.Windows.Sni;
89
using Microsoft.Data.Common;
910

@@ -39,6 +40,13 @@ protected override uint SniPacketGetData(PacketHandle packet, byte[] _inBuff, re
3940
return SniNativeWrapper.SniPacketGetData(packet.NativePointer, _inBuff, ref dataSize);
4041
}
4142

43+
protected override bool CheckPacket(PacketHandle packet, TaskCompletionSource<object> source)
44+
{
45+
Debug.Assert(packet.Type == PacketHandle.NativePointerType, "unexpected packet type when requiring NativePointer");
46+
IntPtr ptr = packet.NativePointer;
47+
return IntPtr.Zero == ptr || IntPtr.Zero != ptr && source != null;
48+
}
49+
4250
internal override bool IsFailedHandle() => _sessionHandle.Status != TdsEnums.SNI_SUCCESS;
4351

4452
internal override bool IsPacketEmpty(PacketHandle readPacket)

src/Microsoft.Data.SqlClient/src/Microsoft/Data/SqlClient/TdsParserStateObject.cs

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -485,6 +485,8 @@ internal long TimeoutTime
485485

486486
protected abstract uint SniPacketGetData(PacketHandle packet, byte[] _inBuff, ref uint dataSize);
487487

488+
protected abstract bool CheckPacket(PacketHandle packet, TaskCompletionSource<object> source);
489+
488490
internal abstract bool IsFailedHandle();
489491

490492
internal abstract bool IsPacketEmpty(PacketHandle readPacket);

0 commit comments

Comments
 (0)