File: id_query.c

package info (click to toggle)
sident 3.4-3
  • links: PTS
  • area: main
  • in suites: sarge
  • size: 1,864 kB
  • ctags: 706
  • sloc: sh: 7,748; ansic: 6,877; makefile: 233; perl: 147
file content (82 lines) | stat: -rw-r--r-- 2,109 bytes parent folder | download
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
/*  id_query.c,v 1.7 2004/06/17 01:27:40 eagle Exp
**
**  Low-level call to transmit a query to an ident server.
**
**  Written by Peter Eriksson <pen@lysator.liu.se>
*/

#include "config.h"

#include <errno.h>
#include <signal.h>
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
#include <sys/time.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <unistd.h>

#ifdef HAVE_SYS_SELECT_H
# include <sys/select.h>
#endif

#include "sident.h"


/*
**  Sends off a query to a remote ident server.  resp_port and req_port are
**  sent to the server to identify the connection for which identification is
**  needed.  timeout is given as for id_open.  auth_data specifies the
**  authentication protocol to use.
**
**  Returns the number of bytes sent to the remote server on success, -1 onq
**  failure.  On failure, errno is set.
*/
int
id_query(ident_t *id, int resp_port, int req_port, struct timeval *timeout,
         struct ident_auth_client_data *auth_data)
{
    RETSIGTYPE (*old_sig)(int);
    int res;
    char buf[IDENT_BUFFER_SIZE];
    fd_set ws;

    if (auth_data != NULL) {
        char *start_data;

        auth_data->requester_port = req_port;
        auth_data->responder_port = resp_port;
        auth_data->fd = id->fd;
        auth_data->timeout = timeout;
        start_data = (*auth_data->auth_struct->start)(auth_data);
        if (start_data == NULL) {
            errno = EINVAL;     /* Arbitrary */
            return -1;
        }
        sprintf(buf, "%d , %d : AUTHENTICATE : %s\r\n", resp_port, req_port,
                start_data);
    } else
        sprintf(buf, "%d , %d\r\n", resp_port, req_port);

#ifdef DEBUG
    printf("Sending.. \n%s",buf) ;
#endif

    if (timeout) {
        FD_ZERO(&ws);
        FD_SET(id->fd, &ws);
        res = select(FD_SETSIZE, NULL, &ws, NULL, timeout);
        if (res < 0)
            return -1;
        else if (res == 0) {
            errno = ETIMEDOUT;
            return -1;
        }
    }
    old_sig = signal(SIGPIPE, SIG_IGN);
    res = write(id->fd, buf, strlen(buf));
    signal(SIGPIPE, old_sig);

    return res;
}