Skip to content

Commit 93311c9

Browse files
committed
Merge WritePacket, IsValidPacket
1 parent 51903e6 commit 93311c9

File tree

4 files changed

+21
-16
lines changed

4 files changed

+21
-16
lines changed

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

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -705,10 +705,6 @@ private Task SNIWritePacket(PacketHandle packet, out uint sniError, bool canAccu
705705
return task;
706706
}
707707

708-
internal abstract bool IsValidPacket(PacketHandle packetPointer);
709-
710-
internal abstract uint WritePacket(PacketHandle packet, bool sync);
711-
712708
// Sends an attention signal - executing thread will consume attn.
713709
internal void SendAttention(bool mustTakeWriteLock = false, bool asyncClose = false)
714710
{

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

Lines changed: 1 addition & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -675,8 +675,7 @@ private Task SNIWritePacket(PacketHandle packet, out uint sniError, bool canAccu
675675
}
676676
finally
677677
{
678-
Debug.Assert(packet.Type == PacketHandle.NativePacketType, "unexpected packet type when requiring NativePacket");
679-
sniError = SniNativeWrapper.SniWritePacket(Handle, packet.NativePacket, sync);
678+
sniError = WritePacket(packet, sync);
680679
}
681680

682681
if (sniError == TdsEnums.SNI_SUCCESS_IO_PENDING)
@@ -770,16 +769,6 @@ private Task SNIWritePacket(PacketHandle packet, out uint sniError, bool canAccu
770769

771770
#pragma warning restore 420
772771

773-
internal bool IsValidPacket(PacketHandle packetPointer)
774-
{
775-
Debug.Assert(packetPointer.Type == PacketHandle.NativePointerType || packetPointer.Type == PacketHandle.NativePacketType, "unexpected packet type when requiring NativePointer");
776-
return (
777-
(packetPointer.Type == PacketHandle.NativePointerType && packetPointer.NativePointer != IntPtr.Zero)
778-
||
779-
(packetPointer.Type == PacketHandle.NativePacketType && packetPointer.NativePacket != null)
780-
);
781-
}
782-
783772
// Sends an attention signal - executing thread will consume attn.
784773
internal void SendAttention(bool mustTakeWriteLock = false, bool asyncClose = false)
785774
{

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

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -76,6 +76,22 @@ internal override PacketHandle ReadSyncOverAsync(int timeoutRemaining, out uint
7676
return PacketHandle.FromNativePointer(readPacketPtr);
7777
}
7878

79+
internal override uint WritePacket(PacketHandle packet, bool sync)
80+
{
81+
Debug.Assert(packet.Type == PacketHandle.NativePacketType, "unexpected packet type when requiring NativePacket");
82+
return SniNativeWrapper.SniWritePacket(Handle, packet.NativePacket, sync);
83+
}
84+
85+
internal override bool IsValidPacket(PacketHandle packetPointer)
86+
{
87+
Debug.Assert(packetPointer.Type == PacketHandle.NativePointerType || packetPointer.Type == PacketHandle.NativePacketType, "unexpected packet type when requiring NativePointer");
88+
return (
89+
(packetPointer.Type == PacketHandle.NativePointerType && packetPointer.NativePointer != IntPtr.Zero)
90+
||
91+
(packetPointer.Type == PacketHandle.NativePacketType && packetPointer.NativePacket != null)
92+
);
93+
}
94+
7995
internal override uint SniGetConnectionId(ref Guid clientConnectionId)
8096
=> SniNativeWrapper.SniGetConnectionId(Handle, ref clientConnectionId);
8197

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

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -495,6 +495,10 @@ internal long TimeoutTime
495495

496496
internal abstract PacketHandle ReadSyncOverAsync(int timeoutRemaining, out uint error);
497497

498+
internal abstract uint WritePacket(PacketHandle packet, bool sync);
499+
500+
internal abstract bool IsValidPacket(PacketHandle packetPointer);
501+
498502
internal abstract PacketHandle ReadAsync(SessionHandle handle, out uint error);
499503

500504
internal abstract uint SniGetConnectionId(ref Guid clientConnectionId);

0 commit comments

Comments
 (0)