Fri Dec 3 17:16:06 PST 2004
- Previous message: [Slony1-commit] By wieck: Changed so that subscribeSet() is called on the data provider
- Next message: [Slony1-commit] By cbbrowne: Added in node_is_subscribing() function to make watchdog
- Messages sorted by: [ date ] [ thread ] [ subject ] [ author ]
Log Message:
-----------
Create confirm records for all old events when slonik creates
a spool node.
Jan
Modified Files:
--------------
slony1-engine/src/slonik:
slonik.c (r1.36 -> r1.37)
-------------- next part --------------
Index: slonik.c
===================================================================
RCS file: /usr/local/cvsroot/slony1/slony1-engine/src/slonik/slonik.c,v
retrieving revision 1.36
retrieving revision 1.37
diff -Lsrc/slonik/slonik.c -Lsrc/slonik/slonik.c -u -w -r1.36 -r1.37
--- src/slonik/slonik.c
+++ src/slonik/slonik.c
@@ -2291,6 +2291,24 @@
return -1;
}
+ /* If the new node is a spool node, produce confirm rows for it */
+ if (stmt->no_spool)
+ {
+ slon_mkquery(&query,
+ "insert into \"_%s\".sl_confirm select "
+ " ev_origin, %d, max(ev_seqno), CURRENT_TIMESTAMP "
+ " from \"_%s\".sl_event group by 1, 2, 4; ",
+ stmt->hdr.script->clustername,
+ stmt->no_id,
+ stmt->hdr.script->clustername);
+
+ if (db_exec_command((SlonikStmt *)stmt, adminfo2, &query) < 0)
+ {
+ dstring_free(&query);
+ return -1;
+ }
+ }
+
dstring_free(&query);
return 0;
}
- Previous message: [Slony1-commit] By wieck: Changed so that subscribeSet() is called on the data provider
- Next message: [Slony1-commit] By cbbrowne: Added in node_is_subscribing() function to make watchdog
- Messages sorted by: [ date ] [ thread ] [ subject ] [ author ]
More information about the Slony1-commit mailing list