* @param[in] conn The specific connection queries will be cancelled on
* @param[in] uctx Context provided to trunk_alloc
*/
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void ldap_request_cancel_mux(UNUSED fr_event_list_t *el, trunk_connection_t *tconn,
connection_t *conn, UNUSED void *uctx)
{
* @param[in] conn on which to send the queries
* @param[in] uctx User context passed to trunk_alloc
*/
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void ldap_trunk_request_mux(UNUSED fr_event_list_t *el, trunk_connection_t *tconn,
connection_t *conn, UNUSED void *uctx)
{
* @param[in] conn Connection handle for these results.
* @param[in] uctx Thread specific trunk structure - contains tree of pending queries.
*/
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void ldap_trunk_request_demux(fr_event_list_t *el, trunk_connection_t *tconn, connection_t *conn, void *uctx)
{
fr_ldap_connection_t *ldap_conn = talloc_get_type_abort(conn->h, fr_ldap_connection_t);
* @param[in] conn on which to send the queries
* @param[in] uctx User context passed to trunk_alloc
*/
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void ldap_trunk_bind_auth_mux(UNUSED fr_event_list_t *el, trunk_connection_t *tconn,
connection_t *conn, void *uctx)
{
* @param[in] conn Connection handle for these results.
* @param[in] uctx Thread specific trunk structure - contains tree of pending queries.
*/
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void ldap_trunk_bind_auth_demux(UNUSED fr_event_list_t *el, UNUSED trunk_connection_t *tconn,
connection_t *conn, void *uctx)
{
* @param[in] conn The specific connection binds will be cancelled on
* @param[in] uctx Context provided to trunk_alloc
*/
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void ldap_bind_auth_cancel_mux(UNUSED fr_event_list_t *el, trunk_connection_t *tconn,
connection_t *conn, UNUSED void *uctx)
{
ERROR("%s - Connection failed: %s", tconn->conn->name, fr_syserror(fd_errno)); \
connection_signal_reconnect(tconn->conn, CONNECTION_FAILED); \
} \
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/ \
static void _name(trunk_connection_t *tconn, connection_t *conn, \
fr_event_list_t *el, trunk_connection_event_t notify_on, UNUSED void *uctx) \
{ \
connection_signal_reconnect(conn, CONNECTION_FAILED);
}
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void thread_conn_notify(trunk_connection_t *tconn, connection_t *conn,
fr_event_list_t *el,
trunk_connection_event_t notify_on, UNUSED void *uctx)
/** A special version of the trunk/event loop glue function which always discards incoming data
*
*/
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void thread_conn_notify_replicate(trunk_connection_t *tconn, connection_t *conn,
fr_event_list_t *el,
trunk_connection_event_t notify_on, UNUSED void *uctx)
trunk_connection_signal_reconnect(tconn, CONNECTION_FAILED);
}
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void request_mux(fr_event_list_t *el,
trunk_connection_t *tconn, connection_t *conn, UNUSED void *uctx)
{
for (i = sent; i < queued; i++) trunk_request_requeue(h->coalesced[i].treq);
}
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void request_mux_replicate(UNUSED fr_event_list_t *el,
trunk_connection_t *tconn, connection_t *conn, UNUSED void *uctx)
{
trunk_connection_signal_active(treq->tconn);
}
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void request_demux(UNUSED fr_event_list_t *el, trunk_connection_t *tconn, connection_t *conn, UNUSED void *uctx)
{
udp_handle_t *h = talloc_get_type_abort(conn->h, udp_handle_t);
TRUNK_NOTIFY_FUNC(sql_trunk_connection_notify, rlm_sql_mysql_conn_t)
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void sql_trunk_request_mux(UNUSED fr_event_list_t *el, trunk_connection_t *tconn,
connection_t *conn, UNUSED void *uctx)
{
if (request) unlang_interpret_mark_runnable(request);
}
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void sql_trunk_request_demux(UNUSED fr_event_list_t *el, UNUSED trunk_connection_t *tconn,
connection_t *conn, UNUSED void *uctx)
{
query_ctx->rcode = RLM_SQL_OK;
}
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void sql_request_cancel(connection_t *conn, void *preq, trunk_cancel_reason_t reason,
UNUSED void *uctx)
{
if (sql_conn->query_ctx == query_ctx) sql_conn->query_ctx = NULL;
}
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void sql_request_cancel_mux(UNUSED fr_event_list_t *el, trunk_connection_t *tconn,
connection_t *conn, UNUSED void *uctx)
{
TRUNK_NOTIFY_FUNC(sql_trunk_connection_notify, rlm_sql_postgres_conn_t)
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void sql_trunk_request_mux(UNUSED fr_event_list_t *el, trunk_connection_t *tconn,
connection_t *conn, UNUSED void *uctx)
{
}
}
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void sql_trunk_request_demux(UNUSED fr_event_list_t *el, UNUSED trunk_connection_t *tconn,
connection_t *conn, UNUSED void *uctx)
{
if (request) unlang_interpret_mark_runnable(request);
}
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void sql_request_cancel(connection_t *conn, void *preq, trunk_cancel_reason_t reason,
UNUSED void *uctx)
{
if (sql_conn->query_ctx == query_ctx) sql_conn->query_ctx = NULL;
}
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void sql_request_cancel_mux(UNUSED fr_event_list_t *el, trunk_connection_t *tconn,
connection_t *conn, UNUSED void *uctx)
{
connection_signal_reconnect(conn, CONNECTION_FAILED);
}
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void thread_conn_notify(trunk_connection_t *tconn, connection_t *conn,
fr_event_list_t *el,
trunk_connection_event_t notify_on, UNUSED void *uctx)
check_for_zombie(el, tconn, now, u->retry.start);
}
+CC_NO_UBSAN(function) /* UBSAN: false positive - public vs private connection_t trips --fsanitize=function*/
static void request_mux(fr_event_list_t *el,
trunk_connection_t *tconn, connection_t *conn, UNUSED void *uctx)
{