tso-server/src/main/java/org/apache/omid/tso/AbstractRequestProcessor.java (6 lines): - line 140: // TODO We can not use this as a timeout trigger for flushing. This timeout is related to the time between - line 141: // TODO (cont) arrivals of requests to the disruptor. We need another mechanism to trigger timeouts - line 142: // TODO (cont) WARNING!!! Take care with the implementation because if there's other thread than request-0 - line 143: // TODO (cont) thread the one that calls persistProc.triggerCurrentBatchFlush(); we'll incur in concurrency issues - line 144: // TODO (cont) This is because, in the current implementation, only the request-0 thread calls the public methods - line 145: // TODO (cont) in persistProc and it is guaranteed that access them serially. common/src/main/java/org/apache/omid/NetworkUtils.java (2 lines): - line 32: //FIXME Popular distros haven't called their network interfaces ethX for a long time - line 37: // FIXME This seems to be only used for determining the host and port when registering TSO benchmarks/src/main/java/org/apache/omid/benchmarks/utils/ZipfianGenerator.java (2 lines): - line 238: //TODO: can also have a negative incremental computation, e.g. if you decrease the number of items, then just subtract - line 285: //TODO Implement ZipfianGenerator.mean() transaction-client/src/main/java/org/apache/omid/transaction/AbstractTransactionManager.java (2 lines): - line 419: // TODO: Decide what we should we do if we can not contact the commit table - line 442: // TODO: Decide what we should we do if we can not contact the commit table tso-server/src/main/java/org/apache/omid/tso/PersistenceProcessorImpl.java (1 line): - line 61: // TODO Next two need to be either int or AtomicLong hbase-commit-table/src/main/java/org/apache/omid/committable/hbase/HBaseCommitTable.java (1 line): - line 268: // TODO: Decide what we should we do if we can not contact the commit table. loop till succeed??? timestamp-storage/src/main/java/org/apache/omid/timestamp/storage/HBaseTimestampStorage.java (1 line): - line 101: //TODO this is never called timestamp-storage/src/main/java/org/apache/omid/timestamp/storage/ZKTimestampStorage.java (1 line): - line 43: timestamp = new DistributedAtomicLong(zkClient, TIMESTAMP_ZNODE, new RetryNTimes(3, 1000)); // TODO Configure tso-server/src/main/java/org/apache/omid/tso/Batch.java (1 line): - line 39: private final PersistEvent[] events; // TODO Check if it's worth to have a dynamic structure for this tso-server/src/main/java/org/apache/omid/tso/BatchPoolModule.java (1 line): - line 63: // TODO There should be a better way to do the pre-creation below avoiding the two loops hbase-client/src/main/java/org/apache/omid/transaction/SnapshotFilterImpl.java (1 line): - line 233: return new CommitTimestamp(NOT_PRESENT, -1L /** TODO Check if we should return this */, true); timestamp-storage/src/main/java/org/apache/omid/timestamp/storage/ZKModule.java (1 line): - line 28: //TODO:IK: move to common? hbase-client/src/main/java/org/apache/omid/transaction/TTable.java (1 line): - line 566: /* TODO What should we do with this methods??? tso-server/src/main/java/org/apache/omid/tso/CommitHashMap.java (1 line): - line 35: * TODO: improve garbage collection, right now an entry is picked at random transaction-client/src/main/java/org/apache/omid/tso/client/MockTSOClient.java (1 line): - line 31: // TODO Would be nice to compile all util classes for testing to a separate package that clients could import for tests hbase-common/src/main/java/org/apache/omid/transaction/CellUtils.java (1 line): - line 337: // TODO: Should we check also here the MVCC and swap if its greater??? hbase-common/src/main/java/org/apache/omid/transaction/CellInfo.java (1 line): - line 30: // TODO: Use Guava preconditions instead of the assertions tso-server/src/main/java/org/apache/omid/tso/PersistenceProcessorHandler.java (1 line): - line 63: String tsoHostAndPort, // TODO This should not be passed here. Should be part of panicker transaction-client/src/main/java/org/apache/omid/tso/client/TSOClient.java (1 line): - line 86: // Basic configuration constants & defaults TODO: Move DEFAULT_ZK_CLUSTER to a conf class???