Commit fadc1105 authored by Wink Saville's avatar Wink Saville

Revert "Merge commit 'e887563a' into fix-merge-conclict"

This reverts commit f65ee55561e2a5f53be6db2ce03e518e249c9e80.

Change-Id: Ia6fed4d96fb4c076b2b51e1d758f3e15d37bffc0
parent 2666d4df
...@@ -437,6 +437,15 @@ and the runtime overhead. An overview of Nano features: ...@@ -437,6 +437,15 @@ and the runtime overhead. An overview of Nano features:
MessageNano. MessageNano.
- The 'bytes' type translates to the Java type byte[]. - The 'bytes' type translates to the Java type byte[].
The generated messages are not thread-safe for writes, but may be
used simultaneously from multiple threads in a read-only manner.
In other words, an appropriate synchronization mechanism (such as
a ReadWriteLock) must be used to ensure that a message, its
ancestors, and descendants are not accessed by any other threads
while the message is being modified. Field reads, getter methods,
toByteArray(...), writeTo(...), getCachedSize(), and
getSerializedSize() are all considered read-only operations.
IMPORTANT: If you have fields with defaults and opt out of accessors IMPORTANT: If you have fields with defaults and opt out of accessors
How fields with defaults are serialized has changed. Because we don't How fields with defaults are serialized has changed. Because we don't
......
...@@ -47,7 +47,7 @@ public abstract class ExtendableMessageNano<M extends ExtendableMessageNano<M>> ...@@ -47,7 +47,7 @@ public abstract class ExtendableMessageNano<M extends ExtendableMessageNano<M>>
protected List<UnknownFieldData> unknownFieldData; protected List<UnknownFieldData> unknownFieldData;
@Override @Override
public int getSerializedSize() { protected int computeSerializedSize() {
int size = 0; int size = 0;
int unknownFieldCount = unknownFieldData == null ? 0 : unknownFieldData.size(); int unknownFieldCount = unknownFieldData == null ? 0 : unknownFieldData.size();
for (int i = 0; i < unknownFieldCount; i++) { for (int i = 0; i < unknownFieldCount; i++) {
...@@ -55,7 +55,6 @@ public abstract class ExtendableMessageNano<M extends ExtendableMessageNano<M>> ...@@ -55,7 +55,6 @@ public abstract class ExtendableMessageNano<M extends ExtendableMessageNano<M>>
size += CodedOutputByteBufferNano.computeRawVarint32Size(unknownField.tag); size += CodedOutputByteBufferNano.computeRawVarint32Size(unknownField.tag);
size += unknownField.bytes.length; size += unknownField.bytes.length;
} }
cachedSize = size;
return size; return size;
} }
......
...@@ -38,7 +38,7 @@ import java.io.IOException; ...@@ -38,7 +38,7 @@ import java.io.IOException;
* @author wink@google.com Wink Saville * @author wink@google.com Wink Saville
*/ */
public abstract class MessageNano { public abstract class MessageNano {
protected int cachedSize = -1; protected volatile int cachedSize = -1;
/** /**
* Get the number of bytes required to encode this message. * Get the number of bytes required to encode this message.
...@@ -61,8 +61,17 @@ public abstract class MessageNano { ...@@ -61,8 +61,17 @@ public abstract class MessageNano {
* using getCachedSize(). * using getCachedSize().
*/ */
public int getSerializedSize() { public int getSerializedSize() {
int size = computeSerializedSize();
cachedSize = size;
return size;
}
/**
* Computes the number of bytes required to encode this message. This does not update the
* cached size.
*/
protected int computeSerializedSize() {
// This is overridden if the generated message has serialized fields. // This is overridden if the generated message has serialized fields.
cachedSize = 0;
return 0; return 0;
} }
......
...@@ -105,6 +105,12 @@ public class NanoTest extends TestCase { ...@@ -105,6 +105,12 @@ public class NanoTest extends TestCase {
assertEquals(456, newMsg.d); assertEquals(456, newMsg.d);
assertEquals(2, msg.nestedMsg.bb); assertEquals(2, msg.nestedMsg.bb);
assertEquals(SimpleMessageNano.BAR, msg.defaultNestedEnum); assertEquals(SimpleMessageNano.BAR, msg.defaultNestedEnum);
msg.nestedMsg = null;
assertTrue(msgSerializedSize != msg.getSerializedSize());
msg.clear();
assertEquals(0, msg.getSerializedSize());
} }
public void testRecursiveMessageNano() throws Exception { public void testRecursiveMessageNano() throws Exception {
...@@ -143,6 +149,12 @@ public class NanoTest extends TestCase { ...@@ -143,6 +149,12 @@ public class NanoTest extends TestCase {
assertEquals(3, newMsg.repeatedRecursiveMessageNano[0].id); assertEquals(3, newMsg.repeatedRecursiveMessageNano[0].id);
} }
public void testMessageNoFields() {
SingleMessageNano msg = new SingleMessageNano();
assertEquals(0, msg.getSerializedSize());
assertEquals(0, MessageNano.toByteArray(msg).length);
}
public void testNanoRequiredInt32() throws Exception { public void testNanoRequiredInt32() throws Exception {
TestAllTypesNano msg = new TestAllTypesNano(); TestAllTypesNano msg = new TestAllTypesNano();
msg.id = 123; msg.id = 123;
...@@ -2898,6 +2910,20 @@ public class NanoTest extends TestCase { ...@@ -2898,6 +2910,20 @@ public class NanoTest extends TestCase {
assertTrue(Arrays.equals(enums, message.getExtension(RepeatedExtensions.repeatedEnum))); assertTrue(Arrays.equals(enums, message.getExtension(RepeatedExtensions.repeatedEnum)));
} }
public void testNullExtensions() throws Exception {
// Check that clearing the extension on an empty message is a no-op.
Extensions.ExtendableMessage message = new Extensions.ExtendableMessage();
message.setExtension(SingularExtensions.someMessage, null);
assertEquals(0, MessageNano.toByteArray(message).length);
// Check that the message is empty after setting and clearing an extension.
AnotherMessage another = new AnotherMessage();
message.setExtension(SingularExtensions.someMessage, another);
assertTrue(MessageNano.toByteArray(message).length > 0);
message.setExtension(SingularExtensions.someMessage, null);
assertEquals(0, MessageNano.toByteArray(message).length);
}
public void testUnknownFields() throws Exception { public void testUnknownFields() throws Exception {
// Check that we roundtrip (serialize and deserialize) unrecognized fields. // Check that we roundtrip (serialize and deserialize) unrecognized fields.
AnotherMessage message = new AnotherMessage(); AnotherMessage message = new AnotherMessage();
......
...@@ -311,8 +311,8 @@ GenerateMessageSerializationMethods(io::Printer* printer) { ...@@ -311,8 +311,8 @@ GenerateMessageSerializationMethods(io::Printer* printer) {
printer->Print( printer->Print(
"\n" "\n"
"@Override\n" "@Override\n"
"public int getSerializedSize() {\n" "protected int computeSerializedSize() {\n"
" int size = super.getSerializedSize();\n"); " int size = super.computeSerializedSize();\n");
printer->Indent(); printer->Indent();
for (int i = 0; i < descriptor_->field_count(); i++) { for (int i = 0; i < descriptor_->field_count(); i++) {
...@@ -321,7 +321,6 @@ GenerateMessageSerializationMethods(io::Printer* printer) { ...@@ -321,7 +321,6 @@ GenerateMessageSerializationMethods(io::Printer* printer) {
printer->Outdent(); printer->Outdent();
printer->Print( printer->Print(
" cachedSize = size;\n"
" return size;\n" " return size;\n"
"}\n"); "}\n");
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment