diff options
author | Susan LoVerso <sue@wiredtiger.com> | 2015-09-15 13:35:11 -0400 |
---|---|---|
committer | Susan LoVerso <sue@wiredtiger.com> | 2015-09-15 13:35:11 -0400 |
commit | 366fc17e0bf9d5bad887f14b2c9e40d8fa13c4bd (patch) | |
tree | 362556f5e737fb950310f71c7f66cf15c0c4c739 /examples | |
parent | 41db2ee37d11b0a885fc883dbcb2a92394e598d1 (diff) | |
download | mongo-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.c | 21 |
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); |