---

recvmsgt.c File Reference

#include "rcs_defs.hh"
#include "recvmsgt.h"
#include "_timer.h"
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/time.h>
#include <unistd.h>
#include <math.h>
#include <errno.h>
#include <string.h>
#include <stdlib.h>
#include "rcs_prnt.hh"
#include "sokintrf.h"
#include "dbg_mem.h"

Include dependency graph for recvmsgt.c:

Go to the source code of this file.

Functions
int	recvmsgt_implementation (int _socket_fd, struct msghdr *_msg_header, int _flags, double _timeout, int print_timeout_errors)
int	recvmsgt (int _socket_fd, struct msghdr *_msg_header, int _flags, double _timeout)
int	recvmsgtq (int _socket_fd, struct msghdr *_msg_header, int _flags, double _timeout)
void	free_recvmsg_collection_buffer ()
Variables
long	total_bytes_read = 0
int	recvmsgt_timed_out = 0

---

Function Documentation

int recvmsgt_implementation (  int    _socket_fd, struct msghdr *    _msg_header, int    _flags, double    _timeout, int    print_timeout_errors )

Definition at line 91 of file recvmsgt.c. { struct timeval timeout_timeval; fd_set read_fd_set; int bytes_read; int recvmsgt_timed_out = 0; #if defined(_Windows) long required_size, bytes_copied, bytes_to_copy; int i = 0; char *temp_pointer; if (_msg_header->msg_iovlen > 1) { for (i = 0, required_size = 0; i < _msg_header->msg_iovlen; i++) { required_size += _msg_header->msg_iov[i].iov_len; } if (required_size > collection_buffer_size) { if (NULL != collection_buffer) { DEBUG_FREE (collection_buffer); collection_buffer = NULL; } collection_buffer = (char *) DEBUG_MALLOC (required_size); collection_buffer_size = required_size; } if (NULL == collection_buffer) { collection_buffer_size = 0; rcs_print_error ("Couldn't malloc collection buffer of size.\n"); return (-1); } } #endif if (etime_disabled) { _timeout = -1.0; } if (_timeout > 1E-6) { timeout_timeval.tv_sec = (long) _timeout; timeout_timeval.tv_usec = (long) (_timeout * 1000000.0); if (timeout_timeval.tv_usec >= 1000000) { timeout_timeval.tv_usec = timeout_timeval.tv_usec % 1000000; } FD_ZERO (&read_fd_set); RCS_FD_SET (_socket_fd, &read_fd_set); switch (dl_select (_socket_fd + 1, &read_fd_set, NULL, NULL, &timeout_timeval)) { case -1: #ifndef UNDER_CE rcs_print_error ("recvmsgt: select error: %d %s\n", errno, strerror (errno)); #endif return -1; case 0: recvmsgt_timed_out = 1; if (print_timeout_errors) { rcs_print_error ("recvmgt: select timed out after %f seconds.\n", _timeout); } return (0); default: break; } } else if (_timeout > -1E-6) { timeout_timeval.tv_sec = (long) 0; timeout_timeval.tv_usec = (long) 0; FD_ZERO (&read_fd_set); RCS_FD_SET (_socket_fd, &read_fd_set); switch (dl_select (_socket_fd + 1, &read_fd_set, NULL, NULL, &timeout_timeval)) { case -1: #ifndef UNDER_CE rcs_print_error ("recvmsgt: select error: %d %s\n", errno, strerror (errno)); #endif return -1; case 0: recvmsgt_timed_out = 1; return (0); default: break; } } #if defined(_Windows) if (_msg_header->msg_iovlen > 1) { bytes_read = dl_recvfrom (_socket_fd, collection_buffer, required_size, _flags, (struct sockaddr *) _msg_header->msg_name, &_msg_header->msg_namelen); if (bytes_read == -1) { #ifdef gnuwin32 rcs_print_error ("recvmsgt: recvfrom error %d:%s\n", errno, strerror (errno)); #else rcs_print_error ("recvmsgt: recvfrom error %d\n", dl_WSAGetLastError ()); #endif return (-1); } for (i = 0, temp_pointer = collection_buffer, bytes_copied = 0; i < _msg_header->msg_iovlen && bytes_copied < bytes_read; i++) { bytes_to_copy = (bytes_read - bytes_copied) < _msg_header->msg_iov[i].iov_len ? bytes_read - bytes_copied : _msg_header->msg_iov[i].iov_len; memcpy (_msg_header->msg_iov[i].iov_base, temp_pointer, bytes_to_copy); temp_pointer += bytes_to_copy; bytes_copied += bytes_to_copy; } } else { bytes_read = dl_recvfrom (_socket_fd, _msg_header->msg_iov[0].iov_base, _msg_header->msg_iov[0].iov_len, _flags, (struct sockaddr *) _msg_header->msg_name, &_msg_header->msg_namelen); if (bytes_read == -1) { #ifdef gnuwin32 rcs_print_error ("recvmsgt: recvfrom error %d:%s\n", errno, strerror (errno)); #else rcs_print_error ("recvmsgt: recvfrom error %d\n", dl_WSAGetLastError ()); #endif return (-1); } } #else bytes_read = recvmsg (_socket_fd, _msg_header, _flags); if (bytes_read < 0) { #ifndef UNDER_CE rcs_print_error ("recvmsg(%d (0x%X), %p, %d (0x%X) error: %d = %s\n", _socket_fd, _socket_fd, _msg_header, _flags, _flags, errno, strerror (errno)); #endif } #endif total_bytes_read += bytes_read; rcs_print_debug (PRINT_SOCKET_READ_SIZE, "recvmsg %d bytes from %d\n", bytes_read, _socket_fd); return (bytes_read); }

int recvmsgt (  int    fd, struct msghdr *    _msg_header, int    _flags, double    _timeout )

Definition at line 75 of file recvmsgt.c. { return (recvmsgt_implementation (_socket_fd, _msg_header, _flags, _timeout, 1)); }

int recvmsgtq (  int    fd, struct msghdr *    _msg_header, int    _flags, double    _timeout )

Definition at line 83 of file recvmsgt.c. { return (recvmsgt_implementation (_socket_fd, _msg_header, _flags, _timeout, 0)); }

void free_recvmsg_collection_buffer (    )

Definition at line 256 of file recvmsgt.c. Referenced by UDPMEM::~UDPMEM(). { #if defined(_Windows) if (NULL != collection_buffer) { DEBUG_FREE (collection_buffer); collection_buffer = NULL; collection_buffer_size = 0; } #endif }

---

Variable Documentation

long total_bytes_read = 0 [static]

Definition at line 61 of file recvmsgt.c.

int recvmsgt_timed_out = 0

Definition at line 68 of file recvmsgt.c.

---