Skip to content

Commit c335c99

Browse files
committed
fixup: PR review feedback
1 parent 8d7c6d3 commit c335c99

File tree

6 files changed

+17
-16
lines changed

6 files changed

+17
-16
lines changed

include/qpid/dispatch/tls_common.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,7 @@ void qd_tls_config_register_update_callback(qd_tls_config_t *config, void *updat
155155
*
156156
* @param config The qd_tls_config_t whose callback will be cancelled
157157
*/
158-
void qd_tls_config_cancel_update_callback(qd_tls_config_t *config);
158+
void qd_tls_config_unregister_update_callback(qd_tls_config_t *config);
159159

160160

161161
/**
@@ -200,7 +200,7 @@ int qd_tls_session_get_ssf(const qd_tls_session_t *session);
200200
* @param session to be queried
201201
* @return the value of the sslProfile ordinal associated with this session.
202202
*/
203-
uint64_t qd_tls_session_get_profile_ordinal(const qd_tls_session_t *session);
203+
uint64_t qd_tls_session_get_ssl_profile_ordinal(const qd_tls_session_t *session);
204204

205205
/**
206206
* Fill out the given *profile with the configuration from the named sslProfile record.

src/adaptors/amqp/amqp_adaptor.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1594,7 +1594,7 @@ static void AMQP_opened_handler(qd_router_t *router, qd_connection_t *conn, bool
15941594
(char*) user,
15951595
container,
15961596
props,
1597-
qd_tls_session_get_profile_ordinal(conn->ssl),
1597+
qd_tls_session_get_ssl_profile_ordinal(conn->ssl),
15981598
ssl_ssf,
15991599
!!conn->ssl,
16001600
rversion,

src/adaptors/amqp/qd_connection.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -862,7 +862,7 @@ void qd_amqp_connection_set_tracing(bool enable_tracing)
862862
bool qd_connection_get_tls_ordinal(const qd_connection_t *qd_conn, uint64_t *tls_ordinal)
863863
{
864864
if (qd_conn->ssl) {
865-
*tls_ordinal = qd_tls_session_get_profile_ordinal(qd_conn->ssl);
865+
*tls_ordinal = qd_tls_session_get_ssl_profile_ordinal(qd_conn->ssl);
866866
return true;
867867
}
868868
*tls_ordinal = 0;

src/adaptors/amqp/qd_connector.c

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -580,7 +580,7 @@ void qd_connector_config_delete(qd_connector_config_t *ctor_config)
580580
ct = DEQ_HEAD(ctor_config->connectors);
581581
}
582582

583-
qd_tls_config_cancel_update_callback(ctor_config->tls_config);
583+
qd_tls_config_unregister_update_callback(ctor_config->tls_config);
584584

585585
// drop ref held by the caller
586586
qd_connector_config_decref(ctor_config);

src/router_core/connections.c

Lines changed: 8 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -210,10 +210,6 @@ qdr_connection_info_t *qdr_connection_info(bool is_encrypted,
210210
connection_info->dir = dir;
211211
if (host)
212212
connection_info->host = strdup(host);
213-
if (tls_proto)
214-
connection_info->tls_proto = strdup(tls_proto);
215-
if (tls_cipher)
216-
connection_info->tls_cipher = strdup(tls_cipher);
217213
if (user)
218214
connection_info->user = strdup(user);
219215
if (version)
@@ -224,11 +220,16 @@ qdr_connection_info_t *qdr_connection_info(bool is_encrypted,
224220
pn_data_copy(qdr_conn_properties, connection_properties);
225221

226222
connection_info->connection_properties = qdr_conn_properties;
227-
connection_info->tls_ssf = tls_ssf;
228-
connection_info->tls = tls;
229-
connection_info->tls_ordinal = tls_ordinal;
230223
connection_info->streaming_links = streaming_links;
231224
connection_info->connection_trunking = connection_trunking;
225+
226+
if (tls) {
227+
connection_info->tls = true;
228+
connection_info->tls_ssf = tls_ssf;
229+
connection_info->tls_ordinal = tls_ordinal;
230+
connection_info->tls_proto = !!tls_proto ? strdup(tls_proto) : 0;
231+
connection_info->tls_cipher = !!tls_cipher ? strdup(tls_cipher) : 0;
232+
}
232233
sys_mutex_init(&connection_info->connection_info_lock);
233234
return connection_info;
234235
}

src/tls/tls.c

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -328,7 +328,7 @@ uint64_t qd_tls_config_get_ordinal(const qd_tls_config_t *config)
328328

329329
uint64_t qd_tls_config_get_oldest_valid_ordinal(const qd_tls_config_t *config)
330330
{
331-
// config->oldest_valid_ordinal can only be changed by the management thread . Calling this from any other thread
331+
// config->oldest_valid_ordinal can only be changed by the management thread. Calling this from any other thread
332332
// risks returning a stale value.
333333
ASSERT_MGMT_THREAD;
334334

@@ -348,7 +348,7 @@ void qd_tls_config_register_update_callback(qd_tls_config_t *config, void *updat
348348
}
349349

350350

351-
void qd_tls_config_cancel_update_callback(qd_tls_config_t *config)
351+
void qd_tls_config_unregister_update_callback(qd_tls_config_t *config)
352352
{
353353
// Since this function can only be called on the mgmt thread there is no chance that the handler is being run while
354354
// it is being cancelled.
@@ -636,7 +636,7 @@ int qd_tls_session_get_ssf(const qd_tls_session_t *tls_session)
636636
}
637637

638638

639-
uint64_t qd_tls_session_get_profile_ordinal(const qd_tls_session_t *session)
639+
uint64_t qd_tls_session_get_ssl_profile_ordinal(const qd_tls_session_t *session)
640640
{
641641
if (session)
642642
return session->ordinal;
@@ -845,7 +845,7 @@ static qd_error_t _update_tls_config(qd_tls_config_t *tls_config, const qd_ssl2_
845845
// new sessions while we change pointers.
846846

847847
sys_mutex_lock(&tls_config->lock);
848-
old_cfg = tls_config->proton_tls_cfg;
848+
old_cfg = tls_config->proton_tls_cfg;
849849
tls_config->proton_tls_cfg = new_cfg;
850850

851851
// And refresh any parameters that must be used when creating new sessions:

0 commit comments

Comments
 (0)