config_parser.c

/*
 * Copyright 2013-2014 sgminer developers (see AUTHORS.md)
 * Copyright 2011-2013 Con Kolivas
 * Copyright 2011-2012 Luke Dashjr
 * Copyright 2010 Jeff Garzik
 *
 * This program is free software; you can redistribute it and/or modify it
 * under the terms of the GNU General Public License as published by the Free
 * Software Foundation; either version 3 of the License, or (at your option)
 * any later version.  See COPYING for more details.
 */

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <stdbool.h>
#include <stdint.h>
#include <unistd.h>
#include <sys/time.h>
#include <time.h>
#include <math.h>
#include <stdarg.h>
#include <assert.h>
#include <signal.h>
#include <limits.h>

#include <sys/stat.h>
#include <sys/types.h>
#include <ccan/opt/opt.h>
#include <jansson.h>
#include <libgen.h>
#include <sha2.h>

#include "compat.h"
#include "miner.h"
#include "config_parser.h"
#include "driver-opencl.h"
#include "bench_block.h"

#include "algorithm.h"
#include "pool.h"

#ifdef HAVE_ADL
#include "adl.h"
#endif

#if defined(unix) || defined(__APPLE__)
  #include <errno.h>
  #include <fcntl.h>
  #include <sys/wait.h>
#endif

char *cnfbuf = NULL;  //config file loaded
int fileconf_load;   //config file load status
const char def_conf[] = "sgminer.conf";
char *default_config;
bool config_loaded;
//static int include_count;

int json_array_index = -1;  //current array index being parsed
char *last_json_error = NULL;  //last json_error
/*#define JSON_MAX_DEPTH 10
#define JSON_MAX_DEPTH_ERR "Too many levels of JSON includes (limit 10) or a loop"*/

/*******************************************
 * Profile list functions
 *******************************************/
struct profile default_profile;
struct profile **profiles;
int total_profiles;

static struct profile *add_profile()
{
  struct profile *profile;
  char buf[32];

  if(!(profile = (struct profile *)calloc(sizeof(struct profile), 1)))
    quit(1, "Failed to calloc profile in add_profile");
  profile->profile_no = total_profiles;

  //default profile name is the profile index
  sprintf(buf, "%d", profile->profile_no);
  profile->name = strdup(buf);

  profiles = (struct profile **)realloc(profiles, sizeof(struct profile *) * (total_profiles + 2));
  profiles[total_profiles++] = profile;

  return profile;
}

static void remove_profile(struct profile *profile)
{
  int i;
  int found = 0;

  for(i = 0; i < (total_profiles - 1); i++)
  {
    //look for the profile
    if(profiles[i]->profile_no == profile->profile_no)
      found = 1;
    
    //once we found the profile, change the current index profile to next
    if(found)
    {
      profiles[i] = profiles[i+1];
      profiles[i]->profile_no = i;
    }
  }
  
  //give the profile an invalid number and remove
  profile->profile_no = total_profiles;
  profile->removed = true;
  total_profiles--;
}

//only used while loading config
static struct profile *get_current_profile()
{
  while ((json_array_index + 1) > total_profiles)
    add_profile();

  if (json_array_index < 0)
  {
    if (!total_profiles)
      add_profile();
    return profiles[total_profiles - 1];
  }

  return profiles[json_array_index];
}

//find a profile by name
static struct profile *get_profile(char *name)
{
  int i;

  for(i=total_profiles;i--;)
  {
    if(!strcasecmp(profiles[i]->name, name))
      return profiles[i];
  }

  return NULL;
}

/******* Default profile functions used during config parsing *****/
char *set_default_devices(const char *arg)
{
  default_profile.devices = arg;
  return NULL;
}

char *set_default_lookup_gap(const char *arg)
{
  default_profile.lookup_gap = arg;
  return NULL;
}

char *set_default_intensity(const char *arg)
{
  default_profile.intensity = arg;
  return NULL;
}

char *set_default_xintensity(const char *arg)
{
  default_profile.xintensity = arg;
  return NULL;
}

char *set_default_rawintensity(const char *arg)
{
  default_profile.rawintensity = arg;
  return NULL;
}

char *set_default_thread_concurrency(const char *arg)
{
  default_profile.thread_concurrency = arg;
  return NULL;
}

#ifdef HAVE_ADL

  char *set_default_gpu_engine(const char *arg)
  {
    default_profile.gpu_engine = arg;
    return NULL;
  }

  char *set_default_gpu_memclock(const char *arg)
  {
    default_profile.gpu_memclock = arg;
    return NULL;
  }

  char *set_default_gpu_threads(const char *arg)
  {
    default_profile.gpu_threads = arg;
    return NULL;
  }

  char *set_default_gpu_fan(const char *arg)
  {
    default_profile.gpu_fan = arg;
    return NULL;
  }

  char *set_default_gpu_powertune(const char *arg)
  {
    default_profile.gpu_powertune = arg;
    return NULL;
  }

  char *set_default_gpu_vddc(const char *arg)
  {
    default_profile.gpu_vddc = arg;
    return NULL;
  }

#endif

char *set_default_profile(char *arg)
{
  default_profile.name = arg;
  return NULL;
}

char *set_default_shaders(const char *arg)
{
  default_profile.shaders = arg;
  return NULL;
}

char *set_default_worksize(const char *arg)
{
  default_profile.worksize = arg;
  return NULL;
}

/****** Profile functions used in during config parsing ********/
char *set_profile_name(const char *arg)
{
  struct profile *profile = get_current_profile();

  applog(LOG_DEBUG, "Setting profile %i name to %s", profile->profile_no, arg);
  opt_set_charp(arg, &profile->name);

  return NULL;
}

char *set_profile_algorithm(const char *arg)
{
  struct profile *profile = get_current_profile();

  //applog(LOG_DEBUG, "Setting profile %s algorithm to %s", profile->name, arg);
  set_algorithm(&profile->algorithm, arg);

  return NULL;
}

char *set_profile_devices(const char *arg)
{
  struct profile *profile = get_current_profile();
  profile->devices = arg;
  return NULL;
}

char *set_profile_lookup_gap(const char *arg)
{
  struct profile *profile = get_current_profile();
  profile->lookup_gap = arg;
  return NULL;
}

char *set_profile_intensity(const char *arg)
{
  struct profile *profile = get_current_profile();
  profile->intensity = arg;
  return NULL;
}

char *set_profile_xintensity(const char *arg)
{
  struct profile *profile = get_current_profile();
  profile->xintensity = arg;
  return NULL;
}

char *set_profile_rawintensity(const char *arg)
{
  struct profile *profile = get_current_profile();
  profile->rawintensity = arg;
  return NULL;
}

char *set_profile_thread_concurrency(const char *arg)
{
  struct profile *profile = get_current_profile();
  profile->thread_concurrency = arg;
  return NULL;
}

#ifdef HAVE_ADL

  char *set_profile_gpu_engine(const char *arg)
  {
    struct profile *profile = get_current_profile();
    profile->gpu_engine = arg;
    return NULL;
  }

  char *set_profile_gpu_memclock(const char *arg)
  {
    struct profile *profile = get_current_profile();
    profile->gpu_memclock = arg;
    return NULL;
  }

  char *set_profile_gpu_threads(const char *arg)
  {
    struct profile *profile = get_current_profile();
    profile->gpu_threads = arg;
    return NULL;
  }

  char *set_profile_gpu_fan(const char *arg)
  {
    struct profile *profile = get_current_profile();
    profile->gpu_fan = arg;
    return NULL;
  }

  char *set_profile_gpu_powertune(const char *arg)
  {
    struct profile *profile = get_current_profile();
    profile->gpu_powertune = arg;
    return NULL;
  }

  char *set_profile_gpu_vddc(const char *arg)
  {
    struct profile *profile = get_current_profile();
    profile->gpu_vddc = arg;
    return NULL;
  }

#endif

char *set_profile_nfactor(const char *arg)
{
  struct profile *profile = get_current_profile();

  applog(LOG_DEBUG, "Setting profile %s N-factor to %s", profile->name, arg);
  set_algorithm_nfactor(&profile->algorithm, (const uint8_t) atoi(arg));

  return NULL;
}

char *set_profile_shaders(const char *arg)
{
  struct profile *profile = get_current_profile();
  profile->shaders = arg;
  return NULL;
}

char *set_profile_worksize(const char *arg)
{
  struct profile *profile = get_current_profile();
  profile->worksize = arg;
  return NULL;
}

/***************************************
* Helper Functions
****************************************/
json_t *json_sprintf(const char *fmt, ...)
{
  va_list args;
  char *buf;
  size_t bufsize;
  
  //build args
  va_start(args, fmt);
  //get final string buffer size
  bufsize = vsnprintf(NULL, 0, fmt, args);
  va_end(args);
  
  if(!(buf = (char *)malloc(++bufsize)))
    quit(1, "Malloc failure in config_parser::json_sprintf().");

  //zero out buffer
  memset(buf, '\0', bufsize);

  //get args again
  va_start(args, fmt);
  vsnprintf(buf, bufsize, fmt, args);
  va_end(args);

  //return json string
  return json_string(buf);
}

//set last json error
char *set_last_json_error(const char *fmt, ...)
{
  va_list args;
  size_t bufsize;

  //build args
  va_start(args, fmt);
  //get final string buffer size
  bufsize = vsnprintf(NULL, 0, fmt, args);
  va_end(args);

  //if NULL allocate memory... otherwise reallocate
  if(!last_json_error)
  {
    if(!(last_json_error = (char *)malloc(++bufsize)))
      quit(1, "Malloc failure in config_parser::set_last_json_error().");
  }
  else
  {
    if(!(last_json_error = (char *)realloc(last_json_error, ++bufsize)))
      quit(1, "Realloc failure in config_parser::set_last_json_error().");
  }

  //zero out buffer
  memset(last_json_error, '\0', bufsize);

  //get args again
  va_start(args, fmt);
  vsnprintf(last_json_error, bufsize, fmt, args);
  va_end(args);
  
  return last_json_error;
}

//find opt by name in an opt table
static struct opt_table *opt_find(struct opt_table *tbl, char *optname)
{
  struct opt_table *opt;
  char *p, *name;

  for(opt = tbl;opt->type != OPT_END;opt++)
  {
    /* We don't handle subtables. */
    assert(!(opt->type & OPT_SUBTABLE));

    if(!opt->names)
      continue;

    /* Pull apart the option name(s). */
    name = strdup(opt->names);
    for(p = strtok(name, "|");p;p = strtok(NULL, "|"))
    {
      /* Ignore short options. */
      if(p[1] != '-')
        continue;

      //if this is the opt we're looking for, return it...
      if(!strcasecmp(optname, p))
      {
        free(name);
        return opt;
      }
    }
    free(name);
  }

  return NULL;
}


/***************************************
* Config Parsing Functions
****************************************/
//Handle parsing JSON objects
void parse_config_object(json_t *obj, const char *parentkey, bool fileconf, int parent_iteration)
{
  //char *err = NULL;
  const char *key;
  json_t *val;

  json_object_foreach(obj, key, val)
  {
    //process include
    if(!strcasecmp(key, "include"))
    {
      if(val && json_is_string(val))
        load_config(json_string_value(val), parentkey, NULL);
    }
    else
      parse_config(val, key, parentkey, fileconf, parent_iteration);
    /*
    {
      if((err = parse_config(val, key, parentkey, fileconf, parent_iteration)))
        return err;
    }*/
  }
}

//Handle parsing JSON arrays
static char *parse_config_array(json_t *obj, char *parentkey, bool fileconf)
{
  char *err = NULL;
  size_t idx;
  json_t *val;

  //fix parent key - remove extra "s" to match opt names (e.g. --pool-gpu-memclock not --pools-gpu-memclock)
  if(!strcasecmp(parentkey, "pools") || !strcasecmp(parentkey, "profiles"))
    parentkey[(strlen(parentkey) - 1)] = '\0';

  json_array_foreach(obj, idx, val)
  {
    //abort on error
    if((err = parse_config(val, "", parentkey, fileconf, idx)))
      return err;
  }

  return NULL;
}

//Parse JSON values from config file
char *parse_config(json_t *val, const char *key, const char *parentkey, bool fileconf, int parent_iteration)
{
  static char err_buf[200];
  char *err = NULL;
  struct opt_table *opt;
  char optname[255];
  /*const char *key
  json_t *val;*/

  json_array_index = parent_iteration;

  if (fileconf && !fileconf_load)
    fileconf_load = 1;

  /*
  parse the json config items into opts instead of looking for opts in the json config...
  This adds greater flexibility with config files.
  */
  switch(json_typeof(val))
  {
    //json value is an object
    case JSON_OBJECT:
      parse_config_object(val, parentkey, false, parent_iteration);
      break;

    //json value is an array
    case JSON_ARRAY:
      err = parse_config_array(val, (char *)key, fileconf);
      break;

    //other json types process here
    default:
      //convert json key to opt name
      sprintf(optname, "--%s%s%s", ((!empty_string(parentkey))?parentkey:""), ((!empty_string(parentkey))?"-":""), key);

      //look up opt name in config table
      if((opt = opt_find(opt_config_table, optname)) != NULL)
      {
        //strings
        if ((opt->type & OPT_HASARG) && json_is_string(val))
          err = opt->cb_arg(json_string_value(val), opt->u.arg);
        //boolean values
        else if ((opt->type & OPT_NOARG) && json_is_true(val))
          err = opt->cb(opt->u.arg);
        else
          err = "Invalid value";
      }
      else
        err = "Invalid option";

      break;
  }

  //error processing JSON...
  if(err)
  {
    /* Allow invalid values to be in configuration
     * file, just skipping over them provided the
     * JSON is still valid after that. */
    if(fileconf)
    {
      applog(LOG_WARNING, "Skipping config option %s: %s", optname+2, err);
      fileconf_load = -1;
    }
    else
    {
      snprintf(err_buf, sizeof(err_buf), "Error parsing JSON option %s: %s", optname+2, err);
      return err_buf;
    }
  }

  return NULL;
}

char *load_config(const char *arg, const char *parentkey, void __maybe_unused *unused)
{
  json_error_t err;
  json_t *config;

  //most likely useless but leaving it here for now...
  if(!cnfbuf)
    cnfbuf = strdup(arg);

  //no need to restrict the number of includes... if it causes problems, restore it later
  /*if(++include_count > JSON_MAX_DEPTH)
    return JSON_MAX_DEPTH_ERR;
  */

#if JANSSON_MAJOR_VERSION > 1
  config = json_load_file(arg, 0, &err);
#else
  config = json_load_file(arg, &err);
#endif

  //if json root is not an object, error out
  if(!json_is_object(config))
    return set_last_json_error("Error: JSON decode of file \"%s\" failed:\n %s", arg, err.text);

  config_loaded = true;

  /* Parse the config now, so we can override it.  That can keep pointers
  * so don't free config object. */
  return parse_config(config, "", parentkey, true, -1);
}

char *set_default_config(const char *arg)
{
  opt_set_charp(arg, &default_config);
  return NULL;
}

void load_default_config(void)
{
  cnfbuf = (char *)malloc(PATH_MAX);

  default_save_file(cnfbuf);

  if (!access(cnfbuf, R_OK))
  load_config(cnfbuf, "", NULL);
  else {
  free(cnfbuf);
  cnfbuf = NULL;
  }
}

/*******************************************
 * Startup functions
 * *****************************************/

// assign default settings from default profile if set
void load_default_profile()
{
  applog(LOG_DEBUG, "default_profile.name is %s", default_profile.name);
  if (empty_string(default_profile.name))
  {
    applog(LOG_WARNING, "Default profile name is not set.");
    return;
  }

  struct profile *profile;

  // find profile ...
  profile = get_profile(default_profile.name);
  if (!profile) {
    applog(LOG_WARNING, "Could not load default profile %s",
	   default_profile.name);
    return;
  }

  // ... and copy settings
  default_profile.algorithm = profile->algorithm;
  default_profile.devices = profile->devices;
  default_profile.lookup_gap = profile->lookup_gap;
  default_profile.intensity = profile->intensity;
  default_profile.xintensity = profile->xintensity;
  default_profile.rawintensity = profile->rawintensity;
  default_profile.thread_concurrency = profile->thread_concurrency;
#ifdef HAVE_ADL
  default_profile.gpu_engine = profile->gpu_engine;
  default_profile.gpu_memclock = profile->gpu_memclock;
  default_profile.gpu_threads = profile->gpu_threads;
  default_profile.gpu_fan = profile->gpu_fan;
  default_profile.gpu_powertune = profile->gpu_powertune;
  default_profile.gpu_vddc = profile->gpu_vddc;
#endif
  default_profile.shaders = profile->shaders;
  default_profile.worksize = profile->worksize;
}

//apply default settings
void apply_defaults()
{
  set_algorithm(&opt_algorithm, default_profile.algorithm.name);

  if (!empty_string(default_profile.devices))
    set_devices((char *)default_profile.devices);

  if (!empty_string(default_profile.intensity))
    set_intensity(default_profile.intensity);

  if (!empty_string(default_profile.xintensity))
    set_xintensity(default_profile.xintensity);

  if (!empty_string(default_profile.rawintensity))
    set_rawintensity(default_profile.rawintensity);

  if (!empty_string(default_profile.lookup_gap))
    set_lookup_gap((char *)default_profile.lookup_gap);

  if (!empty_string(default_profile.thread_concurrency))
    set_thread_concurrency(default_profile.thread_concurrency);

#ifdef HAVE_ADL
  if (!empty_string(default_profile.gpu_engine))
    set_gpu_engine(default_profile.gpu_engine);

  if (!empty_string(default_profile.gpu_memclock))
    set_gpu_memclock(default_profile.gpu_memclock);

  if (!empty_string(default_profile.gpu_threads))
    set_gpu_threads(default_profile.gpu_threads);

  if (!empty_string(default_profile.gpu_fan))
    set_gpu_fan(default_profile.gpu_fan);

  if (!empty_string(default_profile.gpu_powertune))
    set_gpu_powertune((char *)default_profile.gpu_powertune);

  if (!empty_string(default_profile.gpu_vddc))
    set_gpu_vddc((char *)default_profile.gpu_vddc);
#endif

  if (!empty_string(default_profile.shaders))
    set_shaders((char *)default_profile.shaders);

  if (!empty_string(default_profile.worksize))
    set_worksize((char *)default_profile.worksize);
}

//apply profile settings to pools
void apply_pool_profiles()
{
  int i;

  for (i=total_pools; i--;)
  {
    apply_pool_profile(pools[i]);
  }
}

void apply_pool_profile(struct pool *pool)
{
  struct profile *profile;
  
  //if the pool has a profile set
  if(!empty_string(pool->profile))
  {
    applog(LOG_DEBUG, "Loading settings from profile \"%s\" for pool %i", pool->profile, pool->pool_no);

    //find profile and apply settings to the pool
    if((profile = get_profile(pool->profile)))
    {
      pool->algorithm = profile->algorithm;
      applog(LOG_DEBUG, "Pool %i Algorithm set to \"%s\"", pool->pool_no, pool->algorithm.name);

      pool->devices = profile->devices;
      applog(LOG_DEBUG, "Pool %i devices set to \"%s\"", pool->pool_no, pool->devices);

      pool->lookup_gap = profile->lookup_gap;
      applog(LOG_DEBUG, "Pool %i lookup gap set to \"%s\"", pool->pool_no, pool->lookup_gap);

      pool->intensity = profile->intensity;
      applog(LOG_DEBUG, "Pool %i Intensity set to \"%s\"", pool->pool_no, pool->intensity);

      pool->xintensity = profile->xintensity;
      applog(LOG_DEBUG, "Pool %i XIntensity set to \"%s\"", pool->pool_no, pool->xintensity);

      pool->rawintensity = profile->rawintensity;
      applog(LOG_DEBUG, "Pool %i Raw Intensity set to \"%s\"", pool->pool_no, pool->rawintensity);

      pool->thread_concurrency = profile->thread_concurrency;
      applog(LOG_DEBUG, "Pool %i Thread Concurrency set to \"%s\"", pool->pool_no, pool->thread_concurrency);

#ifdef HAVE_ADL
      pool->gpu_engine = profile->gpu_engine;
      applog(LOG_DEBUG, "Pool %i GPU Clock set to \"%s\"", pool->pool_no, pool->gpu_engine);

      pool->gpu_memclock = profile->gpu_memclock;
      applog(LOG_DEBUG, "Pool %i GPU Memory clock set to \"%s\"", pool->pool_no, pool->gpu_memclock);

      pool->gpu_threads = profile->gpu_threads;
      applog(LOG_DEBUG, "Pool %i GPU Threads set to \"%s\"", pool->pool_no, pool->gpu_threads);

      pool->gpu_fan = profile->gpu_fan;
      applog(LOG_DEBUG, "Pool %i GPU Fan set to \"%s\"", pool->pool_no, pool->gpu_fan);

      pool->gpu_powertune = profile->gpu_powertune;
      applog(LOG_DEBUG, "Pool %i GPU Powertune set to \"%s\"", pool->pool_no, pool->gpu_powertune);

      pool->gpu_vddc = profile->gpu_vddc;
      applog(LOG_DEBUG, "Pool %i GPU Vddc set to \"%s\"", pool->pool_no, pool->gpu_vddc);
#endif

      pool->shaders = profile->shaders;
      applog(LOG_DEBUG, "Pool %i Shaders set to \"%s\"", pool->pool_no, pool->shaders);

      pool->worksize = profile->worksize;
      applog(LOG_DEBUG, "Pool %i Worksize set to \"%s\"", pool->pool_no, pool->worksize);
    }
    else
    {
      applog(LOG_DEBUG, "Profile load failed for pool %i: profile %s not found.", pool->pool_no, pool->profile);
      //remove profile name
      pool->profile[0] = '\0';
    }
  }
}

//helper function to add json values to pool object
static bool build_pool_json_add(json_t *object, const char *key, const char *val, const char *str_compare, int id)
{
  if(!empty_string(val))
  {
    if(safe_cmp(str_compare, val))
    {
      if(json_object_set(object, key, json_string(val)) == -1)
      {
        set_last_json_error("json_object_set() failed on pool(%d):%s", id, key);
        return false;
      }
    }
  }

  return true;
}

//builds the "pools" json array for config file
json_t *build_pool_json()
{
  json_t *pool_array, *obj;
  struct pool *pool;
  struct profile *profile;
  int i;
  
  //create the "pools" array
  if(!(pool_array = json_array()))
  {
    set_last_json_error("json_array() failed on pools");
    return NULL;
  }
  
  //process pool entries
  for(i=0;i<total_pools;i++)
  {
    pool = pools[i];

    //create a new object
    if(!(obj = json_object()))
    {
      set_last_json_error("json_object() failed on pool %d", pool->pool_no);
      return NULL;
    }

    //pool name
    if(!empty_string(pool->name))
    {
      if(json_object_set(obj, "name", json_string(pool->name)) == -1)
      {
        set_last_json_error("json_object_set() failed on pool(%d):name", pool->pool_no);
        return NULL;
      }
    }
    
    //add quota/url
    if(pool->quota != 1)
    {
      if(json_object_set(obj, "quota", json_sprintf("%s%s%s%d;%s",
        ((pool->rpc_proxy)?(char *)proxytype(pool->rpc_proxytype):""),
        ((pool->rpc_proxy)?pool->rpc_proxy:""),
        ((pool->rpc_proxy)?"|":""),
        pool->quota,
        pool->rpc_url)) == -1)
      {
        set_last_json_error("json_object_set() failed on pool(%d):quota", pool->pool_no);
        return NULL;
      }
    }
    else
    {
      if(json_object_set(obj, "url", json_sprintf("%s%s%s%s",
        ((pool->rpc_proxy)?(char *)proxytype(pool->rpc_proxytype):""),
        ((pool->rpc_proxy)?pool->rpc_proxy:""),
        ((pool->rpc_proxy)?"|":""),
        pool->rpc_url)) == -1)
      {
        set_last_json_error("json_object_set() failed on pool(%d):url", pool->pool_no);
        return NULL;
      }
    }

    //user
    if(json_object_set(obj, "user", json_string(pool->rpc_user)) == -1)
    {
      set_last_json_error("json_object_set() failed on pool(%d):user", pool->pool_no);
      return NULL;
    }
    
    //pass
    if(json_object_set(obj, "pass", json_string(pool->rpc_pass)) == -1)
    {
      set_last_json_error("json_object_set() failed on pool(%d):pass", pool->pool_no);
      return NULL;
    }

    if(!pool->extranonce_subscribe)
    {
      if(json_object_set(obj, "no-extranonce", json_true()) == -1)
      {
        set_last_json_error("json_object_set() failed on pool(%d):no-extranonce", pool->pool_no);
        return NULL;
      }
    }
    
    if(!empty_string(pool->description))
    {
      if(json_object_set(obj, "description", json_string(pool->description)) == -1)
      {
        set_last_json_error("json_object_set() failed on pool(%d):description", pool->pool_no);
        return NULL;
      }
    }
    
    //if priority isnt the same as array index, specify it
    if(pool->prio != i) 
    {
      if(json_object_set(obj, "priority", json_sprintf("%d", pool->prio)) == -1)
      {
        set_last_json_error("json_object_set() failed on pool(%d):description", pool->pool_no);
        return NULL;
      }
    }
    
    //if a profile was specified, add it then compare pool/profile settings to see what we write
    if(!empty_string(pool->profile))
    {
      if((profile = get_profile(pool->profile)))
      {
        //save profile name
        if(json_object_set(obj, "profile", json_string(pool->profile)) == -1)
        {
          set_last_json_error("json_object_set() failed on pool(%d):profile", pool->pool_no);
          return NULL;
        }
      }
      //profile not found use default profile
      else
        profile = &default_profile;
    }
    //or select default profile
    else
      profile = &default_profile;
    
    //if algorithm is different than profile, add it
    if(!cmp_algorithm(&pool->algorithm, &profile->algorithm)) 
    {
      //save algorithm name
      if(json_object_set(obj, "algorithm", json_string(pool->algorithm.name)) == -1)
      {
        set_last_json_error("json_object_set() failed on pool(%d):algorithm", pool->pool_no);
        return NULL;
      }
      
      //TODO: add other options like nfactor etc...
    }

    //if pool and profile value doesn't match below, add it
    //devices
    if(!build_pool_json_add(obj, "device", pool->devices, profile->devices, pool->pool_no))
      return NULL;

    //lookup-gap
    if(!build_pool_json_add(obj, "lookup-gap", pool->lookup_gap, profile->lookup_gap, pool->pool_no))
      return NULL;

    //intensity
    if(!build_pool_json_add(obj, "intensity", pool->intensity, profile->intensity, pool->pool_no))
      return NULL;

    //xintensity
    if(!build_pool_json_add(obj, "xintensity", pool->xintensity, profile->xintensity, pool->pool_no))
      return NULL;
      
    //rawintensity
    if(!build_pool_json_add(obj, "rawintensity", pool->rawintensity, profile->rawintensity, pool->pool_no))
      return NULL;
      
    //shaders
    if(!build_pool_json_add(obj, "shaders", pool->shaders, profile->shaders, pool->pool_no))
      return NULL;

    //thread_concurrency
    if(!build_pool_json_add(obj, "thread-concurrency", pool->thread_concurrency, profile->thread_concurrency, pool->pool_no))
      return NULL;

    //worksize
    if(!build_pool_json_add(obj, "worksize", pool->worksize, profile->worksize, pool->pool_no))
      return NULL;

#ifdef HAVE_ADL      
    //gpu_engine
    if(!build_pool_json_add(obj, "gpu-engine", pool->gpu_engine, profile->gpu_engine, pool->pool_no))
      return NULL;

    //gpu_memclock
    if(!build_pool_json_add(obj, "gpu-memclock", pool->gpu_memclock, profile->gpu_memclock, pool->pool_no))
      return NULL;

    //gpu_threads
    if(!build_pool_json_add(obj, "gpu-threads", pool->gpu_threads, profile->gpu_threads, pool->pool_no))
      return NULL;

    //gpu_fan
    if(!build_pool_json_add(obj, "gpu-fan", pool->gpu_fan, profile->gpu_fan, pool->pool_no))
      return NULL;

    //gpu-powertune
    if(!build_pool_json_add(obj, "gpu-powertune", pool->gpu_powertune, profile->gpu_powertune, pool->pool_no))
      return NULL;

    //gpu-vddc
    if(!build_pool_json_add(obj, "gpu-vddc", pool->gpu_vddc, profile->gpu_vddc, pool->pool_no))
      return NULL;
#endif
    
    //all done, add pool to array...
    if(json_array_append_new(pool_array, obj) == -1)
    {
      set_last_json_error("json_array_append() failed on pool %d", pool->pool_no);
      return NULL;
    }
  }
  
  return pool_array;
}


//helper function to add json values to profile object
static bool build_profile_json_add(json_t *object, const char *key, const char *val, const char *str_compare, bool isdefault, int id)
{
  if(!empty_string(val))
  {
    //always add if default profile is this profile
    if(safe_cmp(str_compare, val) || isdefault)
    {
      if(json_object_set(object, key, json_string(val)) == -1)
      {
        set_last_json_error("json_object_set() failed on profile(%d):%s", id, key);
        return false;
      }
    }
  }
  
  return true;
}

//builds the "profiles" json array for config file
json_t *build_profile_json()
{
  json_t *profile_array, *obj;
  struct profile *profile;
  bool isdefault;
  int i;
  
  //create the "pools" array
  if(!(profile_array = json_array()))
  {
    set_last_json_error("json_array() failed on profiles");
    return NULL;
  }
  
  //process pool entries
  for(i=0;i<total_profiles;i++)
  {
    profile = profiles[i];
    isdefault = false;

    if(!empty_string(default_profile.name))
    {
      if(!strcmp(profile->name, default_profile.name))
        isdefault = true;
    }

    //create a new object
    if(!(obj = json_object()))
    {
      set_last_json_error("json_object() failed on profile %d", profile->profile_no);
      return NULL;
    }

    //profile name
    if(!empty_string(profile->name))
    {
      if(json_object_set(obj, "name", json_string(profile->name)) == -1)
      {
        set_last_json_error("json_object_set() failed on profile(%d):name", profile->profile_no);
        return NULL;
      }
    }
    
    //if algorithm is different than profile, add it - if default profile is the current profile, always add
    if(!cmp_algorithm(&default_profile.algorithm, &profile->algorithm) || !strcasecmp(default_profile.name, profile->name)) 
    {
      //save algorithm name
      if(json_object_set(obj, "algorithm", json_string(profile->algorithm.name)) == -1)
      {
        set_last_json_error("json_object_set() failed on profile(%d):algorithm", profile->profile_no);
        return NULL;
      }
      
      //TODO: add other options like nfactor etc...
    }

    //if pool and profile value doesn't match below, add it
    //devices
    if(!build_profile_json_add(obj, "device", profile->devices, default_profile.devices, isdefault, profile->profile_no))
      return NULL;
    
    //lookup-gap
    if(!build_profile_json_add(obj, "lookup-gap", profile->lookup_gap, default_profile.lookup_gap, isdefault, profile->profile_no))
      return NULL;

    //intensity
    if(!build_profile_json_add(obj, "intensity", profile->intensity, default_profile.intensity, isdefault, profile->profile_no))
      return NULL;

    //xintensity
    if(!build_profile_json_add(obj, "xintensity", profile->xintensity, default_profile.xintensity, isdefault, profile->profile_no))
      return NULL;
      
    //rawintensity
    if(!build_profile_json_add(obj, "rawintensity", profile->rawintensity, default_profile.rawintensity, isdefault, profile->profile_no))
      return NULL;
      
    //shaders
    if(!build_profile_json_add(obj, "shaders", profile->shaders, default_profile.shaders, isdefault, profile->profile_no))
      return NULL;
    
    //thread_concurrency
    if(!build_profile_json_add(obj, "thread-concurrency", profile->thread_concurrency, default_profile.thread_concurrency, isdefault, profile->profile_no))
      return NULL;

    //worksize
    if(!build_profile_json_add(obj, "worksize", profile->worksize, default_profile.worksize, isdefault, profile->profile_no))
      return NULL;

#ifdef HAVE_ADL      
    //gpu_engine
    if(!build_profile_json_add(obj, "gpu-engine", profile->gpu_engine, default_profile.gpu_engine, isdefault, profile->profile_no))
      return NULL;

    //gpu_memclock
    if(!build_profile_json_add(obj, "gpu-memclock", profile->gpu_memclock, default_profile.gpu_memclock, isdefault, profile->profile_no))
      return NULL;

    //gpu_threads
    if(!build_profile_json_add(obj, "gpu-threads", profile->gpu_threads, default_profile.gpu_threads, isdefault, profile->profile_no))
      return NULL;

    //gpu_fan
    if(!build_profile_json_add(obj, "gpu-fan", profile->gpu_fan, default_profile.gpu_fan, isdefault, profile->profile_no))
      return NULL;

    //gpu-powertune
    if(!build_profile_json_add(obj, "gpu-powertune", profile->gpu_powertune, default_profile.gpu_powertune, isdefault, profile->profile_no))
      return NULL;

    //gpu-vddc
    if(!build_profile_json_add(obj, "gpu-vddc", profile->gpu_vddc, default_profile.gpu_vddc, isdefault, profile->profile_no))
      return NULL;
#endif
    
    //all done, add pool to array...
    if(json_array_append_new(profile_array, obj) == -1)
    {
      set_last_json_error("json_array_append() failed on profile %d", profile->profile_no);
      return NULL;
    }
  }
  
  return profile_array;
}

