Skip to content

Commit

Permalink
Comment updates
Browse files Browse the repository at this point in the history
  • Loading branch information
Bret Ambrose committed Jul 25, 2024
1 parent 13faf2f commit 840332a
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -88,7 +88,7 @@ struct aws_mqtt_request_operation_options {
};

/*
* Describes a change to the state of a request operation subscription
* Describes a change to the state of a streaming operation subscription
*/
enum aws_rr_streaming_subscription_event_type {

Expand Down
8 changes: 4 additions & 4 deletions source/request-response/request_response_client.c
Original file line number Diff line number Diff line change
Expand Up @@ -119,18 +119,18 @@ const char *s_aws_acquire_subscription_result_type(enum aws_acquire_subscription
Client Tables/Lookups
(Authoritative operation container)
(operations: authoritative operation container)
1. &operation.id -> &operation // added on in-thread enqueue, removed on operation completion/destruction
(Response path topic -> Correlation token extraction info)
(request_response_paths: response path topic -> Correlation token extraction info)
2. &topic -> &{topic, topic_buffer, correlation token json path buffer} // ref-counted, per-message-path add on
request dequeue into subscribing/subscribed state, decref/removed on operation completion/destruction
(CorrelationToken -> request operation)
(operations_by_correlation_tokens: correlationToken -> request operation)
3. &operation.correlation token -> (request) &operation // added on request dequeue into subscribing/subscribed
state, removed on operation completion/destruction
(Streaming subscription filter -> list of all operations using that filter)
(streaming_operation_subscription_lists: streaming subscription filter -> list of all operations using that filter)
4. &topic_filter -> &{topic_filter, linked_list} // added on request dequeue into subscribing/subscribed state,
removed from list on operation completion/destruction also checked for empty and removed from table
Expand Down

0 comments on commit 840332a

Please sign in to comment.