/src/libyang/compat/compat.c

Source (jump to first uncovered line)
/**
 * @file compat.c
 * @author Michal Vasko <mvasko@cesnet.cz>
 * @brief compatibility functions
 *
 * Copyright (c) 2021 CESNET, z.s.p.o.
 *
 * This source code is licensed under BSD 3-Clause License (the "License").
 * You may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     https://opensource.org/licenses/BSD-3-Clause
 */
#define _POSIX_C_SOURCE 200809L /* fdopen, _POSIX_PATH_MAX, strdup */
#define _ISOC99_SOURCE /* vsnprintf */

#include "compat.h"

#include <errno.h>
#include <inttypes.h>
#include <limits.h>
#include <pthread.h>
#include <stdarg.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#ifndef _MSC_VER
#include <sys/time.h>
#endif
#include <time.h>
#include <unistd.h>

#ifndef HAVE_VDPRINTF
int
vdprintf(int fd, const char *format, va_list ap)
{
    FILE *stream;
    int count = 0;

    stream = fdopen(dup(fd), "a+");
    if (stream) {
        count = vfprintf(stream, format, ap);
        fclose(stream);
    }
    return count;
}

#endif

#ifndef HAVE_ASPRINTF
int
asprintf(char **strp, const char *fmt, ...)
{
    int ret;
    va_list ap;

    va_start(ap, fmt);
    ret = vasprintf(strp, fmt, ap);
    va_end(ap);
    return ret;
}

#endif

#ifndef HAVE_VASPRINTF
int
vasprintf(char **strp, const char *fmt, va_list ap)
{
    va_list ap2;

    va_copy(ap2, ap);
    int l = vsnprintf(0, 0, fmt, ap2);

    va_end(ap2);

    if ((l < 0) || !(*strp = malloc(l + 1U))) {
        return -1;
    }

    return vsnprintf(*strp, l + 1U, fmt, ap);
}

#endif

#ifndef HAVE_GETLINE
ssize_t
getline(char **lineptr, size_t *n, FILE *stream)
{
    static char chunk[256];
    char *ptr;
    ssize_t len, written;

    if (!lineptr || !n) {
        errno = EINVAL;
        return -1;
    }

    if (ferror(stream) || feof(stream)) {
        return -1;
    }

    *n = *lineptr ? *n : 0;
    written = 0;
    while (fgets(chunk, sizeof(chunk), stream)) {
        len = strlen(chunk);
        if ((size_t)(written + len) > *n) {
            ptr = realloc(*lineptr, *n + sizeof(chunk));
            if (!ptr) {
                return -1;
            }
            *lineptr = ptr;
            *n = *n + sizeof(chunk);
        }
        memcpy(*lineptr + written, &chunk, len);
        written += len;
        if ((*lineptr)[written - 1] == '\n') {
            break;
        }
    }
    if (written) {
        (*lineptr)[written] = '\0';
    } else {
        written = -1;
    }

    return written;
}

#endif

#ifndef HAVE_STRNDUP
char *
strndup(const char *s, size_t n)
{
    char *buf;
    size_t len = 0;

    /* strnlen */
    for ( ; (len < n) && (s[len] != '\0'); ++len) {}

    if (!(buf = malloc(len + 1U))) {
        return NULL;
    }

    memcpy(buf, s, len);
    buf[len] = '\0';
    return buf;
}

#endif

#ifndef HAVE_STRNSTR
char *
strnstr(const char *s, const char *find, size_t slen)
{
    char c, sc;
    size_t len;

    if ((c = *find++) != '\0') {
        len = strlen(find);
        do {
            do {
                if ((slen-- < 1) || ((sc = *s++) == '\0')) {
                    return NULL;
                }
            } while (sc != c);
            if (len > slen) {
                return NULL;
            }
        } while (strncmp(s, find, len));
        s--;
    }
    return (char *)s;
}

#endif

#ifndef HAVE_STRCHRNUL
char *
strchrnul(const char *s, int c)
{
    char *p = strchr(s, c);

    return p ? p : (char *)s + strlen(s);
}

#endif

#ifndef HAVE_GET_CURRENT_DIR_NAME
char *
get_current_dir_name(void)
{
    char tmp[_POSIX_PATH_MAX];
    char *retval = NULL;

    if (getcwd(tmp, sizeof(tmp))) {
        retval = strdup(tmp);
        if (!retval) {
            errno = ENOMEM;
        }
    }

    return retval;
}

#endif

