/* BEGIN_ICS_COPYRIGHT4 ****************************************

Copyright (c) 2015-2017, Intel Corporation

Redistribution and use in source and binary forms, with or without

modification, are permitted provided that the following conditions are met:

    * Redistributions of source code must retain the above copyright notice,

      this list of conditions and the following disclaimer.

    * Redistributions in binary form must reproduce the above copyright

      notice, this list of conditions and the following disclaimer in the

      documentation and/or other materials provided with the distribution.

    * Neither the name of Intel Corporation nor the names of its contributors

      may be used to endorse or promote products derived from this software

      without specific prior written permission.

THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"

AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE

IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE

DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE

FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL

DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR

SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER

CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,

OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE

OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.

** END_ICS_COPYRIGHT4   ****************************************/

/*!

  \file dsap_module.c

  $Revision: 1.5 $

  $Date: 2015/01/27 23:00:24 $

  \brief Provider initialization and cleanup functions.

*/

#include <ctype.h>

/*

  ICS IBT stuff

*/

#include "iba/ibt.h"

#include "iba/public/isemaphore.h"

#include "opasadb_debug.h"

/*

  Module stuff

*/

#include "dsap.h"

// Module parameters

uint32 dsap_dbg_level = _DBG_LVL_NOTICE;

#define LOG_FILE_LENGTH 256

static char dsap_log_file[LOG_FILE_LENGTH] = {0};

static FILE *omgt_log_file = NULL;

/*

 * Parameter handling - replaces module parameters.

 *

 * name   - variable name of the parameter.

 * desc   - human readable description

 * type   - enumerated type of the parameter (integer, unsigned, boolean, etc.)

 * length - for string parameters, the max length of the string. 

 * ptr    - pointer to the variable.

 * parser - points to a function to handle special parameters.

 * printer - points to a function that can print special parameters.

 */

typedef struct parameter {

	char name[32];

	char desc[256];

	char type;

	int  length;

	void *ptr;

	int (*parser)(char *str, void *ptr);

	char *(*printer)(void *ptr);

} parameter_t;

static parameter_t	parameters[] = {

	{	.name="NoSubscribe",

		.type='b',

		.desc="Do not subscribe to SM for notifications.",

		.length = 0,

		.ptr=(void*)&dsap_no_subscribe},

	{	.name="ScanFrequency",

		.type='u',

		.desc="Number of seconds between unconditional sweeps.",

		.length = 0,

		.ptr=(void*)&dsap_scan_frequency},

	{	.name="UnsubscribedScanFrequency",

		.type='u',

		.desc="Number of seconds between sweeps when not receiving "

		      "notifications.",

		.length = 0,

		.ptr=(void*)&dsap_unsub_scan_frequency},

	{	.name="Dbg",

		.type='x',

		.desc="Debug logging controls. Uses syslog log levels, ranging"

		      " from 1 (least)\n\tto 7 (trace level).",

		.length = 0,

		.ptr=(void*)&dsap_dbg_level},

	{	.name="Publish",

		.type='b',

		.desc="Publish paths to shared memory. Defaults to true.",

		.length = 0,

		.ptr=(void*)&dsap_publish},

	{	.name="SID", 

		.type='S', 

		.desc="Service ID that identifies a virtual fabric to include "

		      "in the cache.\n\tCan be specified multiple times.", 

		.parser=dsap_service_id_range_parser, 

		.printer=dsap_service_id_range_printer, 

		.ptr=(void*)&sid_range_args},

	{	.name="LogFile",

		.type='s',

		.desc="Write log messages to a file instead of the system log"

		      "\n\tor stderr.",

		.length = LOG_FILE_LENGTH,

		.ptr=(void*)&dsap_log_file},

	{	.name="dsap_default_fabric",

		.type='S',

		.desc="normal = do not match SIDs to the default fabric unless"

		      " they don't\n\t match any other fabric.\n\tnone = never"

		      " match SIDs to the default fabric.\n\t Defaults to "

		      "normal.",

		.parser=dsap_default_fabric_parser,

		.printer=dsap_default_fabric_printer,

		.ptr=(void*)&dsap_default_fabric },

	{"", "", 0, 0, NULL} 

};

static void dsap_dump_params(parameter_t *params) 

{

	int i=0;

	while (params[i].ptr != NULL) {

		switch (params[i].type) {

		case 'S':

			acm_log(0, "%s = %s\n", params[i].name,

				params[i].printer(params[i].ptr));

			break;

		case 'X':

			acm_log(0, "%s = 0x%016"PRIx64"\n", params[i].name,

				(*(uint64 *) params[i].ptr));

			break;

		case 'x':

			acm_log(0, "%s = 0x%x\n", params[i].name,

				(*(uint32 *) params[i].ptr));

			break;

		case 'u':

			acm_log(0, "%s = %u\n", params[i].name,

				(*(uint32 *) params[i].ptr));

			break;

		case 'i':

			acm_log(0, "%s = %i\n", params[i].name,

				(*(int32 *) params[i].ptr));

			break;

		case 'b':

			acm_log(0, "%s = %s\n", params[i].name,

				(*(uint32 *) params[i].ptr) ? "yes" : "no");

			break;

		case 's':

			acm_log(0, "%s = %s\n", params[i].name,

				(char *)params[i].ptr);

			break;

		default:

			acm_log(0, "%s = Unhandled parameter type.\n",

				params[i].name);

			break;

		} 

		i++;

	} 

}

