Quelle  recv_pass_attr.c

/*++
/* NAME
/* recv_pass_attr 3
/* SUMMARY
/* predicate if string is all numerical
/* SYNOPSIS
/* #include <listen.h>
/*
/* int recv_pass_attr(fd, attr, timeout, bufsize)
/* int fd;
/* HTABLE **attr;
/* int timeout;
/* ssize_t bufsize;
/* DESCRIPTION
/* recv_pass_attr() receives named attributes over the specified
/* descriptor. The result value is zero for success, -1 for error.
/*
/* Arguments:
/* .IP fd
/* The file descriptor to read from.
/* .IP attr
/* Pointer to attribute list pointer. The target is set to
/* zero on error or when the received attribute list is empty,
/* otherwise it is assigned a pointer to non-empty attribute
/* list.
/* .IP timeout
/* The deadline for receiving all attributes.
/* .IP bufsize
/* The read buffer size. Specify 1 to avoid reading past the
/* end of the attribute list.
/* LICENSE
/* .ad
/* .fi
/* The Secure Mailer license must be distributed with this software.
/* AUTHOR(S)
/* Wietse Venema
/* IBM T.J. Watson Research
/* P.O. Box 704
/* Yorktown Heights, NY 10598, USA
/*
/* Wietse Venema
/* Google, Inc.
/* 111 8th Avenue
/* New York, NY 10011, USA
/*--*/

/* System library. */

#include <sys_defs.h>

/* Utility library. */

#include <iostuff.h>
#include <htable.h>
#include <vstream.h>
#include <attr.h>
#include <mymalloc.h>
#include <listen.h>

/* recv_pass_attr - receive connection attributes */

int     recv_pass_attr(int fd, HTABLE **attr, int timeout, ssize_t bufsize)
{
    VSTREAM *fp;
    int     stream_err;

    /*
     * Set up a temporary VSTREAM to receive the attributes.
     * 
     * XXX We use one-character reads to simplify the implementation.
     */
    fp = vstream_fdopen(fd, O_RDWR);
    vstream_control(fp,
      CA_VSTREAM_CTL_BUFSIZE(bufsize),
      CA_VSTREAM_CTL_TIMEOUT(timeout),
      CA_VSTREAM_CTL_START_DEADLINE,
      CA_VSTREAM_CTL_END);
    stream_err = (attr_scan(fp, ATTR_FLAG_NONE,
       ATTR_TYPE_HASH, *attr = htable_create(1),
       ATTR_TYPE_END) < 0
    || vstream_feof(fp) || vstream_ferror(fp));
    vstream_fdclose(fp);

    /*
     * Error reporting and recovery.
     */
    if (stream_err) {
 htable_free(*attr, myfree);
 *attr = 0;
 return (-1);
    } else {
 if ((*attr)->used == 0) {
     htable_free(*attr, myfree);
     *attr = 0;
 }
 return (0);
    }
}