#ifndef _MSC_VER
#ifndef HAVE_PTHREAD_MUTEX_TIMEDLOCK
int
pthread_mutex_timedlock(pthread_mutex_t *mutex, const struct timespec *abstime)
{
    int64_t nsec_diff;
    int32_t diff;
    struct timespec cur, dur;
    int rc;

    /* try to acquire the lock and, if we fail, sleep for 5ms. */
    while ((rc = pthread_mutex_trylock(mutex)) == EBUSY) {
        /* get real time */
#ifdef CLOCK_REALTIME
        clock_gettime(CLOCK_REALTIME, &cur);
#else
        struct timeval tv;

        gettimeofday(&tv, NULL);
        cur.tv_sec = (time_t)tv.tv_sec;
        cur.tv_nsec = 1000L * (long)tv.tv_usec;
#endif

        /* get time diff */
        nsec_diff = 0;
        nsec_diff += (((int64_t)abstime->tv_sec) - ((int64_t)cur.tv_sec)) * 1000000000L;
        nsec_diff += ((int64_t)abstime->tv_nsec) - ((int64_t)cur.tv_nsec);
        diff = (nsec_diff ? nsec_diff / 1000000L : 0);

        if (diff < 1) {
            /* timeout */
            break;
        } else if (diff < 5) {
            /* sleep until timeout */
            dur.tv_sec = 0;
            dur.tv_nsec = (long)diff * 1000000;
        } else {
            /* sleep 5 ms */
            dur.tv_sec = 0;
            dur.tv_nsec = 5000000;
        }

        nanosleep(&dur, NULL);
    }

    return rc;
}

#endif
#endif

#ifndef HAVE_REALPATH
#ifdef _WIN32
char *
realpath(const char *path, char *resolved_path)
{
    char *resolved = _fullpath(resolved_path, path, PATH_MAX);

    if ((_access(resolved, 0) == -1) && (errno == ENOENT)) {
        return NULL;
    }
    return resolved;
}

#elif defined (__NetBSD__)
char *
realpath(const char *path, char *resolved_path)
{
    ssize_t nbytes;

    nbytes = readlink(path, resolved_path, PATH_MAX);
    if (nbytes == -1) {
        return NULL;
    }
    return resolved_path;
}

#else
#error No realpath() implementation for this platform is available.
#endif
#endif

#ifndef HAVE_LOCALTIME_R
#ifdef _WIN32
struct tm *
localtime_r(const time_t *timep, struct tm *result)
{
    errno_t res = localtime_s(result, timep);

    if (res) {
        return NULL;
    } else {
        return result;
    }
}

#else
#error No localtime_r() implementation for this platform is available.
#endif
#endif

#ifndef HAVE_GMTIME_R
#ifdef _WIN32
struct tm *
gmtime_r(const time_t *timep, struct tm *result)
{
    errno_t res = gmtime_s(result, timep);

    if (res) {
        return NULL;
    } else {
        return result;
    }
}

#else
#error No gmtime_r() implementation for this platform is available.
#endif
#endif

#ifndef HAVE_TIMEGM
time_t
timegm(struct tm *tm)
{
    pthread_mutex_t tz_lock = PTHREAD_MUTEX_INITIALIZER;
    time_t ret;
    char *tz;

    pthread_mutex_lock(&tz_lock);

    tz = getenv("TZ");
    if (tz) {
        tz = strdup(tz);
    }
    setenv("TZ", "", 1);
    tzset();

    ret = mktime(tm);

    if (tz) {
        setenv("TZ", tz, 1);
        free(tz);
    } else {
        unsetenv("TZ");
    }
    tzset();

    pthread_mutex_unlock(&tz_lock);

    return ret;
}

#endif

#ifndef HAVE_SETENV
#ifdef _WIN32
int
setenv(const char *name, const char *value, int overwrite)
{
    int errcode = 0;

    if (!overwrite) {
        size_t envsize = 0;

        errcode = getenv_s(&envsize, NULL, 0, name);
        if (errcode || envsize) {
            return errcode;
        }
    }
    return _putenv_s(name, value);
}

#else
#error No setenv() implementation for this platform is available.
#endif
#endif

Coverage Report

Created: 2024-02-29 06:10

