Skip to content

Conversation

@yunhaoling
Copy link
Contributor

Lazy parse message

@yunhaoling
Copy link
Contributor Author

yunhaoling commented Oct 1, 2019

@annatisch Another PR in eventhub:Azure/azure-sdk-for-python#7533 to see the whole picture.

} SOCKETIO_CONFIG;

#define RECEIVE_BYTES_VALUE 64
#define RECEIVE_BYTES_VALUE 1024

Choose a reason for hiding this comment

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

We've diverged from the C-uamqp source code. If someday we copy the new C-uamqp code again, we need to keep these changes. Suggest we keep these changes on records together with the vendored c code.

@yunhaoling yunhaoling marked this pull request as ready for review October 2, 2019 00:25
@yunhaoling yunhaoling requested a review from annatisch October 2, 2019 00:25
Copy link
Member

@annatisch annatisch left a comment

Choose a reason for hiding this comment

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

Just a couple more things :)

@yunhaoling yunhaoling requested a review from annatisch October 2, 2019 18:08
Copy link
Member

@annatisch annatisch left a comment

Choose a reason for hiding this comment

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

LGTM

@yunhaoling yunhaoling merged commit c01e66a into Azure:v1.2.3 Oct 2, 2019
yunhaoling added a commit that referenced this pull request Oct 5, 2019
* Runtime metric (#95)

* Init commit for desired compatibility

* runtime metric init commit

* Small fix of runtime receiver metric

* Fix pylint error

* Update according to review

* update link destroy

* Remove offered capabilities for now

* add sample/test code

* Update test

* Share CBS Session (#89)

* Share CBS Session (#88)

* initial _received_messages object

* Use flag to control the streaming behavior

* Update comments and code

* release_async isn't a sync function

* Add missing module

* Wait too short cause the receive client to close so that the test would fail

* Remove unnecessary queue assignment

* remove unused import module

* Update timeout as the unit is milliseconds

* Update for 1.2.3 (#91)

* review update (#97)

* Service Bus message transfer fixes (#96)

* Support message delivery tag

* Added headers

* Removed null init

* Added memory cleanup

* Fix build error

* Moved delivery tag to message

* Cython fixes

* Binary type

* Attempt to set message tag

* Converted to AMQP_VALUE

* Syntax fixes

* Build error

* Renamed value

* Get tag type

* Fixed name

* Extract tag bytes

* Some C cleanup

* More logging

* Updated test

* pylint fix

* More logging

* More logging

* More logging

* Fixed print formatting

* More logging

* Syntax error

* TLSIO logging

* Log socket error

* Added sleep

* Fixed sleep

* Reduced sleep

* Another attempt

* Ping CI

* Attempt to move outgoing flow

* Moved send flow frame

* Removed debug logging

* Update link status

* Fix diff

* pylint fixes

* Py2.7

* Updated status description

* Fixed executor

* Some review feedback

* Performance improvement (#98)

* Remove deepcopy and increase buffer size

* Move parse into cython

* Small fix

* lazy parse

* small fix

* Update name

* Update message property

* remove unused import

* put deepcopy back as it influences the performance little

* Add footer setter

* Update setters of message

* fix bug in batch message (#99)

* Bug fix, properties of message can be None type (#100)

* on_transfer_received should not fail due to lack of a delivery tag (#101)

* on_transfer_received should not fail due to lack of a delivery tag

* Test reversing if-statements

* Try initialize value

* Trying to make Windows happy

* Fix proxy test (#104)

* Update docs (#103)

* Update docs

* fix typo

* More typo
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants