jni: Update java publisherStatus API.
Still need to update baku-toolkit usage:
(1) Publish a new release version of vanadium java.
(2) Update baku-toolkit code, bumping up the version of vanadium java
used by the test.
Change-Id: Id64defaea4b3562e34b9cf36bd93c5e1a688bf37
MultiPart: 1/2
diff --git a/impl/google/rpc/jni.go b/impl/google/rpc/jni.go
index dce3089..868ed63 100644
--- a/impl/google/rpc/jni.go
+++ b/impl/google/rpc/jni.go
@@ -60,8 +60,8 @@
jListenSpecClass jutil.Class
// Global reference for io.v.v23.rpc.ListenSpec$Address class.
jListenSpecAddressClass jutil.Class
- // Global reference for io.v.v23.rpc.MountStatus class.
- jMountStatusClass jutil.Class
+ // Global reference for io.v.v23.rpc.PublisherEntry class.
+ jPublisherEntryClass jutil.Class
// Global reference for io.v.v23.rpc.NetworkAddress class.
jNetworkAddressClass jutil.Class
// Global reference for io.v.v23.rpc.ProxyStatus class.
@@ -140,7 +140,7 @@
if err != nil {
return err
}
- jMountStatusClass, err = jutil.JFindClass(env, "io/v/v23/rpc/MountStatus")
+ jPublisherEntryClass, err = jutil.JFindClass(env, "io/v/v23/rpc/PublisherEntry")
if err != nil {
return err
}
diff --git a/impl/google/rpc/util.go b/impl/google/rpc/util.go
index 2be58ec..49f49b3 100644
--- a/impl/google/rpc/util.go
+++ b/impl/google/rpc/util.go
@@ -113,11 +113,11 @@
pubarr := make([]jutil.Object, len(status.PublisherStatus))
for i, e := range status.PublisherStatus {
var err error
- if pubarr[i], err = JavaMountStatus(env, e); err != nil {
+ if pubarr[i], err = JavaPublisherEntry(env, e); err != nil {
return jutil.NullObject, err
}
}
- jPublisherStatus, err := jutil.JObjectArray(env, pubarr, jMountStatusClass)
+ jPublisherStatus, err := jutil.JObjectArray(env, pubarr, jPublisherEntryClass)
if err != nil {
return jutil.NullObject, err
}
@@ -159,8 +159,8 @@
}
// Create final server status.
- mountStatusSign := jutil.ClassSign("io.v.v23.rpc.MountStatus")
- jServerStatus, err := jutil.NewObject(env, jServerStatusClass, []jutil.Sign{serverStateSign, jutil.BoolSign, jutil.ArraySign(mountStatusSign), jutil.ArraySign(jutil.StringSign), jutil.MapSign, jutil.MapSign}, jState, status.ServesMountTable, jPublisherStatus, eps, jLnErrors, jProxyErrors)
+ publisherEntrySign := jutil.ClassSign("io.v.v23.rpc.PublisherEntry")
+ jServerStatus, err := jutil.NewObject(env, jServerStatusClass, []jutil.Sign{serverStateSign, jutil.BoolSign, jutil.ArraySign(publisherEntrySign), jutil.ArraySign(jutil.StringSign), jutil.MapSign, jutil.MapSign}, jState, status.ServesMountTable, jPublisherStatus, eps, jLnErrors, jProxyErrors)
if err != nil {
return jutil.NullObject, err
}
@@ -184,12 +184,12 @@
return jutil.CallStaticObjectMethod(env, jServerStateClass, "valueOf", []jutil.Sign{jutil.StringSign}, serverStateSign, name)
}
-// JavaMountStatus converts the provided rpc.PublisherEntry value into a Java
-// MountStatus object.
-// TODO(suharshs): Convert the Java API from MountStatus to PublisherEntry and add PublisherEntry
-// to the Java PublisherEntry (maybe).
-func JavaMountStatus(env jutil.Env, entry rpc.PublisherEntry) (jutil.Object, error) {
- jStatus, err := jutil.NewObject(env, jMountStatusClass, []jutil.Sign{jutil.StringSign, jutil.StringSign, jutil.DateTimeSign, jutil.VExceptionSign, jutil.DurationSign, jutil.DateTimeSign, jutil.VExceptionSign}, entry.Name, entry.Server, entry.LastMount, entry.LastMountErr, entry.TTL, entry.LastUnmount, entry.LastUnmountErr)
+// JavaPublisherEntry converts the provided rpc.PublisherEntry value into a Java
+// PublisherEntry object.
+// TODO(suharshs): Add PublisherState to the java publisher entry? May not make sense, since there is no
+// notification channel in Java.
+func JavaPublisherEntry(env jutil.Env, entry rpc.PublisherEntry) (jutil.Object, error) {
+ jStatus, err := jutil.NewObject(env, jPublisherEntryClass, []jutil.Sign{jutil.StringSign, jutil.StringSign, jutil.DateTimeSign, jutil.VExceptionSign, jutil.DurationSign, jutil.DateTimeSign, jutil.VExceptionSign}, entry.Name, entry.Server, entry.LastMount, entry.LastMountErr, entry.TTL, entry.LastUnmount, entry.LastUnmountErr)
if err != nil {
return jutil.NullObject, err
}
