src/s1ap/sctp_conn.c

/*
 * Copyright (c) 2003-2018, Great Software Laboratory Pvt. Ltd.
 * Copyright (c) 2017 Intel Corporation
 * Copyright (c) 2019, Infosys Ltd.
 *
 * 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.
 */

#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <netinet/sctp.h>

#include "log.h"
#include "sctp_conn.h"
#define ENB_PORT 62324
#define S1AP_PPID 18
int create_sctp_socket(unsigned int remote_ip, unsigned short port)
{
	int connSock;
	struct sockaddr_in servaddr;
	int ret;

	connSock = socket(AF_INET, SOCK_STREAM, IPPROTO_SCTP);

	if (connSock == -1)
	{
		log_msg(LOG_ERROR, "Socket creation failed\n");
		return -1;
	}

	//TODO: use remote_ip
	bzero ((void *) &servaddr, sizeof (servaddr));
	servaddr.sin_family = AF_INET;
	servaddr.sin_addr.s_addr = htonl(remote_ip);
	//servaddr.sin_addr.s_addr = htonl (INADDR_ANY);
	servaddr.sin_port = htons(port);

	ret = bind(connSock, (struct sockaddr *) &servaddr, sizeof (servaddr));

	if(ret == -1 )
	{
		perror("Bind:");
		log_msg(LOG_ERROR, "Bind failed \n");
		close(connSock);
		return -1;
	}

	/* Specify maximum streams available per socket */
	struct sctp_initmsg initmsg;
	memset (&initmsg, 0, sizeof (initmsg));
	initmsg.sinit_num_ostreams = MAX_STREAM;
	initmsg.sinit_max_instreams = MAX_STREAM;
	initmsg.sinit_max_attempts = 4;
	ret = setsockopt(connSock, IPPROTO_SCTP, SCTP_INITMSG,
			&initmsg, sizeof (initmsg));

	if(ret == -1 )
	{
		log_msg(LOG_ERROR, "setsockopt() failed \n");
		close(connSock);
		return -1;
	}

	ret = listen(connSock, MAX_PENDING_CONN);
	if(ret == -1 )
	{
		log_msg(LOG_ERROR, "listen() failed \n");
		close(connSock);
		return -1;
	}
	return connSock;
}

int accept_sctp_socket(int connSock)
{
	return accept(connSock, (struct sockaddr *) NULL, (socklen_t *) NULL);
}

int recv_sctp_msg(int connSock, unsigned char *buffer, size_t len)
{
    struct sctp_sndrcvinfo sndrcvinfo;
	int flags;
	return sctp_recvmsg(connSock, buffer, len,
			(struct sockaddr *) NULL, 0, &sndrcvinfo, &flags);
}

int send_sctp_msg(int connSock, unsigned char *buffer, size_t len, uint16_t stream_no)
{
	uint32_t ppid = S1AP_PPID;
	return sctp_sendmsg(connSock, (void *)buffer, len,
			NULL, 0, htonl(ppid), 0, stream_no, 0, 0);
}

int close_sctp_socket(int connSock)
{
	return close(connSock);
}