diff options
Diffstat (limited to 'src/third_party/wiredtiger/src/txn/txn_ext.c')
| -rw-r--r-- | src/third_party/wiredtiger/src/txn/txn_ext.c | 91 |
1 files changed, 42 insertions, 49 deletions
diff --git a/src/third_party/wiredtiger/src/txn/txn_ext.c b/src/third_party/wiredtiger/src/txn/txn_ext.c index 1f42ab5eb43..43d9c380eb5 100644 --- a/src/third_party/wiredtiger/src/txn/txn_ext.c +++ b/src/third_party/wiredtiger/src/txn/txn_ext.c @@ -10,97 +10,90 @@ /* * __wt_ext_transaction_id -- - * Return the session's transaction ID. + * Return the session's transaction ID. */ uint64_t __wt_ext_transaction_id(WT_EXTENSION_API *wt_api, WT_SESSION *wt_session) { - WT_SESSION_IMPL *session; + WT_SESSION_IMPL *session; - (void)wt_api; /* Unused parameters */ - session = (WT_SESSION_IMPL *)wt_session; - /* Ignore failures: the only case is running out of transaction IDs. */ - WT_IGNORE_RET(__wt_txn_id_check(session)); - return (session->txn.id); + (void)wt_api; /* Unused parameters */ + session = (WT_SESSION_IMPL *)wt_session; + /* Ignore failures: the only case is running out of transaction IDs. */ + WT_IGNORE_RET(__wt_txn_id_check(session)); + return (session->txn.id); } /* * __wt_ext_transaction_isolation_level -- - * Return if the current transaction's isolation level. + * Return if the current transaction's isolation level. */ int -__wt_ext_transaction_isolation_level( - WT_EXTENSION_API *wt_api, WT_SESSION *wt_session) +__wt_ext_transaction_isolation_level(WT_EXTENSION_API *wt_api, WT_SESSION *wt_session) { - WT_SESSION_IMPL *session; - WT_TXN *txn; + WT_SESSION_IMPL *session; + WT_TXN *txn; - (void)wt_api; /* Unused parameters */ + (void)wt_api; /* Unused parameters */ - session = (WT_SESSION_IMPL *)wt_session; - txn = &session->txn; + session = (WT_SESSION_IMPL *)wt_session; + txn = &session->txn; - if (txn->isolation == WT_ISO_READ_COMMITTED) - return (WT_TXN_ISO_READ_COMMITTED); - if (txn->isolation == WT_ISO_READ_UNCOMMITTED) - return (WT_TXN_ISO_READ_UNCOMMITTED); - return (WT_TXN_ISO_SNAPSHOT); + if (txn->isolation == WT_ISO_READ_COMMITTED) + return (WT_TXN_ISO_READ_COMMITTED); + if (txn->isolation == WT_ISO_READ_UNCOMMITTED) + return (WT_TXN_ISO_READ_UNCOMMITTED); + return (WT_TXN_ISO_SNAPSHOT); } /* * __wt_ext_transaction_notify -- - * Request notification of transaction resolution. + * Request notification of transaction resolution. */ int -__wt_ext_transaction_notify( - WT_EXTENSION_API *wt_api, WT_SESSION *wt_session, WT_TXN_NOTIFY *notify) +__wt_ext_transaction_notify(WT_EXTENSION_API *wt_api, WT_SESSION *wt_session, WT_TXN_NOTIFY *notify) { - WT_SESSION_IMPL *session; - WT_TXN *txn; + WT_SESSION_IMPL *session; + WT_TXN *txn; - (void)wt_api; /* Unused parameters */ + (void)wt_api; /* Unused parameters */ - session = (WT_SESSION_IMPL *)wt_session; - txn = &session->txn; + session = (WT_SESSION_IMPL *)wt_session; + txn = &session->txn; - /* - * XXX - * For now, a single slot for notifications: I'm not bothering with - * more than one because more than one data-source in a transaction - * doesn't work anyway. - */ - if (txn->notify == notify) - return (0); - if (txn->notify != NULL) - WT_RET_MSG( - session, WT_ERROR, "transaction notify already scheduled"); + /* + * XXX For now, a single slot for notifications: I'm not bothering with more than one because + * more than one data-source in a transaction doesn't work anyway. + */ + if (txn->notify == notify) + return (0); + if (txn->notify != NULL) + WT_RET_MSG(session, WT_ERROR, "transaction notify already scheduled"); - txn->notify = notify; + txn->notify = notify; - return (0); + return (0); } /* * __wt_ext_transaction_oldest -- - * Return the oldest transaction ID not yet visible to a running - * transaction. + * Return the oldest transaction ID not yet visible to a running transaction. */ uint64_t __wt_ext_transaction_oldest(WT_EXTENSION_API *wt_api) { - return (((WT_CONNECTION_IMPL *)wt_api->conn)->txn_global.oldest_id); + return (((WT_CONNECTION_IMPL *)wt_api->conn)->txn_global.oldest_id); } /* * __wt_ext_transaction_visible -- - * Return if the current transaction can see the given transaction ID. + * Return if the current transaction can see the given transaction ID. */ int __wt_ext_transaction_visible( - WT_EXTENSION_API *wt_api, WT_SESSION *wt_session, uint64_t transaction_id) + WT_EXTENSION_API *wt_api, WT_SESSION *wt_session, uint64_t transaction_id) { - (void)wt_api; /* Unused parameters */ + (void)wt_api; /* Unused parameters */ - return (__wt_txn_visible( - (WT_SESSION_IMPL *)wt_session, transaction_id, WT_TS_NONE)); + return (__wt_txn_visible((WT_SESSION_IMPL *)wt_session, transaction_id, WT_TS_NONE)); } |