2012-05-14 07:37:49 -07:00
|
|
|
/*
|
|
|
|
|
|
|
|
HELPER.C
|
|
|
|
========
|
|
|
|
(c) Paul Griffiths, 1999
|
|
|
|
Email: mail@paulgriffiths.net
|
|
|
|
|
|
|
|
Implementation of sockets helper functions.
|
|
|
|
|
|
|
|
Many of these functions are adapted from, inspired by, or
|
|
|
|
otherwise shamelessly plagiarised from "Unix Network
|
|
|
|
Programming", W Richard Stevens (Prentice Hall).
|
|
|
|
|
|
|
|
*/
|
|
|
|
|
|
|
|
#include "helper.h"
|
|
|
|
#include <sys/socket.h>
|
|
|
|
#include <unistd.h>
|
|
|
|
#include <errno.h>
|
|
|
|
|
|
|
|
|
2012-05-14 07:38:09 -07:00
|
|
|
size_t
|
2012-05-14 07:38:27 -07:00
|
|
|
compose_packet(void **ptr, client_type c, message_type m, void *data, size_t s)
|
2012-05-14 07:38:09 -07:00
|
|
|
{
|
2012-05-14 07:38:27 -07:00
|
|
|
packet pkt = { c, m, s };
|
|
|
|
size_t size = sizeof(packet) + s;
|
2012-05-14 07:38:09 -07:00
|
|
|
|
|
|
|
void *p = malloc(size);
|
|
|
|
memcpy(p, &pkt, sizeof(packet));
|
2012-05-14 07:38:27 -07:00
|
|
|
if (data)
|
|
|
|
memcpy(p + sizeof(packet), data, s);
|
2012-05-14 07:38:09 -07:00
|
|
|
|
|
|
|
*ptr = p;
|
|
|
|
return size;
|
|
|
|
}
|
|
|
|
|
2012-05-14 07:38:27 -07:00
|
|
|
void *
|
|
|
|
get_packet_data(void *ptr)
|
2012-05-14 07:38:09 -07:00
|
|
|
{
|
|
|
|
packet *pkt = ptr;
|
|
|
|
if (pkt->size)
|
2012-05-14 07:38:27 -07:00
|
|
|
return (ptr + sizeof(packet));
|
2012-05-14 07:38:09 -07:00
|
|
|
|
|
|
|
return NULL;
|
|
|
|
}
|
2012-05-14 07:37:49 -07:00
|
|
|
/* Read a line from a socket */
|
|
|
|
|
|
|
|
ssize_t Readline(int sockd, void *vptr, size_t maxlen) {
|
2012-05-14 07:37:59 -07:00
|
|
|
char *ptr = vptr;
|
|
|
|
ssize_t rc = read(sockd, vptr, maxlen);
|
|
|
|
if (rc >= 0)
|
|
|
|
ptr[rc] = 0; /* We know there is space */
|
|
|
|
else
|
|
|
|
{
|
|
|
|
*ptr = 0; /* ERROR */
|
|
|
|
return 0;
|
|
|
|
}
|
|
|
|
|
|
|
|
return rc;
|
|
|
|
|
|
|
|
#if 0
|
2012-05-14 07:37:49 -07:00
|
|
|
ssize_t n, rc;
|
|
|
|
char c, *buffer;
|
|
|
|
|
|
|
|
buffer = vptr;
|
|
|
|
|
|
|
|
for ( n = 1; n < maxlen; n++ ) {
|
|
|
|
if ( (rc = read(sockd, &c, 1)) == 1 ) {
|
|
|
|
*buffer++ = c;
|
|
|
|
if ( c == '\n' )
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
else if ( rc == 0 ) {
|
|
|
|
if ( n == 1 )
|
|
|
|
return 0;
|
|
|
|
else
|
|
|
|
break;
|
|
|
|
}
|
|
|
|
else {
|
|
|
|
if ( errno == EINTR )
|
|
|
|
continue;
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
*buffer = 0;
|
|
|
|
return n;
|
2012-05-14 07:37:59 -07:00
|
|
|
#endif
|
2012-05-14 07:37:49 -07:00
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/* Write a line to a socket */
|
|
|
|
|
|
|
|
ssize_t Writeline(int sockd, const void *vptr, size_t n) {
|
|
|
|
size_t nleft;
|
|
|
|
ssize_t nwritten;
|
|
|
|
const char *buffer;
|
|
|
|
|
|
|
|
buffer = vptr;
|
|
|
|
nleft = n;
|
|
|
|
|
|
|
|
while ( nleft > 0 ) {
|
|
|
|
if ( (nwritten = write(sockd, buffer, nleft)) <= 0 ) {
|
|
|
|
if ( errno == EINTR )
|
|
|
|
nwritten = 0;
|
|
|
|
else
|
|
|
|
return -1;
|
|
|
|
}
|
|
|
|
nleft -= nwritten;
|
|
|
|
buffer += nwritten;
|
|
|
|
}
|
|
|
|
|
|
|
|
return n;
|
|
|
|
}
|