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 D | datadog.c | 301 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 D | repmgrd-physical.c | 85 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 D | repmgr-action-standby.c | 1087 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 D | repmgr-action-node.c | 1458 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 D | repmgr-client.c | 2353 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()
|