Line	Count	Source (jump to first uncovered line)
1		/**
2		* @file compat.c
3		* @author Michal Vasko <mvasko@cesnet.cz>
4		* @brief compatibility functions
5		*
6		* Copyright (c) 2021 CESNET, z.s.p.o.
7		*
8		* This source code is licensed under BSD 3-Clause License (the "License").
9		* You may not use this file except in compliance with the License.
10		* You may obtain a copy of the License at
11		*
12		* https://opensource.org/licenses/BSD-3-Clause
13		*/
14		#define _POSIX_C_SOURCE 200809L /* fdopen, _POSIX_PATH_MAX, strdup */
15		#define _ISOC99_SOURCE /* vsnprintf */
16
17		#include "compat.h"
18
19		#include <errno.h>
20		#include <inttypes.h>
21		#include <limits.h>
22		#include <pthread.h>
23		#include <stdarg.h>
24		#include <stdio.h>
25		#include <stdlib.h>
26		#include <string.h>
27		#ifndef _MSC_VER
28		#include <sys/time.h>
29		#endif
30		#include <time.h>
31		#include <unistd.h>
32
33		#ifndef HAVE_VDPRINTF
34		int
35		vdprintf(int fd, const char *format, va_list ap)
36		{
37		FILE *stream;
38		int count = 0;
39
40		stream = fdopen(dup(fd), "a+");
41		if (stream) {
42		count = vfprintf(stream, format, ap);
43		fclose(stream);
44		}
45		return count;
46		}
47
48		#endif
49
50		#ifndef HAVE_ASPRINTF
51		int
52		asprintf(char *strp, const char fmt, ...)
53		{
54		int ret;
55		va_list ap;
56
57		va_start(ap, fmt);
58		ret = vasprintf(strp, fmt, ap);
59		va_end(ap);
60		return ret;
61		}
62
63		#endif
64
65		#ifndef HAVE_VASPRINTF
66		int
67		vasprintf(char *strp, const char fmt, va_list ap)
68		{
69		va_list ap2;
70
71		va_copy(ap2, ap);
72		int l = vsnprintf(0, 0, fmt, ap2);
73
74		va_end(ap2);
75
76		if ((l < 0) \|\| !(*strp = malloc(l + 1U))) {
77		return -1;
78		}
79
80		return vsnprintf(*strp, l + 1U, fmt, ap);
81		}
82
83		#endif
84
85		#ifndef HAVE_GETLINE
86		ssize_t
87		getline(char *lineptr, size_t n, FILE *stream)
88		{
89		static char chunk[256];
90		char *ptr;
91		ssize_t len, written;
92
93		if (!lineptr \|\| !n) {
94		errno = EINVAL;
95		return -1;
96		}
97
98		if (ferror(stream) \|\| feof(stream)) {
99		return -1;
100		}
101
102		n = lineptr ? *n : 0;
103		written = 0;
104		while (fgets(chunk, sizeof(chunk), stream)) {
105		len = strlen(chunk);
106		if ((size_t)(written + len) > *n) {
107		ptr = realloc(lineptr, n + sizeof(chunk));
108		if (!ptr) {
109		return -1;
110		}
111		*lineptr = ptr;
112		n = n + sizeof(chunk);
113		}
114		memcpy(*lineptr + written, &chunk, len);
115		written += len;
116		if ((*lineptr)[written - 1] == '\n') {
117		break;
118		}
119		}
120		if (written) {
121		(*lineptr)[written] = '\0';
122		} else {
123		written = -1;
124		}
125
126		return written;
127		}
128
129		#endif
130
131		#ifndef HAVE_STRNDUP
132		char *
133		strndup(const char *s, size_t n)
134		{
135		char *buf;
136		size_t len = 0;
137
138		/* strnlen */
139		for ( ; (len < n) && (s[len] != '\0'); ++len) {}
140
141		if (!(buf = malloc(len + 1U))) {
142		return NULL;
143		}
144
145		memcpy(buf, s, len);
146		buf[len] = '\0';
147		return buf;
148		}
149
150		#endif
151
152		#ifndef HAVE_STRNSTR
153		char *
154		strnstr(const char s, const char find, size_t slen)
155	167k	{
156	167k	char c, sc;
157	167k	size_t len;
158
159	167k	if ((c = *find++) != '\0') {
160	167k	len = strlen(find);
161	167k	do {
162	1.21M	do {
163	1.21M	if ((slen-- < 1) \|\| ((sc = *s++) == '\0')) {
164	100k	return NULL;
165	100k	}
166	1.21M	} while (sc != c);
167	66.8k	if (len > slen) {
168	0	return NULL;
169	0	}
170	66.8k	} while (strncmp(s, find, len));
171	66.8k	s--;
172	66.8k	}
173	66.8k	return (char *)s;
174	167k	}
175
176		#endif
177
178		#ifndef HAVE_STRCHRNUL
179		char *
180		strchrnul(const char *s, int c)
181		{
182		char *p = strchr(s, c);
183
184		return p ? p : (char *)s + strlen(s);
185		}
186
187		#endif
188
189		#ifndef HAVE_GET_CURRENT_DIR_NAME
190		char *
191		get_current_dir_name(void)
192		{
193		char tmp[_POSIX_PATH_MAX];
194		char *retval = NULL;
195
196		if (getcwd(tmp, sizeof(tmp))) {
197		retval = strdup(tmp);
198		if (!retval) {
199		errno = ENOMEM;
200		}
201		}
202
203		return retval;
204		}
205
206		#endif
207
208		#ifndef _MSC_VER
209		#ifndef HAVE_PTHREAD_MUTEX_TIMEDLOCK
210		int
211		pthread_mutex_timedlock(pthread_mutex_t mutex, const struct timespec abstime)
212		{
213		int64_t nsec_diff;
214		int32_t diff;
215		struct timespec cur, dur;
216		int rc;
217
218		/* try to acquire the lock and, if we fail, sleep for 5ms. */
219		while ((rc = pthread_mutex_trylock(mutex)) == EBUSY) {
220		/* get real time */
221		#ifdef CLOCK_REALTIME
222		clock_gettime(CLOCK_REALTIME, &cur);
223		#else
224		struct timeval tv;
225
226		gettimeofday(&tv, NULL);
227		cur.tv_sec = (time_t)tv.tv_sec;
228		cur.tv_nsec = 1000L * (long)tv.tv_usec;
229		#endif
230
231		/* get time diff */
232		nsec_diff = 0;
233		nsec_diff += (((int64_t)abstime->tv_sec) - ((int64_t)cur.tv_sec)) * 1000000000L;
234		nsec_diff += ((int64_t)abstime->tv_nsec) - ((int64_t)cur.tv_nsec);
235		diff = (nsec_diff ? nsec_diff / 1000000L : 0);
236
237		if (diff < 1) {
238		/* timeout */
239		break;
240		} else if (diff < 5) {
241		/* sleep until timeout */
242		dur.tv_sec = 0;
243		dur.tv_nsec = (long)diff * 1000000;
244		} else {
245		/* sleep 5 ms */
246		dur.tv_sec = 0;
247		dur.tv_nsec = 5000000;
248		}
249
250		nanosleep(&dur, NULL);
251		}
252
253		return rc;
254		}
255
256		#endif
257		#endif
258
259		#ifndef HAVE_REALPATH
260		#ifdef _WIN32
261		char *
262		realpath(const char path, char resolved_path)
263		{
264		char *resolved = _fullpath(resolved_path, path, PATH_MAX);
265
266		if ((_access(resolved, 0) == -1) && (errno == ENOENT)) {
267		return NULL;
268		}
269		return resolved;
270		}
271
272		#elif defined (__NetBSD__)
273		char *
274		realpath(const char path, char resolved_path)
275		{
276		ssize_t nbytes;
277
278		nbytes = readlink(path, resolved_path, PATH_MAX);
279		if (nbytes == -1) {
280		return NULL;
281		}
282		return resolved_path;
283		}
284
285		#else
286		#error No realpath() implementation for this platform is available.
287		#endif
288		#endif
289
290		#ifndef HAVE_LOCALTIME_R
291		#ifdef _WIN32
292		struct tm *
293		localtime_r(const time_t timep, struct tm result)
294		{
295		errno_t res = localtime_s(result, timep);
296
297		if (res) {
298		return NULL;
299		} else {
300		return result;
301		}
302		}
303
304		#else
305		#error No localtime_r() implementation for this platform is available.
306		#endif
307		#endif
308
309		#ifndef HAVE_GMTIME_R
310		#ifdef _WIN32
311		struct tm *
312		gmtime_r(const time_t timep, struct tm result)
313		{
314		errno_t res = gmtime_s(result, timep);
315
316		if (res) {
317		return NULL;
318		} else {
319		return result;
320		}
321		}
322
323		#else
324		#error No gmtime_r() implementation for this platform is available.
325		#endif
326		#endif
327
328		#ifndef HAVE_TIMEGM
329		time_t
330		timegm(struct tm *tm)
331		{
332		pthread_mutex_t tz_lock = PTHREAD_MUTEX_INITIALIZER;
333		time_t ret;
334		char *tz;
335
336		pthread_mutex_lock(&tz_lock);
337
338		tz = getenv("TZ");
339		if (tz) {
340		tz = strdup(tz);
341		}
342		setenv("TZ", "", 1);
343		tzset();
344
345		ret = mktime(tm);
346
347		if (tz) {
348		setenv("TZ", tz, 1);
349		free(tz);
350		} else {
351		unsetenv("TZ");
352		}
353		tzset();
354
355		pthread_mutex_unlock(&tz_lock);
356
357		return ret;
358		}
359
360		#endif
361
362		#ifndef HAVE_SETENV
363		#ifdef _WIN32
364		int
365		setenv(const char name, const char value, int overwrite)
366		{
367		int errcode = 0;
368
369		if (!overwrite) {
370		size_t envsize = 0;
371
372		errcode = getenv_s(&envsize, NULL, 0, name);
373		if (errcode \|\| envsize) {
374		return errcode;
375		}
376		}
377		return _putenv_s(name, value);
378		}
379
380		#else
381		#error No setenv() implementation for this platform is available.
382		#endif
383		#endif