File pl_file.c

File List > cubrid > src > sp > pl_file.c

Go to the documentation of this file

/*
 * Copyright 2008 Search Solution Corporation
 * Copyright 2016 CUBRID Corporation
 *
 *  Licensed under the Apache License, Version 2.0 (the "License");
 *  you may not use this file except in compliance with the License.
 *  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 *  Unless required by applicable law or agreed to in writing, software
 *  distributed under the License is distributed on an "AS IS" BASIS,
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 *  See the License for the specific language governing permissions and
 *  limitations under the License.
 *
 */


/*
 * pl_file.c - Functions to manage files related to Procedural Language Server
 *
 * Note:
 */

#if defined (WINDOWS)
#include <io.h>
#endif

#include "pl_file.h"

#include "porting.h"
#include "environment_variable.h"

#include <assert.h>
#include <errno.h>
#include <stdlib.h>
#include <stdio.h>
// XXX: SHOULD BE THE LAST INCLUDE HEADER
#include "memory_wrapper.hpp"

bool
pl_open_info_dir ()
{
  char pl_dir[PATH_MAX];
  envvar_vardir_file (pl_dir, sizeof (pl_dir), "pl");

  if (access (pl_dir, F_OK) < 0)
    {
      /* create directory if not exist */
      if (mkdir (pl_dir, 0777) < 0 && errno == ENOENT)
    {
      char pdir[PATH_MAX];

      if (cub_dirname_r (pl_dir, pdir, PATH_MAX) > 0 && access (pdir, F_OK) < 0)
        {
          mkdir (pdir, 0777);
        }
    }
    }

  if (access (pl_dir, F_OK) < 0)
    {
      if (mkdir (pl_dir, 0777) < 0)
    {
      return false;
    }
    }

  return true;
}

FILE *
pl_open_info (const char *db_name, const char *mode)
{
  FILE *fp = NULL;
  char file_name[PATH_MAX] = { 0 };
  char file_path[PATH_MAX] = { 0 };

  snprintf (file_name, PATH_MAX, "pl/pl_%s.info", db_name);
  envvar_vardir_file (file_path, PATH_MAX, file_name);

  fp = fopen (file_path, mode);

  return fp;
}

void
pl_unlink_info (const char *db_name)
{
  char file_name[PATH_MAX] = { 0 };
  char file_path[PATH_MAX] = { 0 };

  snprintf (file_name, PATH_MAX, "pl/pl_%s.info", db_name);
  envvar_vardir_file (file_path, PATH_MAX, file_name);

  unlink (file_path);
}

bool
pl_get_info_file (char *buf, size_t len, const char *db_name)
{
  char pl_vardir[PATH_MAX];
  envvar_vardir_file (pl_vardir, PATH_MAX, "pl");

  if (snprintf (buf, len, "%s/pl_%s.info", pl_vardir, db_name) < 0)
    {
      assert (false);
      buf[0] = '\0';
      return false;
    }
  return true;
}

bool
pl_read_info (const char *db_name, PL_SERVER_INFO & info)
{
  FILE *fp = NULL;

  fp = pl_open_info (db_name, "r");
  if (fp)
    {
      fscanf (fp, "%d %d", &info.pid, &info.port);
      fclose (fp);
      return true;
    }

  return false;
}

bool
pl_write_info (const char *db_name, PL_SERVER_INFO * info)
{
  bool result = false;
  FILE *fp = NULL;

  fp = pl_open_info (db_name, "w+");
  if (fp)
    {
      fprintf (fp, "%d %d", info->pid, info->port);
      fclose (fp);
      result = true;
    }
  return result;
}

bool
pl_reset_info (const char *db_name)
{
  PL_SERVER_INFO reset_info = PL_SERVER_INFO_INITIALIZER;
  return pl_write_info (db_name, &reset_info);
}