core/veyron/runtimes/google/naming/jni.go

// +build android

package naming

import (
	"log"

	jchannel "v.io/jni/core/veyron/runtimes/google/channel"
	jutil "v.io/jni/util"
	jcontext "v.io/jni/v23/context"
	"v.io/v23/naming"
	"v.io/v23/naming/ns"
)

// #cgo LDFLAGS: -ljniwrapper
// #include "jni_wrapper.h"
import "C"

var (
	// Global reference for io.v.core.veyron.runtimes.google.naming.ns.Namespace class.
	jNamespaceImplClass C.jclass
)

// Init initializes the JNI code with the given Java environment. This method
// must be called from the main Java thread.
// NOTE: Because CGO creates package-local types and because this method may be
// invoked from a different package, Java environment is passed in an empty
// interface and then cast into the package-local environment type.
func Init(jEnv interface{}) error {
	class, err := jutil.JFindClass(jEnv, "io/v/core/veyron/runtimes/google/naming/ns/Namespace")
	if err != nil {
		return err
	}
	jNamespaceImplClass = C.jclass(class)
	return nil
}

//export Java_io_v_core_veyron_runtimes_google_naming_ns_Namespace_nativeGlob
func Java_io_v_core_veyron_runtimes_google_naming_ns_Namespace_nativeGlob(env *C.JNIEnv, jNamespace C.jobject, goNamespacePtr C.jlong, jContext C.jobject, pattern C.jstring) C.jobject {
	n := *(*ns.Namespace)(jutil.Ptr(goNamespacePtr))
	context, err := jcontext.GoContext(env, jContext)
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}
	entryChan, err := n.Glob(context, jutil.GoString(env, pattern))
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}

	retChan := make(chan C.jobject, 100)
	go func() {
		for entry := range entryChan {
			switch v := entry.(type) {
			case *naming.MountEntry:
				jEnv, freeFunc := jutil.GetEnv()
				env := (*C.JNIEnv)(jEnv)
				defer freeFunc()
				jMountEntry, err := JavaMountEntry(env, v)
				if err != nil {
					log.Println("Couldn't convert Go MountEntry %v to Java", v)
					continue
				}
				jMountEntry = C.NewGlobalRef(env, jMountEntry)
				retChan <- jMountEntry
			case *naming.GlobError:
				// Silently drop.
				// TODO(spetrovic): convert to Java counter-part.
			default:
				log.Printf("Encountered value %v of unexpected type %T", entry, entry)
			}
		}
		close(retChan)
	}()
	jInputChannel, err := jchannel.JavaInputChannel(env, &retChan, &entryChan)
	if err != nil {
		jutil.JThrowV(env, err)
		return nil
	}
	return C.jobject(jInputChannel)
}

//export Java_io_v_core_veyron_runtimes_google_naming_ns_Namespace_nativeFinalize
func Java_io_v_core_veyron_runtimes_google_naming_ns_Namespace_nativeFinalize(env *C.JNIEnv, jNamespace C.jobject, goNamespacePtr C.jlong) {
	jutil.GoUnref((*ns.Namespace)(jutil.Ptr(goNamespacePtr)))
}