Home
last modified time | relevance | path

Searched refs:upstream_conn (Results 1 – 5 of 5) sorted by relevance

/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_datadog/
H A Ddatadog.c301 struct flb_upstream_conn *upstream_conn; in cb_datadog_flush() local
314 upstream_conn = flb_upstream_conn_get(ctx->upstream); in cb_datadog_flush()
315 if (!upstream_conn) { in cb_datadog_flush()
326 flb_upstream_conn_release(upstream_conn); in cb_datadog_flush()
348 client = flb_http_client(upstream_conn, FLB_HTTP_POST, ctx->uri, in cb_datadog_flush()
353 flb_upstream_conn_release(upstream_conn); in cb_datadog_flush()
407 flb_upstream_conn_release(upstream_conn); in cb_datadog_flush()
/dports/databases/postgresql-repmgr/repmgr-5.2.0/
H A Drepmgrd-physical.c85 static PGconn *upstream_conn = NULL; variable
1354 close_connection(&upstream_conn); in monitor_streaming_standby()
1366 close_connection(&upstream_conn); in monitor_streaming_standby()
1404 primary_conn = upstream_conn; in monitor_streaming_standby()
1584 primary_conn = upstream_conn; in monitor_streaming_standby()
1757 primary_conn = upstream_conn; in monitor_streaming_standby()
2225 close_connection(&upstream_conn); in monitor_streaming_standby()
3278 close_connection(&upstream_conn); in do_upstream_standby_failover()
3625 close_connection(&upstream_conn); in promote_self()
3857 close_connection(&upstream_conn); in follow_new_primary()
[all …]
H A Drepmgr-action-standby.c1087 PGconn *upstream_conn = NULL; in _do_create_replication_conf() local
1282 PQfinish(upstream_conn); in _do_create_replication_conf()
1313 PQfinish(upstream_conn); in _do_create_replication_conf()
1348 PQfinish(upstream_conn); in _do_create_replication_conf()
1500 PQfinish(upstream_conn); in _do_create_replication_conf()
1516 PQfinish(upstream_conn); in _do_create_replication_conf()
1843 PGconn *upstream_conn = NULL; in do_standby_register() local
1892 PQfinish(upstream_conn); in do_standby_register()
6827 PGconn *upstream_conn = NULL; in run_basebackup() local
6883 PQfinish(upstream_conn); in run_basebackup()
[all …]
H A Drepmgr-action-node.c1458 PGconn *upstream_conn = NULL; in do_node_check_upstream() local
1497 upstream_conn = establish_db_connection(upstream_node_info.conninfo, true); in do_node_check_upstream()
1500 …if (is_downstream_node_attached(upstream_conn, config_file_options.node_name, NULL) != NODE_ATTACH… in do_node_check_upstream()
2490 PGconn *upstream_conn = NULL; in do_node_rejoin() local
2605 upstream_conn = establish_db_connection_by_params(&source_conninfo, true); in do_node_rejoin()
2607 if (get_primary_node_record(upstream_conn, &primary_node_record) == false) in do_node_rejoin()
2611 PQfinish(upstream_conn); in do_node_rejoin()
2620 RecoveryType upstream_recovery_type = get_recovery_type(upstream_conn); in do_node_rejoin()
2638 PQfinish(upstream_conn); in do_node_rejoin()
2642 PQfinish(upstream_conn); in do_node_rejoin()
H A Drepmgr-client.c2353 PGconn *upstream_conn = establish_db_connection_quiet(upstream_node_rec.conninfo); in format_node_status() local
2355 if (PQstatus(upstream_conn) != CONNECTION_OK) in format_node_status()
2366 PQfinish(upstream_conn); in format_node_status()
2398 PGconn *upstream_conn = establish_db_connection_quiet(upstream_node_rec.conninfo); in format_node_status() local
2400 if (PQstatus(upstream_conn) != CONNECTION_OK) in format_node_status()
2411 …attached_to_upstream = is_downstream_node_attached(upstream_conn, node_info->node_name, &replicati… in format_node_status()
2414 PQfinish(upstream_conn); in format_node_status()
4003 check_standby_join(PGconn *upstream_conn, t_node_info *upstream_node_record, t_node_info *standby_n… in check_standby_join() argument
4048 NodeAttached node_attached = is_downstream_node_attached(upstream_conn, in check_standby_join()