cyclors 0.4.0

Low-level API for the native CycloneDDS bindings (libddsc-sys).
Documentation
// Copyright(c) 2019 to 2021 ZettaScale Technology and others
//
// This program and the accompanying materials are made available under the
// terms of the Eclipse Public License v. 2.0 which is available at
// http://www.eclipse.org/legal/epl-2.0, or the Eclipse Distribution License
// v. 1.0 which is available at
// http://www.eclipse.org/org/documents/edl-v10.php.
//
// SPDX-License-Identifier: EPL-2.0 OR BSD-3-Clause

#include <stdio.h>
#include <string.h>
#include <assert.h>

#include "dds/ddsrt/dynlib.h"
#include "dds/ddsrt/heap.h"
#include "dds/ddsrt/string.h"
#include "dds/ddsrt/environ.h"

#include "CUnit/Test.h"

#include "dl.h"

#define TEST_LIB_ABSOLUTE ""TEST_LIB_DIR""TEST_LIB_SEP""TEST_LIB_FILE""

#define TEST_ABORT_IF_NULL(var, msg) \
do { \
  if (var == NULL) { \
    char err[256]; \
    r = ddsrt_dlerror(err, sizeof(err)); \
    CU_ASSERT_FATAL (r > 0 || r == DDS_RETCODE_NOT_ENOUGH_SPACE); \
    printf("\n%s", err); \
    CU_FAIL_FATAL(msg); \
  } \
} while(0)


/*
 * Load a library.
 */
CU_Test(ddsrt_library, dlopen_path)
{
  dds_return_t r;
  ddsrt_dynlib_t  l;

  printf("Absolute lib: %s\n", TEST_LIB_ABSOLUTE);
  r = ddsrt_dlopen(TEST_LIB_ABSOLUTE, false, &l);
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
  CU_ASSERT_NEQ (l, NULL)
  TEST_ABORT_IF_NULL(l, "ddsrt_dlopen() failed. Is the proper library path set?");

  r = ddsrt_dlclose(l);
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
}

CU_Test(ddsrt_library, dlopen_file)
{
  dds_return_t r;
  ddsrt_dynlib_t l;

  r = ddsrt_dlopen(TEST_LIB_FILE, false, &l);
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
  CU_ASSERT_NEQ (l, NULL)
  TEST_ABORT_IF_NULL(l, "ddsrt_dlopen() failed. Is the proper library path set?");

  r = ddsrt_dlclose(l);
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
}

CU_Test(ddsrt_library, dlopen_name)
{
  dds_return_t r;
  ddsrt_dynlib_t l;

  r = ddsrt_dlopen(TEST_LIB_NAME, true, &l);
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
  CU_ASSERT_NEQ (l, NULL)
  TEST_ABORT_IF_NULL(l, "ddsrt_dlopen() failed. Is the proper library path set?");

  r = ddsrt_dlclose(l);
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
}

CU_Test(ddsrt_library, dlopen_unknown)
{
  char buffer[256];
  dds_return_t r;
  ddsrt_dynlib_t l;

  r = ddsrt_dlopen("UnknownLib", false, &l);
  CU_ASSERT_NEQ (r, DDS_RETCODE_OK);
  CU_ASSERT_EQ_FATAL (l, NULL)

  r = ddsrt_dlerror(buffer, sizeof(buffer));
  CU_ASSERT_FATAL (r > 0 || r == DDS_RETCODE_NOT_ENOUGH_SPACE);
  printf("\n%s", buffer);
}

CU_Test(ddsrt_library, dlsym)
{
  dds_return_t r;
  ddsrt_dynlib_t l;
  void* f;

  r = ddsrt_dlopen(TEST_LIB_NAME, true, &l);
  CU_ASSERT_NEQ (l, NULL)
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
  TEST_ABORT_IF_NULL(l, "ddsrt_dlopen() failed. Is the proper library path set?");

  r = ddsrt_dlsym(l, "get_int", &f);
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
  CU_ASSERT_NEQ (f, NULL)
  TEST_ABORT_IF_NULL(f, "ddsrt_dlsym(l, \"get_int\") failed.");

  r = ddsrt_dlclose(l);
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
}

CU_Test(ddsrt_library, dlsym_unknown)
{
  char buffer[256];
  dds_return_t r;
  ddsrt_dynlib_t l;
  void* f;

  r = ddsrt_dlopen(TEST_LIB_NAME, true, &l);
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
  CU_ASSERT_NEQ (l, NULL)
  TEST_ABORT_IF_NULL(l,"ddsrt_dlopen() failed. Is the proper library path set?");

  r = ddsrt_dlsym(l, "UnknownSym", &f);
  CU_ASSERT_EQ (r, DDS_RETCODE_ERROR);
  CU_ASSERT_EQ_FATAL (f, NULL)

  r = ddsrt_dlerror(buffer, sizeof(buffer));
  CU_ASSERT_FATAL (r > 0 || r == DDS_RETCODE_NOT_ENOUGH_SPACE);
  printf("\n%s", buffer);

  r = ddsrt_dlclose(l);
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
}

typedef void (*func_set_int)(int val);
typedef int  (*func_get_int)(void);
CU_Test(ddsrt_library, call)
{
  int get_int = 0;
  int set_int = 1234;
  func_get_int f_get;
  func_set_int f_set;
  dds_return_t r;
  ddsrt_dynlib_t l;

  r = ddsrt_dlopen(TEST_LIB_NAME, true, &l);
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
  CU_ASSERT_NEQ (l, NULL)
  TEST_ABORT_IF_NULL(l, "ddsrt_dlopen() failed. Is the proper library path set?");

  r = ddsrt_dlsym(l, "get_int", (void **)&f_get);
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
  CU_ASSERT_NEQ (f_get, NULL)
  TEST_ABORT_IF_NULL(f_get, "ddsrt_dlsym(l, \"get_int\") failed.");

  r = ddsrt_dlsym(l, "set_int", (void **)&f_set);
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
  CU_ASSERT_NEQ (f_set, NULL)
  TEST_ABORT_IF_NULL(f_set, "ddsrt_dlsym(l, \"set_int\") failed.");

  assert(f_set != 0 && f_get != 0); /* for Clang static analyzer */
  f_set(set_int);
  get_int = f_get();
  CU_ASSERT_EQ (set_int, get_int);

  r = ddsrt_dlclose(l);
  CU_ASSERT_EQ (r, DDS_RETCODE_OK);
}

CU_Test(ddsrt_library, dlclose_error)
{
    dds_return_t r;
    ddsrt_dynlib_t l;

    r = ddsrt_dlopen(TEST_LIB_NAME, true, &l);
    CU_ASSERT_EQ (r, DDS_RETCODE_OK);
    CU_ASSERT_NEQ (l, NULL)
    TEST_ABORT_IF_NULL(l, "ddsrt_dlopen() failed. Is the proper library path set?");

    r = ddsrt_dlclose(l);
    CU_ASSERT_EQ (r, DDS_RETCODE_OK);

    r = ddsrt_dlclose( l ); /*already closed handle */
    CU_ASSERT_EQ (r, DDS_RETCODE_ERROR);
}