src/main/java/com/uber/rss/messages/ConnectDownloadRequest.java [55:65]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void serialize(ByteBuf buf) {
        ByteBufUtils.writeLengthAndString(buf, user);
        ByteBufUtils.writeLengthAndString(buf, appId);
        ByteBufUtils.writeLengthAndString(buf, appAttempt);
        buf.writeInt(shuffleId);
        buf.writeInt(partitionId);
        buf.writeInt(taskAttemptIds.size());
        for (Long entry: taskAttemptIds) {
            buf.writeLong(entry);
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/uber/rss/messages/ConnectDownloadRequestMessage.java [59:69]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void serialize(ByteBuf buf) {
        ByteBufUtils.writeLengthAndString(buf, user);
        ByteBufUtils.writeLengthAndString(buf, appId);
        ByteBufUtils.writeLengthAndString(buf, appAttempt);
        buf.writeInt(shuffleId);
        buf.writeInt(partitionId);
        buf.writeInt(taskAttemptIds.size());
        for (Long entry: taskAttemptIds) {
            buf.writeLong(entry);
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -