| // Copyright 2015 The Vanadium Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style |
| // license that can be found in the LICENSE file. |
| |
| // +build java android |
| |
| package syncbased |
| |
| import ( |
| "unsafe" |
| |
| "v.io/x/ref/services/syncbase/server" |
| "v.io/v23" |
| |
| jrpc "v.io/x/jni/impl/google/rpc" |
| jutil "v.io/x/jni/util" |
| jcontext "v.io/x/jni/v23/context" |
| jaccess "v.io/x/jni/v23/security/access" |
| ) |
| |
| // #include "jni.h" |
| import "C" |
| |
| var ( |
| permissionsSign = jutil.ClassSign("io.v.v23.security.access.Permissions") |
| listenSpecSign = jutil.ClassSign("io.v.v23.rpc.ListenSpec") |
| contextSign = jutil.ClassSign("io.v.v23.context.VContext") |
| syncbaseStorageEngineSign = jutil.ClassSign("io.v.v23.syncbase.SyncbaseStorageEngine") |
| |
| jSystemClass jutil.Class |
| jVClass jutil.Class |
| ) |
| |
| func Init(env jutil.Env) error { |
| var err error |
| jSystemClass, err = jutil.JFindClass(env, "java/lang/System") |
| if err != nil { |
| return err |
| } |
| jVClass, err = jutil.JFindClass(env, "io/v/v23/V") |
| if err != nil { |
| return err |
| } |
| return nil |
| } |
| |
| //export Java_io_v_impl_google_services_syncbase_syncbased_SyncbaseServer_nativeInit |
| func Java_io_v_impl_google_services_syncbase_syncbased_SyncbaseServer_nativeInit(jenv *C.JNIEnv, jSyncbaseServerClass C.jclass) { |
| env := jutil.WrapEnv(jenv) |
| if err := Init(env); err != nil { |
| jutil.JThrowV(env, err) |
| return |
| } |
| } |
| |
| //export Java_io_v_impl_google_services_syncbase_syncbased_SyncbaseServer_nativeStart |
| func Java_io_v_impl_google_services_syncbase_syncbased_SyncbaseServer_nativeStart(jenv *C.JNIEnv, jSyncbaseServerClass C.jclass, jContext C.jobject, jSyncbaseServerParams C.jobject) C.jobject { |
| env := jutil.WrapEnv(jenv) |
| jCtx := jutil.WrapObject(jContext) |
| jParams := jutil.WrapObject(jSyncbaseServerParams) |
| |
| // Read and translate all of the server params. |
| jPerms, err := jutil.CallObjectMethod(env, jParams, "getPermissions", nil, permissionsSign) |
| if err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| perms, err := jaccess.GoPermissions(env, jPerms) |
| if err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| jListenSpec, err := jutil.CallObjectMethod(env, jParams, "getListenSpec", nil, listenSpecSign) |
| if err != nil { |
| jutil.JThrowV(env, err) |
| |
| return nil |
| } |
| if jListenSpec.IsNull() { |
| jListenSpec, err = jutil.CallStaticObjectMethod(env, jVClass, "getListenSpec", []jutil.Sign{contextSign}, listenSpecSign, jCtx) |
| if err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| } |
| listenSpec, err := jrpc.GoListenSpec(env, jListenSpec) |
| if err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| name, err := jutil.CallStringMethod(env, jParams, "getName", nil) |
| if err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| rootDir, err := jutil.CallStringMethod(env, jParams, "getStorageRootDir", nil) |
| if err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| if rootDir == "" { |
| rootDir, err = jutil.CallStaticStringMethod(env, jSystemClass, "getProperty", []jutil.Sign{jutil.StringSign}, "java.io.tmpdir") |
| if err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| } |
| jEngine, err := jutil.CallObjectMethod(env, jParams, "getStorageEngine", nil, syncbaseStorageEngineSign) |
| if err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| engine, err := GoStorageEngine(env, jEngine) |
| if err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| |
| // Start the server. |
| ctx, err := jcontext.GoContext(env, jCtx) |
| if err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| s, err := v23.NewServer(ctx) |
| if err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| _, err = s.Listen(listenSpec) |
| if err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| service, err := server.NewService(ctx, nil, server.ServiceOptions{ |
| Perms: perms, |
| RootDir: rootDir, |
| Engine: engine, |
| }) |
| if err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| dispatcher := server.NewDispatcher(service) |
| if err := s.ServeDispatcher(name, dispatcher); err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| jServer, err := jrpc.JavaServer(env, s) |
| if err != nil { |
| jutil.JThrowV(env, err) |
| return nil |
| } |
| return C.jobject(unsafe.Pointer(jServer)) |
| } |