@@ -0,0 +1,2478 @@
+/* This file is part of VoltDB.%0A * Copyright (C) 2008-2012 VoltDB Inc.%0A *%0A * VoltDB is free software: you can redistribute it and/or modify%0A * it under the terms of the GNU General Public License as published by%0A * the Free Software Foundation, either version 3 of the License, or%0A * (at your option) any later version.%0A *%0A * VoltDB is distributed in the hope that it will be useful,%0A * but WITHOUT ANY WARRANTY; without even the implied warranty of%0A * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the%0A * GNU General Public License for more details.%0A *%0A * You should have received a copy of the GNU General Public License%0A * along with VoltDB.  If not, see %3Chttp://www.gnu.org/licenses/%3E.%0A */%0A%0Apackage org.voltdb.iv2;%0A%0Aimport java.util.HashSet;%0A%0Aimport org.voltcore.messaging.TransactionInfoBaseMessage;%0Aimport org.voltdb.StoredProcedureInvocation;%0Aimport org.voltdb.dtxn.TransactionState;%0Aimport org.voltdb.messaging.FragmentTaskMessage;%0Aimport org.voltdb.messaging.Iv2InitiateTaskMessage;%0A%0Apublic class MpTransactionState extends TransactionState%0A%7B%0A    final Iv2InitiateTaskMessage m_task;%0A%0A    MpTransactionState(long txnId, TransactionInfoBaseMessage notice)%0A    %7B%0A        super(txnId, notice);%0A        m_task = (Iv2InitiateTaskMessage)notice;%0A    %7D%0A%0A    @Override%0A    public boolean isSinglePartition()%0A    %7B%0A        return false;%0A    %7D%0A%0A    @Override%0A    public boolean isCoordinator()%0A    %7B%0A        return true;%0A    %7D%0A%0A    @Override%0A    public boolean isBlocked()%0A    %7B%0A        // TODO Auto-generated method stub%0A        return false;%0A    %7D%0A%0A    @Override%0A    public boolean hasTransactionalWork()%0A    %7B%0A        // TODO Auto-generated method stub%0A        return false;%0A    %7D%0A%0A    @Override%0A    public boolean doWork(boolean recovering)%0A    %7B%0A        // TODO Auto-generated method stub%0A        return false;%0A    %7D%0A%0A    @Override%0A    public StoredProcedureInvocation getInvocation()%0A    %7B%0A        // TODO Auto-generated method stub%0A        return null;%0A    %7D%0A%0A    @Override%0A    public void handleSiteFaults(HashSet%3CLong%3E failedSites)%0A    %7B%0A        // TODO Auto-generated method stub%0A%0A    %7D%0A%0A    // Overrides needed by MpProcedureRunner%0A    @Override%0A    public void setupProcedureResume(boolean isFinal, int%5B%5D dependencies)%0A    %7B%0A    %7D%0A%0A    @Override%0A    public void createLocalFragmentWork(FragmentTaskMessage task, boolean nonTransactional)%0A    %7B%0A    %7D%0A%0A    @Override%0A    public void createAllParticipatingFragmentWork(FragmentTaskMessage task)%0A    %7B%0A    %7D%0A%7D

Create skeletal MpTransactionState for the MPI/MpProcedureRunner