| /dports/net/mDNSResponder/mDNSResponder-1310.140.1/ServiceRegistration/ |
| H A D | towire.c | 142 status = dns_parse_label(cur, &next, txn->p, txn->p + 1, txn->lim - txn->p - 1); in dns_name_to_wire_()
156 txn->p = txn->p + *txn->p + 1; in dns_name_to_wire_()
215 if (txn->p + 2 >= txn->lim) { in dns_pointer_to_wire_()
239 if (txn->p + 1 >= txn->lim) { in dns_u8_to_wire_()
254 if (txn->p + 2 >= txn->lim) { in dns_u16_to_wire_()
269 if (txn->p + 4 >= txn->lim) { in dns_u32_to_wire_()
294 if (txn->p + 2 >= txn->lim) { in dns_rdlength_begin_()
305 txn->p_rdlength = txn->p; in dns_rdlength_begin_()
332 if (txn->p + 4 >= txn->lim) { in dns_rdata_a_to_wire_()
453 if (txn->p + 9 >= txn->lim) { in dns_edns0_header_to_wire_()
[all …]
|
| /dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/tokudb/PerconaFT/ft/txn/ |
| H A D | txn.cc | 134 TOKUTXN txn; in toku_txn_begin_with_xid() local
350 TOKUTXN txn; member
402 …txn->do_fsync = !txn->parent && (txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_roll… in toku_txn_commit_with_lsn()
408 toku_log_xcommit(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_commit_with_lsn()
472 toku_log_xabort(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_abort_with_lsn()
492 if (txn->parent || toku_txn_is_read_only(txn)) { in toku_txn_prepare_txn()
506 txn->do_fsync = txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_rollentries>0); in toku_txn_prepare_txn()
509 toku_log_xprepare(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid, xa_xid); in toku_txn_prepare_txn()
554 txn->open_fts.iterate<struct tokutxn, remove_txn>(txn); in note_txn_closing()
565 txn, in toku_txn_complete_txn()
[all …]
|
| H A D | rollback-apply.cc | 43 if (txn->progress_poll_fun) { in poll_txn_progress_function()
49 txn->progress_poll_fun(&progress, txn->progress_poll_fun_extra); in poll_txn_progress_function()
142 txn, in apply_txn()
157 if (txn->parent!=0) { in toku_rollback_commit()
165 toku_logger_save_rollback_rollinclude(txn->parent, txn->txnid, num_nodes, in toku_rollback_commit()
183 toku_get_and_pin_rollback_log(txn, txn->roll_info.current_rollback, &child_log); in toku_rollback_commit()
213 txn, in toku_rollback_commit()
228 r = txn->open_fts.iterate<struct tokutxn, note_ft_used_in_txns_parent>(txn); in toku_rollback_commit()
233 toku_txn_lock(txn->parent); in toku_rollback_commit()
234 txn->parent->force_fsync_on_commit |= txn->force_fsync_on_commit; in toku_rollback_commit()
[all …]
|
| /dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/tokudb/PerconaFT/ft/txn/ |
| H A D | txn.cc | 134 TOKUTXN txn; in toku_txn_begin_with_xid() local
350 TOKUTXN txn; member
402 …txn->do_fsync = !txn->parent && (txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_roll… in toku_txn_commit_with_lsn()
408 toku_log_xcommit(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_commit_with_lsn()
472 toku_log_xabort(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_abort_with_lsn()
492 if (txn->parent || toku_txn_is_read_only(txn)) { in toku_txn_prepare_txn()
506 txn->do_fsync = txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_rollentries>0); in toku_txn_prepare_txn()
509 toku_log_xprepare(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid, xa_xid); in toku_txn_prepare_txn()
554 txn->open_fts.iterate<struct tokutxn, remove_txn>(txn); in note_txn_closing()
565 txn, in toku_txn_complete_txn()
[all …]
|
| H A D | rollback-apply.cc | 43 if (txn->progress_poll_fun) { in poll_txn_progress_function()
49 txn->progress_poll_fun(&progress, txn->progress_poll_fun_extra); in poll_txn_progress_function()
142 txn, in apply_txn()
157 if (txn->parent!=0) { in toku_rollback_commit()
165 toku_logger_save_rollback_rollinclude(txn->parent, txn->txnid, num_nodes, in toku_rollback_commit()
183 toku_get_and_pin_rollback_log(txn, txn->roll_info.current_rollback, &child_log); in toku_rollback_commit()
213 txn, in toku_rollback_commit()
228 r = txn->open_fts.iterate<struct tokutxn, note_ft_used_in_txns_parent>(txn); in toku_rollback_commit()
233 toku_txn_lock(txn->parent); in toku_rollback_commit()
234 txn->parent->force_fsync_on_commit |= txn->force_fsync_on_commit; in toku_rollback_commit()
[all …]
|
| /dports/databases/percona57-server/percona-server-5.7.36-39/storage/tokudb/PerconaFT/ft/txn/ |
| H A D | txn.cc | 134 TOKUTXN txn; in toku_txn_begin_with_xid() local
350 TOKUTXN txn; member
402 …txn->do_fsync = !txn->parent && (txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_roll… in toku_txn_commit_with_lsn()
408 toku_log_xcommit(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_commit_with_lsn()
472 toku_log_xabort(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_abort_with_lsn()
492 if (txn->parent || toku_txn_is_read_only(txn)) { in toku_txn_prepare_txn()
506 txn->do_fsync = txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_rollentries>0); in toku_txn_prepare_txn()
509 toku_log_xprepare(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid, xa_xid); in toku_txn_prepare_txn()
554 txn->open_fts.iterate<struct tokutxn, remove_txn>(txn); in note_txn_closing()
565 txn, in toku_txn_complete_txn()
[all …]
|
| H A D | rollback-apply.cc | 43 if (txn->progress_poll_fun) { in poll_txn_progress_function()
49 txn->progress_poll_fun(&progress, txn->progress_poll_fun_extra); in poll_txn_progress_function()
142 txn, in apply_txn()
157 if (txn->parent!=0) { in toku_rollback_commit()
165 toku_logger_save_rollback_rollinclude(txn->parent, txn->txnid, num_nodes, in toku_rollback_commit()
183 toku_get_and_pin_rollback_log(txn, txn->roll_info.current_rollback, &child_log); in toku_rollback_commit()
213 txn, in toku_rollback_commit()
228 r = txn->open_fts.iterate<struct tokutxn, note_ft_used_in_txns_parent>(txn); in toku_rollback_commit()
233 toku_txn_lock(txn->parent); in toku_rollback_commit()
234 txn->parent->force_fsync_on_commit |= txn->force_fsync_on_commit; in toku_rollback_commit()
[all …]
|
| /dports/databases/percona57-client/percona-server-5.7.36-39/storage/tokudb/PerconaFT/ft/txn/ |
| H A D | txn.cc | 134 TOKUTXN txn; in toku_txn_begin_with_xid() local
350 TOKUTXN txn; member
402 …txn->do_fsync = !txn->parent && (txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_roll… in toku_txn_commit_with_lsn()
408 toku_log_xcommit(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_commit_with_lsn()
472 toku_log_xabort(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_abort_with_lsn()
492 if (txn->parent || toku_txn_is_read_only(txn)) { in toku_txn_prepare_txn()
506 txn->do_fsync = txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_rollentries>0); in toku_txn_prepare_txn()
509 toku_log_xprepare(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid, xa_xid); in toku_txn_prepare_txn()
554 txn->open_fts.iterate<struct tokutxn, remove_txn>(txn); in note_txn_closing()
565 txn, in toku_txn_complete_txn()
[all …]
|
| H A D | rollback-apply.cc | 43 if (txn->progress_poll_fun) { in poll_txn_progress_function()
49 txn->progress_poll_fun(&progress, txn->progress_poll_fun_extra); in poll_txn_progress_function()
142 txn, in apply_txn()
157 if (txn->parent!=0) { in toku_rollback_commit()
165 toku_logger_save_rollback_rollinclude(txn->parent, txn->txnid, num_nodes, in toku_rollback_commit()
183 toku_get_and_pin_rollback_log(txn, txn->roll_info.current_rollback, &child_log); in toku_rollback_commit()
213 txn, in toku_rollback_commit()
228 r = txn->open_fts.iterate<struct tokutxn, note_ft_used_in_txns_parent>(txn); in toku_rollback_commit()
233 toku_txn_lock(txn->parent); in toku_rollback_commit()
234 txn->parent->force_fsync_on_commit |= txn->force_fsync_on_commit; in toku_rollback_commit()
[all …]
|
| /dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/tokudb/PerconaFT/ft/txn/ |
| H A D | txn.cc | 134 TOKUTXN txn; in toku_txn_begin_with_xid() local
350 TOKUTXN txn; member
402 …txn->do_fsync = !txn->parent && (txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_roll… in toku_txn_commit_with_lsn()
408 toku_log_xcommit(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_commit_with_lsn()
472 toku_log_xabort(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_abort_with_lsn()
492 if (txn->parent || toku_txn_is_read_only(txn)) { in toku_txn_prepare_txn()
506 txn->do_fsync = txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_rollentries>0); in toku_txn_prepare_txn()
509 toku_log_xprepare(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid, xa_xid); in toku_txn_prepare_txn()
554 txn->open_fts.iterate<struct tokutxn, remove_txn>(txn); in note_txn_closing()
565 txn, in toku_txn_complete_txn()
[all …]
|
| H A D | rollback-apply.cc | 43 if (txn->progress_poll_fun) { in poll_txn_progress_function()
49 txn->progress_poll_fun(&progress, txn->progress_poll_fun_extra); in poll_txn_progress_function()
142 txn, in apply_txn()
157 if (txn->parent!=0) { in toku_rollback_commit()
165 toku_logger_save_rollback_rollinclude(txn->parent, txn->txnid, num_nodes, in toku_rollback_commit()
183 toku_get_and_pin_rollback_log(txn, txn->roll_info.current_rollback, &child_log); in toku_rollback_commit()
213 txn, in toku_rollback_commit()
228 r = txn->open_fts.iterate<struct tokutxn, note_ft_used_in_txns_parent>(txn); in toku_rollback_commit()
233 toku_txn_lock(txn->parent); in toku_rollback_commit()
234 txn->parent->force_fsync_on_commit |= txn->force_fsync_on_commit; in toku_rollback_commit()
[all …]
|
| /dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/tokudb/PerconaFT/ft/txn/ |
| H A D | txn.cc | 134 TOKUTXN txn; in toku_txn_begin_with_xid() local
350 TOKUTXN txn; member
402 …txn->do_fsync = !txn->parent && (txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_roll… in toku_txn_commit_with_lsn()
408 toku_log_xcommit(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_commit_with_lsn()
472 toku_log_xabort(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_abort_with_lsn()
492 if (txn->parent || toku_txn_is_read_only(txn)) { in toku_txn_prepare_txn()
506 txn->do_fsync = txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_rollentries>0); in toku_txn_prepare_txn()
509 toku_log_xprepare(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid, xa_xid); in toku_txn_prepare_txn()
554 txn->open_fts.iterate<struct tokutxn, remove_txn>(txn); in note_txn_closing()
565 txn, in toku_txn_complete_txn()
[all …]
|
| H A D | rollback-apply.cc | 43 if (txn->progress_poll_fun) { in poll_txn_progress_function()
49 txn->progress_poll_fun(&progress, txn->progress_poll_fun_extra); in poll_txn_progress_function()
142 txn, in apply_txn()
157 if (txn->parent!=0) { in toku_rollback_commit()
165 toku_logger_save_rollback_rollinclude(txn->parent, txn->txnid, num_nodes, in toku_rollback_commit()
183 toku_get_and_pin_rollback_log(txn, txn->roll_info.current_rollback, &child_log); in toku_rollback_commit()
213 txn, in toku_rollback_commit()
228 r = txn->open_fts.iterate<struct tokutxn, note_ft_used_in_txns_parent>(txn); in toku_rollback_commit()
233 toku_txn_lock(txn->parent); in toku_rollback_commit()
234 txn->parent->force_fsync_on_commit |= txn->force_fsync_on_commit; in toku_rollback_commit()
[all …]
|
| /dports/databases/mariadb104-server/mariadb-10.4.24/storage/tokudb/PerconaFT/ft/txn/ |
| H A D | txn.cc | 134 TOKUTXN txn; in toku_txn_begin_with_xid() local
350 TOKUTXN txn; member
402 …txn->do_fsync = !txn->parent && (txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_roll… in toku_txn_commit_with_lsn()
408 toku_log_xcommit(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_commit_with_lsn()
472 toku_log_xabort(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_abort_with_lsn()
492 if (txn->parent || toku_txn_is_read_only(txn)) { in toku_txn_prepare_txn()
506 txn->do_fsync = txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_rollentries>0); in toku_txn_prepare_txn()
509 toku_log_xprepare(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid, xa_xid); in toku_txn_prepare_txn()
554 txn->open_fts.iterate<struct tokutxn, remove_txn>(txn); in note_txn_closing()
565 txn, in toku_txn_complete_txn()
[all …]
|
| H A D | rollback-apply.cc | 43 if (txn->progress_poll_fun) { in poll_txn_progress_function()
49 txn->progress_poll_fun(&progress, txn->progress_poll_fun_extra); in poll_txn_progress_function()
142 txn, in apply_txn()
157 if (txn->parent!=0) { in toku_rollback_commit()
165 toku_logger_save_rollback_rollinclude(txn->parent, txn->txnid, num_nodes, in toku_rollback_commit()
183 toku_get_and_pin_rollback_log(txn, txn->roll_info.current_rollback, &child_log); in toku_rollback_commit()
213 txn, in toku_rollback_commit()
228 r = txn->open_fts.iterate<struct tokutxn, note_ft_used_in_txns_parent>(txn); in toku_rollback_commit()
233 toku_txn_lock(txn->parent); in toku_rollback_commit()
234 txn->parent->force_fsync_on_commit |= txn->force_fsync_on_commit; in toku_rollback_commit()
[all …]
|
| /dports/databases/mariadb104-client/mariadb-10.4.24/storage/tokudb/PerconaFT/ft/txn/ |
| H A D | txn.cc | 134 TOKUTXN txn; in toku_txn_begin_with_xid() local
350 TOKUTXN txn; member
402 …txn->do_fsync = !txn->parent && (txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_roll… in toku_txn_commit_with_lsn()
408 toku_log_xcommit(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_commit_with_lsn()
472 toku_log_xabort(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_abort_with_lsn()
492 if (txn->parent || toku_txn_is_read_only(txn)) { in toku_txn_prepare_txn()
506 txn->do_fsync = txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_rollentries>0); in toku_txn_prepare_txn()
509 toku_log_xprepare(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid, xa_xid); in toku_txn_prepare_txn()
554 txn->open_fts.iterate<struct tokutxn, remove_txn>(txn); in note_txn_closing()
565 txn, in toku_txn_complete_txn()
[all …]
|
| H A D | rollback-apply.cc | 43 if (txn->progress_poll_fun) {
49 txn->progress_poll_fun(&progress, txn->progress_poll_fun_extra); local
142 txn,
157 if (txn->parent!=0) {
165 toku_logger_save_rollback_rollinclude(txn->parent, txn->txnid, num_nodes,
183 toku_get_and_pin_rollback_log(txn, txn->roll_info.current_rollback, &child_log);
213 txn,
228 r = txn->open_fts.iterate<struct tokutxn, note_ft_used_in_txns_parent>(txn);
233 toku_txn_lock(txn->parent);
234 txn->parent->force_fsync_on_commit |= txn->force_fsync_on_commit;
[all …]
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/tokudb/PerconaFT/ft/txn/ |
| H A D | txn.cc | 134 TOKUTXN txn; in toku_txn_begin_with_xid() local
350 TOKUTXN txn; member
402 …txn->do_fsync = !txn->parent && (txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_roll… in toku_txn_commit_with_lsn()
408 toku_log_xcommit(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_commit_with_lsn()
472 toku_log_xabort(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_abort_with_lsn()
492 if (txn->parent || toku_txn_is_read_only(txn)) { in toku_txn_prepare_txn()
506 txn->do_fsync = txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_rollentries>0); in toku_txn_prepare_txn()
509 toku_log_xprepare(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid, xa_xid); in toku_txn_prepare_txn()
554 txn->open_fts.iterate<struct tokutxn, remove_txn>(txn); in note_txn_closing()
565 txn, in toku_txn_complete_txn()
[all …]
|
| /dports/databases/mariadb103-client/mariadb-10.3.34/storage/tokudb/PerconaFT/ft/txn/ |
| H A D | txn.cc | 134 TOKUTXN txn;
350 TOKUTXN txn;
402 …txn->do_fsync = !txn->parent && (txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_roll…
408 toku_log_xcommit(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid);
472 toku_log_xabort(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid);
492 if (txn->parent || toku_txn_is_read_only(txn)) {
506 txn->do_fsync = txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_rollentries>0);
509 toku_log_xprepare(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid, xa_xid);
554 txn->open_fts.iterate<struct tokutxn, remove_txn>(txn);
565 txn,
[all …]
|
| /dports/databases/mariadb103-server/mariadb-10.3.34/storage/tokudb/PerconaFT/ft/txn/ |
| H A D | txn.cc | 134 TOKUTXN txn; in toku_txn_begin_with_xid() local
350 TOKUTXN txn; member
402 …txn->do_fsync = !txn->parent && (txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_roll… in toku_txn_commit_with_lsn()
408 toku_log_xcommit(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_commit_with_lsn()
472 toku_log_xabort(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_abort_with_lsn()
492 if (txn->parent || toku_txn_is_read_only(txn)) { in toku_txn_prepare_txn()
506 txn->do_fsync = txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_rollentries>0); in toku_txn_prepare_txn()
509 toku_log_xprepare(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid, xa_xid); in toku_txn_prepare_txn()
554 txn->open_fts.iterate<struct tokutxn, remove_txn>(txn); in note_txn_closing()
565 txn, in toku_txn_complete_txn()
[all …]
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/tokudb/PerconaFT/ft/txn/ |
| H A D | txn.cc | 134 TOKUTXN txn; in toku_txn_begin_with_xid() local
350 TOKUTXN txn; member
402 …txn->do_fsync = !txn->parent && (txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_roll… in toku_txn_commit_with_lsn()
408 toku_log_xcommit(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_commit_with_lsn()
472 toku_log_xabort(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid); in toku_txn_abort_with_lsn()
492 if (txn->parent || toku_txn_is_read_only(txn)) { in toku_txn_prepare_txn()
506 txn->do_fsync = txn->force_fsync_on_commit || (!nosync && txn->roll_info.num_rollentries>0); in toku_txn_prepare_txn()
509 toku_log_xprepare(txn->logger, &txn->do_fsync_lsn, 0, txn, txn->txnid, xa_xid); in toku_txn_prepare_txn()
554 txn->open_fts.iterate<struct tokutxn, remove_txn>(txn); in note_txn_closing()
565 txn, in toku_txn_complete_txn()
[all …]
|
| /dports/dns/py-dnspython2/dnspython-2.1.0/tests/ |
| H A D | test_transaction.py | 94 txn.add(rrset)
124 txn.add(rrset)
127 txn.add(rrset2)
138 txn.add(rrset)
154 txn.add(rrset)
205 txn.add(1)
214 txn.add(foo)
216 txn.add()
274 txn.rollback()
279 txn.commit()
[all …]
|
| /dports/misc/concourse/concourse-6.7.2/vendor/github.com/concourse/dex/vendor/github.com/coreos/etcd/clientv3/ |
| H A D | txn.go | 71 func (txn *txn) If(cs ...Cmp) Txn { argument
90 txn.cmps = append(txn.cmps, (*pb.Compare)(&cs[i]))
96 func (txn *txn) Then(ops ...Op) Txn { argument
110 txn.isWrite = txn.isWrite || op.isWrite()
111 txn.sus = append(txn.sus, op.toRequestOp())
117 func (txn *txn) Else(ops ...Op) Txn { argument
128 txn.isWrite = txn.isWrite || op.isWrite()
129 txn.fas = append(txn.fas, op.toRequestOp())
135 func (txn *txn) Commit() (*TxnResponse, error) { argument
152 func (txn *txn) commit() (*TxnResponse, error) { argument
[all …]
|
| /dports/devel/etcd31/etcd-3.1.20/clientv3/ |
| H A D | txn.go | 73 func (txn *txn) If(cs ...Cmp) Txn { argument
92 txn.cmps = append(txn.cmps, (*pb.Compare)(&cs[i]))
98 func (txn *txn) Then(ops ...Op) Txn { argument
112 txn.isWrite = txn.isWrite || op.isWrite()
113 txn.sus = append(txn.sus, op.toRequestOp())
119 func (txn *txn) Else(ops ...Op) Txn { argument
130 txn.isWrite = txn.isWrite || op.isWrite()
131 txn.fas = append(txn.fas, op.toRequestOp())
137 func (txn *txn) Commit() (*TxnResponse, error) { argument
154 func (txn *txn) commit() (*TxnResponse, error) { argument
[all …]
|
| /dports/databases/py-lmdb/lmdb-0.97/tests/ |
| H A D | txn_test.py | 62 txn.abort()
69 txn.commit()
79 txn.commit()
86 txn.abort()
100 txn.abort()
137 txn.commit()
144 txn.abort()
202 txn.abort()
235 txn.abort()
300 txn.abort()
[all …]
|