import java.util.concurrent.atomic.AtomicInteger;
import com.ibm.crail.CrailResult;
import com.ibm.crail.conf.CrailConstants;
import com.ibm.crail.datanode.DataResult;
import com.ibm.crail.utils.BufferCheckpoint;
<BUG>public class CoreDataOperation implements Future<CrailResult>, CrailResult {
protected static int RPC_PENDING = 0;</BUG>
protected static int RPC_DONE = 1;
protected static int RPC_ERROR = 2;
private CoreStream stream;

import java.util.concurrent.atomic.AtomicInteger;
import com.ibm.crail.CrailResult;
import com.ibm.crail.conf.CrailConstants;
import com.ibm.crail.datanode.DataResult;
import com.ibm.crail.utils.BufferCheckpoint;
class CoreDataOperation implements Future<CrailResult>, CrailResult {
protected static int RPC_PENDING = 0;
protected static int RPC_DONE = 1;
protected static int RPC_ERROR = 2;
private CoreStream stream;
