GRPC Stream implementation of HeliumStream

blimp/client/app/android/blimp_client_session_android.cc

 // Copyright 2015 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "blimp/client/app/android/blimp_client_session_android.h"
 
 #include <string>
 
 #include "base/android/jni_string.h"
 #include "base/android/scoped_java_ref.h"
@@ skipping 93 matching lines @@
     JNIEnv* env,
     const base::android::JavaParamRef<jobject>& jobj) {
   delete this;
 }
 
 void BlimpClientSessionAndroid::OnAssignmentConnectionAttempted(
     AssignmentRequestResult result,
     const Assignment& assignment) {
   // Notify the front end of the assignment result.
   std::string engine_ip = IPAddressToStringWithPort(
-      assignment.engine_endpoint.address(), assignment.engine_endpoint.port());
+      assignment.assignment_options.engine_endpoint.address(),
+      assignment.assignment_options.engine_endpoint.port());
   JNIEnv* env = base::android::AttachCurrentThread();
   Java_BlimpClientSession_onAssignmentReceived(
       env, java_obj_, static_cast<jint>(result),
       base::android::ConvertUTF8ToJavaString(env, engine_ip),
       base::android::ConvertUTF8ToJavaString(env,
                                              version_info::GetVersionNumber()));
 
   BlimpClientSession::OnAssignmentConnectionAttempted(result, assignment);
 }
 
 base::android::ScopedJavaLocalRef<jintArray>
 BlimpClientSessionAndroid::GetDebugInfo(
     JNIEnv* env,
     const base::android::JavaParamRef<jobject>& jobj) {
   BlimpStats* stats = BlimpStats::GetInstance();
   int metrics[] = {stats->Get(BlimpStats::BYTES_RECEIVED),
                    stats->Get(BlimpStats::BYTES_SENT),
                    stats->Get(BlimpStats::COMMIT)};
   return base::android::ToJavaIntArray(env, metrics, arraysize(metrics));
 }
 
 }  // namespace client
 }  // namespace blimp