java类com.google.protobuf.nano.MessageNano的实例源码

@Nullable
public static <T extends MessageNano> T readFromFile(@NonNull final Context context,
        @NonNull final String fileName,
        @NonNull final T obj) {
    T message = null;
    try {
        final byte[] bytes = FileUtils.readPrivateFile(context, fileName);
        message = MessageNano.mergeFrom(obj, bytes);
    } catch (IOException e) {
        Log.w(TAG, e);
    }

    return message;
}

@NonNull
public static <T extends MessageNano> T readFromFileNonNull(@NonNull final Context context,
        @NonNull final String fileName,
        @NonNull final T obj) {
    final T message = readFromFile(context, fileName, obj);
    return message != null ? message : obj;
}

@Test
public void testToByteArray() throws Exception {
    final WearPlaybackData.PlaybackPosition message = new WearPlaybackData.PlaybackPosition();
    message.mediaId = 666L;
    message.position = 5;

    final byte[] data = ProtoUtils.toByteArray(message);
    assertNotNull(data);

    final WearPlaybackData.PlaybackPosition fromBytes = MessageNano.mergeFrom(
            new WearPlaybackData.PlaybackPosition(), data);

    assertEquals(message.mediaId, fromBytes.mediaId);
    assertEquals(message.position, fromBytes.position);
}

@NonNull
private static MessageNano toWearablePlaybackState(
        @PlaybackState.State final int state) {
    final WearPlaybackData.PlaybackState m = new WearPlaybackData.PlaybackState();
    m.state = state;
    return m;
}

@NonNull
private static MessageNano toWearablePlaybackPosition(final long mediaId,
        final long position) {
    final WearPlaybackData.PlaybackPosition m = new WearPlaybackData.PlaybackPosition();
    m.mediaId = mediaId;
    m.position = position;
    return m;
}

public final Map<String, String> getParams()
  throws AuthFailureError
{
  HashMap localHashMap = new HashMap();
  MessageNano localMessageNano = this.mRequest;
  VendingProtos.RequestProto.Request localRequest = new VendingProtos.RequestProto.Request();
  NanoProtoHelper.setRequestInWrapper(localRequest, VendingProtos.RequestProto.Request.class, localMessageNano, this.mRequestClass);
  VendingProtos.RequestProto localRequestProto = new VendingProtos.RequestProto();
  localRequestProto.requestProperties = this.mApiContext.getRequestProperties(this.mUseSecureAuthToken);
  localRequestProto.request = new VendingProtos.RequestProto.Request[] { localRequest };
  localHashMap.put("request", Base64.encodeToString(MessageNano.toByteArray(localRequestProto), 11));
  localHashMap.put("version", "2");
  return localHashMap;
}

public static void reportUserResponse(Context paramContext, CsdClient.VerifyAppsReport paramVerifyAppsReport)
{
  byte[] arrayOfByte = MessageNano.toByteArray(paramVerifyAppsReport);
  Intent localIntent = new Intent("log_user_response");
  localIntent.setClass(paramContext, PackageVerificationLoggingService.class);
  localIntent.putExtra("proto_bytes", arrayOfByte);
  paramContext.startService(localIntent);
}

protected final Response<PackageVerificationResult> parseNetworkResponse(NetworkResponse paramNetworkResponse)
{
  try
  {
    byte[] arrayOfByte = paramNetworkResponse.data;
    CsdClient.ClientDownloadResponse localClientDownloadResponse = (CsdClient.ClientDownloadResponse)MessageNano.mergeFrom$1ec43da(new CsdClient.ClientDownloadResponse(), arrayOfByte, arrayOfByte.length);
    return Response.success(PackageVerificationResult.fromResponse(localClientDownloadResponse), null);
  }
  catch (InvalidProtocolBufferNanoException localInvalidProtocolBufferNanoException)
  {
    return Response.error(new VolleyError(localInvalidProtocolBufferNanoException));
  }
}

public ProtoDfeRequest(String paramString, MessageNano paramMessageNano, DfeApiContext paramDfeApiContext, Class<T> paramClass, Response.Listener<T> paramListener, Response.ErrorListener paramErrorListener)
{
  super(paramString, paramDfeApiContext, paramClass, paramListener, paramErrorListener, (byte)0);
  this.mRequest = paramMessageNano;
  this.mShouldCache = false;
  this.mIncludeCheckinConsistencyToken = true;
  this.mAvoidBulkCancel = true;
}

private static boolean decodeFromString(String paramString, MessageNano paramMessageNano)
{
  try
  {
    byte[] arrayOfByte = Base64.decode(paramString, 3);
    MessageNano.mergeFrom$1ec43da(paramMessageNano, arrayOfByte, arrayOfByte.length);
    return true;
  }
  catch (InvalidProtocolBufferNanoException localInvalidProtocolBufferNanoException)
  {
    FinskyLog.e(localInvalidProtocolBufferNanoException, "Error parsing string into proto", new Object[0]);
  }
  return false;
}