static char *dsap_trim(char *buffer)

{

	char *p;

	int j = strlen(buffer) - 1;

	/* Trim trailing whitespace. */

	while (j>0 && isspace(buffer[j])) {

		buffer[j] = 0;

		j--;

	}

	p=buffer;

	/* Trim leading whitespce.*/

	j=0;

	while (buffer[j]!=0 && isspace(buffer[j])) j++;

	p=&buffer[j];

	if (*p == '#' || *p == '\n' || *p == 0)

		return NULL;

	return p;

}

static int dsap_parse_record(parameter_t *params, char *buffer) 

{

	char *k, *v, *l;

	int i=0;

	k=strtok_r(buffer, "=", &l);

	v=strtok_r(NULL, "=", &l);

	if (!k || !v) {

		acm_log(0, "Config syntax error: %s\n", buffer);

		return -1;

	}

	/* strip white space */

	k=dsap_trim(k);

	v=dsap_trim(v);

	if (!k || !v) {

		acm_log(0, "Config syntax error: %s\n", buffer);

		return -1;

	}

	while (params[i].ptr != NULL && (k != NULL && v != NULL)) {

		if (strncasecmp(k, params[i].name, strlen(k)) == 0) {

			switch (params[i].type) {

			case 'S':

				return params[i].parser(v, params[i].ptr);

			case 'X':

				(*(uint64 *) params[i].ptr) =

					strtoull(v, NULL, 0);

				return 0;

			case 'x':

			case 'u':

				(*(uint32 *) params[i].ptr) =

					strtoul(v, NULL, 0);

				return 0;

			case 'i':

				(*(int32 *) params[i].ptr) = 

					strtol(v, NULL, 0);

				return 0;

			case 's':

				strncpy((char *) params[i].ptr, v,

					params[i].length);

				((char *) params[i].ptr)[params[i].length - 1] = 0;

				return 0;

			case 'b':

				if (strcmp(v,"yes")==0 || 

				    strcmp(v,"y") == 0 || 

				    strcmp(v,"true") == 0 || 

				    strcmp(v,"t") == 0) 

					(*(uint32 *) params[i].ptr) = 1;

				else 

					(*(uint32 *) params[i].ptr) =

						strtol(v, NULL, 0);

				return 0;

			default:

				acm_log(0, "Unrecognized token in config.\n");

			}

		}

		i++;

	} 

	return -1;

}

static int dsap_parse_settings(char *filename, parameter_t *params)

{

	int err = 0;

	char *ptr;

	char record[1024];

	FILE *f;

	acm_log(2, "\n");

	f = fopen(filename,"r");

	if (!f) {

		acm_log(0, "Unable to open config file %s.\n", filename);

		err=-1;

	}

	while(!err && fgets(record, 1024, f)) {

		ptr = dsap_trim(record);

		if (ptr) {

			if ((err = dsap_parse_record(params, record)))

				acm_log(0, "Invalid Config Option: %s\n", ptr);

		}

	}

	if (f) fclose(f);

	return err;

}

/* Get dsap's own configuration parameters */

void dsap_get_config(char *filename)

{

	if (dsap_parse_settings(filename, parameters))

		return;

	if (dsap_dbg_level > 7) dsap_dbg_level = 7;

	if (strlen(dsap_log_file) > 0) {

		op_log_set_file(dsap_log_file);

		op_log_set_level(dsap_dbg_level);

	}

	dsap_dump_params(parameters);

}

/*!

  \brief Cleanup function called when the provider is unloaded.

*/

void dsap_cleanup(void)

{

	acm_log(2, "\n");

	dsap_scanner_cleanup();

	dsap_topology_cleanup();

	if (omgt_log_file) 

		fclose(omgt_log_file);

}

/*!

  \brief Init function called when the provider is loaded.

*/

FSTATUS

dsap_init(void)

{

	FSTATUS fstatus = FERROR;

	acm_log(2, "\n");

	fstatus = dsap_topology_init();

	if (fstatus != FSUCCESS)

		goto exit;

	fstatus = dsap_scanner_init();

	if (FSUCCESS != fstatus)

		goto exit;

	/* Guard against scans without timeout */

	if (dsap_unsub_scan_frequency == 0)

		dsap_unsub_scan_frequency = 10;

	fstatus = dsap_scanner_start();

exit:

	return fstatus;

}

void dsap_omgt_log_init(struct omgt_port *omgt_port)

{

	if (strlen(dsap_log_file) > 0) {

		omgt_log_file = op_log_get_file();

		omgt_set_err(omgt_port, omgt_log_file);

		if (dsap_dbg_level >= 7)

			omgt_set_dbg(omgt_port, omgt_log_file);

	}

}