| /dports/databases/slony1v2/slony1-2.2.10/src/slon/ |
| H A D | monitor_thread.c | 156 slon_appendquery(&monquery, "%d, ", state.conn_pid); in monitorThread_main()
160 slon_appendquery(&monquery, "NULL::integer, "); in monitorThread_main()
164 slon_appendquery(&monquery, "'%s', ", state.activity); in monitorThread_main()
168 slon_appendquery(&monquery, "NULL::text, "); in monitorThread_main()
170 …slon_appendquery(&monquery, "'1970-01-01 0:0:0 UTC'::timestamptz + '%d seconds'::interval, ", time… in monitorThread_main()
173 slon_appendquery(&monquery, "%L, ", state.event); in monitorThread_main()
177 slon_appendquery(&monquery, "NULL::bigint, "); in monitorThread_main()
181 slon_appendquery(&monquery, "'%s');", state.event_type); in monitorThread_main()
185 slon_appendquery(&monquery, "NULL::text);"); in monitorThread_main()
|
| H A D | remote_worker.c | 736 slon_appendquery(&query1, in remoteWorkerThread_main()
750 slon_appendquery(&query1, in remoteWorkerThread_main()
808 slon_appendquery(&query1, in remoteWorkerThread_main()
823 slon_appendquery(&query1, in remoteWorkerThread_main()
861 slon_appendquery(&query1, in remoteWorkerThread_main()
878 slon_appendquery(&query1, in remoteWorkerThread_main()
896 slon_appendquery(&query1, in remoteWorkerThread_main()
2233 slon_appendquery(dsp, in query_append_event()
2254 slon_appendquery(dsp, in query_append_event()
2275 slon_appendquery(dsp, in query_append_event()
[all …]
|
| H A D | remote_listen.c | 670 slon_appendquery(&query, in remoteListen_receive_events()
679 slon_appendquery(&query, ")"); in remoteListen_receive_events()
686 slon_appendquery(&query, " order by e.ev_origin, e.ev_seqno limit %d", in remoteListen_receive_events()
|
| H A D | dbutils.c | 516 slon_appendquery(SlonDString * dsp, char *fmt,...) in slon_appendquery() function
|
| H A D | slon.h | 615 extern void slon_appendquery(SlonDString * ds, char *fmt,...);
|
| /dports/databases/slony1v2/slony1-2.2.10/src/slony_logshipper/ |
| H A D | slony_logshipper.c | 694 slon_appendquery(&ds, "%s%s", glue, elem->attname); in process_insert()
697 slon_appendquery(&ds, ") values "); in process_insert()
702 slon_appendquery(&ds, "%sNULL", glue); in process_insert()
738 slon_appendquery(&ds, "%s %s=NULL", glue, in process_update()
741 slon_appendquery(&ds, "%s %s='%s'", glue, in process_update()
749 slon_appendquery(&ds, "%s %s IS NULL", glue, in process_update()
752 slon_appendquery(&ds, "%s %s='%s'", glue, in process_update()
789 slon_appendquery(&ds, "%s %s IS NULL", glue, in process_delete()
792 slon_appendquery(&ds, "%s %s='%s'", glue, in process_delete()
854 slon_appendquery(&ds, "%s%s", glue, elem->attname); in process_copy()
[all …]
|
| H A D | dbutil.c | 70 slon_appendquery(SlonDString * dsp, char *fmt,...) in slon_appendquery() function
|
| H A D | slony_logshipper.h | 222 int slon_appendquery(SlonDString * dsp, char *fmt,...);
|
| /dports/databases/slony1v2/slony1-2.2.10/src/slonik/ |
| H A D | slonik.c | 2401 slon_appendquery(&query, in slonik_store_node()
2551 slon_appendquery(&query, in slonik_store_node()
2596 slon_appendquery(&query, in slonik_store_node()
2833 slon_appendquery(&failed_node_list, "%d", node_entry->no_id); in slonik_failed_node()
5289 slon_appendquery(&ignore_condition, in slonik_wait_event()
5292 slon_appendquery(&ignore_condition, in slonik_wait_event()
5296 slon_appendquery(&ignore_condition, ")"); in slonik_wait_event()
5298 slon_appendquery(&ignore_condition, ""); in slonik_wait_event()
6160 slon_appendquery(&event_list, in slonik_wait_config_caughtup()
6166 slon_appendquery(&node_list, "%s (%d) ", in slonik_wait_config_caughtup()
[all …]
|
| H A D | slonik.h | 636 int slon_appendquery(SlonDString * dsp, char *fmt,...);
|
| H A D | dbutil.c | 724 slon_appendquery(SlonDString * dsp, char *fmt,...) in slon_appendquery() function
|