public class org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState extends org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$CoreContext$ThreadState
{
java.util.List openTxns;
long txnId;
public void <init>()
{
org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState v;
java.util.ArrayList v;
v := @this: org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState;
specialinvoke v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$CoreContext$ThreadState: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState: java.util.List openTxns> = v;
return;
}
public void iterSetup()
{
org.slf4j.Logger v;
long v, v, v;
org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState v;
org.apache.hadoop.hive.metastore.tools.HMSClient v;
java.util.List v;
java.lang.Long v, v;
v := @this: org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState;
v = v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState: org.apache.hadoop.hive.metastore.tools.HMSClient client>;
v = staticinvoke <org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds: long executeOpenTxnAndGetTxnId(org.apache.hadoop.hive.metastore.tools.HMSClient)>(v);
v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState: long txnId> = v;
v = <org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks: org.slf4j.Logger LOG>;
v = v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState: long txnId>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Object)>("opened txn, id={}", v);
v = v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState: java.util.List openTxns>;
v = v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState: long txnId>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
public void doTearDown() throws java.lang.Exception
{
org.slf4j.Logger v, v;
org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState v;
org.apache.hadoop.hive.metastore.tools.HMSClient v, v;
java.util.List v, v;
boolean v;
v := @this: org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState;
v = v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState: org.apache.hadoop.hive.metastore.tools.HMSClient client>;
v = v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState: java.util.List openTxns>;
virtualinvoke v.<org.apache.hadoop.hive.metastore.tools.HMSClient: boolean abortTxns(java.util.List)>(v);
v = v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState: org.apache.hadoop.hive.metastore.tools.HMSClient client>;
v = v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState: java.util.List openTxns>;
v = staticinvoke <org.apache.hadoop.hive.metastore.tools.BenchmarkUtils: boolean checkTxnsCleaned(org.apache.hadoop.hive.metastore.tools.HMSClient,java.util.List)>(v, v);
if v != 0 goto label;
v = <org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String)>("Something went wrong with the cleanup of txns");
label:
v = <org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>("aborted all opened txns");
return;
}
}