/********************************************************************
 *
 * Testing for thread safety in H5A (dataset attribute) library
 * operations. -- Threaded program --
 * ------------------------------------------------------------------
 *
 * Plan: Attempt to break H5Acreate by making many simultaneous create
 *       calls.
 *
 * Claim: N calls to H5Acreate should create N attributes for a dataset
 *        if threadsafe. If some unprotected shared data exists for the
 *        dataset (eg, a count of the number of attributes in the
 *        dataset), there is a small chance that consecutive reads occur
 *        before a write to that shared variable.
 *
 * HDF5 APIs exercised in thread:
 * H5Acreate, H5Awrite, H5Aclose.
 *
 * Created: Oct 5 1999
 * Programmer: Chee Wai LEE
 *
 * Modification History
 * --------------------
 * May 15 2000 - incorporated into library tests (Chee Wai LEE)
 *
 ********************************************************************/

#include "ttsafe.h"

#ifndef H5_HAVE_THREADSAFE
static int dummy;	/* just to create a non-empty object file */
#else

#include <stdio.h>
#include <stdlib.h>

#define FILE "ttsafe.h5"
#define DATASETNAME "IntData"
#define NUM_THREADS 16

void *tts_acreate_thread(void *);

typedef struct acreate_data_struct {
  hid_t dataset;
  hid_t datatype;
  hid_t dataspace;
  int current_index;
} ttsafe_name_data_t;

void tts_acreate(void) {

  /* Pthread definitions
  */
  pthread_t threads[NUM_THREADS];

  /* HDF5 data definitions
   */
  hid_t   file, dataset;
  hid_t   dataspace, datatype;
  hid_t   attribute;
  hsize_t dimsf[1];               /* dataset dimensions */

  int     data;                   /* data to write */
  int     buffer, ret;

  int     i;
  ttsafe_name_data_t *attrib_data; 

  /* create a hdf5 file using H5F_ACC_TRUNC access,
   * default file creation plist and default file
   * access plist
   */
  file = H5Fcreate(FILE, H5F_ACC_TRUNC, H5P_DEFAULT, H5P_DEFAULT);

  /* create a simple dataspace for the dataset
   */
  dimsf[0] = 1;
  dataspace = H5Screate_simple(1,dimsf,NULL);

  /* define datatype for the data using native little endian integers
   */
  datatype = H5Tcopy(H5T_NATIVE_INT);
  H5Tset_order(datatype, H5T_ORDER_LE);

  /* create a new dataset within the file
   */
  dataset = H5Dcreate(file, DATASETNAME, datatype, dataspace,
		      H5P_DEFAULT);

  /* initialize data for dataset and write value to dataset
   */
  data = NUM_THREADS;
  H5Dwrite(dataset, H5T_NATIVE_INT, H5S_ALL, H5S_ALL,
	   H5P_DEFAULT, &data);

  /* simultaneously create a large number of attributes to be 
     associated with the dataset
  */

  for (i=0;i<NUM_THREADS;i++) {
    attrib_data = malloc(sizeof(ttsafe_name_data_t));
    attrib_data->dataset = dataset;
    attrib_data->datatype = datatype;
    attrib_data->dataspace = dataspace;
    attrib_data->current_index = i;
    pthread_create(&threads[i],NULL,tts_acreate_thread,attrib_data);
  }

  for (i=0;i<NUM_THREADS;i++) {
    pthread_join(threads[i],NULL);
  }

  /* verify the correctness of the test */
  for (i=0; i<NUM_THREADS; i++) {
    attribute = H5Aopen_name(dataset,gen_name(i));
    if (attribute < 0) {
      fprintf(stderr,"unable to open appropriate attribute. Test failed!\n");
    } else {
      ret = H5Aread(attribute, H5T_NATIVE_INT, &buffer);
      if ((ret < 0) || (buffer != i)) {
	fprintf(stderr,"wrong data values. Test failed!\n");
      }
      H5Aclose(attribute);
    }
  }

  /* close remaining resources
   */
  H5Sclose(dataspace);
  H5Tclose(datatype);
  H5Dclose(dataset);
  H5Fclose(file);
}

void *tts_acreate_thread(void *client_data) {

  hid_t   attribute;
  hsize_t dimsf[1];               /* dataset dimensions */

  char    *attribute_name;
  int     *attribute_data;         /* data for attributes */
  int     i;

  ttsafe_name_data_t *attrib_data = (ttsafe_name_data_t *)client_data;

  /* create attribute
   */
  attribute_name = gen_name(attrib_data->current_index);
  attribute = H5Acreate(attrib_data->dataset,
			attribute_name,
			attrib_data->datatype,
			attrib_data->dataspace,
			H5P_DEFAULT);

  /* Write data to the attribute
   */
  attribute_data = malloc(sizeof(int));
  *attribute_data = attrib_data->current_index;
  H5Awrite(attribute,H5T_NATIVE_INT,attribute_data);
  H5Aclose(attribute);

  return NULL;
}

void cleanup_acreate(void) {
}

#endif /*H5_HAVE_THREADSAFE*/