1 files changed, 145 insertions, 0 deletions
diff --git a/storage/ndb/src/common/portlib/NdbConfig.c b/storage/ndb/src/common/portlib/NdbConfig.c
new file mode 100644
index 00000000000..b275143646f
--- /dev/null
+++ b/storage/ndb/src/common/portlib/NdbConfig.c
@@ -0,0 +1,145 @@
+/* Copyright (C) 2003 MySQL AB
+
+   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 2 of the License, or
+   (at your option) any later version.
+
+   This program is distributed in the hope that it will be useful,
+   but WITHOUT ANY WARRANTY; without even the implied warranty of
+   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+   GNU General Public License for more details.
+
+   You should have received a copy of the GNU General Public License
+   along with this program; if not, write to the Free Software
+   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
+
+#include <ndb_global.h>
+#include <NdbConfig.h>
+#include <NdbEnv.h>
+#include <NdbMem.h>
+#include <basestring_vsnprintf.h>
+
+static const char *datadir_path= 0;
+
+const char *
+NdbConfig_get_path(int *_len)
+{
+  const char *path= NdbEnv_GetEnv("NDB_HOME", 0, 0);
+  int path_len= 0;
+  if (path)
+    path_len= strlen(path);
+  if (path_len == 0 && datadir_path) {
+    path= datadir_path;
+    path_len= strlen(path);
+  }
+  if (path_len == 0) {
+    path= ".";
+    path_len= strlen(path);
+  }
+  if (_len)
+    *_len= path_len;
+  return path;
+}
+
+static char* 
+NdbConfig_AllocHomePath(int _len)
+{
+  int path_len;
+  const char *path= NdbConfig_get_path(&path_len);
+  int len= _len+path_len;
+  char *buf= NdbMem_Allocate(len);
+  basestring_snprintf(buf, len, "%s%s", path, DIR_SEPARATOR);
+  return buf;
+}
+
+void
+NdbConfig_SetPath(const char* path){
+  datadir_path= path;
+}
+
+char* 
+NdbConfig_NdbCfgName(int with_ndb_home){
+  char *buf;
+  int len= 0;
+
+  if (with_ndb_home) {
+    buf= NdbConfig_AllocHomePath(128);
+    len= strlen(buf);
+  } else
+    buf= NdbMem_Allocate(128);
+  basestring_snprintf(buf+len, 128, "Ndb.cfg");
+  return buf;
+}
+
+static
+char *get_prefix_buf(int len, int node_id)
+{
+  char tmp_buf[sizeof("ndb_pid#############")+1];
+  char *buf;
+  if (node_id > 0)
+    basestring_snprintf(tmp_buf, sizeof(tmp_buf), "ndb_%u", node_id);
+  else
+    basestring_snprintf(tmp_buf, sizeof(tmp_buf), "ndb_pid%u", getpid());
+  tmp_buf[sizeof(tmp_buf)-1]= 0;
+
+  buf= NdbConfig_AllocHomePath(len+strlen(tmp_buf));
+  strcat(buf, tmp_buf);
+  return buf;
+}
+
+char* 
+NdbConfig_ErrorFileName(int node_id){
+  char *buf= get_prefix_buf(128, node_id);
+  int len= strlen(buf);
+  basestring_snprintf(buf+len, 128, "_error.log");
+  return buf;
+}
+
+char*
+NdbConfig_ClusterLogFileName(int node_id){
+  char *buf= get_prefix_buf(128, node_id);
+  int len= strlen(buf);
+  basestring_snprintf(buf+len, 128, "_cluster.log");
+  return buf;
+}
+
+char*
+NdbConfig_SignalLogFileName(int node_id){
+  char *buf= get_prefix_buf(128, node_id);
+  int len= strlen(buf);
+  basestring_snprintf(buf+len, 128, "_signal.log");
+  return buf;
+}
+
+char*
+NdbConfig_TraceFileName(int node_id, int file_no){
+  char *buf= get_prefix_buf(128, node_id);
+  int len= strlen(buf);
+  basestring_snprintf(buf+len, 128, "_trace.log.%u", file_no);
+  return buf;
+}
+
+char*
+NdbConfig_NextTraceFileName(int node_id){
+  char *buf= get_prefix_buf(128, node_id);
+  int len= strlen(buf);
+  basestring_snprintf(buf+len, 128, "_trace.log.next");
+  return buf;
+}
+
+char*
+NdbConfig_PidFileName(int node_id){
+  char *buf= get_prefix_buf(128, node_id);
+  int len= strlen(buf);
+  basestring_snprintf(buf+len, 128, ".pid");
+  return buf;
+}
+
+char*
+NdbConfig_StdoutFileName(int node_id){
+  char *buf= get_prefix_buf(128, node_id);
+  int len= strlen(buf);
+  basestring_snprintf(buf+len, 128, "_out.log");
+  return buf;
+}