Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Remove closure allocation on ReceiveMessagesAsyncInternal #19884

Merged
merged 1 commit into from
Mar 30, 2021

Conversation

danielmarbach
Copy link
Contributor

@danielmarbach danielmarbach commented Mar 27, 2021

Before


                awaiter2 = Task.Factory.FromAsync<bool>(new Func<AsyncCallback, object, IAsyncResult>((object) this.\u003C\u003E8__1, __methodptr(\u003CReceiveMessagesAsyncInternal\u003Eb__0)), new Func<IAsyncResult, bool>((object) this.\u003C\u003E8__1, __methodptr(\u003CReceiveMessagesAsyncInternal\u003Eb__1)), (object) TaskCreationOptions.RunContinuationsAsynchronously).ConfigureAwait(false).GetAwaiter();
                if (!awaiter2.IsCompleted)
                {
                  this.\u003C\u003E1__state = num2 = 1;
                  this.\u003C\u003Eu__2 = awaiter2;
                  this.\u003C\u003Et__builder.AwaitUnsafeOnCompleted<ConfiguredTaskAwaitable<bool>.ConfiguredTaskAwaiter, AmqpReceiver.\u003CReceiveMessagesAsyncInternal\u003Ed__34>(ref awaiter2, ref this);
                  return;
                }

After

                awaiter2 = Task.Factory.FromAsync<ValueTuple<ReceivingAmqpLink, int, TimeSpan?, TimeSpan>, IEnumerable<AmqpMessage>>(AmqpReceiver.\u003C\u003Ec.\u003C\u003E9__34_0 ?? (AmqpReceiver.\u003C\u003Ec.\u003C\u003E9__34_0 = new Func<ValueTuple<ReceivingAmqpLink, int, TimeSpan?, TimeSpan>, AsyncCallback, object, IAsyncResult>((object) AmqpReceiver.\u003C\u003Ec.\u003C\u003E9, __methodptr(\u003CReceiveMessagesAsyncInternal\u003Eb__34_0))), AmqpReceiver.\u003C\u003Ec.\u003C\u003E9__34_1 ?? (AmqpReceiver.\u003C\u003Ec.\u003C\u003E9__34_1 = new Func<IAsyncResult, IEnumerable<AmqpMessage>>((object) AmqpReceiver.\u003C\u003Ec.\u003C\u003E9, __methodptr(\u003CReceiveMessagesAsyncInternal\u003Eb__34_1))), new ValueTuple<ReceivingAmqpLink, int, TimeSpan?, TimeSpan>(this.\u003Clink\u003E5__2, this.maxMessages, this.maxWaitTime, this.timeout), (object) null, TaskCreationOptions.RunContinuationsAsynchronously).ConfigureAwait(false).GetAwaiter();
                if (!awaiter2.IsCompleted)
                {
                  this.\u003C\u003E1__state = num2 = 1;
                  this.\u003C\u003Eu__2 = awaiter2;
                  this.\u003C\u003Et__builder.AwaitUnsafeOnCompleted<ConfiguredTaskAwaitable<IEnumerable<AmqpMessage>>.ConfiguredTaskAwaiter, AmqpReceiver.\u003CReceiveMessagesAsyncInternal\u003Ed__34>(ref awaiter2, ref this);
                  return;
                }

All SDK Contribution checklist:

This checklist is used to make sure that common guidelines for a pull request are followed.

  • Please open PR in Draft mode if it is:
    • Work in progress or not intended to be merged.
    • Encountering multiple pipeline failures and working on fixes.
  • If an SDK is being regenerated based on a new swagger spec, a link to the pull request containing these swagger spec changes has been included above.
  • I have read the contribution guidelines.
  • The pull request does not introduce breaking changes.

General Guidelines and Best Practices

  • Title of the pull request is clear and informative.
  • There are a small number of commits, each of which have an informative message. This means that previously merged commits do not appear in the history of the PR. For more information on cleaning up the commits in your PR, see this page.

Testing Guidelines

  • Pull request includes test coverage for the included changes.

SDK Generation Guidelines

  • The generate.cmd file for the SDK has been updated with the version of AutoRest, as well as the commitid of your swagger spec or link to the swagger spec, used to generate the code. (Track 2 only)
  • The *.csproj and AssemblyInfo.cs files have been updated with the new version of the SDK. Please double check nuget.org current release version.

Additional management plane SDK specific contribution checklist:

Note: Only applies to Microsoft.Azure.Management.[RP] or Azure.ResourceManager.[RP]

  • Include updated management metadata.
  • Update AzureRP.props to add/remove version info to maintain up to date API versions.

Management plane SDK Troubleshooting

  • If this is very first SDK for a services and you are adding new service folders directly under /SDK, please add new service label and/or contact assigned reviewer.
  • If the check fails at the Verify Code Generation step, please ensure:
    • Do not modify any code in generated folders.
    • Do not selectively include/remove generated files in the PR.
    • Do use generate.ps1/cmd to generate this PR instead of calling autorest directly.
      Please pay attention to the @microsoft.csharp version output after running generate.ps1. If it is lower than current released version (2.3.82), please run it again as it should pull down the latest version,

Old outstanding PR cleanup

Please note:
If PRs (including draft) has been out for more than 60 days and there are no responses from our query or followups, they will be closed to maintain a concise list for our reviewers.

@ghost ghost added Service Bus customer-reported Issues that are reported by GitHub users external to the Azure organization. labels Mar 27, 2021
@ghost
Copy link

ghost commented Mar 27, 2021

Thank you for your contribution @danielmarbach! We will review the pull request and get back to you soon.

@ghost ghost added the Community Contribution Community members are working on the issue label Mar 27, 2021
var (link, maxMessages, maxWaitTime, timeout) = arguments;
return link.BeginReceiveRemoteMessages(
maxMessages,
TimeSpan.FromMilliseconds(20),
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@JoshLove-msft: Is this the potential TimeSpan.Zero change that has been discussed, or is this an unrelated batching timeout?

@jsquire
Copy link
Member

jsquire commented Mar 29, 2021

/azp run net - servicebus - tests

@azure-pipelines
Copy link

Azure Pipelines successfully started running 1 pipeline(s).

Copy link
Member

@jsquire jsquire left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks, @danielmarbach! LGTM; I'll defer to Josh for the final approval and merge.

@JoshLove-msft JoshLove-msft merged commit 3d5a0eb into Azure:master Mar 30, 2021
@danielmarbach danielmarbach deleted the closure-receive branch March 30, 2021 04:46
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Community Contribution Community members are working on the issue customer-reported Issues that are reported by GitHub users external to the Azure organization. Service Bus
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants