File: relay-filter.c

package info (click to toggle)
ucspi-proxy 0.95-1
  • links: PTS
  • area: main
  • in suites: woody
  • size: 148 kB
  • ctags: 173
  • sloc: ansic: 1,024; makefile: 94; sh: 58
file content (71 lines) | stat: -rw-r--r-- 1,711 bytes parent folder | download | duplicates (2)
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
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <unistd.h>
#include "ucspi-proxy.h"

static unsigned relay_rerun_delay;
static const char* client_ip;
static char** relay_command;

static void run_relay_ctrl(void)
{
  /* Run relay-ctrl-allow to allow the client's IP to relay */
  pid_t pid = fork();
  switch(pid) {
  case -1:
    return;
  case 0:
    setenv("TCPREMOTEIP", client_ip, 1);
    execvp(relay_command[0], relay_command);
    exit(1);
  default:
    waitpid(pid, 0, 0);
  }
}

static void catch_alarm(int ignored)
{
  /* Run the relay-ctrl process, and then set it up to re-run */
  fprintf(stderr, "%s: Running relay-ctrl-allow\n", filter_name);
  run_relay_ctrl();
  signal(SIGALRM, catch_alarm);
  alarm(relay_rerun_delay);
}

void relay_init(int argc, char** argv)
{
  char* tmp;
  if(argc < 3)
    usage("Incorrect usage.");
  client_ip = argv[0];
  relay_rerun_delay = strtoul(argv[1], &tmp, 10);
  if(!relay_rerun_delay || *tmp)
    usage("Delay parameter is not a positive number");
  relay_command = argv+2;
}

void accept_client(const char* username)
{
  if (username)
    fprintf(stderr, "%s: Accepted relay client %s, username '%s'\n",
	    filter_name, client_ip, username);
  else
    fprintf(stderr, "%s: Accepted relay client %s, unknown username\n",
	    filter_name, client_ip);
  
  /* Turn off all further filtering, as this IP has already authenticated */
  del_filter(CLIENT_IN);
  del_filter(SERVER_IN);
  add_filter(CLIENT_IN, write_server, 0);
  add_filter(SERVER_IN, write_client, 0);

  catch_alarm(0);
}

void deny_client(void)
{
  fprintf(stderr, "%s: Failed login from %s\n", filter_name, client_ip);
}