aboutsummaryrefslogtreecommitdiff
path: root/src/core
diff options
context:
space:
mode:
Diffstat (limited to 'src/core')
-rw-r--r--src/core/nng_impl.h45
-rw-r--r--src/core/panic.c45
-rw-r--r--src/core/platform.h212
-rw-r--r--src/core/snprintf.c31
-rw-r--r--src/core/snprintf.h24
5 files changed, 128 insertions, 229 deletions
diff --git a/src/core/nng_impl.h b/src/core/nng_impl.h
index 5b473434..f45394e9 100644
--- a/src/core/nng_impl.h
+++ b/src/core/nng_impl.h
@@ -1,44 +1,39 @@
-/*
- * Copyright 2016 Garrett D'Amore <garrett@damore.org>
- *
- * This software is supplied under the terms of the MIT License, a
- * copy of which should be located in the distribution where this
- * file was obtained (LICENSE.txt). A copy of the license may also be
- * found online at https://opensource.org/licenses/MIT.
- */
-
+//
+// Copyright 2016 Garrett D'Amore <garrett@damore.org>
+//
+// This software is supplied under the terms of the MIT License, a
+// copy of which should be located in the distribution where this
+// file was obtained (LICENSE.txt). A copy of the license may also be
+// found online at https://opensource.org/licenses/MIT.
+//
#ifndef CORE_NNG_IMPL_H
#define CORE_NNG_IMPL_H
#include "nng.h"
-/*
- * Internal implementation things for NNG, common definitions, etc.
- * All internal modules wind up including this file to avoid having
- * to figure out which header(s) to include.
- *
- * Hopefully it should be clear by the name that this file and its contents
- * are *NOT* for use outside of this library.
- *
- * Symbols that are private to the library begin with the nni_ prefix, whereas
- * those starting with nng_ are intended for external consumption. The latter
- * symbols should be found in the toplevel nng.h header.
- */
-
+// Internal implementation things for NNG, common definitions, etc.
+// All internal modules wind up including this file to avoid having
+// to figure out which header(s) to include.
+//
+// Hopefully it should be clear by the name that this file and its contents
+// are *NOT* for use outside of this library.
+//
+// Symbols that are private to the library begin with the nni_ prefix, whereas
+// those starting with nng_ are intended for external consumption. The latter
+// symbols should be found in the toplevel nng.h header.
#include "core/defs.h"
#include "core/list.h"
#include "core/init.h"
#include "core/message.h"
#include "core/msgqueue.h"
#include "core/panic.h"
-#include "core/snprintf.h"
#include "core/platform.h"
#include "core/protocol.h"
#include "core/transport.h"
-/* These have to come after the others - particularly transport.h */
+// These have to come after the others - particularly transport.h
#include "core/pipe.h"
#include "core/socket.h"
#include "core/endpt.h"
-#endif /* CORE_NNG_IMPL_H */
+#endif // CORE_NNG_IMPL_H
diff --git a/src/core/panic.c b/src/core/panic.c
index 822c0904..65eb0747 100644
--- a/src/core/panic.c
+++ b/src/core/panic.c
@@ -1,15 +1,16 @@
-/*
- * Copyright 2016 Garrett D'Amore <garrett@damore.org>
- *
- * This software is supplied under the terms of the MIT License, a
- * copy of which should be located in the distribution where this
- * file was obtained (LICENSE.txt). A copy of the license may also be
- * found online at https://opensource.org/licenses/MIT.
- */
+//
+// Copyright 2016 Garrett D'Amore <garrett@damore.org>
+//
+// This software is supplied under the terms of the MIT License, a
+// copy of which should be located in the distribution where this
+// file was obtained (LICENSE.txt). A copy of the license may also be
+// found online at https://opensource.org/licenses/MIT.
+//
#include <stdlib.h>
#include <string.h>
#include <stdarg.h>
+#include <stdio.h>
#ifdef NNG_HAVE_BACKTRACE
#include <execinfo.h>
@@ -17,11 +18,11 @@
#include "core/nng_impl.h"
-/*
- * Panic handling.
- */
+//
+// Panic handling.
+//
static void
-show_backtrace(void)
+nni_show_backtrace(void)
{
#if NNG_HAVE_BACKTRACE
void *frames[50];
@@ -43,13 +44,13 @@ show_backtrace(void)
}
-/*
- * nni_panic shows a panic message, a possible stack bracktrace, then aborts
- * the process/program. This should only be called when a condition arises
- * that should not be possible, e.g. a programming assertion failure. It should
- * not be called in situations such as ENOMEM, as nni_panic is fairly rude
- * to any application it may be called from within.
- */
+//
+// nni_panic shows a panic message, a possible stack bracktrace, then aborts
+// the process/program. This should only be called when a condition arises
+// that should not be possible, e.g. a programming assertion failure. It should
+// not be called in situations such as ENOMEM, as nni_panic is fairly rude
+// to any application it may be called from within.
+//
void
nni_panic(const char *fmt, ...)
{
@@ -58,15 +59,15 @@ nni_panic(const char *fmt, ...)
va_list va;
va_start(va, fmt);
- (void) nni_snprintf(fbuf, sizeof (buf), "panic: %s", fmt);
- (void) nni_vsnprintf(buf, sizeof (buf), fbuf, va);
+ (void) snprintf(fbuf, sizeof (fbuf), "panic: %s", fmt);
+ (void) vsnprintf(buf, sizeof (buf), fbuf, va);
va_end(va);
nni_println(buf);
nni_println("This message is indicative of a BUG.");
nni_println("Report this at http://github.com/nanomsg/nanomsg");
- show_backtrace();
+ nni_show_backtrace();
nni_plat_abort();
}
diff --git a/src/core/platform.h b/src/core/platform.h
index 32e8727f..00401493 100644
--- a/src/core/platform.h
+++ b/src/core/platform.h
@@ -1,90 +1,69 @@
-/*
- * Copyright 2016 Garrett D'Amore <garrett@damore.org>
- *
- * This software is supplied under the terms of the MIT License, a
- * copy of which should be located in the distribution where this
- * file was obtained (LICENSE.txt). A copy of the license may also be
- * found online at https://opensource.org/licenses/MIT.
- */
+//
+// Copyright 2016 Garrett D'Amore <garrett@damore.org>
+//
+// This software is supplied under the terms of the MIT License, a
+// copy of which should be located in the distribution where this
+// file was obtained (LICENSE.txt). A copy of the license may also be
+// found online at https://opensource.org/licenses/MIT.
+//
#ifndef CORE_PLATFORM_H
#define CORE_PLATFORM_H
-/*
- * We require some standard C header files. The only one of these that might
- * be problematic is <stdint.h>, which is required for C99. Older versions
- * of the Windows compilers might not have this. However, latest versions of
- * MS Studio have a functional <stdint.h>. If this impacts you, just upgrade
- * your tool chain.
- */
+// We require some standard C header files. The only one of these that might
+// be problematic is <stdint.h>, which is required for C99. Older versions
+// of the Windows compilers might not have this. However, latest versions of
+// MS Studio have a functional <stdint.h>. If this impacts you, just upgrade
+// your tool chain.
#include <stdarg.h>
#include <stddef.h>
#include <stdint.h>
-/*
- * These are the APIs that a platform must implement to support nng.
- */
-
-/*
- * A word about fork-safety: This library is *NOT* fork safe, in that
- * functions may not be called in the child process without an intervening
- * exec(). The library attempts to detect this situation, and crashes the
- * process with an error message if it encounters it. (See nn_platform_init
- * below.)
- *
- * Additionally, some file descriptors may leak across fork even to
- * child processes. We make every reasonable effort to ensure that this
- * does not occur, but on some platforms there are unavoidable race
- * conditions between file creation and marking the file close-on-exec.
- *
- * Forkers should use posix_spawn() if possible, and as much as possible
- * arrange for file close on exec by posix_spawn, or close the descriptors
- * they do not need in the child.
- */
-
-/*
- * nni_plat_abort crashes the system; it should do whatever is appropriate
- * for abnormal programs on the platform, such as calling abort().
- */
+// These are the APIs that a platform must implement to support nng.
+
+// A word about fork-safety: This library is *NOT* fork safe, in that
+// functions may not be called in the child process without an intervening
+// exec(). The library attempts to detect this situation, and crashes the
+// process with an error message if it encounters it. (See nn_platform_init
+// below.)
+//
+// Additionally, some file descriptors may leak across fork even to
+// child processes. We make every reasonable effort to ensure that this
+// does not occur, but on some platforms there are unavoidable race
+// conditions between file creation and marking the file close-on-exec.
+//
+// Forkers should use posix_spawn() if possible, and as much as possible
+// arrange for file close on exec by posix_spawn, or close the descriptors
+// they do not need in the child. (Note that posix_spawn() does *NOT*
+// arrange for pthread_atfork() handlers to be called on some platforms.)
+
+// nni_plat_abort crashes the system; it should do whatever is appropriate
+// for abnormal programs on the platform, such as calling abort().
extern void nni_plat_abort(void);
-/*
- * nni_plat_vnsprintf is exactly like its POSIX counterpart.
- * Some platforms (Windows!) need a special version of this.
- */
-extern void nni_plat_vsnprintf(char *, size_t, const char *, va_list);
-
-/*
- * nni_plat_println is used to emit debug messages. Typically this is used
- * during core debugging, or to emit panic messages. Message content will
- * not contain newlines, but the output will add them.
- */
+// nni_plat_println is used to emit debug messages. Typically this is used
+// during core debugging, or to emit panic messages. Message content will
+// not contain newlines, but the output will add them.
extern void nni_plat_println(const char *);
-/*
- * nni_alloc allocates memory. In most cases this can just be malloc().
- * However, you may provide a different allocator, for example it is
- * possible to use a slab allocator or somesuch. It is permissible for this
- * to return NULL if memory cannot be allocated.
- */
+// nni_alloc allocates memory. In most cases this can just be malloc().
+// However, you may provide a different allocator, for example it is
+// possible to use a slab allocator or somesuch. It is permissible for this
+// to return NULL if memory cannot be allocated.
extern void *nni_alloc(size_t);
-/*
- * nni_free frees memory allocated with nni_alloc. It takes a size because
- * some allocators do not track size, or can operate more efficiently if
- * the size is provided with the free call. Examples of this are slab
- * allocators like this found in Solaris/illumos (see libumem or kmem).
- * This routine does nothing if supplied with a NULL pointer and zero size.
- * Most implementations can just call free() here.
- */
+// nni_free frees memory allocated with nni_alloc. It takes a size because
+// some allocators do not track size, or can operate more efficiently if
+// the size is provided with the free call. Examples of this are slab
+// allocators like this found in Solaris/illumos (see libumem or kmem).
+// This routine does nothing if supplied with a NULL pointer and zero size.
+// Most implementations can just call free() here.
extern void nni_free(void *, size_t);
typedef struct nni_mutex * nni_mutex_t;
typedef struct nni_cond * nni_cond_t;
-/*
- * Mutex handling.
- */
+// Mutex handling.
extern int nni_mutex_create(nni_mutex_t *);
extern void nni_mutex_destroy(nni_mutex_t);
@@ -95,90 +74,69 @@ extern int nni_mutex_tryenter(nni_mutex_t);
extern int nni_cond_create(nni_cond_t *, nni_mutex_t);
extern void nni_cond_destroy(nni_cond_t);
-/*
- * nni_cond_broadcast wakes all waiters on the condition. This should be
- * called with the lock held.
- */
+// nni_cond_broadcast wakes all waiters on the condition. This should be
+// called with the lock held.
extern void nni_cond_broadcast(nni_cond_t);
-/*
- * nni_cond_signal wakes a signal waiter.
- */
+// nni_cond_signal wakes a signal waiter.
extern void nni_cond_signal(nni_cond_t);
-/*
- * nni_condwait waits for a wake up on the condition variable. The
- * associated lock is atomically released and reacquired upon wake up.
- * Callers can be spuriously woken. The associated lock must be held.
- */
+// nni_cond_wait waits for a wake up on the condition variable. The
+// associated lock is atomically released and reacquired upon wake up.
+// Callers can be spuriously woken. The associated lock must be held.
extern void nni_cond_wait(nni_cond_t);
-/*
- * nni_cond_timedwait waits for a wakeup on the condition variable, just
- * as with nni_condwait, but it will also wake after the given number of
- * microseconds has passed. (This is a relative timed wait.) Early
- * wakeups are permitted, and the caller must take care to double check any
- * conditions. The return value is 0 on success, or an error code, which
- * can be NNG_ETIMEDOUT. Note that it is permissible to wait for longer
- * than the timeout based on the resolution of your system clock.
- */
+// nni_cond_timedwait waits for a wakeup on the condition variable, just
+// as with nni_condwait, but it will also wake after the given number of
+// microseconds has passed. (This is a relative timed wait.) Early
+// wakeups are permitted, and the caller must take care to double check any
+// conditions. The return value is 0 on success, or an error code, which
+// can be NNG_ETIMEDOUT. Note that it is permissible to wait for longer
+// than the timeout based on the resolution of your system clock.
extern int nni_cond_timedwait(nni_cond_t, uint64_t);
typedef struct nni_thread * nni_thread_t;
-/*
- * nni_thread_creates a thread that runs the given function. The thread
- * receives a single argument.
- */
+// nni_thread_creates a thread that runs the given function. The thread
+// receives a single argument.
extern int nni_thread_create(nni_thread_t *, void (*fn)(void *), void *);
-/*
- * nni_thread_reap waits for the thread to exit, and then releases any
- * resources associated with the thread. After this returns, it
- * is an error to reference the thread in any further way.
- */
+// nni_thread_reap waits for the thread to exit, and then releases any
+// resources associated with the thread. After this returns, it
+// is an error to reference the thread in any further way.
extern void nni_thread_reap(nni_thread_t);
-/*
- * nn_clock returns a number of microseconds since some arbitrary time
- * in the past. The values returned by nni_clock may be used with
- * nni_cond_timedwait.
- */
+// nn_clock returns a number of microseconds since some arbitrary time
+// in the past. The values returned by nni_clock may be used with
+// nni_cond_timedwait.
extern uint64_t nni_clock(void);
-/*
- * nni_usleep sleeps for the specified number of microseconds (at least).
- */
+// nni_usleep sleeps for the specified number of microseconds (at least).
extern void nni_usleep(uint64_t);
-/*
- * nni_platform_init is called to allow the platform the chance to
- * do any necessary initialization. This routine MUST be idempotent,
- * and threadsafe, and will be called before any other API calls, and
- * may be called at any point thereafter. It is permitted to return
- * an error if some critical failure inializing the platform occurs,
- * but once this succeeds, all future calls must succeed as well, unless
- * nni_plat_fini has been called.
- *
- * The function argument should be called if the platform has not initialized
- * (i.e. exactly once please), and its result passed back to the caller.
- */
+// nni_platform_init is called to allow the platform the chance to
+// do any necessary initialization. This routine MUST be idempotent,
+// and threadsafe, and will be called before any other API calls, and
+// may be called at any point thereafter. It is permitted to return
+// an error if some critical failure inializing the platform occurs,
+// but once this succeeds, all future calls must succeed as well, unless
+// nni_plat_fini has been called.
+//
+// The function argument should be called if the platform has not initialized
+// (i.e. exactly once please), and its result passed back to the caller.
+//
extern int nni_plat_init(int (*)(void));
-/*
- * nni_platform_fini is called to clean up resources. It is intended to
- * be called as the last thing executed in the library, and no other functions
- * will be called until nni_platform_init is called.
- */
+// nni_platform_fini is called to clean up resources. It is intended to
+// be called as the last thing executed in the library, and no other functions
+// will be called until nni_platform_init is called.
extern void nni_plat_fini(void);
-/*
- * Actual platforms we support.
- */
+// Actual platforms we support.
#if defined(PLATFORM_POSIX)
#include "platform/posix/posix_impl.h"
#else
#error "unknown platform"
#endif
-#endif /* CORE_PLATFORM_H */
+#endif // CORE_PLATFORM_H
diff --git a/src/core/snprintf.c b/src/core/snprintf.c
deleted file mode 100644
index be002e57..00000000
--- a/src/core/snprintf.c
+++ /dev/null
@@ -1,31 +0,0 @@
-/*
- * Copyright 2016 Garrett D'Amore <garrett@damore.org>
- *
- * This software is supplied under the terms of the MIT License, a
- * copy of which should be located in the distribution where this
- * file was obtained (LICENSE.txt). A copy of the license may also be
- * found online at https://opensource.org/licenses/MIT.
- */
-
-#include <stdarg.h>
-#include <stdint.h>
-#include <stdlib.h>
-
-#include "core/nng_impl.h"
-
-void
-nni_snprintf(char *dst, size_t sz, const char *fmt, ...)
-{
- va_list va;
-
- va_start(va, fmt);
- nni_vsnprintf(dst, sz, fmt, va);
- va_end(va);
-}
-
-
-void
-nni_vsnprintf(char *dst, size_t sz, const char *fmt, va_list va)
-{
- nni_plat_vsnprintf(dst, sz, fmt, va);
-}
diff --git a/src/core/snprintf.h b/src/core/snprintf.h
deleted file mode 100644
index 66028de3..00000000
--- a/src/core/snprintf.h
+++ /dev/null
@@ -1,24 +0,0 @@
-/*
- * Copyright 2016 Garrett D'Amore <garrett@damore.org>
- *
- * This software is supplied under the terms of the MIT License, a
- * copy of which should be located in the distribution where this
- * file was obtained (LICENSE.txt). A copy of the license may also be
- * found online at https://opensource.org/licenses/MIT.
- */
-
-#ifndef CORE_SNPRINTF_H
-#define CORE_SNPRINTF_H
-
-#include <stddef.h>
-#include <stdarg.h>
-
-/*
- * We have our own snprintf, because some platforms lack this, while
- * others need special handling. Ours just calls the vsnprintf version
- * from the platform.
- */
-extern void nni_snprintf(char *, size_t, const char *, ...);
-extern void nni_vsnprintf(char *, size_t, const char *, va_list);
-
-#endif /* CORE_SNPRINTF_H */