blob: b10f1094062b83a9654e311f14f1be13c2d778e4 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 2009, 2015 Oracle and/or its affiliates. All rights reserved.
*
*/
using System;
using System.Collections.Generic;
using System.Text;
using BerkeleyDB.Internal;
namespace BerkeleyDB {
/// <summary>
/// The ActiveTransaction class describes a currently active transaction.
/// </summary>
public class ActiveTransaction {
private DB_TXN_ACTIVE txn;
private LSN _lsn;
private LSN _read_lsn;
private byte[] gid;
private string txnname;
internal ActiveTransaction(DB_TXN_ACTIVE active, byte[] GlobalID, string Name) {
txn = active;
_lsn = new LSN(txn.lsn.file, txn.lsn.offset);
_read_lsn = new LSN(txn.read_lsn.file, txn.read_lsn.offset);
gid = GlobalID;
txnname = Name;
}
/// <summary>
/// The transaction ID of the transaction.
/// </summary>
public uint ID { get { return txn.txnid; } }
/// <summary>
/// The transaction ID of the parent transaction (or 0, if no parent).
/// </summary>
public uint ParentID { get { return txn.parentid; } }
/// <summary>
/// The process ID of the originator of the transaction.
/// </summary>
public int ProcessID { get { return txn.pid; } }
/// <summary>
/// The thread of control ID of the originator of the transaction.
/// </summary>
public uint ThreadID { get { return txn.tid; } }
/// <summary>
/// The current log sequence number when the transaction was begun.
/// </summary>
public LSN Begun { get { return _lsn; } }
/// <summary>
/// The log sequence number of reads for snapshot transactions.
/// </summary>
public LSN SnapshotReads { get { return _read_lsn; } }
/// <summary>
/// The number of MVCC buffer copies created by this transaction that
/// remains in the cache.
/// </summary>
public uint BufferCopiesInCache { get { return txn.mvcc_ref; } }
/// <summary>
/// If the transaction is a prepared transaction, return the transaction's
/// Global ID. Otherwise, the GlobalID contents are undefined.
/// </summary>
public byte[] GlobalID { get { return gid; } }
/// <summary>
/// If a name was specified for the transaction, return up to the first 50
/// bytes of that name.
/// </summary>
public string Name { get { return txnname; } }
/// <summary>
/// Assigned priority used when resolving deadlocks.
/// </summary>
public uint Priority { get { return txn.priority; } }
}
}
|
