summaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorSusan LoVerso <sue@wiredtiger.com>2015-09-15 13:35:11 -0400
committerSusan LoVerso <sue@wiredtiger.com>2015-09-15 13:35:11 -0400
commit366fc17e0bf9d5bad887f14b2c9e40d8fa13c4bd (patch)
tree362556f5e737fb950310f71c7f66cf15c0c4c739 /examples
parent41db2ee37d11b0a885fc883dbcb2a92394e598d1 (diff)
downloadmongo-366fc17e0bf9d5bad887f14b2c9e40d8fa13c4bd.tar.gz
WT-2104 New log_flush API to control the flushing or syncing of the log.
Diffstat (limited to 'examples')
-rw-r--r--examples/c/ex_sync.c21
1 files changed, 21 insertions, 0 deletions
diff --git a/examples/c/ex_sync.c b/examples/c/ex_sync.c
index 46317f3112c..0c293341e74 100644
--- a/examples/c/ex_sync.c
+++ b/examples/c/ex_sync.c
@@ -125,7 +125,28 @@ main(void)
fprintf(stderr,
"Unexpected error %d from WT_SESSION::transaction_sync\n",
ret);
+ /*
+ * Demonstrate using log_flush to force the log to disk.
+ */
+ for (i = 0; i < MAX_KEYS; i++, record_count++) {
+ snprintf(k, sizeof(k), "key%d", record_count);
+ snprintf(v, sizeof(v), "value%d", record_count);
+ cursor->set_key(cursor, k);
+ cursor->set_value(cursor, v);
+ ret = cursor->insert(cursor);
+ }
+ session->log_flush(session, "sync=sync");
+
+ for (i = 0; i < MAX_KEYS; i++, record_count++) {
+ snprintf(k, sizeof(k), "key%d", record_count);
+ snprintf(v, sizeof(v), "value%d", record_count);
+ cursor->set_key(cursor, k);
+ cursor->set_value(cursor, v);
+ ret = cursor->insert(cursor);
+ }
ret = cursor->close(cursor);
+ session->log_flush(session, "sync=write");
+ session->log_flush(session, "sync=sync");
ret = wt_conn->close(wt_conn, NULL);
return (ret);