Skip to content

Commit 6b47ff9

Browse files
committed
Reuse Ping and Quit payload objects.
1 parent e95d80f commit 6b47ff9

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

src/MySqlConnector/Core/ServerSession.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -197,7 +197,7 @@ public async Task DisposeAsync(IOBehavior ioBehavior, CancellationToken cancella
197197
{
198198
Log.Info("{0} sending QUIT command", m_logArguments);
199199
m_payloadHandler.StartNewConversation();
200-
await m_payloadHandler.WritePayloadAsync(QuitPayload.Create().ArraySegment, ioBehavior).ConfigureAwait(false);
200+
await m_payloadHandler.WritePayloadAsync(QuitPayload.Instance.ArraySegment, ioBehavior).ConfigureAwait(false);
201201
}
202202
catch (IOException)
203203
{
@@ -514,7 +514,7 @@ public async ValueTask<bool> TryPingAsync(IOBehavior ioBehavior, CancellationTok
514514
try
515515
{
516516
Log.Debug("{0} pinging server", m_logArguments);
517-
await SendAsync(PingPayload.Create(), ioBehavior, cancellationToken).ConfigureAwait(false);
517+
await SendAsync(PingPayload.Instance, ioBehavior, cancellationToken).ConfigureAwait(false);
518518
var payload = await ReceiveReplyAsync(ioBehavior, cancellationToken).ConfigureAwait(false);
519519
OkPayload.Create(payload);
520520
Log.Info("{0} successfully pinged server", m_logArguments);

src/MySqlConnector/Protocol/Payloads/PingPayload.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,6 @@ namespace MySqlConnector.Protocol.Payloads
22
{
33
internal sealed class PingPayload
44
{
5-
public static PayloadData Create() => new PayloadData(new[] { (byte) CommandKind.Ping });
5+
public static PayloadData Instance { get; } = new PayloadData(new[] { (byte) CommandKind.Ping });
66
}
77
}

src/MySqlConnector/Protocol/Payloads/QuitPayload.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,6 @@ namespace MySqlConnector.Protocol.Payloads
22
{
33
internal sealed class QuitPayload
44
{
5-
public static PayloadData Create() => new PayloadData(new[] { (byte) CommandKind.Quit });
5+
public static PayloadData Instance { get; } = new PayloadData(new[] { (byte) CommandKind.Quit });
66
}
77
}

0 commit comments

Comments
 (0)