/*
- * Copyright (C) 2011 - David Goulet <david.goulet@polymtl.ca>
- * Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
+ * Copyright (C) 2011 David Goulet <david.goulet@polymtl.ca>
+ * Copyright (C) 2011 Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
+ *
+ * SPDX-License-Identifier: GPL-2.0-only
*
- * This program is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License, version 2 only,
- * as published by the Free Software Foundation.
- *
- * 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.,
- * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
*/
#define _LGPL_SOURCE
-#include <assert.h>
#include <limits.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <unistd.h>
-#include <errno.h>
#include <inttypes.h>
#include <common/common.h>
+#include <common/compat/errno.h>
#include "sessiond-comm.h"
*
* These code MUST be negative in other to treat that as an error value.
*/
-LTTNG_HIDDEN
const char *lttcomm_get_readable_code(enum lttcomm_return_code code)
{
code = -code;
* Create socket from an already allocated lttcomm socket structure and init
* sockaddr in the lttcomm sock.
*/
-LTTNG_HIDDEN
int lttcomm_create_sock(struct lttcomm_sock *sock)
{
int ret, _sock_type, _sock_proto, domain;
- assert(sock);
+ LTTNG_ASSERT(sock);
domain = sock->sockaddr.type;
if (domain != LTTCOMM_INET && domain != LTTCOMM_INET6) {
/*
* Return allocated lttcomm socket structure.
*/
-LTTNG_HIDDEN
struct lttcomm_sock *lttcomm_alloc_sock(enum lttcomm_sock_proto proto)
{
struct lttcomm_sock *sock;
* This is mostly useful when lttcomm_sock are passed between process where the
* fd and ops have to be changed within the correct address space.
*/
-LTTNG_HIDDEN
struct lttcomm_sock *lttcomm_alloc_copy_sock(struct lttcomm_sock *src)
{
struct lttcomm_sock *sock;
/* Safety net */
- assert(src);
+ LTTNG_ASSERT(src);
sock = lttcomm_alloc_sock(src->proto);
if (sock == NULL) {
* This is mostly useful when lttcomm_sock are passed between process where the
* fd and ops have to be changed within the correct address space.
*/
-LTTNG_HIDDEN
void lttcomm_copy_sock(struct lttcomm_sock *dst, struct lttcomm_sock *src)
{
/* Safety net */
- assert(dst);
- assert(src);
+ LTTNG_ASSERT(dst);
+ LTTNG_ASSERT(src);
dst->proto = src->proto;
dst->fd = src->fd;
/*
* Init IPv4 sockaddr structure.
*/
-LTTNG_HIDDEN
int lttcomm_init_inet_sockaddr(struct lttcomm_sockaddr *sockaddr,
const char *ip, unsigned int port)
{
int ret;
- assert(sockaddr);
- assert(ip);
- assert(port > 0 && port <= 65535);
+ LTTNG_ASSERT(sockaddr);
+ LTTNG_ASSERT(ip);
+ LTTNG_ASSERT(port > 0 && port <= 65535);
memset(sockaddr, 0, sizeof(struct lttcomm_sockaddr));
/*
* Init IPv6 sockaddr structure.
*/
-LTTNG_HIDDEN
int lttcomm_init_inet6_sockaddr(struct lttcomm_sockaddr *sockaddr,
const char *ip, unsigned int port)
{
int ret;
- assert(sockaddr);
- assert(ip);
- assert(port > 0 && port <= 65535);
+ LTTNG_ASSERT(sockaddr);
+ LTTNG_ASSERT(ip);
+ LTTNG_ASSERT(port > 0 && port <= 65535);
memset(sockaddr, 0, sizeof(struct lttcomm_sockaddr));
/*
* Return allocated lttcomm socket structure from lttng URI.
*/
-LTTNG_HIDDEN
struct lttcomm_sock *lttcomm_alloc_sock_from_uri(struct lttng_uri *uri)
{
int ret;
struct lttcomm_sock *sock = NULL;
/* Safety net */
- assert(uri);
+ LTTNG_ASSERT(uri);
/* Check URI protocol */
if (uri->proto == LTTNG_TCP) {
/*
* Destroy and free lttcomm socket.
*/
-LTTNG_HIDDEN
void lttcomm_destroy_sock(struct lttcomm_sock *sock)
{
free(sock);
*
* On error, NULL is returned.
*/
-LTTNG_HIDDEN
struct lttcomm_relayd_sock *lttcomm_alloc_relayd_sock(struct lttng_uri *uri,
uint32_t major, uint32_t minor)
{
struct lttcomm_sock *tmp_sock = NULL;
struct lttcomm_relayd_sock *rsock = NULL;
- assert(uri);
+ LTTNG_ASSERT(uri);
rsock = zmalloc(sizeof(*rsock));
if (!rsock) {
/*
* Set socket receiving timeout.
*/
-LTTNG_HIDDEN
int lttcomm_setsockopt_rcv_timeout(int sock, unsigned int msec)
{
int ret;
/*
* Set socket sending timeout.
*/
-LTTNG_HIDDEN
int lttcomm_setsockopt_snd_timeout(int sock, unsigned int msec)
{
int ret;
return ret;
}
-LTTNG_HIDDEN
int lttcomm_sock_get_port(const struct lttcomm_sock *sock, uint16_t *port)
{
- assert(sock);
- assert(port);
- assert(sock->sockaddr.type == LTTCOMM_INET ||
+ LTTNG_ASSERT(sock);
+ LTTNG_ASSERT(port);
+ LTTNG_ASSERT(sock->sockaddr.type == LTTCOMM_INET ||
sock->sockaddr.type == LTTCOMM_INET6);
- assert(sock->proto == LTTCOMM_SOCK_TCP ||
+ LTTNG_ASSERT(sock->proto == LTTCOMM_SOCK_TCP ||
sock->proto == LTTCOMM_SOCK_UDP);
switch (sock->sockaddr.type) {
return 0;
}
-LTTNG_HIDDEN
int lttcomm_sock_set_port(struct lttcomm_sock *sock, uint16_t port)
{
- assert(sock);
- assert(sock->sockaddr.type == LTTCOMM_INET ||
+ LTTNG_ASSERT(sock);
+ LTTNG_ASSERT(sock->sockaddr.type == LTTCOMM_INET ||
sock->sockaddr.type == LTTCOMM_INET6);
- assert(sock->proto == LTTCOMM_SOCK_TCP ||
+ LTTNG_ASSERT(sock->proto == LTTCOMM_SOCK_TCP ||
sock->proto == LTTCOMM_SOCK_UDP);
switch (sock->sockaddr.type) {
return 0;
}
-LTTNG_HIDDEN
void lttcomm_init(void)
{
const char *env;
}
}
-LTTNG_HIDDEN
unsigned long lttcomm_get_network_timeout(void)
{
return network_timeout;