A small memory footprint AMQP implimentation
Dependents: iothub_client_sample_amqp remote_monitoring simplesample_amqp
Diff: connection.c
- Revision:
- 15:5db103709f20
- Parent:
- 14:0b0e28c75ded
- Child:
- 16:22a72cf8e416
diff -r 0b0e28c75ded -r 5db103709f20 connection.c --- a/connection.c Wed Dec 14 16:00:07 2016 -0800 +++ b/connection.c Sun Jan 08 11:12:13 2017 -0800 @@ -22,7 +22,7 @@ /* Codes_SRS_CONNECTION_01_088: [Any data appearing beyond the protocol header MUST match the version indicated by the protocol header.] */ /* Codes_SRS_CONNECTION_01_015: [Implementations SHOULD NOT expect to be able to reuse open TCP sockets after close performatives have been exchanged.] */ -/* Codes_SRS_CONNECTION_01_087: [The protocol header consists of the upper case ASCII letters AMQP followed by a protocol id of zero, followed by three unsigned bytes representing the major, minor, and revision of the protocol version (currently 1 (MAJOR), 0 (MINOR), 0 (REVISION)). In total this is an 8-octet sequence] */ +/* Codes_SRS_CONNECTION_01_087: [The protocol header consists of the upper case ASCII letters âAMQPâ followed by a protocol id of zero, followed by three unsigned bytes representing the major, minor, and revision of the protocol version (currently 1 (MAJOR), 0 (MINOR), 0 (REVISION)). In total this is an 8-octet sequence] */ static const unsigned char amqp_header[] = { 'A', 'M', 'Q', 'P', 0, 1, 0, 0 }; typedef enum RECEIVE_FRAME_STATE_TAG @@ -94,7 +94,7 @@ connection_instance->on_connection_state_changed(connection_instance->on_connection_state_changed_callback_context, connection_state, previous_state); } - /* Codes_SRS_CONNECTION_01_260: [Each endpoints on_connection_state_changed shall be called.] */ + /* Codes_SRS_CONNECTION_01_260: [Each endpointâs on_connection_state_changed shall be called.] */ for (i = 0; i < connection_instance->endpoint_count; i++) { /* Codes_SRS_CONNECTION_01_259: [The callback_context passed in connection_create_endpoint.] */ @@ -106,7 +106,7 @@ { int result; - /* Codes_SRS_CONNECTION_01_093: [_ When the client opens a new socket connection to a server, it MUST send a protocol header with the clients preferred protocol version.] */ + /* Codes_SRS_CONNECTION_01_093: [_ When the client opens a new socket connection to a server, it MUST send a protocol header with the clientâs preferred protocol version.] */ /* Codes_SRS_CONNECTION_01_104: [Sending the protocol header shall be done by using xio_send.] */ if (xio_send(connection_instance->io, amqp_header, sizeof(amqp_header), NULL, NULL) != 0) { @@ -421,7 +421,7 @@ { /* Codes_SRS_CONNECTION_01_213: [When passing the bytes to frame_codec fails, a CLOSE frame shall be sent and the state shall be set to DISCARDING.] */ /* Codes_SRS_CONNECTION_01_055: [DISCARDING The DISCARDING state is a variant of the CLOSE SENT state where the close is triggered by an error.] */ - /* Codes_SRS_CONNECTION_01_010: [After writing this frame the peer SHOULD continue to read from the connection until it receives the partners close frame ] */ + /* Codes_SRS_CONNECTION_01_010: [After writing this frame the peer SHOULD continue to read from the connection until it receives the partnerâs close frame ] */ connection_set_state(connection_instance, CONNECTION_STATE_DISCARDING); }