Class: Bdb::Txn

Inherits:

Object

• Object
• Bdb::Txn

Defined in:

ext/bdb.c

Instance Method Summary

• #abort ⇒ Object

  txn.abort -> true.

• #commit(vflags) ⇒ Object

  txn.commit(flags) -> true.

• #discard ⇒ Object

  txn.discard -> true.

• #set_timeout(vtimeout, vflags) ⇒ Object

  tx.set_timeout(timeout,flags) -> true.

• #tid ⇒ Object

  txn.tid -> Fixnum.

Instance Method Details

#abort ⇒ Object

txn.abort -> true

abort a transaction

# File 'ext/bdb.c', line 3166

VALUE txn_abort(VALUE obj)
{
  t_txnh *txn=NULL;
  int rv;

  Data_Get_Struct(obj,t_txnh,txn);

  if (!txn->txn)
    return Qfalse;

  rv=txn->txn->abort(txn->txn);
  txn_finish(txn);
  if ( rv != 0 ) {
    raise_error(rv, "txn_abort: %s",db_strerror(rv));
    return Qnil;
  }
  return Qtrue;
}

#commit(vflags) ⇒ Object

txn.commit(flags) -> true

commit a transaction

# File 'ext/bdb.c', line 3137

VALUE txn_commit(VALUE obj, VALUE vflags)
{
  t_txnh *txn=NULL;
  u_int32_t flags=0;
  int rv;

  if ( ! NIL_P(vflags))
    flags=NUM2UINT(vflags);

  Data_Get_Struct(obj,t_txnh,txn);

  if (!txn->txn) 
    return Qfalse;
  
  rv=txn->txn->commit(txn->txn,flags);
  txn_finish(txn);
  if ( rv != 0 ) {
    raise_error(rv, "txn_commit: %s",db_strerror(rv));
    return Qnil;
  }
  return Qtrue;
}

#discard ⇒ Object

txn.discard -> true

discard a transaction. Since prepare is not yet supported, I don’t think this has much value.

# File 'ext/bdb.c', line 3192

VALUE txn_discard(VALUE obj)
{
  t_txnh *txn=NULL;
  int rv;

  Data_Get_Struct(obj,t_txnh,txn);

  if (!txn->txn)
    raise_error(0,"txn is closed");

  rv=txn->txn->discard(txn->txn,NOFLAGS);
  txn_finish(txn);
  if ( rv != 0 ) {
    raise_error(rv, "txn_abort: %s",db_strerror(rv));
    return Qnil;
  }
  return Qtrue;
}

#set_timeout(vtimeout, vflags) ⇒ Object

tx.set_timeout(timeout,flags) -> true

set transaction lock timeout

# File 'ext/bdb.c', line 3237

VALUE txn_set_timeout(VALUE obj, VALUE vtimeout, VALUE vflags)
{
  t_txnh *txn=NULL;
  db_timeout_t timeout;
  u_int32_t flags=0;
  int rv;

  if ( ! NIL_P(vflags))
    flags=NUM2UINT(vflags);

  if ( ! FIXNUM_P(vtimeout) )
    raise_error(0,"timeout must be a fixed integer");
  timeout=FIX2UINT(vtimeout);

  Data_Get_Struct(obj,t_txnh,txn);

  if (!txn->txn)
    raise_error(0,"txn is closed");

  rv=txn->txn->set_timeout(txn->txn,timeout,flags);
  if ( rv != 0 ) {
    raise_error(rv, "txn_set_timeout: %s",db_strerror(rv));
    return Qnil;
  }
  return Qtrue;
}

#tid ⇒ Object

txn.tid -> Fixnum

return the transaction id, (named tid to not conflict with ruby’s id method)

# File 'ext/bdb.c', line 3218

VALUE txn_id(VALUE obj)
{
  t_txnh *txn=NULL;
  int rv;

  Data_Get_Struct(obj,t_txnh,txn);
  if (!txn->txn)
    raise_error(0,"txn is closed");

  rv=txn->txn->id(txn->txn);
  return INT2FIX(rv);
}