natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

improve asserts 

git-svn-id: https://svn.apache.org/repos/asf/cassandra/branches/cassandra-0.7@1079652 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Jonathan Ellis 2011-03-09 03:27:48 +00:00
parent 5947c59072
commit 55a1e170d2
4 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/java/org/apache/cassandra/db/CompactionManager.java
View File

@ -1122,7 +1122,7 @@ public class CompactionManager implements CompactionManagerMBean
public void write(PageCacheInformer out) throws IOException
{
assert row.dataSize != 0;
assert row.dataSize > 0;
out.writeLong(row.dataSize);
row.echoData(out);
}

4
src/java/org/apache/cassandra/io/LazilyCompactedRow.java
View File

@ -98,7 +98,7 @@ public class LazilyCompactedRow extends AbstractCompactedRow implements IIterabl
if (rows.size() == 1 && !shouldPurge && rows.get(0).sstable.descriptor.isLatestVersion && !forceDeserialize)
{
SSTableIdentityIterator row = rows.get(0);
assert row.dataSize != 0;
assert row.dataSize > 0;
out.writeLong(row.dataSize);
row.echoData(out);
return;
@ -108,7 +108,7 @@ public class LazilyCompactedRow extends AbstractCompactedRow implements IIterabl
ColumnFamily.serializer().serializeCFInfo(emptyColumnFamily, clockOut);
long dataSize = headerBuffer.getLength() + clockOut.getLength() + columnSerializedSize;
assert dataSize != 0;
assert dataSize > 0;
out.writeLong(dataSize);
out.write(headerBuffer.getData(), 0, headerBuffer.getLength());
out.write(clockOut.getData(), 0, clockOut.getLength());

2
src/java/org/apache/cassandra/io/PrecompactedRow.java
View File

@ -118,7 +118,7 @@ public class PrecompactedRow extends AbstractCompactedRow
public void write(PageCacheInformer out) throws IOException
{
assert buffer.getLength() != 0;
assert buffer.getLength() > 0;
out.writeLong(buffer.getLength());
List<Pair<Integer, Integer>> pageCacheMarkers = buffer.getPageCacheMarkers();

2
src/java/org/apache/cassandra/io/sstable/SSTableWriter.java
View File

@ -148,7 +148,7 @@ public class SSTableWriter extends SSTable
long endPosition = dataFile.getFilePointer();
dataFile.seek(sizePosition);
long dataSize = endPosition - (sizePosition + 8);
assert dataSize != 0;
assert dataSize > 0;
dataFile.writeLong(dataSize);
// finally, reset for next row
dataFile.seek(endPosition);