mirror of
https://github.com/HDFGroup/hdf5.git
synced 2024-11-27 02:10:55 +08:00
Add back missing java implementation
This commit is contained in:
Allen Byrne
parent
e3e9cf04b0
commit
dcab85c83b
@ -23,14 +23,14 @@ import java.io.Serializable;
|
||||
* Used for the access of files hosted on the Hadoop Distributed File System.
|
||||
*/
|
||||
|
||||
@SuppressWarnings("serial") // mute default serialUID warnings until someone knowledgeable comes along or something breaks horribly
|
||||
public class H5FD_hdfs_fapl_t implements Serializable {
|
||||
private static final long serialVersionUID = 2072473407027648309L;
|
||||
|
||||
private long version;
|
||||
private int version;
|
||||
private String namenode_name;
|
||||
private int namenode_port;
|
||||
private String user_name;
|
||||
private String kerberos_ticket_cache;
|
||||
private int namenode_port;
|
||||
private int stream_buffer_size;
|
||||
|
||||
/*
|
||||
|
||||
@ -17,13 +17,14 @@ package hdf.hdf5lib.structs;
|
||||
import java.io.Serializable;
|
||||
|
||||
/*
|
||||
* Java representation of the ROS3 VFD file access property list (fapl)
|
||||
* Java representation of the ROS3 VFD file access property list (fapl)
|
||||
* structure.
|
||||
*
|
||||
* Used for the access of files hosted remotely on S3 by Amazon.
|
||||
*
|
||||
*
|
||||
* For simplicity, implemented assuming that all ROS3 fapls have components:
|
||||
* - version
|
||||
* - authenticate
|
||||
* - aws_region
|
||||
* - secret_id
|
||||
* - secret_key
|
||||
@ -38,14 +39,15 @@ import java.io.Serializable;
|
||||
* H5FD_ros3_fapl_v2_t (extends super with Version 2 components)
|
||||
* and so on, for each version
|
||||
*
|
||||
* "super" is passed around, and is version-checked and re-cast as
|
||||
* "super" is passed around, and is version-checked and re-cast as
|
||||
* appropriate
|
||||
*/
|
||||
|
||||
@SuppressWarnings("serial") // mute default serialUID warnings until someone knowledgeable comes along or something breaks horribly
|
||||
public class H5FD_ros3_fapl_t implements Serializable {
|
||||
private static final long serialVersionUID = 8985533001471224030L;
|
||||
|
||||
private long version;
|
||||
private int version;
|
||||
private boolean authenticate;
|
||||
private String aws_region;
|
||||
private String secret_id;
|
||||
private String secret_key;
|
||||
@ -111,10 +113,10 @@ public class H5FD_ros3_fapl_t implements Serializable {
|
||||
@Override
|
||||
public String toString() {
|
||||
return "H5FD_ros3_fapl_t (Version:" + this.version + ") {" +
|
||||
"\n aws_region : " + this.aws_region +
|
||||
"\n secret_id : " + this.secret_id +
|
||||
"\n secret_key : " + this.secret_key +
|
||||
"\n}\n";
|
||||
"\n aws_region : " + this.aws_region +
|
||||
"\n secret_id : " + this.secret_id +
|
||||
"\n secret_key : " + this.secret_key +
|
||||
"\n}\n";
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@ -370,6 +370,176 @@ done:
|
||||
return (jlong)offset;
|
||||
} /* end Java_hdf_hdf5lib_H5_H5Pget_1family_1offset */
|
||||
|
||||
/* Class: hdf_hdf5lib_H5
|
||||
* Method: H5Pset_fapl_hdfs
|
||||
* Signature: (J)Lhdf/hdf5lib/structs/H5FD_hdfs_fapl_t;
|
||||
*/
|
||||
JNIEXPORT jobject JNICALL
|
||||
Java_hdf_hdf5lib_H5_H5Pget_1fapl_1hdfs
|
||||
(JNIEnv *env, jclass clss, jlong fapl_id)
|
||||
{
|
||||
#ifdef H5_HAVE_LIBHDFS
|
||||
H5FD_hdfs_fapl_t fa;
|
||||
jvalue args[5];
|
||||
jint j_namenode_port = 0;
|
||||
jstring j_namenode_name = NULL;
|
||||
jstring j_user_name = NULL;
|
||||
jstring j_kerb_cache_path = NULL;
|
||||
jint j_stream_buffer_size = 0;
|
||||
#endif /* H5_HAVE_LIBHDFS */
|
||||
jobject ret_obj = NULL;
|
||||
|
||||
UNUSED(clss);
|
||||
|
||||
#ifdef H5_HAVE_LIBHDFS
|
||||
if (H5Pget_fapl_hdfs((hid_t)fapl_id, &fa) < 0)
|
||||
H5_LIBRARY_ERROR(ENVONLY);
|
||||
|
||||
if (NULL != fa.namenode_name) {
|
||||
if (NULL == (j_namenode_name = ENVPTR->NewStringUTF(ENVONLY, fa.namenode_name))) {
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_TRUE);
|
||||
H5_JNI_FATAL_ERROR(ENVONLY, "H5Pget_fapl_hdfs: out of memory - can't create namenode_name string");
|
||||
}
|
||||
}
|
||||
args[0].l = j_namenode_name;
|
||||
|
||||
args[1].i = (jint)fa.namenode_port;
|
||||
|
||||
if (NULL != fa.user_name) {
|
||||
if (NULL == (j_user_name = ENVPTR->NewStringUTF(ENVONLY, fa.user_name))) {
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_TRUE);
|
||||
H5_JNI_FATAL_ERROR(ENVONLY, "H5Pget_fapl_hdfs: out of memory - can't create user_name string");
|
||||
}
|
||||
}
|
||||
args[2].l = j_user_name;
|
||||
|
||||
if (NULL != fa.kerberos_ticket_cache) {
|
||||
if (NULL == (j_kerb_cache_path = ENVPTR->NewStringUTF(ENVONLY, fa.kerberos_ticket_cache))) {
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_TRUE);
|
||||
H5_JNI_FATAL_ERROR(ENVONLY, "H5Pget_fapl_hdfs: out of memory - can't create kerberos_ticket_cache string");
|
||||
}
|
||||
}
|
||||
args[3].l = j_kerb_cache_path;
|
||||
|
||||
args[4].i = (jint)fa.stream_buffer_size;
|
||||
|
||||
CALL_CONSTRUCTOR(ENVONLY, "hdf/hdf5lib/structs/H5FD_hdfs_fapl_t", "(Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;I)V", args, ret_obj);
|
||||
|
||||
done:
|
||||
#else
|
||||
H5_UNIMPLEMENTED(ENVONLY, "H5Pget_fapl_hdfs: not implemented");
|
||||
#endif /* H5_HAVE_LIBHDFS */
|
||||
return ret_obj;
|
||||
} /* end Java_hdf_hdf5lib_H5_H5Pget_1fapl_1hdfs */
|
||||
|
||||
/*
|
||||
* Class: hdf_hdf5lib_H5
|
||||
* Method: H5Pset_fapl_hdfs
|
||||
* Signature: (JLhdf/hdf5lib/structs/H5FD_hdfs_fapl_t;)V
|
||||
*/
|
||||
JNIEXPORT void JNICALL
|
||||
Java_hdf_hdf5lib_H5_H5Pset_1fapl_1hdfs
|
||||
(JNIEnv *env, jclass clss, jlong fapl_id, jobject fapl_config)
|
||||
{
|
||||
#ifdef H5_HAVE_LIBHDFS
|
||||
H5FD_hdfs_fapl_t instance;
|
||||
const char *str = NULL;
|
||||
jfieldID fid;
|
||||
jstring j_str;
|
||||
jclass cls;
|
||||
#endif /* H5_HAVE_LIBHDFS */
|
||||
|
||||
UNUSED(clss);
|
||||
|
||||
#ifdef H5_HAVE_LIBHDFS
|
||||
HDmemset(&instance, 0, sizeof(H5FD_hdfs_fapl_t));
|
||||
|
||||
if (NULL == (cls = ENVPTR->GetObjectClass(ENVONLY, fapl_config)))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (NULL == (fid = ENVPTR->GetFieldID(ENVONLY, cls, "version", "I")))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
instance.version = ENVPTR->GetIntField(ENVONLY, fapl_config, fid);
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (NULL == (fid = ENVPTR->GetFieldID(ENVONLY, cls, "namenode_name", "Ljava/lang/String;")))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (NULL == (j_str = (jstring)ENVPTR->GetObjectField(ENVONLY, fapl_config, fid)))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (j_str) {
|
||||
PIN_JAVA_STRING(ENVONLY, j_str, str, NULL, "H5FDset_fapl_hdfs: fapl_config namenode_name not pinned");
|
||||
|
||||
HDstrncpy(instance.namenode_name, str, H5FD__HDFS_NODE_NAME_SPACE + 1);
|
||||
instance.namenode_name[H5FD__HDFS_NODE_NAME_SPACE] = '\0';
|
||||
|
||||
UNPIN_JAVA_STRING(ENVONLY, j_str, str);
|
||||
str = NULL;
|
||||
}
|
||||
else
|
||||
HDmemset(instance.namenode_name, 0, H5FD__HDFS_NODE_NAME_SPACE + 1);
|
||||
|
||||
if (NULL == (fid = ENVPTR->GetFieldID(ENVONLY, cls, "namenode_port", "I")))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
instance.namenode_port = ENVPTR->GetIntField(ENVONLY, fapl_config, fid);
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (NULL == (fid = ENVPTR->GetFieldID(ENVONLY, cls, "user_name", "Ljava/lang/String;")))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (NULL == (j_str = (jstring)ENVPTR->GetObjectField(ENVONLY, fapl_config, fid)))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (j_str) {
|
||||
PIN_JAVA_STRING(ENVONLY, j_str, str, NULL, "H5FDset_fapl_hdfs: fapl_config user_name not pinned");
|
||||
|
||||
HDstrncpy(instance.user_name, str, H5FD__HDFS_USER_NAME_SPACE + 1);
|
||||
instance.user_name[H5FD__HDFS_USER_NAME_SPACE] = '\0';
|
||||
|
||||
UNPIN_JAVA_STRING(ENVONLY, j_str, str);
|
||||
str = NULL;
|
||||
}
|
||||
else
|
||||
HDmemset(instance.user_name, 0, H5FD__HDFS_USER_NAME_SPACE + 1);
|
||||
|
||||
if (NULL == (fid = ENVPTR->GetFieldID(ENVONLY, cls, "kerberos_ticket_cache", "Ljava/lang/String;")))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (NULL == (j_str = (jstring)ENVPTR->GetObjectField(ENVONLY, fapl_config, fid)))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (j_str) {
|
||||
PIN_JAVA_STRING(ENVONLY, j_str, str, NULL, "H5FDset_fapl_hdfs: fapl_config kerberos_ticket_cache not pinned");
|
||||
|
||||
HDstrncpy(instance.kerberos_ticket_cache, str, H5FD__HDFS_KERB_CACHE_PATH_SPACE + 1);
|
||||
instance.kerberos_ticket_cache[H5FD__HDFS_KERB_CACHE_PATH_SPACE] = '\0';
|
||||
|
||||
UNPIN_JAVA_STRING(ENVONLY, j_str, str);
|
||||
str = NULL;
|
||||
}
|
||||
else
|
||||
HDmemset(instance.kerberos_ticket_cache, 0, H5FD__HDFS_KERB_CACHE_PATH_SPACE + 1);
|
||||
|
||||
if (NULL == (fid = ENVPTR->GetFieldID(ENVONLY, cls, "stream_buffer_size", "I")))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
instance.stream_buffer_size = ENVPTR->GetIntField(ENVONLY, fapl_config, fid);
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (H5Pset_fapl_hdfs((hid_t) fapl_id, &instance) < 0)
|
||||
H5_LIBRARY_ERROR(ENVONLY);
|
||||
|
||||
done:
|
||||
if (str)
|
||||
UNPIN_JAVA_STRING(ENVONLY, j_str, str);
|
||||
#else
|
||||
H5_UNIMPLEMENTED(ENVONLY, "H5Pset_fapl_hdfs: not implemented");
|
||||
#endif /* H5_HAVE_LIBHDFS */
|
||||
} /* end Java_hdf_hdf5lib_H5_H5Pset_1fapl_1hdfs */
|
||||
|
||||
/*
|
||||
* Class: hdf_hdf5lib_H5
|
||||
* Method: H5Pset_fapl_log
|
||||
@ -616,6 +786,164 @@ done:
|
||||
* TODO: H5Pget_multi_type
|
||||
*/
|
||||
|
||||
/*
|
||||
* Class: hdf5_hdf5lib_H5
|
||||
* Method: H5Pget_fapl_ros3
|
||||
* Signature: (J)Lhdf/hdf5lib/structs/H5FD_ros3_fapl_t;
|
||||
*/
|
||||
JNIEXPORT jobject JNICALL
|
||||
Java_hdf_hdf5lib_H5_H5Pget_1fapl_1ros3
|
||||
(JNIEnv *env, jclass clss, jlong fapl_id)
|
||||
{
|
||||
#ifdef H5_HAVE_ROS3_VFD
|
||||
H5FD_ros3_fapl_t fa;
|
||||
jvalue args[3];
|
||||
jstring j_aws = NULL;
|
||||
jstring j_id = NULL;
|
||||
jstring j_key = NULL;
|
||||
#endif /* H5_HAVE_ROS3_VFD */
|
||||
jobject ret_obj = NULL;
|
||||
|
||||
UNUSED(clss);
|
||||
|
||||
#ifdef H5_HAVE_ROS3_VFD
|
||||
/* pass fapl and fapl_t instance into library get_fapl */
|
||||
/* store fapl details in ros3_fapl_t instance `fa` */
|
||||
if (H5Pget_fapl_ros3((hid_t)loc_id, &fa) < 0)
|
||||
H5_LIBRARY_ERROR(ENVONLY);
|
||||
|
||||
if (NULL != fa.aws_region) {
|
||||
if (NULL == (j_aws = ENVPTR->NewStringUTF(ENVONLY, fa.aws_region))) {
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_TRUE);
|
||||
H5_JNI_FATAL_ERROR(ENVONLY, "H5Pget_fapl_ros3: out of memory - can't create aws_region string");
|
||||
}
|
||||
}
|
||||
args[0].l = j_aws;
|
||||
|
||||
if (NULL != fa.secret_id) {
|
||||
if (NULL == (j_id = ENVPTR->NewStringUTF(ENVONLY, fa.secret_id))) {
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_TRUE);
|
||||
H5_JNI_FATAL_ERROR(ENVONLY, "H5Pget_fapl_ros3: out of memory - can't create secret_id string");
|
||||
}
|
||||
}
|
||||
args[1].l = j_id;
|
||||
|
||||
if (NULL != fa.secret_key) {
|
||||
if (NULL == (j_key = ENVPTR->NewStringUTF(ENVONLY, fa.secret_key))) {
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_TRUE);
|
||||
H5_JNI_FATAL_ERROR(ENVONLY, "H5Pget_fapl_ros3: out of memory - can't create secret_key string");
|
||||
}
|
||||
}
|
||||
args[2].l = j_key;
|
||||
|
||||
CALL_CONSTRUCTOR(ENVONLY, "hdf/hdf5lib/structs/H5FD_ros3_fapl_t", "(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;)V", args, ret_obj);
|
||||
|
||||
done:
|
||||
#else
|
||||
H5_UNIMPLEMENTED(ENVONLY, "H5Pget_fapl_ros3: not implemented");
|
||||
#endif /* H5_HAVE_ROS3_VFD */
|
||||
return ret_obj;
|
||||
} /* end Java_hdf_hdf5lib_H5_H5Pget_1fapl_1ros3 */
|
||||
|
||||
/*
|
||||
* Class: hdf_hdf5lib_H5
|
||||
* Method: H5Pset_fapl_ros3
|
||||
* Signature: (JLhdf/hdf5lib/structs/H5FD_ros3_fapl_t;)V
|
||||
*/
|
||||
JNIEXPORT void JNICALL
|
||||
Java_hdf_hdf5lib_H5_H5Pset_1fapl_1ros3
|
||||
(JNIEnv *env, jclass clss, jlong fapl_id, jobject fapl_config)
|
||||
{
|
||||
#ifdef H5_HAVE_ROS3_VFD
|
||||
H5FD_ros3_fapl_t instance;
|
||||
const char *str = NULL;
|
||||
jfieldID fid;
|
||||
jstring j_str;
|
||||
jclass cls;
|
||||
#endif /* H5_HAVE_ROS3_VFD */
|
||||
|
||||
UNUSED(clss);
|
||||
|
||||
#ifdef H5_HAVE_ROS3_VFD
|
||||
HDmemset(&instance, 0, sizeof(H5FD_ros3_fapl_t));
|
||||
|
||||
if (NULL == (cls = ENVPTR->GetObjectClass(ENVONLY, fapl_config)))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (NULL == (fid = ENVPTR->GetFieldID(ENVONLY, cls, "version", "I")))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
instance.version = ENVPTR->GetIntField(ENVONLY, fapl_config, fid);
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (NULL == (fid = ENVPTR->GetFieldID(ENVONLY, cls, "aws_region", "Ljava/lang/String;")))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (NULL == (j_str = (jstring)ENVPTR->GetObjectField(ENVONLY, fapl_config, fid)))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (j_str) {
|
||||
PIN_JAVA_STRING(ENVONLY, j_str, str, NULL, "H5Pset_fapl_ros3: fapl_config aws_region not pinned");
|
||||
|
||||
HDstrncpy(instance.aws_region, str, H5FD_ROS3_MAX_REGION_LEN + 1);
|
||||
instance.aws_region[H5FD_ROS3_MAX_REGION_LEN] = '\0';
|
||||
|
||||
UNPIN_JAVA_STRING(ENVONLY, j_str, str);
|
||||
str = NULL;
|
||||
}
|
||||
else
|
||||
HDmemset(instance.aws_region, 0, H5FD_ROS3_MAX_REGION_LEN + 1);
|
||||
|
||||
if (NULL == (fid = ENVPTR->GetFieldID(ENVONLY, cls, "secret_id", "Ljava/lang/String;")))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (NULL == (j_str = (jstring)ENVPTR->GetObjectField(ENVONLY, fapl_config, fid)))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (j_str) {
|
||||
PIN_JAVA_STRING(ENVONLY, j_str, str, NULL, "H5Pset_fapl_ros3: fapl_config secret_id not pinned");
|
||||
|
||||
HDstrncpy(instance.secret_id, str, H5FD_ROS3_MAX_SECRET_ID_LEN + 1);
|
||||
instance.secret_id[H5FD_ROS3_MAX_SECRET_ID_LEN] = '\0';
|
||||
|
||||
UNPIN_JAVA_STRING(ENVONLY, j_str, str);
|
||||
str = NULL;
|
||||
}
|
||||
else
|
||||
HDmemset(instance.secret_id, 0, H5FD_ROS3_MAX_SECRET_ID_LEN + 1);
|
||||
|
||||
if (NULL == (fid = ENVPTR->GetFieldID(ENVONLY, cls, "secret_key", "Ljava/lang/String;")))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (NULL == (j_str = (jstring)ENVPTR->GetObjectField(ENVONLY, fapl_config, fid)))
|
||||
CHECK_JNI_EXCEPTION(ENVONLY, JNI_FALSE);
|
||||
|
||||
if (j_str) {
|
||||
PIN_JAVA_STRING(ENVONLY, j_str, str, NULL, "H5Pset_fapl_ros3: fapl_config secret_key not pinned");
|
||||
|
||||
HDstrncpy(instance.secret_key, str, H5FD_ROS3_MAX_SECRET_KEY_LEN + 1);
|
||||
instance.secret_key[H5FD_ROS3_MAX_SECRET_KEY_LEN] = '\0';
|
||||
|
||||
UNPIN_JAVA_STRING(ENVONLY, j_str, str);
|
||||
str = NULL;
|
||||
}
|
||||
else
|
||||
HDmemset(instance.secret_key, 0, H5FD_ROS3_MAX_SECRET_KEY_LEN + 1);
|
||||
|
||||
if (instance.aws_region[0] != '\0' && instance.secret_id[0] !='\0' && instance.secret_key[0] !='\0')
|
||||
instance.authenticate = TRUE;
|
||||
|
||||
if (H5Pset_fapl_ros3((hid_t)fapl_id, &instance) < 0)
|
||||
H5_LIBRARY_ERROR(ENVONLY);
|
||||
|
||||
done:
|
||||
if (str)
|
||||
UNPIN_JAVA_STRING(ENVONLY, j_str, str);
|
||||
#else
|
||||
H5_UNIMPLEMENTED(ENVONLY, "H5Pset_fapl_ros3: not implemented");
|
||||
#endif /* H5_HAVE_ROS3_VFD */
|
||||
} /* end Java_hdf_hdf5lib_H5_H5Pset_1fapl_1ros3 */
|
||||
|
||||
/*
|
||||
* Class: hdf_hdf5lib_H5
|
||||
* Method: H5Pset_fapl_split
|
||||
|
||||
@ -135,6 +135,24 @@ JNIEXPORT jlong JNICALL
|
||||
Java_hdf_hdf5lib_H5_H5Pget_1family_1offset
|
||||
(JNIEnv *, jclass, jlong);
|
||||
|
||||
/*
|
||||
* Class: hdf_hdf5lib_H5
|
||||
* Method: H5Pget_fapl_hdfs
|
||||
* Signature: (J)Lhdf/hdf5lib/structs/H5FD_hdfs_fapl_t;
|
||||
*/
|
||||
JNIEXPORT jobject JNICALL
|
||||
Java_hdf_hdf5lib_H5_H5Pget_1fapl_1hdfs
|
||||
(JNIEnv *, jclass, jlong);
|
||||
|
||||
/*
|
||||
* Class: hdf_hdf5lib_H5
|
||||
* Method: H5Pset_fapl_hdfs
|
||||
* Signature: (JLhdf/hdf5lib/structs/H5FD_hdfs_fapl_t;)V
|
||||
*/
|
||||
JNIEXPORT void JNICALL
|
||||
Java_hdf_hdf5lib_H5_H5Pset_1fapl_1hdfs
|
||||
(JNIEnv *, jclass, jlong, jobject);
|
||||
|
||||
/*
|
||||
* Class: hdf_hdf5lib_H5
|
||||
* Method: H5Pset_fapl_log
|
||||
@ -186,6 +204,24 @@ Java_hdf_hdf5lib_H5_H5Pget_1fapl_1multi
|
||||
* TODO: H5Pget_multi_type
|
||||
*/
|
||||
|
||||
/*
|
||||
* Class: hdf_hdf5lib_H5
|
||||
* Method: H5Pget_fapl_ros3
|
||||
* Signature: (J)Lhdf/hdf5lib/structs/H5FD_ros3_fapl_t;
|
||||
*/
|
||||
JNIEXPORT jobject JNICALL
|
||||
Java_hdf_hdf5lib_H5_H5Pget_1fapl_1ros3
|
||||
(JNIEnv *, jclass, jlong);
|
||||
|
||||
/*
|
||||
* Class: hdf_hdf5lib_H5
|
||||
* Method: H5Pset_fapl_ros3
|
||||
* Signature: (JLhdf/hdf5lib/structs/H5FD_ros3_fapl_t;)V
|
||||
*/
|
||||
JNIEXPORT void JNICALL
|
||||
Java_hdf_hdf5lib_H5_H5Pset_1fapl_1ros3
|
||||
(JNIEnv *, jclass, jlong, jobject);
|
||||
|
||||
/*
|
||||
* Class: hdf_hdf5lib_H5
|
||||
* Method: H5Pset_fapl_split
|
||||
|
||||
@ -19,18 +19,11 @@ import static org.junit.Assert.assertNull;
|
||||
import static org.junit.Assert.assertTrue;
|
||||
import static org.junit.Assert.fail;
|
||||
|
||||
import java.io.File;
|
||||
import java.text.DecimalFormat;
|
||||
import java.text.NumberFormat;
|
||||
|
||||
import hdf.hdf5lib.H5;
|
||||
import hdf.hdf5lib.HDF5Constants;
|
||||
import hdf.hdf5lib.exceptions.HDF5Exception;
|
||||
import hdf.hdf5lib.exceptions.HDF5LibraryException;
|
||||
import hdf.hdf5lib.exceptions.HDF5PropertyListInterfaceException;
|
||||
import hdf.hdf5lib.structs.H5AC_cache_config_t;
|
||||
import hdf.hdf5lib.structs.H5FD_hdfs_fapl_t;
|
||||
import hdf.hdf5lib.structs.H5FD_ros3_fapl_t;
|
||||
|
||||
import org.junit.After;
|
||||
import org.junit.Before;
|
||||
@ -41,11 +34,6 @@ import org.junit.rules.TestName;
|
||||
public class TestH5Pfaplhdfs {
|
||||
@Rule public TestName testname = new TestName();
|
||||
|
||||
long H5fid = -1;
|
||||
long H5dsid = -1;
|
||||
long H5did = -1;
|
||||
long H5Fdsid = -1;
|
||||
long H5Fdid = -1;
|
||||
long fapl_id = -1;
|
||||
long plapl_id = -1;
|
||||
long dapl_id = -1;
|
||||
@ -53,9 +41,9 @@ public class TestH5Pfaplhdfs {
|
||||
long btplist_id = -1;
|
||||
|
||||
@Before
|
||||
public void createFileAccess()
|
||||
throws NullPointerException, HDF5Exception {
|
||||
assertTrue("H5 open ids is 0",H5.getOpenIDCount()==0);
|
||||
public void createFileAccess() throws NullPointerException, HDF5Exception
|
||||
{
|
||||
assertTrue("H5 open ids is 0", H5.getOpenIDCount() == 0);
|
||||
System.out.print(testname.getMethodName());
|
||||
|
||||
try {
|
||||
@ -89,7 +77,8 @@ public class TestH5Pfaplhdfs {
|
||||
}
|
||||
|
||||
@After
|
||||
public void deleteFileAccess() throws HDF5LibraryException {
|
||||
public void deleteFileAccess() throws HDF5LibraryException
|
||||
{
|
||||
if (fapl_id > 0)
|
||||
try {H5.H5Pclose(fapl_id);} catch (Exception ex) {}
|
||||
if (plapl_id > 0)
|
||||
@ -100,23 +89,11 @@ public class TestH5Pfaplhdfs {
|
||||
try {H5.H5Pclose(plist_id);} catch (Exception ex) {}
|
||||
if (btplist_id > 0)
|
||||
try {H5.H5Pclose(btplist_id);} catch (Exception ex) {}
|
||||
|
||||
if (H5Fdsid > 0)
|
||||
try {H5.H5Sclose(H5Fdsid);} catch (Exception ex) {}
|
||||
if (H5Fdid > 0)
|
||||
try {H5.H5Dclose(H5Fdid);} catch (Exception ex) {}
|
||||
if (H5dsid > 0)
|
||||
try {H5.H5Sclose(H5dsid);} catch (Exception ex) {}
|
||||
if (H5did > 0)
|
||||
try {H5.H5Dclose(H5did);} catch (Exception ex) {}
|
||||
if (H5fid > 0)
|
||||
try {H5.H5Fclose(H5fid);} catch (Exception ex) {}
|
||||
System.out.println();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testHDFS_fapl()
|
||||
throws Exception
|
||||
public void testHDFS_fapl() throws Exception
|
||||
{
|
||||
if (HDF5Constants.H5FD_HDFS < 0)
|
||||
throw new HDF5LibraryException("skip");
|
||||
@ -127,34 +104,17 @@ public class TestH5Pfaplhdfs {
|
||||
String kerbcache = "/dev/null";
|
||||
int streamsize = 1024;
|
||||
|
||||
final H5FD_hdfs_fapl_t config = new H5FD_hdfs_fapl_t(
|
||||
nodename,
|
||||
nodeport,
|
||||
username,
|
||||
kerbcache,
|
||||
streamsize
|
||||
);
|
||||
assertTrue("setting fapl should succeed",
|
||||
-1 < H5.H5Pset_fapl_hdfs(fapl_id, config));
|
||||
final H5FD_hdfs_fapl_t config = new H5FD_hdfs_fapl_t(nodename, nodeport, username, kerbcache, streamsize);
|
||||
assertTrue("setting fapl should succeed", -1 < H5.H5Pset_fapl_hdfs(fapl_id, config));
|
||||
|
||||
assertEquals("driver types should match",
|
||||
HDF5Constants.H5FD_HDFS,
|
||||
H5.H5Pget_driver(fapl_id));
|
||||
assertEquals("driver types should match", HDF5Constants.H5FD_HDFS, H5.H5Pget_driver(fapl_id));
|
||||
|
||||
H5FD_hdfs_fapl_t copy = H5.H5Pget_fapl_hdfs(fapl_id);
|
||||
assertEquals("fapl contents should match",
|
||||
new H5FD_hdfs_fapl_t(
|
||||
nodename,
|
||||
nodeport,
|
||||
username,
|
||||
kerbcache,
|
||||
streamsize),
|
||||
copy);
|
||||
assertEquals("fapl contents should match", new H5FD_hdfs_fapl_t(nodename, nodeport, username, kerbcache, streamsize), copy);
|
||||
}
|
||||
|
||||
@Test(expected = HDF5LibraryException.class)
|
||||
public void testH5Pget_fapl_hdfs_invalid_fapl_id()
|
||||
throws Exception
|
||||
public void testH5Pget_fapl_hdfs_invalid_fapl_id() throws Exception
|
||||
{
|
||||
if (HDF5Constants.H5FD_HDFS < 0)
|
||||
throw new HDF5LibraryException("skip");
|
||||
@ -162,8 +122,7 @@ public class TestH5Pfaplhdfs {
|
||||
}
|
||||
|
||||
@Test(expected = HDF5LibraryException.class)
|
||||
public void testH5Pget_fapl_hdfs_fapl_id_of_wrong_driver_type()
|
||||
throws Exception
|
||||
public void testH5Pget_fapl_hdfs_fapl_id_of_wrong_driver_type() throws Exception
|
||||
{
|
||||
if (HDF5Constants.H5FD_HDFS < 0)
|
||||
throw new HDF5LibraryException("skip");
|
||||
@ -172,9 +131,7 @@ public class TestH5Pfaplhdfs {
|
||||
/* TODO: for now, test against a sec2 fapl only */
|
||||
|
||||
H5.H5Pset_fapl_sec2(fapl_id);
|
||||
assertEquals("fapl_id was not set properly",
|
||||
HDF5Constants.H5FD_SEC2,
|
||||
H5.H5Pget_driver(fapl_id));
|
||||
assertEquals("fapl_id was not set properly", HDF5Constants.H5FD_SEC2, H5.H5Pget_driver(fapl_id));
|
||||
H5FD_hdfs_fapl_t fails = H5.H5Pget_fapl_hdfs(fapl_id);
|
||||
}
|
||||
|
||||
|
||||
@ -19,17 +19,10 @@ import static org.junit.Assert.assertNull;
|
||||
import static org.junit.Assert.assertTrue;
|
||||
import static org.junit.Assert.fail;
|
||||
|
||||
import java.io.File;
|
||||
import java.text.DecimalFormat;
|
||||
import java.text.NumberFormat;
|
||||
|
||||
import hdf.hdf5lib.H5;
|
||||
import hdf.hdf5lib.HDF5Constants;
|
||||
import hdf.hdf5lib.exceptions.HDF5Exception;
|
||||
import hdf.hdf5lib.exceptions.HDF5LibraryException;
|
||||
import hdf.hdf5lib.exceptions.HDF5PropertyListInterfaceException;
|
||||
import hdf.hdf5lib.structs.H5AC_cache_config_t;
|
||||
import hdf.hdf5lib.structs.H5FD_hdfs_fapl_t;
|
||||
import hdf.hdf5lib.structs.H5FD_ros3_fapl_t;
|
||||
|
||||
import org.junit.After;
|
||||
@ -41,11 +34,6 @@ import org.junit.rules.TestName;
|
||||
public class TestH5Pfapls3 {
|
||||
@Rule public TestName testname = new TestName();
|
||||
|
||||
long H5fid = -1;
|
||||
long H5dsid = -1;
|
||||
long H5did = -1;
|
||||
long H5Fdsid = -1;
|
||||
long H5Fdid = -1;
|
||||
long fapl_id = -1;
|
||||
long plapl_id = -1;
|
||||
long dapl_id = -1;
|
||||
@ -53,9 +41,9 @@ public class TestH5Pfapls3 {
|
||||
long btplist_id = -1;
|
||||
|
||||
@Before
|
||||
public void createFileAccess()
|
||||
throws NullPointerException, HDF5Exception {
|
||||
assertTrue("H5 open ids is 0",H5.getOpenIDCount()==0);
|
||||
public void createFileAccess() throws NullPointerException, HDF5Exception
|
||||
{
|
||||
assertTrue("H5 open ids is 0", H5.getOpenIDCount() == 0);
|
||||
System.out.print(testname.getMethodName());
|
||||
|
||||
try {
|
||||
@ -89,7 +77,8 @@ public class TestH5Pfapls3 {
|
||||
}
|
||||
|
||||
@After
|
||||
public void deleteFileAccess() throws HDF5LibraryException {
|
||||
public void deleteFileAccess() throws HDF5LibraryException
|
||||
{
|
||||
if (fapl_id > 0)
|
||||
try {H5.H5Pclose(fapl_id);} catch (Exception ex) {}
|
||||
if (plapl_id > 0)
|
||||
@ -100,48 +89,32 @@ public class TestH5Pfapls3 {
|
||||
try {H5.H5Pclose(plist_id);} catch (Exception ex) {}
|
||||
if (btplist_id > 0)
|
||||
try {H5.H5Pclose(btplist_id);} catch (Exception ex) {}
|
||||
|
||||
if (H5Fdsid > 0)
|
||||
try {H5.H5Sclose(H5Fdsid);} catch (Exception ex) {}
|
||||
if (H5Fdid > 0)
|
||||
try {H5.H5Dclose(H5Fdid);} catch (Exception ex) {}
|
||||
if (H5dsid > 0)
|
||||
try {H5.H5Sclose(H5dsid);} catch (Exception ex) {}
|
||||
if (H5did > 0)
|
||||
try {H5.H5Dclose(H5did);} catch (Exception ex) {}
|
||||
if (H5fid > 0)
|
||||
try {H5.H5Fclose(H5fid);} catch (Exception ex) {}
|
||||
System.out.println();
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testH5Pset_fapl_ros3()
|
||||
throws Exception
|
||||
public void testH5Pset_fapl_ros3() throws Exception
|
||||
{
|
||||
if (HDF5Constants.H5FD_ROS3 < 0)
|
||||
return;
|
||||
|
||||
final H5FD_ros3_fapl_t config = new H5FD_ros3_fapl_t();
|
||||
assertEquals("Default fapl has unexpected contents",
|
||||
new H5FD_ros3_fapl_t("", "", ""),
|
||||
config);
|
||||
new H5FD_ros3_fapl_t("", "", ""), config);
|
||||
|
||||
H5.H5Pset_fapl_ros3(fapl_id, config);
|
||||
|
||||
assertEquals("driver types don't match",
|
||||
HDF5Constants.H5FD_ROS3,
|
||||
H5.H5Pget_driver(fapl_id));
|
||||
HDF5Constants.H5FD_ROS3, H5.H5Pget_driver(fapl_id));
|
||||
|
||||
/* get_fapl_ros3 can throw exception in error cases */
|
||||
H5FD_ros3_fapl_t copy = H5.H5Pget_fapl_ros3(fapl_id);
|
||||
assertEquals("contents of fapl set and get don't match",
|
||||
new H5FD_ros3_fapl_t("", "", ""),
|
||||
copy);
|
||||
new H5FD_ros3_fapl_t("", "", ""), copy);
|
||||
}
|
||||
|
||||
@Test(expected = HDF5LibraryException.class)
|
||||
public void testH5Pget_fapl_ros3_invalid_fapl_id()
|
||||
throws Exception
|
||||
public void testH5Pget_fapl_ros3_invalid_fapl_id() throws Exception
|
||||
{
|
||||
if (HDF5Constants.H5FD_ROS3 < 0)
|
||||
throw new HDF5LibraryException("skip");
|
||||
@ -149,8 +122,7 @@ public class TestH5Pfapls3 {
|
||||
}
|
||||
|
||||
@Test(expected = HDF5LibraryException.class)
|
||||
public void testH5Pget_fapl_ros3_fapl_id_of_wrong_driver_type()
|
||||
throws Exception
|
||||
public void testH5Pget_fapl_ros3_fapl_id_of_wrong_driver_type() throws Exception
|
||||
{
|
||||
if (HDF5Constants.H5FD_ROS3 < 0)
|
||||
throw new HDF5LibraryException("skip");
|
||||
@ -160,14 +132,12 @@ public class TestH5Pfapls3 {
|
||||
|
||||
H5.H5Pset_fapl_sec2(fapl_id);
|
||||
assertEquals("fapl_id was not set properly",
|
||||
HDF5Constants.H5FD_SEC2,
|
||||
H5.H5Pget_driver(fapl_id));
|
||||
HDF5Constants.H5FD_SEC2, H5.H5Pget_driver(fapl_id));
|
||||
H5FD_ros3_fapl_t fails = H5.H5Pget_fapl_ros3(fapl_id);
|
||||
}
|
||||
|
||||
@Test
|
||||
public void testH5Pset_fapl_ros3_specified()
|
||||
throws Exception
|
||||
public void testH5Pset_fapl_ros3_specified() throws Exception
|
||||
{
|
||||
if (HDF5Constants.H5FD_ROS3 < 0)
|
||||
return;
|
||||
@ -176,19 +146,14 @@ public class TestH5Pfapls3 {
|
||||
String acc_id = "my_access_id";
|
||||
String acc_key = "my_access_key";
|
||||
|
||||
final H5FD_ros3_fapl_t config = new H5FD_ros3_fapl_t(
|
||||
region,
|
||||
acc_id,
|
||||
acc_key);
|
||||
final H5FD_ros3_fapl_t config = new H5FD_ros3_fapl_t(region, acc_id, acc_key);
|
||||
H5.H5Pset_fapl_ros3(fapl_id, config);
|
||||
assertEquals("driver types don't match",
|
||||
HDF5Constants.H5FD_ROS3,
|
||||
H5.H5Pget_driver(fapl_id));
|
||||
HDF5Constants.H5FD_ROS3, H5.H5Pget_driver(fapl_id));
|
||||
|
||||
H5FD_ros3_fapl_t copy = H5.H5Pget_fapl_ros3(fapl_id);
|
||||
assertEquals("contents of fapl set and get don't match",
|
||||
new H5FD_ros3_fapl_t(region, acc_id, acc_key),
|
||||
copy);
|
||||
new H5FD_ros3_fapl_t(region, acc_id, acc_key), copy);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@ -11,12 +11,12 @@
|
||||
* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
|
||||
|
||||
/*
|
||||
* Read-Only S3 Virtual File Driver (VFD)
|
||||
* Read-Only S3 Virtual File Driver (VFD)
|
||||
*
|
||||
* Programmer: John Mainzer
|
||||
* 2017-10-10
|
||||
*
|
||||
* Purpose: The public header file for the ros3 driver.
|
||||
* Purpose: The public header file for the ros3 driver.
|
||||
*/
|
||||
#ifndef H5FDros3_H
|
||||
#define H5FDros3_H
|
||||
@ -35,16 +35,16 @@
|
||||
*
|
||||
* Purpose:
|
||||
*
|
||||
* H5FD_ros3_fapl_t is a public structure that is used to pass S3
|
||||
* authentication data to the appropriate S3 VFD via the FAPL. A pointer
|
||||
* to an instance of this structure is a parameter to H5Pset_fapl_ros3()
|
||||
* H5FD_ros3_fapl_t is a public structure that is used to pass S3
|
||||
* authentication data to the appropriate S3 VFD via the FAPL. A pointer
|
||||
* to an instance of this structure is a parameter to H5Pset_fapl_ros3()
|
||||
* and H5Pget_fapl_ros3().
|
||||
*
|
||||
*
|
||||
*
|
||||
* `version` (int32_t)
|
||||
*
|
||||
* Version number of the H5FD_ros3_fapl_t structure. Any instance passed
|
||||
* Version number of the H5FD_ros3_fapl_t structure. Any instance passed
|
||||
* to the above calls must have a recognized version number, or an error
|
||||
* will be flagged.
|
||||
*
|
||||
@ -53,8 +53,8 @@
|
||||
* `authenticate` (hbool_t)
|
||||
*
|
||||
* Flag TRUE or FALSE whether or not requests are to be authenticated
|
||||
* with the AWS4 algorithm.
|
||||
* If TRUE, `aws_region`, `secret_id`, and `secret_key` must be populated.
|
||||
* with the AWS4 algorithm.
|
||||
* If TRUE, `aws_region`, `secret_id`, and `secret_key` must be populated.
|
||||
* If FALSE, those three components are unused.
|
||||
*
|
||||
* `aws_region` (char[])
|
||||
@ -91,8 +91,8 @@ extern "C" {
|
||||
#endif
|
||||
|
||||
H5_DLL hid_t H5FD_ros3_init(void);
|
||||
H5_DLL herr_t H5Pget_fapl_ros3(hid_t fapl_id, H5FD_ros3_fapl_t * fa_out);
|
||||
H5_DLL herr_t H5Pset_fapl_ros3(hid_t fapl_id, H5FD_ros3_fapl_t * fa);
|
||||
H5_DLL herr_t H5Pget_fapl_ros3(hid_t fapl_id, H5FD_ros3_fapl_t *fa_out);
|
||||
H5_DLL herr_t H5Pset_fapl_ros3(hid_t fapl_id, H5FD_ros3_fapl_t *fa);
|
||||
|
||||
#ifdef __cplusplus
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user