Skip to content

Commit 99206f8

Browse files
author
Gabor Dozsa
committed
Fixes for listenerAddress entity mgmt calls
1 parent 21c960e commit 99206f8

File tree

4 files changed

+10
-4
lines changed

4 files changed

+10
-4
lines changed

python/skupper_router_internal/dispatch.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ def __init__(self) -> None:
112112
self._prototype(self.qd_dispatch_configure_tcp_listener, c_void_p, [self.qd_dispatch_p, py_object])
113113
self._prototype(self.qd_dispatch_delete_tcp_listener, None, [self.qd_dispatch_p, c_void_p])
114114
self._prototype(self.qd_dispatch_update_tcp_listener, c_void_p, [self.qd_dispatch_p, py_object, c_void_p])
115-
self._prototype(self.qd_dispatch_configure_tcp_listener_address, c_void_p, [self.qd_dispatch_p, py_object, c_void_p])
115+
self._prototype(self.qd_dispatch_configure_tcp_listener_address, c_void_p, [self.qd_dispatch_p, py_object])
116116
self._prototype(self.qd_dispatch_delete_tcp_listener_address, None, [self.qd_dispatch_p, c_void_p])
117117
self._prototype(self.qd_dispatch_configure_listener, c_void_p, [self.qd_dispatch_p, py_object])
118118
self._prototype(self.qd_connection_manager_delete_listener, None, [self.qd_dispatch_p, c_void_p])

python/skupper_router_internal/management/agent.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -472,17 +472,17 @@ def _delete(self):
472472

473473
class ListenerAddressEntity(EntityAdapter):
474474
def create(self):
475-
config_listener_address = self._qd.qd_dispatch_configure_listener_address(self._dispatch, self)
475+
config_listener_address = self._qd.qd_dispatch_configure_tcp_listener_address(self._dispatch, self)
476476
return config_listener_address
477477

478478
def _identifier(self):
479-
return _host_port_name_identifier(self)
479+
return self.name
480480

481481
def __str__(self):
482482
return super(ListenerAddressEntity, self).__str__().replace("Entity(", "ListenerAddressEntity(")
483483

484484
def _delete(self):
485-
self._qd.qd_dispatch_delete_listener_address(self._dispatch, self._implementations[0].key)
485+
self._qd.qd_dispatch_delete_tcp_listener_address(self._dispatch, self._implementations[0].key)
486486

487487

488488
class ConnectorEntity(ConnectionBaseEntity):

src/adaptors/tcp/tcp_adaptor.c

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2521,6 +2521,11 @@ QD_EXPORT void qd_dispatch_delete_tcp_listener_address(qd_dispatch_t *qd, void *
25212521
qd_adaptor_listener_delete_address(qd, impl);
25222522
}
25232523

2524+
QD_EXPORT qd_error_t qd_entity_refresh_listenerAddress(qd_entity_t* entity, void *impl)
2525+
{
2526+
return QD_ERROR_NONE;
2527+
}
2528+
25242529
QD_EXPORT void qd_dispatch_delete_tcp_connector(qd_dispatch_t *qd, void *impl)
25252530
{
25262531
SET_THREAD_UNKNOWN;

src/adaptors/tcp/tcp_adaptor.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -169,6 +169,7 @@ QD_EXPORT void qd_dispatch_delete_tcp_listener(qd_dispatch_t *qd, void *i
169169
QD_EXPORT qd_error_t qd_entity_refresh_tcpListener(qd_entity_t* entity, void *impl);
170170
QD_EXPORT void *qd_dispatch_configure_tcp_listener_address(qd_dispatch_t *qd, qd_entity_t *entity);
171171
QD_EXPORT void qd_dispatch_delete_tcp_connector(qd_dispatch_t *qd, void *impl);
172+
QD_EXPORT qd_error_t qd_entity_refresh_listenerAddress(qd_entity_t *entity, void *impl);
172173
QD_EXPORT qd_error_t qd_entity_refresh_tcpConnector(qd_entity_t* entity, void *impl);
173174
qd_tcp_connector_t *qd_dispatch_configure_tcp_connector(qd_dispatch_t *qd, qd_entity_t *entity);
174175

0 commit comments

Comments
 (0)