void write_config(const char *filename)
{
  json_t *config, *obj;
  struct opt_table *opt;
  char *p, *optname;
  int i;
  
  if(!(config = json_object()))
  {
    applog(LOG_ERR, "Error: config_parser::write_config():\n json_object() failed on root."); 
    return;
  }
  
  //build pools
  if(!(obj = build_pool_json()))
  {
    applog(LOG_ERR, "Error: config_parser::write_config():\n %s.", last_json_error); 
    return;
  }
  
  //add pools to config
  if(json_object_set(config, "pools", obj) == -1)
  {
    applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set(pools) failed."); 
    return;
  }
  
  //build profiles
  if(!(obj = build_profile_json()))
  {
    applog(LOG_ERR, "Error: config_parser::write_config():\n %s.", last_json_error); 
    return;
  }
  
  //add profiles to config
  if(json_object_set(config, "profiles", obj) == -1)
  {
    applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set(profiles) failed."); 
    return;
  }

  //pool strategy
  switch(pool_strategy)
  {
    case POOL_BALANCE:
      if(json_object_set(config, "balance", json_true()) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on balance");
        return;
      }
      break;
    case POOL_LOADBALANCE:
      if(json_object_set(config, "load-balance", json_true()) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on load-balance");
        return;
      }
      break;
    case POOL_ROUNDROBIN:
      if(json_object_set(config, "round-robin", json_true()) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on round-robin");
        return;
      }
      break;
    case POOL_ROTATE:
      if(json_object_set(config, "rotate", json_sprintf("%d", opt_rotate_period)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on rotate");
        return;
      }
      break;
    //default failover only
    default:
      if(json_object_set(config, "failover-only", json_true()) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on failover-only");
        return;
      }
      break;
  }
  
  //if using a specific profile as default, set it
  if(!empty_string(default_profile.name))
  {
    if(json_object_set(config, "default-profile", json_string(default_profile.name)) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on default_profile");
      return;
    }
  }
  //otherwise save default profile values
  else
  {
    //save algorithm name
    if(json_object_set(config, "algorithm", json_string(opt_algorithm.name)) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on algorithm");
      return;
    }
    //TODO: add other options like nfactor etc...

    //devices
    if(!empty_string(default_profile.devices))
    {
      if(json_object_set(config, "devices", json_string(default_profile.devices)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on devices");
        return;
      }
    }

    //lookup-gap
    if(!empty_string(default_profile.lookup_gap))
    {
      if(json_object_set(config, "lookup-gap", json_string(default_profile.lookup_gap)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on lookup-gap");
        return;
      }
    }

    //intensity
    if(!empty_string(default_profile.intensity))
    {
      if(json_object_set(config, "intensity", json_string(default_profile.intensity)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on intensity");
        return;
      }
    }

    //xintensity
    if(!empty_string(default_profile.xintensity))
    {
      if(json_object_set(config, "xintensity", json_string(default_profile.xintensity)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on xintensity");
        return;
      }
    }
      
    //rawintensity
    if(!empty_string(default_profile.rawintensity))
    {
      if(json_object_set(config, "rawintensity", json_string(default_profile.rawintensity)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on rawintensity");
        return;
      }
    }
      
    //shaders
    if(!empty_string(default_profile.shaders))
    {
      if(json_object_set(config, "shaders", json_string(default_profile.shaders)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on shaders");
        return;
      }
    }

    //thread_concurrency
    if(!empty_string(default_profile.thread_concurrency))
    {
      if(json_object_set(config, "thread-concurrency", json_string(default_profile.thread_concurrency)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on thread_concurrency");
        return;
      }
    }

    //worksize
    if(!empty_string(default_profile.worksize))
    {
      if(json_object_set(config, "worksize", json_string(default_profile.worksize)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on worksize");
        return;
      }
    }

#ifdef HAVE_ADL      
    //gpu_engine
    if(!empty_string(default_profile.gpu_engine))
    {
      if(json_object_set(config, "gpu-engine", json_string(default_profile.gpu_engine)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on gpu-engine");
        return;
      }
    }

    //gpu_memclock
    if(!empty_string(default_profile.gpu_memclock))
    {
      if(json_object_set(config, "gpu-memclock", json_string(default_profile.gpu_memclock)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on gpu-memclock");
        return;
      }
    }

    //gpu_threads
    if(!empty_string(default_profile.gpu_threads))
    {
      if(json_object_set(config, "gpu-threads", json_string(default_profile.gpu_threads)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on gpu-threads");
        return;
      }
    }

    //gpu_fan
    if(!empty_string(default_profile.gpu_fan))
    {
      if(json_object_set(config, "gpu-fan", json_string(default_profile.gpu_fan)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on gpu-fan");
        return;
      }
    }

    //gpu-powertune
    if(!empty_string(default_profile.gpu_powertune))
    {
      if(json_object_set(config, "gpu-powertune", json_string(default_profile.gpu_powertune)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on gpu-powertune");
        return;
      }
    }

    //gpu-vddc
    if(!empty_string(default_profile.gpu_vddc))
    {
      if(json_object_set(config, "gpu-vddc", json_string(default_profile.gpu_vddc)) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on gpu-vddc");
        return;
      }
    }
#endif
  }

  //devices
  /*if(opt_devs_enabled) 
  {
    bool extra_devs = false;
    obj = json_string("");

    for(i = 0; i < MAX_DEVICES; i++) 
    {
      if(devices_enabled[i]) 
      {
        int startd = i;

        if(extra_devs)
          obj = json_sprintf("%s%s", json_string_value(obj), ",");

        while (i < MAX_DEVICES && devices_enabled[i + 1])
          ++i;
        
        obj = json_sprintf("%s%d", json_string_value(obj), startd);
        if(i > startd)
          obj = json_sprintf("%s-%d", json_string_value(obj), i);
      }
    }
    
    if(json_object_set(config, "devices", obj) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on devices");
      return;
    }    
  }*/
  
  //remove-disabled
  if(opt_removedisabled)
  {
    if(json_object_set(config, "remove-disabled", json_true()) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on remove-disabled");
      return;
    }    
    
  }

  //write gpu settings that aren't part of profiles -- only write if gpus are available
  if(nDevs)
  {
  
#ifdef HAVE_ADL
    //temp-cutoff
    for(i = 0;i < nDevs; i++)
      obj = json_sprintf("%s%s%d", ((i > 0)?json_string_value(obj):""), ((i > 0)?",":""), gpus[i].cutofftemp);
      
    if(json_object_set(config, "temp-cutoff", obj) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on temp-cutoff");
      return;
    }

    //temp-overheat
    for(i = 0;i < nDevs; i++)
      obj = json_sprintf("%s%s%d", ((i > 0)?json_string_value(obj):""), ((i > 0)?",":""), gpus[i].adl.overtemp);
      
    if(json_object_set(config, "temp-overheat", obj) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on temp-overheat");
      return;
    }

    //temp-target
    for(i = 0;i < nDevs; i++)
      obj = json_sprintf("%s%s%d", ((i > 0)?json_string_value(obj):""), ((i > 0)?",":""), gpus[i].adl.targettemp);
      
    if(json_object_set(config, "temp-target", obj) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on temp-target");
      return;
    }
    
    //reorder gpus
    if(opt_reorder)
    {
      if(json_object_set(config, "gpu-reorder", json_true()) == -1)
      {
        applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on gpu-reorder");
        return;
      }
    }

    //gpu-memdiff
    for(i = 0;i < nDevs; i++)
      obj = json_sprintf("%s%s%d", ((i > 0)?json_string_value(obj):""), ((i > 0)?",":""), (int)gpus[i].gpu_memdiff);
      
    if(json_object_set(config, "gpu-memdiff", obj) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on gpu-memdiff");
      return;
    }
#endif
  }

  //add other misc options
  //shares
  if(json_object_set(config, "shares", json_sprintf("%d", opt_shares)) == -1)
  {
    applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on shares");
    return;
  }
  
#if defined(unix) || defined(__APPLE__)
  //monitor
  if(opt_stderr_cmd && *opt_stderr_cmd)
  {
    if(json_object_set(config, "monitor", json_string(opt_stderr_cmd)) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on monitor");
      return;
    }
  }
#endif // defined(unix)

  //kernel path
  if(opt_kernel_path && *opt_kernel_path) 
  {
    //strip end /
    char *kpath = strdup(opt_kernel_path);
    if(kpath[strlen(kpath)-1] == '/')
      kpath[strlen(kpath)-1] = 0;
    
    if(json_object_set(config, "kernel-path", json_string(kpath)) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on kernel-path");
      return;
    }
  }
  
  //sched-time
  if(schedstart.enable)
  {
    if(json_object_set(config, "sched-time", json_sprintf("%d:%d", schedstart.tm.tm_hour, schedstart.tm.tm_min)) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on sched-time");
      return;
    }
  }
  
  //stop-time
  if(schedstop.enable)
  {
    if(json_object_set(config, "stop-time", json_sprintf("%d:%d", schedstop.tm.tm_hour, schedstop.tm.tm_min)) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on stop-time");
      return;
    }
  }
  
  //socks-proxy
  if(opt_socks_proxy && *opt_socks_proxy)
  {
    if(json_object_set(config, "socks-proxy", json_string(opt_socks_proxy)) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on socks-proxy");
      return;
    }
  }
  
  
  //api stuff
  //api-allow
  if(opt_api_allow)
  {
    if(json_object_set(config, "api-allow", json_string(opt_api_allow)) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on api-allow");
      return;
    }
  }
  
  //api-mcast-addr
  if(strcmp(opt_api_mcast_addr, API_MCAST_ADDR) != 0)
  {
    if(json_object_set(config, "api-mcast-addr", json_string(opt_api_mcast_addr)) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on api-mcast-addr");
      return;
    }
  }

  //api-mcast-code
  if(strcmp(opt_api_mcast_code, API_MCAST_CODE) != 0)
  {
    if(json_object_set(config, "api-mcast-code", json_string(opt_api_mcast_code)) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on api-mcast-code");
      return;
    }
  }

  //api-mcast-des
  if(*opt_api_mcast_des)
  {
    if(json_object_set(config, "api-mcast-des", json_string(opt_api_mcast_des)) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on api-mcast-des");
      return;
    }
  }

  //api-description
  if(strcmp(opt_api_description, PACKAGE_STRING) != 0)
  {
    if(json_object_set(config, "api-description", json_string(opt_api_description)) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on api-description");
      return;
    }
  }
  
  //api-groups
  if(opt_api_groups)
  {
    if(json_object_set(config, "api-groups", json_string(opt_api_groups)) == -1)
    {
      applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on api-groups");
      return;
    }
  }

  //add other misc bool/int options
  for(opt = opt_config_table; opt->type != OPT_END; opt++) 
  {
    optname = strdup(opt->names);
    
    //ignore --pool-* and --profile-* options
    if(!strstr(optname, "--pool-") && !strstr(optname, "--profile-"))
    {
      //get first available long form option name
      for(p = strtok(optname, "|"); p; p = strtok(NULL, "|")) 
      {
        //skip short options
        if(p[1] != '-')
          continue;

        //type bool
        if (opt->type & OPT_NOARG &&
          ((void *)opt->cb == (void *)opt_set_bool || (void *)opt->cb == (void *)opt_set_invbool) &&
          (*(bool *)opt->u.arg == ((void *)opt->cb == (void *)opt_set_bool)))
        {
          if(json_object_set(config, p+2, json_true()) == -1)
          {
            applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on %s.", p+2); 
            return;
          }
          break;  //exit for loop... so we don't enter a duplicate value if an option has multiple names
        }
        //numeric types
        else if (opt->type & OPT_HASARG &&
          ((void *)opt->cb_arg == (void *)set_int_0_to_9999 ||
          (void *)opt->cb_arg == (void *)set_int_1_to_65535 ||
          (void *)opt->cb_arg == (void *)set_int_0_to_10 ||
          (void *)opt->cb_arg == (void *)set_int_1_to_10) && opt->desc != opt_hidden)
        {
          if(json_object_set(config, p+2, json_sprintf("%d", *(int *)opt->u.arg)) == -1)
          {
            applog(LOG_ERR, "Error: config_parser::write_config():\n json_object_set() failed on %s.", p+2); 
            return;
          }
          break;  //exit for loop... so we don't enter a duplicate value if an option has multiple names
        }
      }
    }
  } 
  
  json_dump_file(config, filename, JSON_PRESERVE_ORDER|JSON_INDENT(2));
}

/*********************************************
 * API functions 
 * *******************************************/
//profile parameters
enum {
  PR_ALGORITHM,
  PR_NFACTOR,
  PR_LOOKUPGAP,
  PR_DEVICES,
  PR_INTENSITY,
  PR_XINTENSITY,
  PR_RAWINTENSITY,
  PR_GPUENGINE,
  PR_GPUMEMCLOCK,
  PR_GPUTHREADS,
  PR_GPUFAN,
  PR_GPUPOWERTUNE,
  PR_GPUVDDC,
  PR_SHADERS,
  PR_TC,
  PR_WORKSIZE
};

void api_profile_list(struct io_data *io_data, __maybe_unused SOCKETTYPE c, __maybe_unused char *param, bool isjson, __maybe_unused char group)
{
  struct api_data *root = NULL;
  struct profile *profile;
  char buf[TMPBUFSIZ];
  bool io_open = false;
  bool b;
  int i;

  if (total_profiles == 0) 
  {
    message(io_data, MSG_NOPROFILE, 0, NULL, isjson);
    return;
  }

  message(io_data, MSG_PROFILE, 0, NULL, isjson);

  if (isjson)
    io_open = io_add(io_data, COMSTR JSON_PROFILES);

  for (i = 0; i <= total_profiles; i++) 
  {
    //last profile is the default profile
    if(i == total_profiles)
      profile = &default_profile;
    else
      profile = profiles[i];

    //if default profile name is profile name or loop index is beyond the last profile, then it is the default profile
    b = (((i == total_profiles) || (!strcasecmp(default_profile.name, profile->name)))?true:false);

    root = api_add_int(root, "PROFILE", &i, false);
    root = api_add_escape(root, "Name", profile->name, true);
    root = api_add_bool(root, "IsDefault", &b, false);
    root = api_add_escape(root, "Algorithm", isnull((char *)profile->algorithm.name, ""), true);
    root = api_add_int(root, "NFactor", (int *)&profile->algorithm.nfactor, false);
    root = api_add_escape(root, "LookupGap", isnull((char *)profile->lookup_gap, ""), true);
    root = api_add_escape(root, "Devices", isnull((char *)profile->devices, ""), true);
    root = api_add_escape(root, "Intensity", isnull((char *)profile->intensity, ""), true);
    root = api_add_escape(root, "XIntensity", isnull((char *)profile->xintensity, ""), true);
    root = api_add_escape(root, "RawIntensity", isnull((char *)profile->rawintensity, ""), true);
    root = api_add_escape(root, "Gpu Engine", isnull((char *)profile->gpu_engine, ""), true);
    root = api_add_escape(root, "Gpu MemClock", isnull((char *)profile->gpu_memclock, ""), true);
    root = api_add_escape(root, "Gpu Threads", isnull((char *)profile->gpu_threads, ""), true);
    root = api_add_escape(root, "Gpu Fan%", isnull((char *)profile->gpu_fan, ""), true);
    root = api_add_escape(root, "Gpu Powertune%", isnull((char *)profile->gpu_powertune, ""), true);
    root = api_add_escape(root, "Gpu Vddc", isnull((char *)profile->gpu_vddc, ""), true);
    root = api_add_escape(root, "Shaders", isnull((char *)profile->shaders, ""), true);
    root = api_add_escape(root, "Thread Concurrency", isnull((char *)profile->thread_concurrency, ""), true);
    root = api_add_escape(root, "Worksize", isnull((char *)profile->worksize, ""), true);
    
    root = print_data(root, buf, isjson, isjson && (i > 0));
    io_add(io_data, buf);
  }

  if (isjson && io_open)
    io_close(io_data);
}

void api_profile_add(struct io_data *io_data, __maybe_unused SOCKETTYPE c, char *param, bool isjson, __maybe_unused char group)
{
  char *p;
  char *split_str;
  struct profile *profile;
  int idx;
  
  split_str = strdup(param);
  
  //split all params by colon (:) because the comma (,) can be used in some of those parameters
  if((p = strsep(&split_str, ":")))
  {
    //get name first and see if the profile already exists
    if((profile = get_profile(p)))
    {
      message(io_data, MSG_PROFILEEXIST, 0, p, isjson);
      return;
    }
    
    //doesnt exist, create new profile
    profile = add_profile();
    
    //assign name
    profile->name = strdup(p);
    
    //get other parameters
    idx = 0;
    while((p = strsep(&split_str, ":")) != NULL)
    {
      switch(idx)
      {
        case PR_ALGORITHM:
          set_algorithm(&profile->algorithm, p);
          break;
        case PR_NFACTOR:
          if(!empty_string(p))
            set_algorithm_nfactor(&profile->algorithm, (const uint8_t)atoi(p));
          break;
        case PR_LOOKUPGAP:
          if(!empty_string(p))
            profile->lookup_gap = strdup(p);
          break;
        case PR_DEVICES:
          if(!empty_string(p))
            profile->devices = strdup(p);
          break;
        case PR_INTENSITY:
          if(!empty_string(p))
            profile->intensity = strdup(p);
          break;
        case PR_XINTENSITY:
          if(!empty_string(p))
            profile->xintensity = strdup(p);
          break;
        case PR_RAWINTENSITY:
          if(!empty_string(p))
            profile->rawintensity = strdup(p);
          break;
        case PR_GPUENGINE:
          if(!empty_string(p))
            profile->gpu_engine = strdup(p);
          break;
        case PR_GPUMEMCLOCK:
          if(!empty_string(p))
            profile->gpu_memclock = strdup(p);
          break;
        case PR_GPUTHREADS:
          if(!empty_string(p))
            profile->gpu_threads = strdup(p);
          break;
        case PR_GPUFAN:
          if(!empty_string(p))
            profile->gpu_fan = strdup(p);
          break;
        case PR_GPUPOWERTUNE:
          if(!empty_string(p))
            profile->gpu_powertune = strdup(p);
          break;
        case PR_GPUVDDC:
          if(!empty_string(p))
            profile->gpu_vddc = strdup(p);
          break;
        case PR_SHADERS:
          if(!empty_string(p))
            profile->shaders = strdup(p);
          break;
        case PR_TC:
          if(!empty_string(p))
            profile->thread_concurrency = strdup(p);
          break;
        case PR_WORKSIZE:
          if(!empty_string(p))
            profile->worksize = strdup(p);
          break;
        default:
          //invalid option ignore
          break;
      }
      
      idx++;
    }
  }
  else
  {
      message(io_data, MSG_MISPRD, 0, NULL, isjson);
      return;
  }

  message(io_data, MSG_ADDPROFILE, 0, profile->name, isjson);
}

void api_profile_remove(struct io_data *io_data, __maybe_unused SOCKETTYPE c, char *param, bool isjson, __maybe_unused char group)
{
  struct profile *profile;
  struct pool *pool;
  int i;

  //no profiles, nothing to remove
  if (total_profiles == 0) 
  {
    message(io_data, MSG_NOPROFILE, 0, NULL, isjson);
    return;
  }

  //make sure profile name is supplied
  if(param == NULL || *param == '\0') 
  {
    message(io_data, MSG_MISPRID, 0, NULL, isjson);
    return;
  }

  //see if the profile exists
  if(!(profile = get_profile(param)))
  {
    message(io_data, MSG_PRNOEXIST, 0, param, isjson);
    return;
  }

  //next make sure it's not the default profile
  if(!strcasecmp(default_profile.name, profile->name))
  {
    message(io_data, MSG_PRISDEFAULT, 0, param, isjson);
    return;
  }

  //make sure no pools use it
  for(i = 0;i < total_pools; i++)
  {
    pool = pools[i];
    
    if(!strcasecmp(pool->profile, profile->name))
    {
      message(io_data, MSG_PRINUSE, 0, param, isjson);
      return;
    }
  }

  //all set, delete the profile
  remove_profile(profile);

  message(io_data, MSG_REMPROFILE, profile->profile_no, profile->name, isjson);
  
  free(profile);
}

//should move to pool.c with the other pool stuff...
void api_pool_profile(struct io_data *io_data, __maybe_unused SOCKETTYPE c, char *param, bool isjson, __maybe_unused char group)
{
  struct profile *profile;
  struct pool *pool;
  char *p;
  int i;

  //no pool, nothing to change
  if (total_pools == 0) 
  {
    message(io_data, MSG_NOPOOL, 0, NULL, isjson);
    return;
  }

  //no profiles, nothing to change
  if (total_profiles == 0) 
  {
    message(io_data, MSG_NOPROFILE, 0, NULL, isjson);
    return;
  }

  //check if parameters were passed
  if (param == NULL || *param == '\0') 
  {
    message(io_data, MSG_MISPID, 0, NULL, isjson);
    return;
  }

  //get pool number in parameter 1
  if(!(p = strtok(param, ",")))
  {
    message(io_data, MSG_MISPID, 0, NULL, isjson);
    return;
  }
  
  //check valid pool id
  i = atoi(p);
  
  if(i < 0 || i >= total_pools)
  {
    message(io_data, MSG_INVPID, i, NULL, isjson);
    return;
  }
  
  //get pool
  pool = pools[i];

  //get profile name in parameter 2
  if(!(p = strtok(NULL, ",")))
  {
    message(io_data, MSG_MISPRID, 0, NULL, isjson);
    return;
  }
  
  //see if the profile exists
  if(!(profile = get_profile(p)))
  {
    message(io_data, MSG_PRNOEXIST, 0, p, isjson);
    return;
  }

  //set profile
  pool->profile = strdup(profile->name);
  //apply settings
  apply_pool_profile(pool);

  //if current pool restart it
  if (pool == current_pool())
    switch_pools(NULL);

  message(io_data, MSG_CHPOOLPR, pool->pool_no, profile->name, isjson);
}