julianhowarth commented on issue #2275:
URL: https://github.com/apache/fory/issues/2275#issuecomment-3189509749
ok, here's the code for VideoForyCodecMetaShared1_0 - let me know if that's
sufficient or if you need anything more. (Sorry about it being pasted, github
isn't letting me upload it)
```java
package com.endeavorstreaming.vesper.content_engine.common.domain.video;
import org.apache.fory.Fory;
import org.apache.fory.memory.MemoryBuffer;
import org.apache.fory.resolver.NoRefResolver;
import org.apache.fory.memory.Platform;
import org.apache.fory.resolver.ClassInfo;
import org.apache.fory.resolver.ClassInfoHolder;
import org.apache.fory.resolver.ClassResolver;
import org.apache.fory.builder.Generated;
import org.apache.fory.serializer.CodegenSerializer.LazyInitBeanSerializer;
import org.apache.fory.serializer.EnumSerializer;
import org.apache.fory.serializer.Serializer;
import org.apache.fory.serializer.StringSerializer;
import org.apache.fory.serializer.ObjectSerializer;
import org.apache.fory.serializer.CompatibleSerializer;
import org.apache.fory.serializer.collection.AbstractCollectionSerializer;
import org.apache.fory.serializer.collection.AbstractMapSerializer;
import org.apache.fory.builder.Generated.GeneratedObjectSerializer;
import org.apache.fory.builder.Generated.GeneratedMetaSharedSerializer;
public final class VideoForyCodecMetaShared1_0 extends
GeneratedMetaSharedSerializer {
private final NoRefResolver refResolver;
private final ClassResolver classResolver;
private final StringSerializer strSerializer;
private Fory fory;
private final org.apache.fory.serializer.TimeSerializers.InstantSerializer
instantSerializer;
private final
org.apache.fory.serializer.TimeSerializers.DurationSerializer
durationSerializer;
private final ClassInfo adInsertionClassInfo;
private final ClassInfo videoArtClassInfo;
private final ClassInfo contentIdClassInfo;
private final ClassInfo externalIdClassInfo;
private final ClassInfo contentItemGeoBlockingClassInfo;
private final ClassInfo geoBlockingLegacyClassInfo;
private final ClassInfo legacyDataClassInfo;
private final ClassInfo localisationsClassInfo;
private final ClassInfo onlinePlaybackAvailabilityClassInfo;
private final ClassInfo participantsClassInfo;
private final ClassInfo playbackTypeClassInfo;
private final ClassInfo releaseSchedulingClassInfo;
private final ClassInfo videoSeasonPositionClassInfo;
private final ClassInfo streamingClassInfo;
private final ClassInfo vodTypeClassInfo;
private final ClassInfoHolder immutableListClassInfoHolder;
private final ClassInfo audioStreamClassInfo;
private final Serializer serializer1;
private final ClassInfoHolder immutableSetClassInfoHolder;
private final ClassInfo basicTagClassInfo;
private final org.apache.fory.serializer.ReplaceResolveSerializer
replaceResolveSerializer;
private final ClassInfoHolder immutableSet1ClassInfoHolder;
private final ClassInfo countryContentRatingClassInfo;
private final Serializer serializer3;
private final ClassInfoHolder immutableSet2ClassInfoHolder;
private final ClassInfo downloadToGoPolicyClassInfo;
private final Serializer serializer5;
private final ClassInfoHolder immutableSet3ClassInfoHolder;
private final ClassInfo downloadablePlaybackClassInfo;
private final Serializer serializer7;
private final ClassInfoHolder immutableSet4ClassInfoHolder;
private final ClassInfo subtitleStreamClassInfo;
private final Serializer serializer9;
private final ClassInfoHolder immutableSet5ClassInfoHolder;
private final ClassInfo textTagClassInfo;
private final Serializer serializer11;
private final ClassInfoHolder immutableMapClassInfoHolder;
private final org.apache.fory.serializer.ReplaceResolveSerializer
replaceResolveSerializer1;
private final ClassInfo contentSourceIdClassInfo;
private final Serializer serializer13;
private final ClassInfo contentSourceClassInfo;
public VideoForyCodecMetaShared1_0(Fory fory, Class classType) {
super(fory, classType);
this.fory = fory;
serializer =
org.apache.fory.builder.MetaSharedCodecBuilder.setCodegenSerializer(fory,
classType, this);
org.apache.fory.resolver.RefResolver refResolver0 =
fory.getRefResolver();
refResolver = ((NoRefResolver)refResolver0);
classResolver = fory.getClassResolver();
strSerializer = fory.getStringSerializer();
instantSerializer =
((org.apache.fory.serializer.TimeSerializers.InstantSerializer)classResolver.getRawSerializer(java.time.Instant.class));
durationSerializer =
((org.apache.fory.serializer.TimeSerializers.DurationSerializer)classResolver.getRawSerializer(java.time.Duration.class));
adInsertionClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.AdInsertion.class);
videoArtClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.VideoArt.class);
contentIdClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.content.ContentId.class);
externalIdClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.ExternalId.class);
contentItemGeoBlockingClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.content.ContentItemGeoBlocking.class);
geoBlockingLegacyClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.GeoBlockingLegacy.class);
legacyDataClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.LegacyData.class);
localisationsClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.localisation.Localisations.class);
onlinePlaybackAvailabilityClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.OnlinePlaybackAvailability.class);
participantsClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.content.Participants.class);
playbackTypeClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.PlaybackType.class);
releaseSchedulingClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.content.ReleaseScheduling.class);
videoSeasonPositionClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.VideoSeasonPosition.class);
streamingClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.Streaming.class);
vodTypeClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.VodType.class);
immutableListClassInfoHolder = classResolver.nilClassInfoHolder();
audioStreamClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.AudioStream.class);
serializer1 =
classResolver.getRawSerializer(com.endeavorstreaming.vesper.content_engine.common.domain.video.AudioStream.class);
immutableSetClassInfoHolder = classResolver.nilClassInfoHolder();
basicTagClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.BasicTag.class);
replaceResolveSerializer =
((org.apache.fory.serializer.ReplaceResolveSerializer)classResolver.getRawSerializer(com.endeavorstreaming.vesper.content_engine.common.domain.video.BasicTag.class));
immutableSet1ClassInfoHolder = classResolver.nilClassInfoHolder();
countryContentRatingClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.CountryContentRating.class);
serializer3 =
classResolver.getRawSerializer(com.endeavorstreaming.vesper.content_engine.common.domain.video.CountryContentRating.class);
immutableSet2ClassInfoHolder = classResolver.nilClassInfoHolder();
downloadToGoPolicyClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.d2g.DownloadToGoPolicy.class);
serializer5 =
classResolver.getRawSerializer(com.endeavorstreaming.vesper.content_engine.common.domain.video.d2g.DownloadToGoPolicy.class);
immutableSet3ClassInfoHolder = classResolver.nilClassInfoHolder();
downloadablePlaybackClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.DownloadablePlayback.class);
serializer7 =
classResolver.getRawSerializer(com.endeavorstreaming.vesper.content_engine.common.domain.video.DownloadablePlayback.class);
immutableSet4ClassInfoHolder = classResolver.nilClassInfoHolder();
subtitleStreamClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.SubtitleStream.class);
serializer9 =
classResolver.getRawSerializer(com.endeavorstreaming.vesper.content_engine.common.domain.video.SubtitleStream.class);
immutableSet5ClassInfoHolder = classResolver.nilClassInfoHolder();
textTagClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.video.TextTag.class);
serializer11 =
classResolver.getRawSerializer(com.endeavorstreaming.vesper.content_engine.common.domain.video.TextTag.class);
immutableMapClassInfoHolder = classResolver.nilClassInfoHolder();
replaceResolveSerializer1 =
((org.apache.fory.serializer.ReplaceResolveSerializer)classResolver.getRawSerializer(com.endeavorstreaming.vesper.content_engine.common.domain.content.ContentSourceId.class));
contentSourceIdClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.content.ContentSourceId.class);
serializer13 =
classResolver.getRawSerializer(com.endeavorstreaming.vesper.content_engine.common.domain.content.ContentSource.class);
contentSourceClassInfo =
classResolver.getClassInfo(com.endeavorstreaming.vesper.content_engine.common.domain.content.ContentSource.class);
}
private void readFields(MemoryBuffer memoryBuffer,
com.endeavorstreaming.vesper.content_engine.common.domain.video.Video video) {
org.apache.fory.serializer.TimeSerializers.InstantSerializer
instantSerializer = this.instantSerializer;
if ((memoryBuffer.readByte() != ((byte)-3))) {
java.time.Instant instant = instantSerializer.read(memoryBuffer);
Platform.putObject(video, 64L, instant);
} else {
Platform.putObject(video, 64L, null);
}
if ((memoryBuffer.readByte() != ((byte)-3))) {
java.time.Instant instant1 = instantSerializer.read(memoryBuffer);
Platform.putObject(video, 68L, instant1);
} else {
Platform.putObject(video, 68L, null);
}
if ((memoryBuffer.readByte() != ((byte)-3))) {
java.time.Instant instant2 = instantSerializer.read(memoryBuffer);
Platform.putObject(video, 28L, instant2);
} else {
Platform.putObject(video, 28L, null);
}
if ((memoryBuffer.readByte() != ((byte)-3))) {
java.time.Duration duration =
durationSerializer.read(memoryBuffer);
Platform.putObject(video, 72L, duration);
} else {
Platform.putObject(video, 72L, null);
}
}
private void readFields1(MemoryBuffer memoryBuffer1,
com.endeavorstreaming.vesper.content_engine.common.domain.video.Video video1) {
ClassResolver classResolver = this.classResolver;
if ((memoryBuffer1.readByte() != ((byte)-3))) {
Object object = classResolver.readClassInfo(memoryBuffer1,
adInsertionClassInfo).getSerializer().read(memoryBuffer1);
Platform.putObject(video1, 80L,
((com.endeavorstreaming.vesper.content_engine.common.domain.video.AdInsertion)object));
} else {
Platform.putObject(video1, 80L, null);
}
if ((memoryBuffer1.readByte() != ((byte)-3))) {
Object object1 = classResolver.readClassInfo(memoryBuffer1,
videoArtClassInfo).getSerializer().read(memoryBuffer1);
Platform.putObject(video1, 76L,
((com.endeavorstreaming.vesper.content_engine.common.domain.video.VideoArt)object1));
} else {
Platform.putObject(video1, 76L, null);
}
if ((memoryBuffer1.readByte() != ((byte)-3))) {
Object object2 = classResolver.readClassInfo(memoryBuffer1,
contentIdClassInfo).getSerializer().read(memoryBuffer1);
Platform.putObject(video1, 16L,
((com.endeavorstreaming.vesper.content_engine.common.domain.content.ContentId)object2));
} else {
Platform.putObject(video1, 16L, null);
}
if ((memoryBuffer1.readByte() != ((byte)-3))) {
Object object3 = classResolver.readClassInfo(memoryBuffer1,
externalIdClassInfo).getSerializer().read(memoryBuffer1);
Platform.putObject(video1, 60L,
((com.endeavorstreaming.vesper.content_engine.common.domain.video.ExternalId)object3));
} else {
Platform.putObject(video1, 60L, null);
}
if ((memoryBuffer1.readByte() != ((byte)-3))) {
Object object4 = classResolver.readClassInfo(memoryBuffer1,
contentItemGeoBlockingClassInfo).getSerializer().read(memoryBuffer1);
Platform.putObject(video1, 88L,
((com.endeavorstreaming.vesper.content_engine.common.domain.content.ContentItemGeoBlocking)object4));
} else {
Platform.putObject(video1, 88L, null);
}
}
private void readFields2(MemoryBuffer memoryBuffer2,
com.endeavorstreaming.vesper.content_engine.common.domain.video.Video video2) {
ClassResolver classResolver = this.classResolver;
if ((memoryBuffer2.readByte() != ((byte)-3))) {
Object object0 = classResolver.readClassInfo(memoryBuffer2,
geoBlockingLegacyClassInfo).getSerializer().read(memoryBuffer2);
Platform.putObject(video2, 84L,
((com.endeavorstreaming.vesper.content_engine.common.domain.video.GeoBlockingLegacy)object0));
} else {
Platform.putObject(video2, 84L, null);
}
if ((memoryBuffer2.readByte() != ((byte)-3))) {
Object object5 = classResolver.readClassInfo(memoryBuffer2,
legacyDataClassInfo).getSerializer().read(memoryBuffer2);
Platform.putObject(video2, 116L,
((com.endeavorstreaming.vesper.content_engine.common.domain.video.LegacyData)object5));
} else {
Platform.putObject(video2, 116L, null);
}
if ((memoryBuffer2.readByte() != ((byte)-3))) {
Object object6 = classResolver.readClassInfo(memoryBuffer2,
localisationsClassInfo).getSerializer().read(memoryBuffer2);
Platform.putObject(video2, 52L,
((com.endeavorstreaming.vesper.content_engine.common.domain.localisation.Localisations)object6));
} else {
Platform.putObject(video2, 52L, null);
}
if ((memoryBuffer2.readByte() != ((byte)-3))) {
Object object7 = classResolver.readClassInfo(memoryBuffer2,
onlinePlaybackAvailabilityClassInfo).getSerializer().read(memoryBuffer2);
Platform.putObject(video2, 104L,
((com.endeavorstreaming.vesper.content_engine.common.domain.video.OnlinePlaybackAvailability)object7));
} else {
Platform.putObject(video2, 104L, null);
}
if ((memoryBuffer2.readByte() != ((byte)-3))) {
Object object8 = classResolver.readClassInfo(memoryBuffer2,
participantsClassInfo).getSerializer().read(memoryBuffer2);
Platform.putObject(video2, 32L,
((com.endeavorstreaming.vesper.content_engine.common.domain.content.Participants)object8));
} else {
Platform.putObject(video2, 32L, null);
}
}
private void readFields3(MemoryBuffer memoryBuffer3,
com.endeavorstreaming.vesper.content_engine.common.domain.video.Video video3) {
ClassResolver classResolver = this.classResolver;
if ((memoryBuffer3.readByte() != ((byte)-3))) {
Object object9 = classResolver.readClassInfo(memoryBuffer3,
playbackTypeClassInfo).getSerializer().read(memoryBuffer3);
Platform.putObject(video3, 124L,
((com.endeavorstreaming.vesper.content_engine.common.domain.video.PlaybackType)object9));
} else {
Platform.putObject(video3, 124L, null);
}
if ((memoryBuffer3.readByte() != ((byte)-3))) {
Object object10 = classResolver.readClassInfo(memoryBuffer3,
releaseSchedulingClassInfo).getSerializer().read(memoryBuffer3);
Platform.putObject(video3, 56L,
((com.endeavorstreaming.vesper.content_engine.common.domain.content.ReleaseScheduling)object10));
} else {
Platform.putObject(video3, 56L, null);
}
if ((memoryBuffer3.readByte() != ((byte)-3))) {
Object object11 = classResolver.readClassInfo(memoryBuffer3,
videoSeasonPositionClassInfo).getSerializer().read(memoryBuffer3);
Platform.putObject(video3, 108L,
((com.endeavorstreaming.vesper.content_engine.common.domain.video.VideoSeasonPosition)object11));
} else {
Platform.putObject(video3, 108L, null);
}
if ((memoryBuffer3.readByte() != ((byte)-3))) {
Object object12 = classResolver.readClassInfo(memoryBuffer3,
streamingClassInfo).getSerializer().read(memoryBuffer3);
Platform.putObject(video3, 92L,
((com.endeavorstreaming.vesper.content_engine.common.domain.video.Streaming)object12));
} else {
Platform.putObject(video3, 92L, null);
}
if ((memoryBuffer3.readByte() != ((byte)-3))) {
Object object13 = classResolver.readClassInfo(memoryBuffer3,
vodTypeClassInfo).getSerializer().read(memoryBuffer3);
Platform.putObject(video3, 120L,
((com.endeavorstreaming.vesper.content_engine.common.domain.video.VodType)object13));
} else {
Platform.putObject(video3, 120L, null);
}
}
private void differentTypeElemsRead(MemoryBuffer memoryBuffer4, boolean
value37, java.util.Collection collection, int value38) {
ClassResolver classResolver = this.classResolver;
ClassInfo audioStreamClassInfo = this.audioStreamClassInfo;
for (int i = 0; i < value38; i+=1) {
if (value37) {
if ((memoryBuffer4.readByte() != ((byte)-3))) {
collection.add(classResolver.readClassInfo(memoryBuffer4,
audioStreamClassInfo).getSerializer().read(memoryBuffer4));
} else {
collection.add(null);
}
} else {
collection.add(classResolver.readClassInfo(memoryBuffer4,
audioStreamClassInfo).getSerializer().read(memoryBuffer4));
}
}
}
private void readFields4(MemoryBuffer memoryBuffer5,
com.endeavorstreaming.vesper.content_engine.common.domain.video.Video video4) {
ClassResolver classResolver = this.classResolver;
if ((memoryBuffer5.readByte() != ((byte)-3))) {
AbstractCollectionSerializer collectionSerializer =
(AbstractCollectionSerializer)classResolver.readClassInfo(memoryBuffer5,
immutableListClassInfoHolder).getSerializer();
Object object16;
if (collectionSerializer.supportCodegenHook()) {
java.util.Collection collection0 =
collectionSerializer.newCollection(memoryBuffer5);
int size = collectionSerializer.getAndClearNumElements();
if ((size > 0)) {
int flags = memoryBuffer5.readByte();
boolean sameElementClass = (flags & 8) != 8;
boolean hasNull = (flags & 2) == 2;
if (sameElementClass) {
Serializer serializer0;
if (((flags & 4) != 4)) {
serializer0 = serializer1;
} else {
serializer0 =
classResolver.readClassInfo(memoryBuffer5,
audioStreamClassInfo).getSerializer();
}
for (int i0 = 0; i0 < size; i0+=1) {
if (hasNull) {
if ((memoryBuffer5.readByte() != ((byte)-3))) {
collection0.add(serializer0.read(memoryBuffer5));
} else {
collection0.add(null);
}
} else {
collection0.add(serializer0.read(memoryBuffer5));
}
}
} else {
this.differentTypeElemsRead(memoryBuffer5, hasNull,
collection0, size);
}
}
Object object14 =
collectionSerializer.onCollectionRead(collection0);
object16 = object14;
} else {
Object object15 = collectionSerializer.read(memoryBuffer5);
object16 = object15;
}
Platform.putObject(video4, 100L,
((com.google.common.collect.ImmutableList)object16));
} else {
Platform.putObject(video4, 100L, null);
}
}
private void differentTypeElemsRead1(MemoryBuffer memoryBuffer6, int
value41, boolean value42, java.util.Collection collection1) {
ClassResolver classResolver = this.classResolver;
ClassInfo basicTagClassInfo = this.basicTagClassInfo;
for (int i1 = 0; i1 < value41; i1+=1) {
if (value42) {
if ((memoryBuffer6.readByte() != ((byte)-3))) {
collection1.add(classResolver.readClassInfo(memoryBuffer6,
basicTagClassInfo).getSerializer().read(memoryBuffer6));
} else {
collection1.add(null);
}
} else {
collection1.add(classResolver.readClassInfo(memoryBuffer6,
basicTagClassInfo).getSerializer().read(memoryBuffer6));
}
}
}
private void readFields5(MemoryBuffer memoryBuffer7,
com.endeavorstreaming.vesper.content_engine.common.domain.video.Video video5) {
ClassResolver classResolver = this.classResolver;
if ((memoryBuffer7.readByte() != ((byte)-3))) {
AbstractCollectionSerializer collectionSerializer0 =
(AbstractCollectionSerializer)classResolver.readClassInfo(memoryBuffer7,
immutableSetClassInfoHolder).getSerializer();
Object object19;
if (collectionSerializer0.supportCodegenHook()) {
java.util.Collection collection2 =
collectionSerializer0.newCollection(memoryBuffer7);
int size0 = collectionSerializer0.getAndClearNumElements();
if ((size0 > 0)) {
int flags0 = memoryBuffer7.readByte();
boolean sameElementClass0 = (flags0 & 8) != 8;
boolean hasNull0 = (flags0 & 2) == 2;
if (sameElementClass0) {
Serializer serializer2;
if (((flags0 & 4) != 4)) {
serializer2 = replaceResolveSerializer;
} else {
serializer2 =
classResolver.readClassInfo(memoryBuffer7, basicTagClassInfo).getSerializer();
}
for (int i2 = 0; i2 < size0; i2+=1) {
if (hasNull0) {
if ((memoryBuffer7.readByte() != ((byte)-3))) {
collection2.add(serializer2.read(memoryBuffer7));
} else {
collection2.add(null);
}
} else {
collection2.add(serializer2.read(memoryBuffer7));
}
}
} else {
this.differentTypeElemsRead1(memoryBuffer7, size0,
hasNull0, collection2);
}
}
Object object17 =
collectionSerializer0.onCollectionRead(collection2);
object19 = object17;
} else {
Object object18 = collectionSerializer0.read(memoryBuffer7);
object19 = object18;
}
Platform.putObject(video5, 24L,
((com.google.common.collect.ImmutableSet)object19));
} else {
Platform.putObject(video5, 24L, null);
}
}
private void differentTypeElemsRead2(MemoryBuffer memoryBuffer8, boolean
value45, java.util.Collection collection3, int value46) {
ClassResolver classResolver = this.classResolver;
ClassInfo countryContentRatingClassInfo =
this.countryContentRatingClassInfo;
for (int i3 = 0; i3 < value46; i3+=1) {
if (value45) {
if ((memoryBuffer8.readByte() != ((byte)-3))) {
collection3.add(classResolver.readClassInfo(memoryBuffer8,
countryContentRatingClassInfo).getSerializer().read(memoryBuffer8));
} else {
collection3.add(null);
}
} else {
collection3.add(classResolver.readClassInfo(memoryBuffer8,
countryContentRatingClassInfo).getSerializer().read(memoryBuffer8));
}
}
}
private void readFields6(MemoryBuffer memoryBuffer9,
com.endeavorstreaming.vesper.content_engine.common.domain.video.Video video6) {
ClassResolver classResolver = this.classResolver;
if ((memoryBuffer9.readByte() != ((byte)-3))) {
AbstractCollectionSerializer collectionSerializer1 =
(AbstractCollectionSerializer)classResolver.readClassInfo(memoryBuffer9,
immutableSet1ClassInfoHolder).getSerializer();
Object object22;
if (collectionSerializer1.supportCodegenHook()) {
java.util.Collection collection4 =
collectionSerializer1.newCollection(memoryBuffer9);
int size1 = collectionSerializer1.getAndClearNumElements();
if ((size1 > 0)) {
int flags1 = memoryBuffer9.readByte();
boolean sameElementClass1 = (flags1 & 8) != 8;
boolean hasNull1 = (flags1 & 2) == 2;
if (sameElementClass1) {
Serializer serializer4;
if (((flags1 & 4) != 4)) {
serializer4 = serializer3;
} else {
serializer4 =
classResolver.readClassInfo(memoryBuffer9,
countryContentRatingClassInfo).getSerializer();
}
for (int i4 = 0; i4 < size1; i4+=1) {
if (hasNull1) {
if ((memoryBuffer9.readByte() != ((byte)-3))) {
collection4.add(serializer4.read(memoryBuffer9));
} else {
collection4.add(null);
}
} else {
collection4.add(serializer4.read(memoryBuffer9));
}
}
} else {
this.differentTypeElemsRead2(memoryBuffer9, hasNull1,
collection4, size1);
}
}
Object object20 =
collectionSerializer1.onCollectionRead(collection4);
object22 = object20;
} else {
Object object21 = collectionSerializer1.read(memoryBuffer9);
object22 = object21;
}
Platform.putObject(video6, 44L,
((com.google.common.collect.ImmutableSet)object22));
} else {
Platform.putObject(video6, 44L, null);
}
}
private void differentTypeElemsRead3(MemoryBuffer memoryBuffer10, boolean
value49, java.util.Collection collection5, int value50) {
ClassResolver classResolver = this.classResolver;
ClassInfo downloadToGoPolicyClassInfo =
this.downloadToGoPolicyClassInfo;
for (int i5 = 0; i5 < value50; i5+=1) {
if (value49) {
if ((memoryBuffer10.readByte() != ((byte)-3))) {
collection5.add(classResolver.readClassInfo(memoryBuffer10,
downloadToGoPolicyClassInfo).getSerializer().read(memoryBuffer10));
} else {
collection5.add(null);
}
} else {
collection5.add(classResolver.readClassInfo(memoryBuffer10,
downloadToGoPolicyClassInfo).getSerializer().read(memoryBuffer10));
}
}
}
private void readFields7(MemoryBuffer memoryBuffer11,
com.endeavorstreaming.vesper.content_engine.common.domain.video.Video video7) {
ClassResolver classResolver = this.classResolver;
if ((memoryBuffer11.readByte() != ((byte)-3))) {
AbstractCollectionSerializer collectionSerializer2 =
(AbstractCollectionSerializer)classResolver.readClassInfo(memoryBuffer11,
immutableSet2ClassInfoHolder).getSerializer();
Object object25;
if (collectionSerializer2.supportCodegenHook()) {
java.util.Collection collection6 =
collectionSerializer2.newCollection(memoryBuffer11);
int size2 = collectionSerializer2.getAndClearNumElements();
if ((size2 > 0)) {
int flags2 = memoryBuffer11.readByte();
boolean sameElementClass2 = (flags2 & 8) != 8;
boolean hasNull2 = (flags2 & 2) == 2;
if (sameElementClass2) {
Serializer serializer6;
if (((flags2 & 4) != 4)) {
serializer6 = serializer5;
} else {
serializer6 =
classResolver.readClassInfo(memoryBuffer11,
downloadToGoPolicyClassInfo).getSerializer();
}
for (int i6 = 0; i6 < size2; i6+=1) {
if (hasNull2) {
if ((memoryBuffer11.readByte() != ((byte)-3))) {
collection6.add(serializer6.read(memoryBuffer11));
} else {
collection6.add(null);
}
} else {
collection6.add(serializer6.read(memoryBuffer11));
}
}
} else {
this.differentTypeElemsRead3(memoryBuffer11, hasNull2,
collection6, size2);
}
}
Object object23 =
collectionSerializer2.onCollectionRead(collection6);
object25 = object23;
} else {
Object object24 = collectionSerializer2.read(memoryBuffer11);
object25 = object24;
}
Platform.putObject(video7, 132L,
((com.google.common.collect.ImmutableSet)object25));
} else {
Platform.putObject(video7, 132L, null);
}
}
private void differentTypeElemsRead4(MemoryBuffer memoryBuffer12,
java.util.Collection collection7, boolean value53, int value54) {
ClassResolver classResolver = this.classResolver;
ClassInfo downloadablePlaybackClassInfo =
this.downloadablePlaybackClassInfo;
for (int i7 = 0; i7 < value54; i7+=1) {
if (value53) {
if ((memoryBuffer12.readByte() != ((byte)-3))) {
collection7.add(classResolver.readClassInfo(memoryBuffer12,
downloadablePlaybackClassInfo).getSerializer().read(memoryBuffer12));
} else {
collection7.add(null);
}
} else {
collection7.add(classResolver.readClassInfo(memoryBuffer12,
downloadablePlaybackClassInfo).getSerializer().read(memoryBuffer12));
}
}
}
private void readFields8(MemoryBuffer memoryBuffer13,
com.endeavorstreaming.vesper.content_engine.common.domain.video.Video video8) {
ClassResolver classResolver = this.classResolver;
if ((memoryBuffer13.readByte() != ((byte)-3))) {
AbstractCollectionSerializer collectionSerializer3 =
(AbstractCollectionSerializer)classResolver.readClassInfo(memoryBuffer13,
immutableSet3ClassInfoHolder).getSerializer();
Object object28;
if (collectionSerializer3.supportCodegenHook()) {
java.util.Collection collection8 =
collectionSerializer3.newCollection(memoryBuffer13);
int size3 = collectionSerializer3.getAndClearNumElements();
if ((size3 > 0)) {
int flags3 = memoryBuffer13.readByte();
boolean sameElementClass3 = (flags3 & 8) != 8;
boolean hasNull3 = (flags3 & 2) == 2;
if (sameElementClass3) {
Serializer serializer8;
if (((flags3 & 4) != 4)) {
serializer8 = serializer7;
} else {
serializer8 =
classResolver.readClassInfo(memoryBuffer13,
downloadablePlaybackClassInfo).getSerializer();
}
for (int i8 = 0; i8 < size3; i8+=1) {
if (hasNull3) {
if ((memoryBuffer13.readByte() != ((byte)-3))) {
collection8.add(serializer8.read(memoryBuffer13));
} else {
collection8.add(null);
}
} else {
collection8.add(serializer8.read(memoryBuffer13));
}
}
} else {
this.differentTypeElemsRead4(memoryBuffer13,
collection8, hasNull3, size3);
}
}
Object object26 =
collectionSerializer3.onCollectionRead(collection8);
object28 = object26;
} else {
Object object27 = collectionSerializer3.read(memoryBuffer13);
object28 = object27;
}
Platform.putObject(video8, 112L,
((com.google.common.collect.ImmutableSet)object28));
} else {
Platform.putObject(video8, 112L, null);
}
}
private void differentTypeElemsRead5(MemoryBuffer memoryBuffer14, int
value57, java.util.Collection collection9, boolean value58) {
ClassResolver classResolver = this.classResolver;
ClassInfo subtitleStreamClassInfo = this.subtitleStreamClassInfo;
for (int i9 = 0; i9 < value57; i9+=1) {
if (value58) {
if ((memoryBuffer14.readByte() != ((byte)-3))) {
collection9.add(classResolver.readClassInfo(memoryBuffer14,
subtitleStreamClassInfo).getSerializer().read(memoryBuffer14));
} else {
collection9.add(null);
}
} else {
collection9.add(classResolver.readClassInfo(memoryBuffer14,
subtitleStreamClassInfo).getSerializer().read(memoryBuffer14));
}
}
}
private void readFields9(MemoryBuffer memoryBuffer15,
com.endeavorstreaming.vesper.content_engine.common.domain.video.Video video9) {
ClassResolver classResolver = this.classResolver;
if ((memoryBuffer15.readByte() != ((byte)-3))) {
AbstractCollectionSerializer collectionSerializer4 =
(AbstractCollectionSerializer)classResolver.readClassInfo(memoryBuffer15,
immutableSet4ClassInfoHolder).getSerializer();
Object object31;
if (collectionSerializer4.supportCodegenHook()) {
java.util.Collection collection10 =
collectionSerializer4.newCollection(memoryBuffer15);
int size4 = collectionSerializer4.getAndClearNumElements();
if ((size4 > 0)) {
int flags4 = memoryBuffer15.readByte();
boolean sameElementClass4 = (flags4 & 8) != 8;
boolean hasNull4 = (flags4 & 2) == 2;
if (sameElementClass4) {
Serializer serializer10;
if (((flags4 & 4) != 4)) {
serializer10 = serializer9;
} else {
serializer10 =
classResolver.readClassInfo(memoryBuffer15,
subtitleStreamClassInfo).getSerializer();
}
for (int i10 = 0; i10 < size4; i10+=1) {
if (hasNull4) {
if ((memoryBuffer15.readByte() != ((byte)-3))) {
collection10.add(serializer10.read(memoryBuffer15));
} else {
collection10.add(null);
}
} else {
collection10.add(serializer10.read(memoryBuffer15));
}
}
} else {
this.differentTypeElemsRead5(memoryBuffer15, size4,
collection10, hasNull4);
}
}
Object object29 =
collectionSerializer4.onCollectionRead(collection10);
object31 = object29;
} else {
Object object30 = collectionSerializer4.read(memoryBuffer15);
object31 = object30;
}
Platform.putObject(video9, 96L,
((com.google.common.collect.ImmutableSet)object31));
} else {
Platform.putObject(video9, 96L, null);
}
}
private void differentTypeElemsRead6(MemoryBuffer memoryBuffer16,
java.util.Collection collection11, int value61, boolean value62) {
ClassResolver classResolver = this.classResolver;
ClassInfo textTagClassInfo = this.textTagClassInfo;
for (int i11 = 0; i11 < value61; i11+=1) {
if (value62) {
if ((memoryBuffer16.readByte() != ((byte)-3))) {
collection11.add(classResolver.readClassInfo(memoryBuffer16,
textTagClassInfo).getSerializer().read(memoryBuffer16));
} else {
collection11.add(null);
}
} else {
collection11.add(classResolver.readClassInfo(memoryBuffer16,
textTagClassInfo).getSerializer().read(memoryBuffer16));
}
}
}
private void readFields10(MemoryBuffer memoryBuffer17,
com.endeavorstreaming.vesper.content_engine.common.domain.video.Video video10) {
ClassResolver classResolver = this.classResolver;
if ((memoryBuffer17.readByte() != ((byte)-3))) {
AbstractCollectionSerializer collectionSerializer5 =
(AbstractCollectionSerializer)classResolver.readClassInfo(memoryBuffer17,
immutableSet5ClassInfoHolder).getSerializer();
Object object34;
if (collectionSerializer5.supportCodegenHook()) {
java.util.Collection collection12 =
collectionSerializer5.newCollection(memoryBuffer17);
int size5 = collectionSerializer5.getAndClearNumElements();
if ((size5 > 0)) {
int flags5 = memoryBuffer17.readByte();
boolean sameElementClass5 = (flags5 & 8) != 8;
boolean hasNull5 = (flags5 & 2) == 2;
if (sameElementClass5) {
Serializer serializer12;
if (((flags5 & 4) != 4)) {
serializer12 = serializer11;
} else {
serializer12 =
classResolver.readClassInfo(memoryBuffer17, textTagClassInfo).getSerializer();
}
for (int i12 = 0; i12 < size5; i12+=1) {
if (hasNull5) {
if ((memoryBuffer17.readByte() != ((byte)-3))) {
collection12.add(serializer12.read(memoryBuffer17));
} else {
collection12.add(null);
}
} else {
collection12.add(serializer12.read(memoryBuffer17));
}
}
} else {
this.differentTypeElemsRead6(memoryBuffer17,
collection12, size5, hasNull5);
}
}
Object object32 =
collectionSerializer5.onCollectionRead(collection12);
object34 = object32;
} else {
Object object33 = collectionSerializer5.read(memoryBuffer17);
object34 = object33;
}
Platform.putObject(video10, 20L,
((com.google.common.collect.ImmutableSet)object34));
} else {
Platform.putObject(video10, 20L, null);
}
}
private int readChunk(MemoryBuffer memoryBuffer18, java.util.Map map, int
value65, int value66) {
ClassResolver classResolver = this.classResolver;
int chunkSize = memoryBuffer18.readUnsignedByte();
Serializer serializer14;
if (((value66 & 4) != 0)) {
serializer14 = replaceResolveSerializer1;
} else {
serializer14 = classResolver.readClassInfo(memoryBuffer18,
contentSourceIdClassInfo).getSerializer();
}
Serializer serializer15;
if (((value66 & 32) != 0)) {
serializer15 = serializer13;
} else {
serializer15 = classResolver.readClassInfo(memoryBuffer18,
contentSourceClassInfo).getSerializer();
}
for (int i13 = 0; i13 < chunkSize; i13+=1) {
Object object35 = serializer14.read(memoryBuffer18);
Object object36 = serializer15.read(memoryBuffer18);
map.put(object35, object36);
value65 = (value65 - 1);
}
if ((value65 > 0)) {
return ((value65 << 8) | memoryBuffer18.readUnsignedByte());
} else {
return 0;
}
}
private void readFields11(MemoryBuffer memoryBuffer19,
com.endeavorstreaming.vesper.content_engine.common.domain.video.Video video11) {
if ((memoryBuffer19.readByte() != ((byte)-3))) {
AbstractMapSerializer mapSerializer =
(AbstractMapSerializer)classResolver.readClassInfo(memoryBuffer19,
immutableMapClassInfoHolder).getSerializer();
Object object38;
if (mapSerializer.supportCodegenHook()) {
java.util.Map map0 = mapSerializer.newMap(memoryBuffer19);
int size6 = mapSerializer.getAndClearNumElements();
int value67;
if ((size6 == 0)) {
value67 = 0;
} else {
value67 = memoryBuffer19.readUnsignedByte();
}
while ((size6 > 0)) {
long sizeAndHeader =
mapSerializer.readJavaNullChunk(memoryBuffer19, map0, value67, size6, null,
null);
value67 = ((int)(sizeAndHeader & 255));
size6 = ((int)(sizeAndHeader >>> 8));
if ((size6 == 0)) {
break;
}
int value68 = this.readChunk(memoryBuffer19, map0, size6,
value67);
value67 = (value68 & 255);
size6 = (value68 >>> 8);
}
object38 = mapSerializer.onMapRead(map0);
} else {
Object object37 = mapSerializer.read(memoryBuffer19);
object38 = object37;
}
Platform.putObject(video11, 128L,
((com.google.common.collect.ImmutableMap)object38));
} else {
Platform.putObject(video11, 128L, null);
}
}
@Override public final Object read(MemoryBuffer buffer) {
Object instance =
Platform.newInstance(com.endeavorstreaming.vesper.content_engine.common.domain.video.Video.class);
com.endeavorstreaming.vesper.content_engine.common.domain.video.Video
video12 =
(com.endeavorstreaming.vesper.content_engine.common.domain.video.Video)instance;
refResolver.reference(video12);
this.readFields(buffer, video12);
this.readFields1(buffer, video12);
this.readFields2(buffer, video12);
this.readFields3(buffer, video12);
this.readFields4(buffer, video12);
this.readFields5(buffer, video12);
this.readFields6(buffer, video12);
this.readFields7(buffer, video12);
this.readFields8(buffer, video12);
this.readFields9(buffer, video12);
this.readFields10(buffer, video12);
this.readFields11(buffer, video12);
return video12;
}
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
