src/java.c

   1 /**
   2  * collectd - src/java.c
   3  * Copyright (C) 2009  Florian octo Forster
   4  * Copyright (C) 2008  Justo Alonso Achaques
   5  *
   6  * This program is free software; you can redistribute it and/or modify it
   7  * under the terms of the GNU General Public License as published by the
   8  * Free Software Foundation; only version 2 of the License is applicable.
   9  *
  10  * This program is distributed in the hope that it will be useful, but
  11  * WITHOUT ANY WARRANTY; without even the implied warranty of
  12  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  13  * General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU General Public License along
  16  * with this program; if not, write to the Free Software Foundation, Inc.,
  17  * 51 Franklin St, Fifth Floor, Boston, MA  02110-1301 USA
  18  *
  19  * Authors:
  20  *   Florian octo Forster <octo at verplant.org>
  21  *   Justo Alonso Achaques <justo.alonso at gmail.com>
  22  **/
  23
  24 #include "collectd.h"
  25 #include "plugin.h"
  26 #include "common.h"
  27
  28 #include <pthread.h>
  29 #include <jni.h>
  30
  31 #if !defined(JNI_VERSION_1_2)
  32 # error "Need JNI 1.2 compatible interface!"
  33 #endif
  34
  35 /*
  36  * Types
  37  */
  38 struct cjni_jvm_env_s /* {{{ */
  39 {
  40   JNIEnv *jvm_env;
  41   int reference_counter;
  42 };
  43 typedef struct cjni_jvm_env_s cjni_jvm_env_t;
  44 /* }}} */
  45
  46 struct java_plugin_class_s /* {{{ */
  47 {
  48   char     *name;
  49   jclass    class;
  50   jobject   object;
  51 };
  52 typedef struct java_plugin_class_s java_plugin_class_t;
  53 /* }}} */
  54
  55 struct java_plugin_config_s /* {{{ */
  56 {
  57   char *name;
  58   oconfig_item_t *ci;
  59 };
  60 typedef struct java_plugin_config_s java_plugin_config_t;
  61 /* }}} */
  62
  63 #define CB_TYPE_CONFIG   1
  64 #define CB_TYPE_INIT     2
  65 #define CB_TYPE_READ     3
  66 #define CB_TYPE_WRITE    4
  67 #define CB_TYPE_SHUTDOWN 5
  68 struct cjni_callback_info_s /* {{{ */
  69 {
  70   char     *name;
  71   int       type;
  72   jclass    class;
  73   jobject   object;
  74   jmethodID method;
  75 };
  76 typedef struct cjni_callback_info_s cjni_callback_info_t;
  77 /* }}} */
  78
  79 /*
  80  * Global variables
  81  */
  82 static JavaVM *jvm = NULL;
  83 static pthread_key_t jvm_env_key;
  84
  85 /* Configuration options for the JVM. */
  86 static char **jvm_argv = NULL;
  87 static size_t jvm_argc = 0;
  88
  89 /* List of class names to load */
  90 static java_plugin_class_t  *java_classes_list = NULL;
  91 static size_t                java_classes_list_len;
  92
  93 /* List of `config_item_t's for Java plugins */
  94 static java_plugin_config_t *java_plugin_configs     = NULL;
  95 static size_t                java_plugin_configs_num = 0;
  96
  97 /* List of config, init, and shutdown callbacks. */
  98 static cjni_callback_info_t *java_callbacks      = NULL;
  99 static size_t                java_callbacks_num  = 0;
 100 static pthread_mutex_t       java_callbacks_lock = PTHREAD_MUTEX_INITIALIZER;
 101
 102 /*
 103  * Prototypes
 104  *
 105  * Mostly functions that are needed by the Java interface functions.
 106  */
 107 static void cjni_callback_info_destroy (void *arg);
 108 static int cjni_read (user_data_t *user_data);
 109 static int cjni_write (const data_set_t *ds, const value_list_t *vl,
 110     user_data_t *ud);
 111
 112 /*
 113  * C to Java conversion functions
 114  */
 115 static int ctoj_string (JNIEnv *jvm_env, /* {{{ */
 116     const char *string,
 117     jclass class_ptr, jobject object_ptr, const char *method_name)
 118 {
 119   jmethodID m_set;
 120   jstring o_string;
 121
 122   /* Create a java.lang.String */
 123   o_string = (*jvm_env)->NewStringUTF (jvm_env,
 124       (string != NULL) ? string : "");
 125   if (o_string == NULL)
 126   {
 127     ERROR ("java plugin: ctoj_string: NewStringUTF failed.");
 128     return (-1);
 129   }
 130
 131   /* Search for the `void setFoo (String s)' method. */
 132   m_set = (*jvm_env)->GetMethodID (jvm_env, class_ptr,
 133       method_name, "(Ljava/lang/String;)V");
 134   if (m_set == NULL)
 135   {
 136     ERROR ("java plugin: ctoj_string: Cannot find method `void %s (String)'.",
 137         method_name);
 138     (*jvm_env)->DeleteLocalRef (jvm_env, o_string);
 139     return (-1);
 140   }
 141
 142   /* Call the method. */
 143   (*jvm_env)->CallVoidMethod (jvm_env, object_ptr, m_set, o_string);
 144
 145   /* Decrease reference counter on the java.lang.String object. */
 146   (*jvm_env)->DeleteLocalRef (jvm_env, o_string);
 147
 148   return (0);
 149 } /* }}} int ctoj_string */
 150
 151 static int ctoj_int (JNIEnv *jvm_env, /* {{{ */
 152     jint value,
 153     jclass class_ptr, jobject object_ptr, const char *method_name)
 154 {
 155   jmethodID m_set;
 156
 157   /* Search for the `void setFoo (int i)' method. */
 158   m_set = (*jvm_env)->GetMethodID (jvm_env, class_ptr,
 159       method_name, "(I)V");
 160   if (m_set == NULL)
 161   {
 162     ERROR ("java plugin: ctoj_int: Cannot find method `void %s (int)'.",
 163         method_name);
 164     return (-1);
 165   }
 166
 167   (*jvm_env)->CallVoidMethod (jvm_env, object_ptr, m_set, value);
 168
 169   return (0);
 170 } /* }}} int ctoj_int */
 171
 172 static int ctoj_long (JNIEnv *jvm_env, /* {{{ */
 173     jlong value,
 174     jclass class_ptr, jobject object_ptr, const char *method_name)
 175 {
 176   jmethodID m_set;
 177
 178   /* Search for the `void setFoo (long l)' method. */
 179   m_set = (*jvm_env)->GetMethodID (jvm_env, class_ptr,
 180       method_name, "(J)V");
 181   if (m_set == NULL)
 182   {
 183     ERROR ("java plugin: ctoj_long: Cannot find method `void %s (long)'.",
 184         method_name);
 185     return (-1);
 186   }
 187
 188   (*jvm_env)->CallVoidMethod (jvm_env, object_ptr, m_set, value);
 189
 190   return (0);
 191 } /* }}} int ctoj_long */
 192
 193 static int ctoj_double (JNIEnv *jvm_env, /* {{{ */
 194     jdouble value,
 195     jclass class_ptr, jobject object_ptr, const char *method_name)
 196 {
 197   jmethodID m_set;
 198
 199   /* Search for the `void setFoo (double d)' method. */
 200   m_set = (*jvm_env)->GetMethodID (jvm_env, class_ptr,
 201       method_name, "(D)V");
 202   if (m_set == NULL)
 203   {
 204     ERROR ("java plugin: ctoj_double: Cannot find method `void %s (double)'.",
 205         method_name);
 206     return (-1);
 207   }
 208
 209   (*jvm_env)->CallVoidMethod (jvm_env, object_ptr, m_set, value);
 210
 211   return (0);
 212 } /* }}} int ctoj_double */
 213
 214 /* Convert a jlong to a java.lang.Number */
 215 static jobject ctoj_jlong_to_number (JNIEnv *jvm_env, jlong value) /* {{{ */
 216 {
 217   jclass c_long;
 218   jmethodID m_long_constructor;
 219
 220   /* Look up the java.lang.Long class */
 221   c_long = (*jvm_env)->FindClass (jvm_env, "java.lang.Long");
 222   if (c_long == NULL)
 223   {
 224     ERROR ("java plugin: ctoj_jlong_to_number: Looking up the "
 225         "java.lang.Long class failed.");
 226     return (NULL);
 227   }
 228
 229   m_long_constructor = (*jvm_env)->GetMethodID (jvm_env,
 230       c_long, "<init>", "(J)V");
 231   if (m_long_constructor == NULL)
 232   {
 233     ERROR ("java plugin: ctoj_jlong_to_number: Looking up the "
 234         "`Long (long)' constructor failed.");
 235     return (NULL);
 236   }
 237
 238   return ((*jvm_env)->NewObject (jvm_env,
 239         c_long, m_long_constructor, value));
 240 } /* }}} jobject ctoj_jlong_to_number */
 241
 242 /* Convert a jdouble to a java.lang.Number */
 243 static jobject ctoj_jdouble_to_number (JNIEnv *jvm_env, jdouble value) /* {{{ */
 244 {
 245   jclass c_double;
 246   jmethodID m_double_constructor;
 247
 248   /* Look up the java.lang.Long class */
 249   c_double = (*jvm_env)->FindClass (jvm_env, "java.lang.Double");
 250   if (c_double == NULL)
 251   {
 252     ERROR ("java plugin: ctoj_jdouble_to_number: Looking up the "
 253         "java.lang.Double class failed.");
 254     return (NULL);
 255   }
 256
 257   m_double_constructor = (*jvm_env)->GetMethodID (jvm_env,
 258       c_double, "<init>", "(D)V");
 259   if (m_double_constructor == NULL)
 260   {
 261     ERROR ("java plugin: ctoj_jdouble_to_number: Looking up the "
 262         "`Double (double)' constructor failed.");
 263     return (NULL);
 264   }
 265
 266   return ((*jvm_env)->NewObject (jvm_env,
 267         c_double, m_double_constructor, value));
 268 } /* }}} jobject ctoj_jdouble_to_number */
 269
 270 /* Convert a value_t to a java.lang.Number */
 271 static jobject ctoj_value_to_number (JNIEnv *jvm_env, /* {{{ */
 272     value_t value, int ds_type)
 273 {
 274   if (ds_type == DS_TYPE_COUNTER)
 275     return (ctoj_jlong_to_number (jvm_env, (jlong) value.counter));
 276   else if (ds_type == DS_TYPE_GAUGE)
 277     return (ctoj_jdouble_to_number (jvm_env, (jdouble) value.gauge));
 278   else
 279     return (NULL);
 280 } /* }}} jobject ctoj_value_to_number */
 281
 282 /* Convert a data_source_t to a org.collectd.api.DataSource */
 283 static jobject ctoj_data_source (JNIEnv *jvm_env, /* {{{ */
 284     const data_source_t *dsrc)
 285 {
 286   jclass c_datasource;
 287   jmethodID m_datasource_constructor;
 288   jobject o_datasource;
 289   int status;
 290
 291   /* Look up the DataSource class */
 292   c_datasource = (*jvm_env)->FindClass (jvm_env,
 293       "org.collectd.api.DataSource");
 294   if (c_datasource == NULL)
 295   {
 296     ERROR ("java plugin: ctoj_data_source: "
 297         "FindClass (org.collectd.api.DataSource) failed.");
 298     return (NULL);
 299   }
 300
 301   /* Lookup the `ValueList ()' constructor. */
 302   m_datasource_constructor = (*jvm_env)->GetMethodID (jvm_env, c_datasource,
 303       "<init>", "()V");
 304   if (m_datasource_constructor == NULL)
 305   {
 306     ERROR ("java plugin: ctoj_data_source: Cannot find the "
 307         "`DataSource ()' constructor.");
 308     return (NULL);
 309   }
 310
 311   /* Create a new instance. */
 312   o_datasource = (*jvm_env)->NewObject (jvm_env, c_datasource,
 313       m_datasource_constructor);
 314   if (o_datasource == NULL)
 315   {
 316     ERROR ("java plugin: ctoj_data_source: "
 317         "Creating a new DataSource instance failed.");
 318     return (NULL);
 319   }
 320
 321   /* Set name via `void setName (String name)' */
 322   status = ctoj_string (jvm_env, dsrc->name,
 323       c_datasource, o_datasource, "setName");
 324   if (status != 0)
 325   {
 326     ERROR ("java plugin: ctoj_data_source: "
 327         "ctoj_string (setName) failed.");
 328     (*jvm_env)->DeleteLocalRef (jvm_env, o_datasource);
 329     return (NULL);
 330   }
 331
 332   /* Set type via `void setType (int type)' */
 333   status = ctoj_int (jvm_env, dsrc->type,
 334       c_datasource, o_datasource, "setType");
 335   if (status != 0)
 336   {
 337     ERROR ("java plugin: ctoj_data_source: "
 338         "ctoj_int (setType) failed.");
 339     (*jvm_env)->DeleteLocalRef (jvm_env, o_datasource);
 340     return (NULL);
 341   }
 342
 343   /* Set min via `void setMin (double min)' */
 344   status = ctoj_double (jvm_env, dsrc->min,
 345       c_datasource, o_datasource, "setMin");
 346   if (status != 0)
 347   {
 348     ERROR ("java plugin: ctoj_data_source: "
 349         "ctoj_double (setMin) failed.");
 350     (*jvm_env)->DeleteLocalRef (jvm_env, o_datasource);
 351     return (NULL);
 352   }
 353
 354   /* Set max via `void setMax (double max)' */
 355   status = ctoj_double (jvm_env, dsrc->max,
 356       c_datasource, o_datasource, "setMax");
 357   if (status != 0)
 358   {
 359     ERROR ("java plugin: ctoj_data_source: "
 360         "ctoj_double (setMax) failed.");
 361     (*jvm_env)->DeleteLocalRef (jvm_env, o_datasource);
 362     return (NULL);
 363   }
 364
 365   return (o_datasource);
 366 } /* }}} jobject ctoj_data_source */
 367
 368 /* Convert a oconfig_value_t to a org.collectd.api.OConfigValue */
 369 static jobject ctoj_oconfig_value (JNIEnv *jvm_env, /* {{{ */
 370     oconfig_value_t ocvalue)
 371 {
 372   jclass c_ocvalue;
 373   jmethodID m_ocvalue_constructor;
 374   jobject o_argument;
 375   jobject o_ocvalue;
 376
 377   m_ocvalue_constructor = NULL;
 378   o_argument = NULL;
 379
 380   c_ocvalue = (*jvm_env)->FindClass (jvm_env,
 381       "org.collectd.api.OConfigValue");
 382   if (c_ocvalue == NULL)
 383   {
 384     ERROR ("java plugin: ctoj_oconfig_value: "
 385         "FindClass (org.collectd.api.OConfigValue) failed.");
 386     return (NULL);
 387   }
 388
 389   if (ocvalue.type == OCONFIG_TYPE_BOOLEAN)
 390   {
 391     jboolean tmp_boolean;
 392
 393     tmp_boolean = (ocvalue.value.boolean == 0) ? JNI_FALSE : JNI_TRUE;
 394
 395     m_ocvalue_constructor = (*jvm_env)->GetMethodID (jvm_env, c_ocvalue,
 396         "<init>", "(Z)V");
 397     if (m_ocvalue_constructor == NULL)
 398     {
 399       ERROR ("java plugin: ctoj_oconfig_value: Cannot find the "
 400           "`OConfigValue (boolean)' constructor.");
 401       return (NULL);
 402     }
 403
 404     return ((*jvm_env)->NewObject (jvm_env,
 405           c_ocvalue, m_ocvalue_constructor, tmp_boolean));
 406   } /* if (ocvalue.type == OCONFIG_TYPE_BOOLEAN) */
 407   else if (ocvalue.type == OCONFIG_TYPE_STRING)
 408   {
 409     m_ocvalue_constructor = (*jvm_env)->GetMethodID (jvm_env, c_ocvalue,
 410         "<init>", "(Ljava/lang/String;)V");
 411     if (m_ocvalue_constructor == NULL)
 412     {
 413       ERROR ("java plugin: ctoj_oconfig_value: Cannot find the "
 414           "`OConfigValue (String)' constructor.");
 415       return (NULL);
 416     }
 417
 418     o_argument = (*jvm_env)->NewStringUTF (jvm_env, ocvalue.value.string);
 419     if (o_argument == NULL)
 420     {
 421       ERROR ("java plugin: ctoj_oconfig_value: "
 422           "Creating a String object failed.");
 423       return (NULL);
 424     }
 425   }
 426   else if (ocvalue.type == OCONFIG_TYPE_NUMBER)
 427   {
 428     m_ocvalue_constructor = (*jvm_env)->GetMethodID (jvm_env, c_ocvalue,
 429         "<init>", "(Ljava/lang/Number;)V");
 430     if (m_ocvalue_constructor == NULL)
 431     {
 432       ERROR ("java plugin: ctoj_oconfig_value: Cannot find the "
 433           "`OConfigValue (Number)' constructor.");
 434       return (NULL);
 435     }
 436
 437     o_argument = ctoj_jdouble_to_number (jvm_env,
 438         (jdouble) ocvalue.value.number);
 439     if (o_argument == NULL)
 440     {
 441       ERROR ("java plugin: ctoj_oconfig_value: "
 442           "Creating a Number object failed.");
 443       return (NULL);
 444     }
 445   }
 446   else
 447   {
 448     return (NULL);
 449   }
 450
 451   assert (m_ocvalue_constructor != NULL);
 452   assert (o_argument != NULL);
 453
 454   o_ocvalue = (*jvm_env)->NewObject (jvm_env,
 455       c_ocvalue, m_ocvalue_constructor, o_argument);
 456   if (o_ocvalue == NULL)
 457   {
 458     ERROR ("java plugin: ctoj_oconfig_value: "
 459         "Creating an OConfigValue object failed.");
 460     (*jvm_env)->DeleteLocalRef (jvm_env, o_argument);
 461     return (NULL);
 462   }
 463
 464   (*jvm_env)->DeleteLocalRef (jvm_env, o_argument);
 465   return (o_ocvalue);
 466 } /* }}} jobject ctoj_oconfig_value */
 467
 468 /* Convert a oconfig_item_t to a org.collectd.api.OConfigItem */
 469 static jobject ctoj_oconfig_item (JNIEnv *jvm_env, /* {{{ */
 470     const oconfig_item_t *ci)
 471 {
 472   jclass c_ocitem;
 473   jmethodID m_ocitem_constructor;
 474   jmethodID m_addvalue;
 475   jmethodID m_addchild;
 476   jobject o_key;
 477   jobject o_ocitem;
 478   int i;
 479
 480   c_ocitem = (*jvm_env)->FindClass (jvm_env, "org.collectd.api.OConfigItem");
 481   if (c_ocitem == NULL)
 482   {
 483     ERROR ("java plugin: ctoj_oconfig_item: "
 484         "FindClass (org.collectd.api.OConfigItem) failed.");
 485     return (NULL);
 486   }
 487
 488   /* Get the required methods: m_ocitem_constructor, m_addvalue, and m_addchild
 489    * {{{ */
 490   m_ocitem_constructor = (*jvm_env)->GetMethodID (jvm_env, c_ocitem,
 491       "<init>", "(Ljava/lang/String;)V");
 492   if (m_ocitem_constructor == NULL)
 493   {
 494     ERROR ("java plugin: ctoj_oconfig_item: Cannot find the "
 495         "`OConfigItem (String)' constructor.");
 496     return (NULL);
 497   }
 498
 499   m_addvalue = (*jvm_env)->GetMethodID (jvm_env, c_ocitem,
 500       "addValue", "(Lorg/collectd/api/OConfigValue;)V");
 501   if (m_addvalue == NULL)
 502   {
 503     ERROR ("java plugin: ctoj_oconfig_item: Cannot find the "
 504         "`addValue (OConfigValue)' method.");
 505     return (NULL);
 506   }
 507
 508   m_addchild = (*jvm_env)->GetMethodID (jvm_env, c_ocitem,
 509       "addChild", "(Lorg/collectd/api/OConfigItem;)V");
 510   if (m_addchild == NULL)
 511   {
 512     ERROR ("java plugin: ctoj_oconfig_item: Cannot find the "
 513         "`addChild (OConfigItem)' method.");
 514     return (NULL);
 515   }
 516   /* }}} */
 517
 518   /* Create a String object with the key.
 519    * Needed for calling the constructor. */
 520   o_key = (*jvm_env)->NewStringUTF (jvm_env, ci->key);
 521   if (o_key == NULL)
 522   {
 523     ERROR ("java plugin: ctoj_oconfig_item: "
 524         "Creating String object failed.");
 525     return (NULL);
 526   }
 527
 528   /* Create an OConfigItem object */
 529   o_ocitem = (*jvm_env)->NewObject (jvm_env,
 530       c_ocitem, m_ocitem_constructor, o_key);
 531   if (o_ocitem == NULL)
 532   {
 533     ERROR ("java plugin: ctoj_oconfig_item: "
 534         "Creating an OConfigItem object failed.");
 535     (*jvm_env)->DeleteLocalRef (jvm_env, o_key);
 536     return (NULL);
 537   }
 538
 539   /* We don't need the String object any longer.. */
 540   (*jvm_env)->DeleteLocalRef (jvm_env, o_key);
 541
 542   /* Call OConfigItem.addValue for each value */
 543   for (i = 0; i < ci->values_num; i++) /* {{{ */
 544   {
 545     jobject o_value;
 546
 547     o_value = ctoj_oconfig_value (jvm_env, ci->values[i]);
 548     if (o_value == NULL)
 549     {
 550       ERROR ("java plugin: ctoj_oconfig_item: "
 551           "Creating an OConfigValue object failed.");
 552       (*jvm_env)->DeleteLocalRef (jvm_env, o_ocitem);
 553       return (NULL);
 554     }
 555
 556     (*jvm_env)->CallVoidMethod (jvm_env, o_ocitem, m_addvalue, o_value);
 557     (*jvm_env)->DeleteLocalRef (jvm_env, o_value);
 558   } /* }}} for (i = 0; i < ci->values_num; i++) */
 559
 560   /* Call OConfigItem.addChild for each child */
 561   for (i = 0; i < ci->children_num; i++) /* {{{ */
 562   {
 563     jobject o_child;
 564
 565     o_child = ctoj_oconfig_item (jvm_env, ci->children + i);
 566     if (o_child == NULL)
 567     {
 568       ERROR ("java plugin: ctoj_oconfig_item: "
 569           "Creating an OConfigItem object failed.");
 570       (*jvm_env)->DeleteLocalRef (jvm_env, o_ocitem);
 571       return (NULL);
 572     }
 573
 574     (*jvm_env)->CallVoidMethod (jvm_env, o_ocitem, m_addvalue, o_child);
 575     (*jvm_env)->DeleteLocalRef (jvm_env, o_child);
 576   } /* }}} for (i = 0; i < ci->children_num; i++) */
 577
 578   return (o_ocitem);
 579 } /* }}} jobject ctoj_oconfig_item */
 580
 581 /* Convert a data_set_t to a org.collectd.api.DataSet */
 582 static jobject ctoj_data_set (JNIEnv *jvm_env, const data_set_t *ds) /* {{{ */
 583 {
 584   jclass c_dataset;
 585   jmethodID m_constructor;
 586   jmethodID m_add;
 587   jobject o_type;
 588   jobject o_dataset;
 589   int i;
 590
 591   /* Look up the org.collectd.api.DataSet class */
 592   c_dataset = (*jvm_env)->FindClass (jvm_env, "org.collectd.api.DataSet");
 593   if (c_dataset == NULL)
 594   {
 595     ERROR ("java plugin: ctoj_data_set: Looking up the "
 596         "org.collectd.api.DataSet class failed.");
 597     return (NULL);
 598   }
 599
 600   /* Search for the `DataSet (String type)' constructor. */
 601   m_constructor = (*jvm_env)->GetMethodID (jvm_env,
 602       c_dataset, "<init>", "(Ljava.lang.String;)V");
 603   if (m_constructor == NULL)
 604   {
 605     ERROR ("java plugin: ctoj_data_set: Looking up the "
 606         "`DataSet (String)' constructor failed.");
 607     return (NULL);
 608   }
 609
 610   /* Search for the `void addDataSource (DataSource)' method. */
 611   m_add = (*jvm_env)->GetMethodID (jvm_env,
 612       c_dataset, "addDataSource", "(Lorg.collectd.api.DataSource;)V");
 613   if (m_add == NULL)
 614   {
 615     ERROR ("java plugin: ctoj_data_set: Looking up the "
 616         "`addDataSource (DataSource)' method failed.");
 617     return (NULL);
 618   }
 619
 620   o_type = (*jvm_env)->NewStringUTF (jvm_env, ds->type);
 621   if (o_type == NULL)
 622   {
 623     ERROR ("java plugin: ctoj_data_set: Creating a String object failed.");
 624     return (NULL);
 625   }
 626
 627   o_dataset = (*jvm_env)->NewObject (jvm_env,
 628       c_dataset, m_constructor, o_type);
 629   if (o_dataset == NULL)
 630   {
 631     ERROR ("java plugin: ctoj_data_set: Creating a DataSet object failed.");
 632     (*jvm_env)->DeleteLocalRef (jvm_env, o_type);
 633     return (NULL);
 634   }
 635
 636   /* Decrease reference counter on the java.lang.String object. */
 637   (*jvm_env)->DeleteLocalRef (jvm_env, o_type);
 638
 639   for (i = 0; i < ds->ds_num; i++)
 640   {
 641     jobject o_datasource;
 642
 643     o_datasource = ctoj_data_source (jvm_env, ds->ds + i);
 644     if (o_datasource == NULL)
 645     {
 646       ERROR ("java plugin: ctoj_data_set: ctoj_data_source (%s.%s) failed",
 647           ds->type, ds->ds[i].name);
 648       (*jvm_env)->DeleteLocalRef (jvm_env, o_dataset);
 649       return (NULL);
 650     }
 651
 652     (*jvm_env)->CallVoidMethod (jvm_env, o_dataset, m_add, o_datasource);
 653
 654     (*jvm_env)->DeleteLocalRef (jvm_env, o_datasource);
 655   } /* for (i = 0; i < ds->ds_num; i++) */
 656
 657   return (o_dataset);
 658 } /* }}} jobject ctoj_data_set */
 659
 660 static int ctoj_value_list_add_value (JNIEnv *jvm_env, /* {{{ */
 661     value_t value, int ds_type,
 662     jclass class_ptr, jobject object_ptr)
 663 {
 664   jmethodID m_addvalue;
 665   jobject o_number;
 666
 667   m_addvalue = (*jvm_env)->GetMethodID (jvm_env, class_ptr,
 668       "addValue", "(Ljava/lang/Number;)V");
 669   if (m_addvalue == NULL)
 670   {
 671     ERROR ("java plugin: ctoj_value_list_add_value: "
 672         "Cannot find method `void addValue (Number)'.");
 673     return (-1);
 674   }
 675
 676   o_number = ctoj_value_to_number (jvm_env, value, ds_type);
 677   if (o_number == NULL)
 678   {
 679     ERROR ("java plugin: ctoj_value_list_add_value: "
 680         "ctoj_value_to_number failed.");
 681     return (-1);
 682   }
 683
 684   (*jvm_env)->CallVoidMethod (jvm_env, object_ptr, m_addvalue, o_number);
 685
 686   (*jvm_env)->DeleteLocalRef (jvm_env, o_number);
 687
 688   return (0);
 689 } /* }}} int ctoj_value_list_add_value */
 690
 691 static int ctoj_value_list_add_data_set (JNIEnv *jvm_env, /* {{{ */
 692     jclass c_valuelist, jobject o_valuelist, const data_set_t *ds)
 693 {
 694   jmethodID m_setdataset;
 695   jobject o_dataset;
 696
 697   /* Look for the `void setDataSource (List<DataSource> ds)' method. */
 698   m_setdataset = (*jvm_env)->GetMethodID (jvm_env, c_valuelist,
 699       "setDataSet", "(Lorg.collectd.api.DataSet;)V");
 700   if (m_setdataset == NULL)
 701   {
 702     ERROR ("java plugin: ctoj_value_list_add_data_set: "
 703         "Cannot find the `void setDataSet (DataSet)' method.");
 704     return (-1);
 705   }
 706
 707   /* Create a DataSet object. */
 708   o_dataset = ctoj_data_set (jvm_env, ds);
 709   if (o_dataset == NULL)
 710   {
 711     ERROR ("java plugin: ctoj_value_list_add_data_set: "
 712         "ctoj_data_set (%s) failed.", ds->type);
 713     return (-1);
 714   }
 715
 716   /* Actually call the method. */
 717   (*jvm_env)->CallVoidMethod (jvm_env,
 718       o_valuelist, m_setdataset, o_dataset);
 719
 720   /* Decrease reference counter on the List<DataSource> object. */
 721   (*jvm_env)->DeleteLocalRef (jvm_env, o_dataset);
 722
 723   return (0);
 724 } /* }}} int ctoj_value_list_add_data_set */
 725
 726 static jobject ctoj_value_list (JNIEnv *jvm_env, /* {{{ */
 727     const data_set_t *ds, const value_list_t *vl)
 728 {
 729   jclass c_valuelist;
 730   jmethodID m_valuelist_constructor;
 731   jobject o_valuelist;
 732   int status;
 733   int i;
 734
 735   /* First, create a new ValueList instance..
 736    * Look up the class.. */
 737   c_valuelist = (*jvm_env)->FindClass (jvm_env,
 738       "org.collectd.api.ValueList");
 739   if (c_valuelist == NULL)
 740   {
 741     ERROR ("java plugin: ctoj_value_list: "
 742         "FindClass (org.collectd.api.ValueList) failed.");
 743     return (NULL);
 744   }
 745
 746   /* Lookup the `ValueList ()' constructor. */
 747   m_valuelist_constructor = (*jvm_env)->GetMethodID (jvm_env, c_valuelist,
 748       "<init>", "()V");
 749   if (m_valuelist_constructor == NULL)
 750   {
 751     ERROR ("java plugin: ctoj_value_list: Cannot find the "
 752         "`ValueList ()' constructor.");
 753     return (NULL);
 754   }
 755
 756   /* Create a new instance. */
 757   o_valuelist = (*jvm_env)->NewObject (jvm_env, c_valuelist,
 758       m_valuelist_constructor);
 759   if (o_valuelist == NULL)
 760   {
 761     ERROR ("java plugin: ctoj_value_list: Creating a new ValueList instance "
 762         "failed.");
 763     return (NULL);
 764   }
 765
 766   status = ctoj_value_list_add_data_set (jvm_env,
 767       c_valuelist, o_valuelist, ds);
 768   if (status != 0)
 769   {
 770     ERROR ("java plugin: ctoj_value_list: "
 771         "ctoj_value_list_add_data_set failed.");
 772     (*jvm_env)->DeleteLocalRef (jvm_env, o_valuelist);
 773     return (NULL);
 774   }
 775
 776   /* Set the strings.. */
 777 #define SET_STRING(str,method_name) do { \
 778   status = ctoj_string (jvm_env, str, \
 779       c_valuelist, o_valuelist, method_name); \
 780   if (status != 0) { \
 781     ERROR ("java plugin: ctoj_value_list: jtoc_string (%s) failed.", \
 782         method_name); \
 783     (*jvm_env)->DeleteLocalRef (jvm_env, o_valuelist); \
 784     return (NULL); \
 785   } } while (0)
 786
 787   SET_STRING (vl->host,            "setHost");
 788   SET_STRING (vl->plugin,          "setPlugin");
 789   SET_STRING (vl->plugin_instance, "setPluginInstance");
 790   SET_STRING (vl->type,            "setType");
 791   SET_STRING (vl->type_instance,   "setTypeInstance");
 792
 793 #undef SET_STRING
 794
 795   /* Set the `time' member. Java stores time in milliseconds. */
 796   status = ctoj_long (jvm_env, ((jlong) vl->time) * ((jlong) 1000),
 797       c_valuelist, o_valuelist, "setTime");
 798   if (status != 0)
 799   {
 800     ERROR ("java plugin: ctoj_value_list: ctoj_long (setTime) failed.");
 801     (*jvm_env)->DeleteLocalRef (jvm_env, o_valuelist);
 802     return (NULL);
 803   }
 804
 805   /* Set the `interval' member.. */
 806   status = ctoj_long (jvm_env, (jlong) vl->interval,
 807       c_valuelist, o_valuelist, "setInterval");
 808   if (status != 0)
 809   {
 810     ERROR ("java plugin: ctoj_value_list: ctoj_long (setInterval) failed.");
 811     (*jvm_env)->DeleteLocalRef (jvm_env, o_valuelist);
 812     return (NULL);
 813   }
 814
 815   for (i = 0; i < vl->values_len; i++)
 816   {
 817     status = ctoj_value_list_add_value (jvm_env, vl->values[i], ds->ds[i].type,
 818         c_valuelist, o_valuelist);
 819     if (status != 0)
 820     {
 821       ERROR ("java plugin: ctoj_value_list: "
 822           "ctoj_value_list_add_value failed.");
 823       (*jvm_env)->DeleteLocalRef (jvm_env, o_valuelist);
 824       return (NULL);
 825     }
 826   }
 827
 828   return (o_valuelist);
 829 } /* }}} int ctoj_value_list */
 830
 831 /*
 832  * Java to C conversion functions
 833  */
 834 static int jtoc_string (JNIEnv *jvm_env, /* {{{ */
 835     char *buffer, size_t buffer_size,
 836     jclass class_ptr, jobject object_ptr, const char *method_name)
 837 {
 838   jmethodID method_id;
 839   jobject string_obj;
 840   const char *c_str;
 841
 842   method_id = (*jvm_env)->GetMethodID (jvm_env, class_ptr,
 843       method_name, "()Ljava/lang/String;");
 844   if (method_id == NULL)
 845   {
 846     ERROR ("java plugin: jtoc_string: Cannot find method `String %s ()'.",
 847         method_name);
 848     return (-1);
 849   }
 850
 851   string_obj = (*jvm_env)->CallObjectMethod (jvm_env, object_ptr, method_id);
 852   if (string_obj == NULL)
 853   {
 854     ERROR ("java plugin: jtoc_string: CallObjectMethod (%s) failed.",
 855         method_name);
 856     return (-1);
 857   }
 858
 859   c_str = (*jvm_env)->GetStringUTFChars (jvm_env, string_obj, 0);
 860   if (c_str == NULL)
 861   {
 862     ERROR ("java plugin: jtoc_string: GetStringUTFChars failed.");
 863     (*jvm_env)->DeleteLocalRef (jvm_env, string_obj);
 864     return (-1);
 865   }
 866
 867   sstrncpy (buffer, c_str, buffer_size);
 868
 869   (*jvm_env)->ReleaseStringUTFChars (jvm_env, string_obj, c_str);
 870   (*jvm_env)->DeleteLocalRef (jvm_env, string_obj);
 871
 872   return (0);
 873 } /* }}} int jtoc_string */
 874
 875 static int jtoc_long (JNIEnv *jvm_env, /* {{{ */
 876     jlong *ret_value,
 877     jclass class_ptr, jobject object_ptr, const char *method_name)
 878 {
 879   jmethodID method_id;
 880
 881   method_id = (*jvm_env)->GetMethodID (jvm_env, class_ptr,
 882       method_name, "()J");
 883   if (method_id == NULL)
 884   {
 885     ERROR ("java plugin: jtoc_long: Cannot find method `long %s ()'.",
 886         method_name);
 887     return (-1);
 888   }
 889
 890   *ret_value = (*jvm_env)->CallLongMethod (jvm_env, object_ptr, method_id);
 891
 892   return (0);
 893 } /* }}} int jtoc_long */
 894
 895 static int jtoc_double (JNIEnv *jvm_env, /* {{{ */
 896     jdouble *ret_value,
 897     jclass class_ptr, jobject object_ptr, const char *method_name)
 898 {
 899   jmethodID method_id;
 900
 901   method_id = (*jvm_env)->GetMethodID (jvm_env, class_ptr,
 902       method_name, "()D");
 903   if (method_id == NULL)
 904   {
 905     ERROR ("java plugin: jtoc_string: Cannot find method `double %s ()'.",
 906         method_name);
 907     return (-1);
 908   }
 909
 910   *ret_value = (*jvm_env)->CallDoubleMethod (jvm_env, object_ptr, method_id);
 911
 912   return (0);
 913 } /* }}} int jtoc_double */
 914
 915 static int jtoc_value (JNIEnv *jvm_env, /* {{{ */
 916     value_t *ret_value, int ds_type, jobject object_ptr)
 917 {
 918   jclass class_ptr;
 919   int status;
 920
 921   class_ptr = (*jvm_env)->GetObjectClass (jvm_env, object_ptr);
 922
 923   if (ds_type == DS_TYPE_COUNTER)
 924   {
 925     jlong tmp_long;
 926
 927     status = jtoc_long (jvm_env, &tmp_long,
 928         class_ptr, object_ptr, "longValue");
 929     if (status != 0)
 930     {
 931       ERROR ("java plugin: jtoc_value: "
 932           "jtoc_long failed.");
 933       return (-1);
 934     }
 935     (*ret_value).counter = (counter_t) tmp_long;
 936   }
 937   else
 938   {
 939     jdouble tmp_double;
 940
 941     status = jtoc_double (jvm_env, &tmp_double,
 942         class_ptr, object_ptr, "doubleValue");
 943     if (status != 0)
 944     {
 945       ERROR ("java plugin: jtoc_value: "
 946           "jtoc_double failed.");
 947       return (-1);
 948     }
 949     (*ret_value).gauge = (gauge_t) tmp_double;
 950   }
 951
 952   return (0);
 953 } /* }}} int jtoc_value */
 954
 955 static int jtoc_values_array (JNIEnv *jvm_env, /* {{{ */
 956     const data_set_t *ds, value_list_t *vl,
 957     jclass class_ptr, jobject object_ptr)
 958 {
 959   jmethodID m_getvalues;
 960   jmethodID m_toarray;
 961   jobject o_list;
 962   jobjectArray o_number_array;
 963
 964   value_t *values;
 965   int values_num;
 966   int i;
 967
 968   values_num = ds->ds_num;
 969
 970   values = NULL;
 971   o_number_array = NULL;
 972   o_list = NULL;
 973
 974 #define BAIL_OUT(status) \
 975   free (values); \
 976   if (o_number_array != NULL) \
 977     (*jvm_env)->DeleteLocalRef (jvm_env, o_number_array); \
 978   if (o_list != NULL) \
 979     (*jvm_env)->DeleteLocalRef (jvm_env, o_list); \
 980   return (status);
 981
 982   /* Call: List<Number> ValueList.getValues () */
 983   m_getvalues = (*jvm_env)->GetMethodID (jvm_env, class_ptr,
 984       "getValues", "()Ljava/util/List;");
 985   if (m_getvalues == NULL)
 986   {
 987     ERROR ("java plugin: jtoc_values_array: "
 988         "Cannot find method `List getValues ()'.");
 989     BAIL_OUT (-1);
 990   }
 991
 992   o_list = (*jvm_env)->CallObjectMethod (jvm_env, object_ptr, m_getvalues);
 993   if (o_list == NULL)
 994   {
 995     ERROR ("java plugin: jtoc_values_array: "
 996         "CallObjectMethod (getValues) failed.");
 997     BAIL_OUT (-1);
 998   }
 999
1000   /* Call: Number[] List.toArray () */
1001   m_toarray = (*jvm_env)->GetMethodID (jvm_env,
1002       (*jvm_env)->GetObjectClass (jvm_env, o_list),
1003       "toArray", "()[Ljava/lang/Object;");
1004   if (m_toarray == NULL)
1005   {
1006     ERROR ("java plugin: jtoc_values_array: "
1007         "Cannot find method `Object[] toArray ()'.");
1008     BAIL_OUT (-1);
1009   }
1010
1011   o_number_array = (*jvm_env)->CallObjectMethod (jvm_env, o_list, m_toarray);
1012   if (o_number_array == NULL)
1013   {
1014     ERROR ("java plugin: jtoc_values_array: "
1015         "CallObjectMethod (toArray) failed.");
1016     BAIL_OUT (-1);
1017   }
1018
1019   values = calloc (values_num, sizeof (value_t));
1020   if (values == NULL)
1021   {
1022     ERROR ("java plugin: jtoc_values_array: calloc failed.");
1023     BAIL_OUT (-1);
1024   }
1025
1026   for (i = 0; i < values_num; i++)
1027   {
1028     jobject o_number;
1029     int status;
1030
1031     o_number = (*jvm_env)->GetObjectArrayElement (jvm_env,
1032         o_number_array, (jsize) i);
1033     if (o_number == NULL)
1034     {
1035       ERROR ("java plugin: jtoc_values_array: "
1036           "GetObjectArrayElement (%i) failed.", i);
1037       BAIL_OUT (-1);
1038     }
1039
1040     status = jtoc_value (jvm_env, values + i, ds->ds[i].type, o_number);
1041     if (status != 0)
1042     {
1043       ERROR ("java plugin: jtoc_values_array: "
1044           "jtoc_value (%i) failed.", i);
1045       BAIL_OUT (-1);
1046     }
1047   } /* for (i = 0; i < values_num; i++) */
1048
1049   vl->values = values;
1050   vl->values_len = values_num;
1051
1052 #undef BAIL_OUT
1053   (*jvm_env)->DeleteLocalRef (jvm_env, o_number_array);
1054   (*jvm_env)->DeleteLocalRef (jvm_env, o_list);
1055   return (0);
1056 } /* }}} int jtoc_values_array */
1057
1058 /* Convert a org.collectd.api.ValueList to a value_list_t. */
1059 static int jtoc_value_list (JNIEnv *jvm_env, value_list_t *vl, /* {{{ */
1060     jobject object_ptr)
1061 {
1062   jclass class_ptr;
1063   int status;
1064   jlong tmp_long;
1065   const data_set_t *ds;
1066
1067   class_ptr = (*jvm_env)->GetObjectClass (jvm_env, object_ptr);
1068   if (class_ptr == NULL)
1069   {
1070     ERROR ("java plugin: jtoc_value_list: GetObjectClass failed.");
1071     return (-1);
1072   }
1073
1074 #define SET_STRING(buffer,method) do { \
1075   status = jtoc_string (jvm_env, buffer, sizeof (buffer), \
1076       class_ptr, object_ptr, method); \
1077   if (status != 0) { \
1078     ERROR ("java plugin: jtoc_value_list: jtoc_string (%s) failed.", \
1079         method); \
1080     return (-1); \
1081   } } while (0)
1082
1083   SET_STRING(vl->type, "getType");
1084
1085   ds = plugin_get_ds (vl->type);
1086   if (ds == NULL)
1087   {
1088     ERROR ("java plugin: jtoc_value_list: Data-set `%s' is not defined. "
1089         "Please consult the types.db(5) manpage for mor information.",
1090         vl->type);
1091     return (-1);
1092   }
1093
1094   SET_STRING(vl->host, "getHost");
1095   SET_STRING(vl->plugin, "getPlugin");
1096   SET_STRING(vl->plugin_instance, "getPluginInstance");
1097   SET_STRING(vl->type_instance, "getTypeInstance");
1098
1099 #undef SET_STRING
1100
1101   status = jtoc_long (jvm_env, &tmp_long, class_ptr, object_ptr, "getTime");
1102   if (status != 0)
1103   {
1104     ERROR ("java plugin: jtoc_value_list: jtoc_long (getTime) failed.");
1105     return (-1);
1106   }
1107   /* Java measures time in milliseconds. */
1108   vl->time = (time_t) (tmp_long / ((jlong) 1000));
1109
1110   status = jtoc_long (jvm_env, &tmp_long,
1111       class_ptr, object_ptr, "getInterval");
1112   if (status != 0)
1113   {
1114     ERROR ("java plugin: jtoc_value_list: jtoc_long (getInterval) failed.");
1115     return (-1);
1116   }
1117   vl->interval = (int) tmp_long;
1118
1119   status = jtoc_values_array (jvm_env, ds, vl, class_ptr, object_ptr);
1120   if (status != 0)
1121   {
1122     ERROR ("java plugin: jtoc_value_list: jtoc_values_array failed.");
1123     return (-1);
1124   }
1125
1126   return (0);
1127 } /* }}} int jtoc_value_list */
1128
1129 static cjni_callback_info_t *cjni_callback_info_create (JNIEnv *jvm_env, /* {{{ */
1130     jobject o_name, jobject o_callback, int type)
1131 {
1132   const char *c_name;
1133   cjni_callback_info_t *cbi;
1134   const char *method_name;
1135   const char *method_signature;
1136
1137   switch (type)
1138   {
1139     case CB_TYPE_CONFIG:
1140       method_name = "Config";
1141       method_signature = "(Lorg/collectd/api/OConfigItem;)I";
1142       break;
1143
1144     case CB_TYPE_INIT:
1145       method_name = "Init";
1146       method_signature = "()I";
1147       break;
1148
1149     case CB_TYPE_READ:
1150       method_name = "Read";
1151       method_signature = "()I";
1152       break;
1153
1154     case CB_TYPE_WRITE:
1155       method_name = "Write";
1156       method_signature = "(Lorg/collectd/api/ValueList;)I";
1157       break;
1158
1159     case CB_TYPE_SHUTDOWN:
1160       method_name = "Shutdown";
1161       method_signature = "()I";
1162       break;
1163
1164     default:
1165       ERROR ("java plugin: cjni_callback_info_create: Unknown type: %#x",
1166           type);
1167       return (NULL);
1168   }
1169
1170   c_name = (*jvm_env)->GetStringUTFChars (jvm_env, o_name, 0);
1171   if (c_name == NULL)
1172   {
1173     ERROR ("java plugin: cjni_callback_info_create: "
1174         "GetStringUTFChars failed.");
1175     return (NULL);
1176   }
1177
1178   cbi = (cjni_callback_info_t *) malloc (sizeof (*cbi));
1179   if (cbi == NULL)
1180   {
1181     ERROR ("java plugin: cjni_callback_info_create: malloc failed.");
1182     (*jvm_env)->ReleaseStringUTFChars (jvm_env, o_name, c_name);
1183     return (NULL);
1184   }
1185   memset (cbi, 0, sizeof (*cbi));
1186   cbi->type = type;
1187
1188   cbi->name = strdup (c_name);
1189   if (cbi->name == NULL)
1190   {
1191     pthread_mutex_unlock (&java_callbacks_lock);
1192     ERROR ("java plugin: cjni_callback_info_create: strdup failed.");
1193     (*jvm_env)->ReleaseStringUTFChars (jvm_env, o_name, c_name);
1194     return (NULL);
1195   }
1196
1197   (*jvm_env)->ReleaseStringUTFChars (jvm_env, o_name, c_name);
1198
1199   cbi->class  = (*jvm_env)->GetObjectClass (jvm_env, o_callback);
1200   if (cbi->class == NULL)
1201   {
1202     ERROR ("java plugin: cjni_callback_info_create: GetObjectClass failed.");
1203     free (cbi);
1204     return (NULL);
1205   }
1206
1207   cbi->object = o_callback;
1208
1209   cbi->method = (*jvm_env)->GetMethodID (jvm_env, cbi->class,
1210       method_name, method_signature);
1211   if (cbi->method == NULL)
1212   {
1213     ERROR ("java plugin: cjni_callback_info_create: "
1214         "Cannot find the `%s' method with signature `%s'.",
1215         method_name, method_signature);
1216     free (cbi);
1217     return (NULL);
1218   }
1219
1220   (*jvm_env)->NewGlobalRef (jvm_env, o_callback);
1221
1222   return (cbi);
1223 } /* }}} cjni_callback_info_t cjni_callback_info_create */
1224
1225 static int cjni_callback_register (JNIEnv *jvm_env, /* {{{ */
1226     jobject o_name, jobject o_callback, int type)
1227 {
1228   cjni_callback_info_t *cbi;
1229   cjni_callback_info_t *tmp;
1230 #if COLLECT_DEBUG
1231   const char *type_str;
1232 #endif
1233
1234   cbi = cjni_callback_info_create (jvm_env, o_name, o_callback, type);
1235   if (cbi == NULL)
1236     return (-1);
1237
1238 #if COLLECT_DEBUG
1239   switch (type)
1240   {
1241     case CB_TYPE_CONFIG:
1242       type_str = "config";
1243       break;
1244
1245     case CB_TYPE_INIT:
1246       type_str = "init";
1247       break;
1248
1249     case CB_TYPE_SHUTDOWN:
1250       type_str = "shutdown";
1251       break;
1252
1253     default:
1254       type_str = "<unknown>";
1255   }
1256   DEBUG ("java plugin: Registering new %s callback: %s",
1257       type_str, cbi->name);
1258 #endif
1259
1260   pthread_mutex_lock (&java_callbacks_lock);
1261
1262   tmp = (cjni_callback_info_t *) realloc (java_callbacks,
1263       (java_callbacks_num + 1) * sizeof (*java_callbacks));
1264   if (tmp == NULL)
1265   {
1266     pthread_mutex_unlock (&java_callbacks_lock);
1267     ERROR ("java plugin: cjni_callback_register: realloc failed.");
1268
1269     (*jvm_env)->DeleteGlobalRef (jvm_env, cbi->object);
1270     free (cbi);
1271
1272     return (-1);
1273   }
1274   java_callbacks = tmp;
1275   java_callbacks[java_callbacks_num] = *cbi;
1276   java_callbacks_num++;
1277
1278   pthread_mutex_unlock (&java_callbacks_lock);
1279
1280   free (cbi);
1281   return (0);
1282 } /* }}} int cjni_callback_register */
1283
1284 /*
1285  * Functions accessible from Java
1286  */
1287 static jint JNICALL cjni_api_dispatch_values (JNIEnv *jvm_env, /* {{{ */
1288     jobject this, jobject java_vl)
1289 {
1290   value_list_t vl = VALUE_LIST_INIT;
1291   int status;
1292
1293   DEBUG ("cjni_api_dispatch_values: java_vl = %p;", (void *) java_vl);
1294
1295   status = jtoc_value_list (jvm_env, &vl, java_vl);
1296   if (status != 0)
1297   {
1298     ERROR ("java plugin: cjni_api_dispatch_values: jtoc_value_list failed.");
1299     return (-1);
1300   }
1301
1302   status = plugin_dispatch_values (&vl);
1303
1304   sfree (vl.values);
1305
1306   return (status);
1307 } /* }}} jint cjni_api_dispatch_values */
1308
1309 static jobject JNICALL cjni_api_get_ds (JNIEnv *jvm_env, /* {{{ */
1310     jobject this, jobject o_string_type)
1311 {
1312   const char *ds_name;
1313   const data_set_t *ds;
1314   jobject o_dataset;
1315
1316   ds_name = (*jvm_env)->GetStringUTFChars (jvm_env, o_string_type, 0);
1317   if (ds_name == NULL)
1318   {
1319     ERROR ("java plugin: cjni_api_get_ds: GetStringUTFChars failed.");
1320     return (NULL);
1321   }
1322
1323   ds = plugin_get_ds (ds_name);
1324   DEBUG ("java plugin: cjni_api_get_ds: "
1325       "plugin_get_ds (%s) = %p;", ds_name, (void *) ds);
1326
1327   (*jvm_env)->ReleaseStringUTFChars (jvm_env, o_string_type, ds_name);
1328
1329   if (ds == NULL)
1330     return (NULL);
1331
1332   o_dataset = ctoj_data_set (jvm_env, ds);
1333   return (o_dataset);
1334 } /* }}} jint cjni_api_get_ds */
1335
1336 static jint JNICALL cjni_api_register_config (JNIEnv *jvm_env, /* {{{ */
1337     jobject this, jobject o_name, jobject o_config)
1338 {
1339   return (cjni_callback_register (jvm_env, o_name, o_config, CB_TYPE_CONFIG));
1340 } /* }}} jint cjni_api_register_config */
1341
1342 static jint JNICALL cjni_api_register_init (JNIEnv *jvm_env, /* {{{ */
1343     jobject this, jobject o_name, jobject o_config)
1344 {
1345   return (cjni_callback_register (jvm_env, o_name, o_config, CB_TYPE_INIT));
1346 } /* }}} jint cjni_api_register_init */
1347
1348 static jint JNICALL cjni_api_register_read (JNIEnv *jvm_env, /* {{{ */
1349     jobject this, jobject o_name, jobject o_read)
1350 {
1351   user_data_t ud;
1352   cjni_callback_info_t *cbi;
1353
1354   cbi = cjni_callback_info_create (jvm_env, o_name, o_read, CB_TYPE_READ);
1355   if (cbi == NULL)
1356     return (-1);
1357
1358   DEBUG ("java plugin: Registering new read callback: %s", cbi->name);
1359
1360   memset (&ud, 0, sizeof (ud));
1361   ud.data = (void *) cbi;
1362   ud.free_func = cjni_callback_info_destroy;
1363
1364   plugin_register_complex_read (cbi->name, cjni_read, &ud);
1365
1366   (*jvm_env)->DeleteLocalRef (jvm_env, o_read);
1367
1368   return (0);
1369 } /* }}} jint cjni_api_register_read */
1370
1371 static jint JNICALL cjni_api_register_write (JNIEnv *jvm_env, /* {{{ */
1372     jobject this, jobject o_name, jobject o_write)
1373 {
1374   user_data_t ud;
1375   cjni_callback_info_t *cbi;
1376
1377   cbi = cjni_callback_info_create (jvm_env, o_name, o_write, CB_TYPE_WRITE);
1378   if (cbi == NULL)
1379     return (-1);
1380
1381   DEBUG ("java plugin: Registering new write callback: %s", cbi->name);
1382
1383   memset (&ud, 0, sizeof (ud));
1384   ud.data = (void *) cbi;
1385   ud.free_func = cjni_callback_info_destroy;
1386
1387   plugin_register_write (cbi->name, cjni_write, &ud);
1388
1389   (*jvm_env)->DeleteLocalRef (jvm_env, o_write);
1390
1391   return (0);
1392 } /* }}} jint cjni_api_register_write */
1393
1394 static jint JNICALL cjni_api_register_shutdown (JNIEnv *jvm_env, /* {{{ */
1395     jobject this, jobject o_name, jobject o_shutdown)
1396 {
1397   return (cjni_callback_register (jvm_env, o_name, o_shutdown,
1398         CB_TYPE_SHUTDOWN));
1399 } /* }}} jint cjni_api_register_shutdown */
1400
1401 static JNINativeMethod jni_api_functions[] = /* {{{ */
1402 {
1403   { "DispatchValues",
1404     "(Lorg/collectd/api/ValueList;)I",
1405     cjni_api_dispatch_values },
1406
1407   { "GetDS",
1408     "(Ljava/lang/String;)Lorg/collectd/api/DataSet;",
1409     cjni_api_get_ds },
1410
1411   { "RegisterConfig",
1412     "(Ljava/lang/String;Lorg/collectd/api/CollectdConfigInterface;)I",
1413     cjni_api_register_config },
1414
1415   { "RegisterInit",
1416     "(Ljava/lang/String;Lorg/collectd/api/CollectdInitInterface;)I",
1417     cjni_api_register_init },
1418
1419   { "RegisterRead",
1420     "(Ljava/lang/String;Lorg/collectd/api/CollectdReadInterface;)I",
1421     cjni_api_register_read },
1422
1423   { "RegisterWrite",
1424     "(Ljava/lang/String;Lorg/collectd/api/CollectdWriteInterface;)I",
1425     cjni_api_register_write },
1426
1427   { "RegisterShutdown",
1428     "(Ljava/lang/String;Lorg/collectd/api/CollectdShutdownInterface;)I",
1429     cjni_api_register_shutdown }
1430
1431 };
1432 static size_t jni_api_functions_num = sizeof (jni_api_functions)
1433   / sizeof (jni_api_functions[0]);
1434 /* }}} */
1435
1436 /*
1437  * Functions
1438  */
1439 static JNIEnv *cjni_thread_attach (void) /* {{{ */
1440 {
1441   cjni_jvm_env_t *cjni_env;
1442   JNIEnv *jvm_env;
1443
1444   cjni_env = pthread_getspecific (jvm_env_key);
1445   if (cjni_env == NULL)
1446   {
1447     /* This pointer is free'd in `cjni_jvm_env_destroy'. */
1448     cjni_env = (cjni_jvm_env_t *) malloc (sizeof (*cjni_env));
1449     if (cjni_env == NULL)
1450     {
1451       ERROR ("java plugin: cjni_thread_attach: malloc failed.");
1452       return (NULL);
1453     }
1454     memset (cjni_env, 0, sizeof (*cjni_env));
1455     cjni_env->reference_counter = 0;
1456     cjni_env->jvm_env = NULL;
1457
1458     pthread_setspecific (jvm_env_key, cjni_env);
1459   }
1460
1461   if (cjni_env->reference_counter > 0)
1462   {
1463     cjni_env->reference_counter++;
1464     jvm_env = cjni_env->jvm_env;
1465   }
1466   else
1467   {
1468     int status;
1469     JavaVMAttachArgs args;
1470
1471     assert (cjni_env->jvm_env == NULL);
1472
1473     memset (&args, 0, sizeof (args));
1474     args.version = JNI_VERSION_1_2;
1475
1476     status = (*jvm)->AttachCurrentThread (jvm, (void *) &jvm_env, (void *) &args);
1477     if (status != 0)
1478     {
1479       ERROR ("java plugin: cjni_thread_attach: AttachCurrentThread failed "
1480           "with status %i.", status);
1481       return (NULL);
1482     }
1483
1484     cjni_env->reference_counter = 1;
1485     cjni_env->jvm_env = jvm_env;
1486   }
1487
1488   DEBUG ("java plugin: cjni_thread_attach: cjni_env->reference_counter = %i",
1489       cjni_env->reference_counter);
1490   assert (jvm_env != NULL);
1491   return (jvm_env);
1492 } /* }}} JNIEnv *cjni_thread_attach */
1493
1494 static int cjni_thread_detach (void) /* {{{ */
1495 {
1496   cjni_jvm_env_t *cjni_env;
1497   int status;
1498
1499   cjni_env = pthread_getspecific (jvm_env_key);
1500   if (cjni_env == NULL)
1501   {
1502     ERROR ("java plugin: cjni_thread_detach: pthread_getspecific failed.");
1503     return (-1);
1504   }
1505
1506   assert (cjni_env->reference_counter > 0);
1507   assert (cjni_env->jvm_env != NULL);
1508
1509   cjni_env->reference_counter--;
1510   DEBUG ("java plugin: cjni_thread_detach: cjni_env->reference_counter = %i",
1511       cjni_env->reference_counter);
1512
1513   if (cjni_env->reference_counter > 0)
1514     return (0);
1515
1516   status = (*jvm)->DetachCurrentThread (jvm);
1517   if (status != 0)
1518   {
1519     ERROR ("java plugin: cjni_thread_detach: DetachCurrentThread failed "
1520         "with status %i.", status);
1521   }
1522
1523   cjni_env->reference_counter = 0;
1524   cjni_env->jvm_env = NULL;
1525
1526   return (0);
1527 } /* }}} JNIEnv *cjni_thread_attach */
1528
1529 static void cjni_jvm_env_destroy (void *args) /* {{{ */
1530 {
1531   cjni_jvm_env_t *cjni_env;
1532
1533   if (args == NULL)
1534     return;
1535
1536   cjni_env = (cjni_jvm_env_t *) args;
1537
1538   if (cjni_env->reference_counter > 0)
1539   {
1540     ERROR ("java plugin: cjni_jvm_env_destroy: "
1541         "cjni_env->reference_counter = %i;", cjni_env->reference_counter);
1542   }
1543
1544   if (cjni_env->jvm_env != NULL)
1545   {
1546     ERROR ("java plugin: cjni_jvm_env_destroy: cjni_env->jvm_env = %p;",
1547         (void *) cjni_env->jvm_env);
1548   }
1549
1550   /* The pointer is allocated in `cjni_thread_attach' */
1551   free (cjni_env);
1552 } /* }}} void cjni_jvm_env_destroy */
1553
1554 /*
1555  * Delete a global reference, set by the various `Register*' functions.
1556  */
1557 static void cjni_callback_info_destroy (void *arg) /* {{{ */
1558 {
1559   JNIEnv *jvm_env;
1560   cjni_callback_info_t *cbi;
1561
1562   DEBUG ("java plugin: cjni_callback_info_destroy (arg = %p);", arg);
1563
1564   if (arg == NULL)
1565     return;
1566
1567   jvm_env = cjni_thread_attach ();
1568   if (jvm_env == NULL)
1569   {
1570     ERROR ("java plugin: cjni_callback_info_destroy: cjni_thread_attach failed.");
1571     return;
1572   }
1573
1574   cbi = (cjni_callback_info_t *) arg;
1575
1576   (*jvm_env)->DeleteGlobalRef (jvm_env, cbi->object);
1577
1578   cbi->method = NULL;
1579   cbi->object = NULL;
1580   cbi->class  = NULL;
1581   free (cbi);
1582
1583   cjni_thread_detach ();
1584 } /* }}} void cjni_callback_info_destroy */
1585
1586 static int cjni_config_add_jvm_arg (oconfig_item_t *ci) /* {{{ */
1587 {
1588   char **tmp;
1589
1590   if ((ci->values_num != 1) || (ci->values[0].type != OCONFIG_TYPE_STRING))
1591   {
1592     WARNING ("java plugin: `JVMArg' needs exactly one string argument.");
1593     return (-1);
1594   }
1595
1596   tmp = (char **) realloc (jvm_argv, sizeof (char *) * (jvm_argc + 1));
1597   if (tmp == NULL)
1598   {
1599     ERROR ("java plugin: realloc failed.");
1600     return (-1);
1601   }
1602   jvm_argv = tmp;
1603
1604   jvm_argv[jvm_argc] = strdup (ci->values[0].value.string);
1605   if (jvm_argv[jvm_argc] == NULL)
1606   {
1607     ERROR ("java plugin: strdup failed.");
1608     return (-1);
1609   }
1610   jvm_argc++;
1611
1612   return (0);
1613 } /* }}} int cjni_config_add_jvm_arg */
1614
1615 static int cjni_config_load_plugin (oconfig_item_t *ci) /* {{{ */
1616 {
1617   java_plugin_class_t *tmp;
1618
1619   if ((ci->values_num != 1) || (ci->values[0].type != OCONFIG_TYPE_STRING))
1620   {
1621     WARNING ("java plugin: `LoadPlugin' needs exactly one string argument.");
1622     return (-1);
1623   }
1624
1625   tmp = (java_plugin_class_t *) realloc (java_classes_list,
1626       (java_classes_list_len + 1) * sizeof (*java_classes_list));
1627   if (tmp == NULL)
1628   {
1629     ERROR ("java plugin: realloc failed.");
1630     return (-1);
1631   }
1632   java_classes_list = tmp;
1633   tmp = java_classes_list + java_classes_list_len;
1634
1635   memset (tmp, 0, sizeof (*tmp));
1636   tmp->name = strdup (ci->values[0].value.string);
1637   if (tmp->name == NULL)
1638   {
1639     ERROR ("java plugin: strdup failed.");
1640     return (-1);
1641   }
1642   tmp->class = NULL;
1643   tmp->object = NULL;
1644
1645   java_classes_list_len++;
1646
1647   return (0);
1648 } /* }}} int cjni_config_load_plugin */
1649
1650 static int cjni_config_plugin_block (oconfig_item_t *ci) /* {{{ */
1651 {
1652   java_plugin_config_t *tmp;
1653   char *name;
1654   size_t i;
1655
1656   if ((ci->values_num != 1) || (ci->values[0].type != OCONFIG_TYPE_STRING))
1657   {
1658     WARNING ("java plugin: `Plugin' blocks "
1659         "need exactly one string argument.");
1660     return (-1);
1661   }
1662
1663   name = strdup (ci->values[0].value.string);
1664   if (name == NULL)
1665   {
1666     ERROR ("java plugin: cjni_config_plugin_block: strdup faiiled.");
1667     return (-1);
1668   }
1669
1670   for (i = 0; i < java_plugin_configs_num; i++)
1671   {
1672     if (strcmp (java_plugin_configs[i].name, name) == 0)
1673     {
1674       WARNING ("java plugin: There is more than one <Plugin \"%s\"> block. "
1675           "This is currently not supported - "
1676           "only the first block will be used!",
1677           name);
1678       free (name);
1679       return (0);
1680     }
1681   }
1682
1683   tmp = (java_plugin_config_t *) realloc (java_plugin_configs,
1684       (java_plugin_configs_num + 1) * sizeof (*java_plugin_configs));
1685   if (tmp == NULL)
1686   {
1687     ERROR ("java plugin: cjni_config_plugin_block: realloc failed.");
1688     free (name);
1689     return (-1);
1690   }
1691   java_plugin_configs = tmp;
1692   tmp = java_plugin_configs + java_plugin_configs_num;
1693
1694   tmp->name = name;
1695   tmp->ci = oconfig_clone (ci);
1696   if (tmp->ci == NULL)
1697   {
1698     ERROR ("java plugin: cjni_config_plugin_block: "
1699         "oconfig_clone failed for `%s'.",
1700         name);
1701     free (name);
1702     return (-1);
1703   }
1704
1705   DEBUG ("java plugin: cjni_config_plugin_block: "
1706       "Successfully copied config for `%s'.",
1707       name);
1708
1709   java_plugin_configs_num++;
1710   return (0);
1711 } /* }}} int cjni_config_plugin_block */
1712
1713 static int cjni_config (oconfig_item_t *ci) /* {{{ */
1714 {
1715   int success;
1716   int errors;
1717   int status;
1718   int i;
1719
1720   success = 0;
1721   errors = 0;
1722
1723   for (i = 0; i < ci->children_num; i++)
1724   {
1725     oconfig_item_t *child = ci->children + i;
1726
1727     if (strcasecmp ("JVMArg", child->key) == 0)
1728     {
1729       status = cjni_config_add_jvm_arg (child);
1730       if (status == 0)
1731         success++;
1732       else
1733         errors++;
1734     }
1735     else if (strcasecmp ("LoadPlugin", child->key) == 0)
1736     {
1737       status = cjni_config_load_plugin (child);
1738       if (status == 0)
1739         success++;
1740       else
1741         errors++;
1742     }
1743     else if (strcasecmp ("Plugin", child->key) == 0)
1744     {
1745       status = cjni_config_plugin_block (child);
1746       if (status == 0)
1747         success++;
1748       else
1749         errors++;
1750     }
1751     else
1752     {
1753       WARNING ("java plugin: Option `%s' not allowed here.", child->key);
1754       errors++;
1755     }
1756   }
1757
1758   DEBUG ("java plugin: jvm_argc = %zu;", jvm_argc);
1759   DEBUG ("java plugin: java_classes_list_len = %zu;", java_classes_list_len);
1760   DEBUG ("java plugin: java_plugin_configs_num = %zu;",
1761       java_plugin_configs_num);
1762
1763   if ((success == 0) && (errors > 0))
1764   {
1765     ERROR ("java plugin: All statements failed.");
1766     return (-1);
1767   }
1768
1769   return (0);
1770 } /* }}} int cjni_config */
1771
1772 static int cjni_read (user_data_t *ud) /* {{{ */
1773 {
1774   JNIEnv *jvm_env;
1775   cjni_callback_info_t *cbi;
1776   int status;
1777
1778   if (jvm == NULL)
1779   {
1780     ERROR ("java plugin: cjni_read: jvm == NULL");
1781     return (-1);
1782   }
1783
1784   if ((ud == NULL) || (ud->data == NULL))
1785   {
1786     ERROR ("java plugin: cjni_read: Invalid user data.");
1787     return (-1);
1788   }
1789
1790   jvm_env = cjni_thread_attach ();
1791   if (jvm_env == NULL)
1792     return (-1);
1793
1794   cbi = (cjni_callback_info_t *) ud->data;
1795
1796   status = (*jvm_env)->CallIntMethod (jvm_env, cbi->object,
1797       cbi->method);
1798
1799   status = cjni_thread_detach ();
1800   if (status != 0)
1801   {
1802     ERROR ("java plugin: cjni_read: cjni_thread_detach failed.");
1803     return (-1);
1804   }
1805
1806   return (status);
1807 } /* }}} int cjni_read */
1808
1809 static int cjni_write (const data_set_t *ds, const value_list_t *vl, /* {{{ */
1810     user_data_t *ud)
1811 {
1812   JNIEnv *jvm_env;
1813   cjni_callback_info_t *cbi;
1814   jobject vl_java;
1815   int status;
1816
1817   if (jvm == NULL)
1818   {
1819     ERROR ("java plugin: cjni_write: jvm == NULL");
1820     return (-1);
1821   }
1822
1823   if ((ud == NULL) || (ud->data == NULL))
1824   {
1825     ERROR ("java plugin: cjni_write: Invalid user data.");
1826     return (-1);
1827   }
1828
1829   jvm_env = cjni_thread_attach ();
1830   if (jvm_env == NULL)
1831     return (-1);
1832
1833   cbi = (cjni_callback_info_t *) ud->data;
1834
1835   vl_java = ctoj_value_list (jvm_env, ds, vl);
1836   if (vl_java == NULL)
1837   {
1838     ERROR ("java plugin: cjni_write: ctoj_value_list failed.");
1839     return (-1);
1840   }
1841
1842   status = (*jvm_env)->CallIntMethod (jvm_env,
1843       cbi->object, cbi->method, vl_java);
1844
1845   (*jvm_env)->DeleteLocalRef (jvm_env, vl_java);
1846
1847   status = cjni_thread_detach ();
1848   if (status != 0)
1849   {
1850     ERROR ("java plugin: cjni_write: cjni_thread_detach failed.");
1851     return (-1);
1852   }
1853
1854   return (status);
1855 } /* }}} int cjni_write */
1856
1857
1858 static int cjni_load_plugins (JNIEnv *jvm_env) /* {{{ */
1859 {
1860   size_t i;
1861
1862   for (i = 0; i < java_classes_list_len; i++)
1863   {
1864     java_plugin_class_t *class;
1865     jmethodID constructor_id;
1866
1867     class = java_classes_list + i;
1868
1869     DEBUG ("java plugin: Loading class %s", class->name);
1870
1871     class->class = (*jvm_env)->FindClass (jvm_env, class->name);
1872     if (class->class == NULL)
1873     {
1874       ERROR ("java plugin: cjni_load_plugins: FindClass (%s) failed.",
1875           class->name);
1876       continue;
1877     }
1878
1879     constructor_id = (*jvm_env)->GetMethodID (jvm_env, class->class,
1880         "<init>", "()V");
1881     if (constructor_id == NULL)
1882     {
1883       ERROR ("java plugin: cjni_load_plugins: Could not find the constructor for `%s'.",
1884           class->name);
1885       continue;
1886     }
1887
1888     class->object = (*jvm_env)->NewObject (jvm_env, class->class,
1889         constructor_id);
1890     if (class->object == NULL)
1891     {
1892       ERROR ("java plugin: cjni_load_plugins: Could create a new `%s' object.",
1893           class->name);
1894       continue;
1895     }
1896
1897     (*jvm_env)->NewGlobalRef (jvm_env, class->object);
1898   } /* for (i = 0; i < java_classes_list_len; i++) */
1899
1900   return (0);
1901 } /* }}} int cjni_load_plugins */
1902
1903 static int cjni_config_plugins (JNIEnv *jvm_env) /* {{{ */
1904 {
1905   int status;
1906   size_t i;
1907   size_t j;
1908
1909   for (i = 0; i < java_plugin_configs_num; i++)
1910   {
1911     jobject o_ocitem;
1912
1913     if (java_plugin_configs[i].ci == NULL)
1914       continue;
1915
1916     for (j = 0; j < java_callbacks_num; j++)
1917     {
1918       if (java_callbacks[j].type != CB_TYPE_CONFIG)
1919         continue;
1920
1921       if (strcmp (java_plugin_configs[i].name, java_callbacks[j].name) == 0)
1922         break;
1923     }
1924
1925     if (j >= java_callbacks_num)
1926     {
1927       NOTICE ("java plugin: Configuration for `%s' is present, but no such "
1928           "configuration callback has been registered.",
1929           java_plugin_configs[i].name);
1930       continue;
1931     }
1932
1933     DEBUG ("java plugin: Configuring %s", java_plugin_configs[i].name);
1934
1935     o_ocitem = ctoj_oconfig_item (jvm_env, java_plugin_configs[i].ci);
1936     if (o_ocitem == NULL)
1937     {
1938       ERROR ("java plugin: cjni_config_plugins: ctoj_oconfig_item failed.");
1939       continue;
1940     }
1941
1942     status = (*jvm_env)->CallIntMethod (jvm_env,
1943         java_callbacks[j].object, java_callbacks[j].method, o_ocitem);
1944     WARNING ("java plugin: Config callback for `%s' returned status %i.",
1945         java_plugin_configs[i].name, status);
1946   } /* for (i = 0; i < java_plugin_configs; i++) */
1947
1948   return (0);
1949 } /* }}} int cjni_config_plugins */
1950
1951 static int cjni_init_plugins (JNIEnv *jvm_env) /* {{{ */
1952 {
1953   int status;
1954   size_t i;
1955
1956   for (i = 0; i < java_callbacks_num; i++)
1957   {
1958     if (java_callbacks[i].type != CB_TYPE_INIT)
1959       continue;
1960
1961     DEBUG ("java plugin: Initializing %s", java_callbacks[i].name);
1962
1963     status = (*jvm_env)->CallIntMethod (jvm_env,
1964         java_callbacks[i].object, java_callbacks[i].method);
1965     if (status != 0)
1966     {
1967       ERROR ("java plugin: Initializing `%s' failed with status %i. "
1968           "Removing read function.",
1969           java_callbacks[i].name, status);
1970       plugin_unregister_read (java_callbacks[i].name);
1971     }
1972   }
1973
1974   return (0);
1975 } /* }}} int cjni_init_plugins */
1976
1977 static int cjni_shutdown_plugins (JNIEnv *jvm_env) /* {{{ */
1978 {
1979   int status;
1980   size_t i;
1981
1982   for (i = 0; i < java_callbacks_num; i++)
1983   {
1984     if (java_callbacks[i].type != CB_TYPE_SHUTDOWN)
1985       continue;
1986
1987     DEBUG ("java plugin: Shutting down %s", java_callbacks[i].name);
1988
1989     status = (*jvm_env)->CallIntMethod (jvm_env,
1990         java_callbacks[i].object, java_callbacks[i].method);
1991     if (status != 0)
1992     {
1993       ERROR ("java plugin: Shutting down `%s' failed with status %i. ",
1994           java_callbacks[i].name, status);
1995     }
1996   }
1997
1998   return (0);
1999 } /* }}} int cjni_shutdown_plugins */
2000
2001
2002 static int cjni_shutdown (void) /* {{{ */
2003 {
2004   JNIEnv *jvm_env;
2005   JavaVMAttachArgs args;
2006   int status;
2007   size_t i;
2008
2009   if (jvm == NULL)
2010     return (0);
2011
2012   jvm_env = NULL;
2013   memset (&args, 0, sizeof (args));
2014   args.version = JNI_VERSION_1_2;
2015
2016   status = (*jvm)->AttachCurrentThread (jvm, (void **) &jvm_env, &args);
2017   if (status != 0)
2018   {
2019     ERROR ("java plugin: cjni_shutdown: AttachCurrentThread failed with status %i.",
2020         status);
2021     return (-1);
2022   }
2023
2024   /* Execute all the shutdown functions registered by plugins. */
2025   cjni_shutdown_plugins (jvm_env);
2026
2027   /* Release all the global references to callback functions */
2028   for (i = 0; i < java_callbacks_num; i++)
2029   {
2030     if (java_callbacks[i].object != NULL)
2031     {
2032       (*jvm_env)->DeleteGlobalRef (jvm_env, java_callbacks[i].object);
2033       java_callbacks[i].object = NULL;
2034     }
2035     sfree (java_callbacks[i].name);
2036   }
2037   java_callbacks_num = 0;
2038   sfree (java_callbacks);
2039
2040   /* Release all the global references to directly loaded classes. */
2041   for (i = 0; i < java_classes_list_len; i++)
2042   {
2043     if (java_classes_list[i].object != NULL)
2044     {
2045       (*jvm_env)->DeleteGlobalRef (jvm_env, java_classes_list[i].object);
2046       java_classes_list[i].object = NULL;
2047     }
2048     sfree (java_classes_list[i].name);
2049   }
2050   java_classes_list_len = 0;
2051   sfree (java_classes_list);
2052
2053   /* Destroy the JVM */
2054   (*jvm)->DestroyJavaVM (jvm);
2055   jvm = NULL;
2056   jvm_env = NULL;
2057
2058   pthread_key_delete (jvm_env_key);
2059
2060   /* Free the JVM argument list */
2061   for (i = 0; i < jvm_argc; i++)
2062     sfree (jvm_argv[i]);
2063   jvm_argc = 0;
2064   sfree (jvm_argv);
2065
2066   /* Free the copied configuration */
2067   for (i = 0; i < java_plugin_configs_num; i++)
2068   {
2069     sfree (java_plugin_configs[i].name);
2070     oconfig_free (java_plugin_configs[i].ci);
2071   }
2072   java_plugin_configs_num = 0;
2073   sfree (java_plugin_configs);
2074
2075   return (0);
2076 } /* }}} int cjni_shutdown */
2077
2078 static int cjni_init_native (JNIEnv *jvm_env) /* {{{ */
2079 {
2080   jclass api_class_ptr;
2081   int status;
2082
2083   api_class_ptr = (*jvm_env)->FindClass (jvm_env, "org.collectd.api.CollectdAPI");
2084   if (api_class_ptr == NULL)
2085   {
2086     ERROR ("cjni_init_native: Cannot find API class `org.collectd.api.CollectdAPI'.");
2087     return (-1);
2088   }
2089
2090   status = (*jvm_env)->RegisterNatives (jvm_env, api_class_ptr,
2091       jni_api_functions, (jint) jni_api_functions_num);
2092   if (status != 0)
2093   {
2094     ERROR ("cjni_init_native: RegisterNatives failed with status %i.", status);
2095     return (-1);
2096   }
2097
2098   return (0);
2099 } /* }}} int cjni_init_native */
2100
2101 static int cjni_init (void) /* {{{ */
2102 {
2103   JNIEnv *jvm_env;
2104   JavaVMInitArgs vm_args;
2105   JavaVMOption vm_options[jvm_argc];
2106
2107   int status;
2108   size_t i;
2109
2110   if (jvm != NULL)
2111     return (0);
2112
2113   status = pthread_key_create (&jvm_env_key, cjni_jvm_env_destroy);
2114   if (status != 0)
2115   {
2116     ERROR ("java plugin: cjni_init: pthread_key_create failed "
2117         "with status %i.", status);
2118     return (-1);
2119   }
2120
2121   jvm_env = NULL;
2122
2123   memset (&vm_args, 0, sizeof (vm_args));
2124   vm_args.version = JNI_VERSION_1_2;
2125   vm_args.options = vm_options;
2126   vm_args.nOptions = (jint) jvm_argc;
2127
2128   for (i = 0; i < jvm_argc; i++)
2129   {
2130     DEBUG ("java plugin: cjni_init: jvm_argv[%zu] = %s", i, jvm_argv[i]);
2131     vm_args.options[i].optionString = jvm_argv[i];
2132   }
2133   /*
2134   vm_args.options[0].optionString = "-verbose:jni";
2135   vm_args.options[1].optionString = "-Djava.class.path=/home/octo/collectd/bindings/java";
2136   */
2137
2138   status = JNI_CreateJavaVM (&jvm, (void **) &jvm_env, (void **) &vm_args);
2139   if (status != 0)
2140   {
2141     ERROR ("cjni_init: JNI_CreateJavaVM failed with status %i.",
2142         status);
2143     return (-1);
2144   }
2145   assert (jvm != NULL);
2146   assert (jvm_env != NULL);
2147
2148   /* Call RegisterNatives */
2149   status = cjni_init_native (jvm_env);
2150   if (status != 0)
2151   {
2152     ERROR ("cjni_init: cjni_init_native failed.");
2153     return (-1);
2154   }
2155
2156   cjni_load_plugins (jvm_env);
2157   cjni_config_plugins (jvm_env);
2158   cjni_init_plugins (jvm_env);
2159
2160   return (0);
2161 } /* }}} int cjni_init */
2162
2163 void module_register (void)
2164 {
2165   plugin_register_complex_config ("java", cjni_config);
2166   plugin_register_init ("java", cjni_init);
2167   plugin_register_shutdown ("java", cjni_shutdown);
2168 } /* void module_register (void) */
2169
2170 /* vim: set sw=2 sts=2 et fdm=marker : */