From: simon Date: Sun, 12 Jan 2003 15:26:10 +0000 (+0000) Subject: proxy.c now no longer refers to `cfg'. Instead, each of the three X-Git-Url: https://git.distorted.org.uk/u/mdw/putty/commitdiff_plain/e8fa8f62da443bfc89c416d3eeafcde69c8c6403 proxy.c now no longer refers to `cfg'. Instead, each of the three proxy-indirection network functions (name_lookup, new_connection, new_listener) takes a `const Config *' as an argument, and extracts enough information from it before returning to handle that particular network operation in accordance with the proxy settings it specifies. This involved {win,ux}net.c due to a `const' repercussion. git-svn-id: svn://svn.tartarus.org/sgt/putty@2567 cda61777-01e9-0310-a592-d414129be87e --- diff --git a/network.h b/network.h index 673831fb..657bdcb2 100644 --- a/network.h +++ b/network.h @@ -13,6 +13,13 @@ #ifndef PUTTY_NETWORK_H #define PUTTY_NETWORK_H +#ifndef DONE_TYPEDEFS +#define DONE_TYPEDEFS +typedef struct config_tag Config; +typedef struct backend_tag Backend; +typedef struct terminal_tag Terminal; +#endif + typedef struct SockAddr_tag *SockAddr; /* pay attention to levels of indirection */ typedef struct socket_function_table **Socket; @@ -66,17 +73,20 @@ struct plug_function_table { /* proxy indirection layer */ Socket new_connection(SockAddr addr, char *hostname, int port, int privport, - int oobinline, int nodelay, Plug plug); -Socket new_listener(char *srcaddr, int port, Plug plug, int local_host_only); -SockAddr name_lookup(char *host, int port, char **canonicalname); + int oobinline, int nodelay, Plug plug, + const Config *cfg); +Socket new_listener(char *srcaddr, int port, Plug plug, int local_host_only, + const Config *cfg); +SockAddr name_lookup(char *host, int port, char **canonicalname, + const Config *cfg); /* socket functions */ void sk_init(void); /* called once at program startup */ void sk_cleanup(void); /* called just before program exit */ -SockAddr sk_namelookup(char *host, char **canonicalname); -SockAddr sk_nonamelookup(char *host); +SockAddr sk_namelookup(const char *host, char **canonicalname); +SockAddr sk_nonamelookup(const char *host); void sk_getaddr(SockAddr addr, char *buf, int buflen); int sk_hostname_is_local(char *name); int sk_address_is_local(SockAddr addr); diff --git a/portfwd.c b/portfwd.c index 010838ea..e1499de9 100644 --- a/portfwd.c +++ b/portfwd.c @@ -108,7 +108,8 @@ static void pfd_sent(Plug plug, int bufsize) /* * Called when receiving a PORT OPEN from the server */ -char *pfd_newconnect(Socket *s, char *hostname, int port, void *c) +char *pfd_newconnect(Socket *s, char *hostname, int port, void *c, + const Config *cfg) { static struct plug_function_table fn_table = { pfd_closing, @@ -124,7 +125,7 @@ char *pfd_newconnect(Socket *s, char *hostname, int port, void *c) /* * Try to find host. */ - addr = name_lookup(hostname, port, &dummy_realhost); + addr = name_lookup(hostname, port, &dummy_realhost, cfg); if ((err = sk_addr_error(addr)) != NULL) return err; @@ -138,7 +139,8 @@ char *pfd_newconnect(Socket *s, char *hostname, int port, void *c) pr->c = c; pr->backhandle = NULL; /* we shouldn't need this */ - pr->s = *s = new_connection(addr, dummy_realhost, port, 0, 1, 0, (Plug) pr); + pr->s = *s = new_connection(addr, dummy_realhost, port, + 0, 1, 0, (Plug) pr, cfg); if ((err = sk_socket_error(*s)) != NULL) { sfree(pr); return err; @@ -204,7 +206,7 @@ static int pfd_accepting(Plug p, void *sock) sets up a listener on the local machine on (srcaddr:)port */ char *pfd_addforward(char *desthost, int destport, char *srcaddr, int port, - void *backhandle, int acceptall) + void *backhandle, const Config *cfg) { static struct plug_function_table fn_table = { pfd_closing, @@ -230,7 +232,8 @@ char *pfd_addforward(char *desthost, int destport, char *srcaddr, int port, pr->waiting = NULL; pr->backhandle = backhandle; - pr->s = s = new_listener(srcaddr, port, (Plug) pr, !acceptall); + pr->s = s = new_listener(srcaddr, port, (Plug) pr, + !cfg->lport_acceptall, cfg); if ((err = sk_socket_error(s)) != NULL) { sfree(pr); return err; diff --git a/proxy.c b/proxy.c index a4847b9a..be238c34 100644 --- a/proxy.c +++ b/proxy.c @@ -14,9 +14,9 @@ #include "network.h" #include "proxy.h" -#define do_proxy_dns \ - (cfg.proxy_dns == 2 || \ - (cfg.proxy_dns == 1 && cfg.proxy_type != PROXY_SOCKS)) +#define do_proxy_dns(cfg) \ + (cfg->proxy_dns == 2 || \ + (cfg->proxy_dns == 1 && cfg->proxy_type != PROXY_SOCKS)) /* * Call this when proxy negotiation is complete, so that this @@ -248,18 +248,19 @@ static int plug_proxy_accepting (Plug p, void *sock) * This function can accept a NULL pointer as `addr', in which case * it will only check the host name. */ -static int proxy_for_destination (SockAddr addr, char * hostname, int port) +static int proxy_for_destination (SockAddr addr, char *hostname, int port, + const Config *cfg) { int s = 0, e = 0; char hostip[64]; int hostip_len, hostname_len; - char * exclude_list; + const char *exclude_list; /* * Check the host name and IP against the hard-coded * representations of `localhost'. */ - if (!cfg.even_proxy_localhost && + if (!cfg->even_proxy_localhost && (sk_hostname_is_local(hostname) || (addr && sk_address_is_local(addr)))) return 0; /* do not proxy */ @@ -272,7 +273,7 @@ static int proxy_for_destination (SockAddr addr, char * hostname, int port) hostname_len = strlen(hostname); - exclude_list = cfg.proxy_exclude_list; + exclude_list = cfg->proxy_exclude_list; /* now parse the exclude list, and see if either our IP * or hostname matches anything in it. @@ -332,10 +333,12 @@ static int proxy_for_destination (SockAddr addr, char * hostname, int port) return 1; } -SockAddr name_lookup(char *host, int port, char **canonicalname) +SockAddr name_lookup(char *host, int port, char **canonicalname, + const Config *cfg) { - if (cfg.proxy_type != PROXY_NONE && - do_proxy_dns && proxy_for_destination(NULL, host, port)) { + if (cfg->proxy_type != PROXY_NONE && + do_proxy_dns(cfg) && + proxy_for_destination(NULL, host, port, cfg)) { *canonicalname = dupstr(host); return sk_nonamelookup(host); } @@ -345,7 +348,8 @@ SockAddr name_lookup(char *host, int port, char **canonicalname) Socket new_connection(SockAddr addr, char *hostname, int port, int privport, - int oobinline, int nodelay, Plug plug) + int oobinline, int nodelay, Plug plug, + const Config *cfg) { static const struct socket_function_table socket_fn_table = { sk_proxy_plug, @@ -366,8 +370,8 @@ Socket new_connection(SockAddr addr, char *hostname, plug_proxy_accepting }; - if (cfg.proxy_type != PROXY_NONE && - proxy_for_destination(addr, hostname, port)) + if (cfg->proxy_type != PROXY_NONE && + proxy_for_destination(addr, hostname, port, cfg)) { Proxy_Socket ret; Proxy_Plug pplug; @@ -376,6 +380,7 @@ Socket new_connection(SockAddr addr, char *hostname, ret = smalloc(sizeof(struct Socket_proxy_tag)); ret->fn = &socket_fn_table; + ret->cfg = *cfg; /* STRUCTURE COPY */ ret->plug = plug; ret->remote_addr = addr; ret->remote_port = port; @@ -392,14 +397,14 @@ Socket new_connection(SockAddr addr, char *hostname, ret->state = PROXY_STATE_NEW; ret->negotiate = NULL; - if (cfg.proxy_type == PROXY_HTTP) { + if (cfg->proxy_type == PROXY_HTTP) { ret->negotiate = proxy_http_negotiate; - } else if (cfg.proxy_type == PROXY_SOCKS) { - if (cfg.proxy_socks_version == 4) + } else if (cfg->proxy_type == PROXY_SOCKS) { + if (cfg->proxy_socks_version == 4) ret->negotiate = proxy_socks4_negotiate; else ret->negotiate = proxy_socks5_negotiate; - } else if (cfg.proxy_type == PROXY_TELNET) { + } else if (cfg->proxy_type == PROXY_TELNET) { ret->negotiate = proxy_telnet_negotiate; } else { ret->error = "Proxy error: Unknown proxy method"; @@ -413,7 +418,7 @@ Socket new_connection(SockAddr addr, char *hostname, pplug->proxy_socket = ret; /* look-up proxy */ - proxy_addr = sk_namelookup(cfg.proxy_host, + proxy_addr = sk_namelookup(cfg->proxy_host, &proxy_canonical_name); if ((err = sk_addr_error(proxy_addr)) != NULL) { ret->error = "Proxy error: Unable to resolve proxy host name"; @@ -424,7 +429,7 @@ Socket new_connection(SockAddr addr, char *hostname, /* create the actual socket we will be using, * connected to our proxy server and port. */ - ret->sub_socket = sk_new(proxy_addr, cfg.proxy_port, + ret->sub_socket = sk_new(proxy_addr, cfg->proxy_port, privport, oobinline, nodelay, (Plug) pplug); if (sk_socket_error(ret->sub_socket) != NULL) @@ -443,7 +448,8 @@ Socket new_connection(SockAddr addr, char *hostname, return sk_new(addr, port, privport, oobinline, nodelay, plug); } -Socket new_listener(char *srcaddr, int port, Plug plug, int local_host_only) +Socket new_listener(char *srcaddr, int port, Plug plug, int local_host_only, + const Config *cfg) { /* TODO: SOCKS (and potentially others) support inbound * TODO: connections via the proxy. support them. @@ -507,11 +513,11 @@ int proxy_http_negotiate (Proxy_Socket p, int change) sk_write(p->sub_socket, buf, strlen(buf)); sfree(buf); - if (cfg.proxy_username[0] || cfg.proxy_password[0]) { - char buf[sizeof(cfg.proxy_username)+sizeof(cfg.proxy_password)]; + if (p->cfg.proxy_username[0] || p->cfg.proxy_password[0]) { + char buf[sizeof(p->cfg.proxy_username)+sizeof(p->cfg.proxy_password)]; char buf2[sizeof(buf)*4/3 + 100]; int i, j, len; - sprintf(buf, "%s:%s", cfg.proxy_username, cfg.proxy_password); + sprintf(buf, "%s:%s", p->cfg.proxy_username, p->cfg.proxy_password); len = strlen(buf); sprintf(buf2, "Proxy-Authorization: basic "); for (i = 0, j = strlen(buf2); i < len; i += 3, j += 4) @@ -695,9 +701,9 @@ int proxy_socks4_negotiate (Proxy_Socket p, int change) addr[3] = 1; } - length = strlen(cfg.proxy_username) + namelen + 9; + length = strlen(p->cfg.proxy_username) + namelen + 9; command = (char*) smalloc(length); - strcpy(command + 8, cfg.proxy_username); + strcpy(command + 8, p->cfg.proxy_username); command[0] = 4; /* version 4 */ command[1] = 1; /* CONNECT command */ @@ -710,7 +716,7 @@ int proxy_socks4_negotiate (Proxy_Socket p, int change) memcpy(command + 4, addr, 4); /* hostname */ - memcpy(command + 8 + strlen(cfg.proxy_username) + 1, + memcpy(command + 8 + strlen(p->cfg.proxy_username) + 1, hostname, namelen); sk_write(p->sub_socket, command, length); @@ -838,7 +844,7 @@ int proxy_socks5_negotiate (Proxy_Socket p, int change) int len; command[0] = 5; /* version 5 */ - if (cfg.proxy_username[0] || cfg.proxy_password[0]) { + if (p->cfg.proxy_username[0] || p->cfg.proxy_password[0]) { command[1] = 2; /* two methods supported: */ command[2] = 0x00; /* no authentication */ command[3] = 0x02; /* username/password */ @@ -1107,18 +1113,18 @@ int proxy_socks5_negotiate (Proxy_Socket p, int change) } if (p->state == 5) { - if (cfg.proxy_username[0] || cfg.proxy_password[0]) { + if (p->cfg.proxy_username[0] || p->cfg.proxy_password[0]) { char userpwbuf[514]; int ulen, plen; - ulen = strlen(cfg.proxy_username); + ulen = strlen(p->cfg.proxy_username); if (ulen > 255) ulen = 255; if (ulen < 1) ulen = 1; - plen = strlen(cfg.proxy_password); + plen = strlen(p->cfg.proxy_password); if (plen > 255) plen = 255; if (plen < 1) plen = 1; userpwbuf[0] = 1; /* version number of subnegotiation */ userpwbuf[1] = ulen; - memcpy(userpwbuf+2, cfg.proxy_username, ulen); + memcpy(userpwbuf+2, p->cfg.proxy_username, ulen); userpwbuf[ulen+2] = plen; - memcpy(userpwbuf+ulen+3, cfg.proxy_password, plen); + memcpy(userpwbuf+ulen+3, p->cfg.proxy_password, plen); sk_write(p->sub_socket, userpwbuf, ulen + plen + 3); p->state = 7; } else @@ -1162,37 +1168,37 @@ int proxy_telnet_negotiate (Proxy_Socket p, int change) * %%, %host, %port, %user, and %pass */ - while (cfg.proxy_telnet_command[eo] != 0) { + while (p->cfg.proxy_telnet_command[eo] != 0) { /* scan forward until we hit end-of-line, * or an escape character (\ or %) */ - while (cfg.proxy_telnet_command[eo] != 0 && - cfg.proxy_telnet_command[eo] != '%' && - cfg.proxy_telnet_command[eo] != '\\') eo++; + while (p->cfg.proxy_telnet_command[eo] != 0 && + p->cfg.proxy_telnet_command[eo] != '%' && + p->cfg.proxy_telnet_command[eo] != '\\') eo++; /* if we hit eol, break out of our escaping loop */ - if (cfg.proxy_telnet_command[eo] == 0) break; + if (p->cfg.proxy_telnet_command[eo] == 0) break; /* if there was any unescaped text before the escape * character, send that now */ if (eo != so) { sk_write(p->sub_socket, - cfg.proxy_telnet_command + so, eo - so); + p->cfg.proxy_telnet_command + so, eo - so); } so = eo++; /* if the escape character was the last character of * the line, we'll just stop and send it. */ - if (cfg.proxy_telnet_command[eo] == 0) break; + if (p->cfg.proxy_telnet_command[eo] == 0) break; - if (cfg.proxy_telnet_command[so] == '\\') { + if (p->cfg.proxy_telnet_command[so] == '\\') { /* we recognize \\, \%, \r, \n, \t, \x??. * anything else, we just send unescaped (including the \). */ - switch (cfg.proxy_telnet_command[eo]) { + switch (p->cfg.proxy_telnet_command[eo]) { case '\\': sk_write(p->sub_socket, "\\", 1); @@ -1228,15 +1234,15 @@ int proxy_telnet_negotiate (Proxy_Socket p, int change) for (;;) { eo++; - if (cfg.proxy_telnet_command[eo] >= '0' && - cfg.proxy_telnet_command[eo] <= '9') - v += cfg.proxy_telnet_command[eo] - '0'; - else if (cfg.proxy_telnet_command[eo] >= 'a' && - cfg.proxy_telnet_command[eo] <= 'f') - v += cfg.proxy_telnet_command[eo] - 'a' + 10; - else if (cfg.proxy_telnet_command[eo] >= 'A' && - cfg.proxy_telnet_command[eo] <= 'F') - v += cfg.proxy_telnet_command[eo] - 'A' + 10; + if (p->cfg.proxy_telnet_command[eo] >= '0' && + p->cfg.proxy_telnet_command[eo] <= '9') + v += p->cfg.proxy_telnet_command[eo] - '0'; + else if (p->cfg.proxy_telnet_command[eo] >= 'a' && + p->cfg.proxy_telnet_command[eo] <= 'f') + v += p->cfg.proxy_telnet_command[eo] - 'a' + 10; + else if (p->cfg.proxy_telnet_command[eo] >= 'A' && + p->cfg.proxy_telnet_command[eo] <= 'F') + v += p->cfg.proxy_telnet_command[eo] - 'A' + 10; else { /* non hex character, so we abort and just * send the whole thing unescaped (including \x) @@ -1261,7 +1267,7 @@ int proxy_telnet_negotiate (Proxy_Socket p, int change) default: sk_write(p->sub_socket, - cfg.proxy_telnet_command + so, 2); + p->cfg.proxy_telnet_command + so, 2); eo++; break; } @@ -1271,34 +1277,34 @@ int proxy_telnet_negotiate (Proxy_Socket p, int change) * anything else, we just send unescaped (including the %). */ - if (cfg.proxy_telnet_command[eo] == '%') { + if (p->cfg.proxy_telnet_command[eo] == '%') { sk_write(p->sub_socket, "%", 1); eo++; } - else if (strnicmp(cfg.proxy_telnet_command + eo, + else if (strnicmp(p->cfg.proxy_telnet_command + eo, "host", 4) == 0) { char dest[512]; sk_getaddr(p->remote_addr, dest, lenof(dest)); sk_write(p->sub_socket, dest, strlen(dest)); eo += 4; } - else if (strnicmp(cfg.proxy_telnet_command + eo, + else if (strnicmp(p->cfg.proxy_telnet_command + eo, "port", 4) == 0) { char port[8]; sprintf(port, "%i", p->remote_port); sk_write(p->sub_socket, port, strlen(port)); eo += 4; } - else if (strnicmp(cfg.proxy_telnet_command + eo, + else if (strnicmp(p->cfg.proxy_telnet_command + eo, "user", 4) == 0) { - sk_write(p->sub_socket, cfg.proxy_username, - strlen(cfg.proxy_username)); + sk_write(p->sub_socket, p->cfg.proxy_username, + strlen(p->cfg.proxy_username)); eo += 4; } - else if (strnicmp(cfg.proxy_telnet_command + eo, + else if (strnicmp(p->cfg.proxy_telnet_command + eo, "pass", 4) == 0) { - sk_write(p->sub_socket, cfg.proxy_password, - strlen(cfg.proxy_password)); + sk_write(p->sub_socket, p->cfg.proxy_password, + strlen(p->cfg.proxy_password)); eo += 4; } else { @@ -1316,7 +1322,7 @@ int proxy_telnet_negotiate (Proxy_Socket p, int change) /* if there is any unescaped text at the end of the line, send it */ if (eo != so) { - sk_write(p->sub_socket, cfg.proxy_telnet_command + so, eo - so); + sk_write(p->sub_socket, p->cfg.proxy_telnet_command + so, eo - so); } p->state = 1; diff --git a/proxy.h b/proxy.h index c79759c4..cc11061e 100644 --- a/proxy.h +++ b/proxy.h @@ -79,6 +79,8 @@ struct Socket_proxy_tag { /* accepting */ void *accepting_sock; + /* configuration, used to look up proxy settings */ + Config cfg; }; typedef struct Plug_proxy_tag * Proxy_Plug; diff --git a/raw.c b/raw.c index 09903338..94ff43f1 100644 --- a/raw.c +++ b/raw.c @@ -96,7 +96,7 @@ static char *raw_init(void *frontend_handle, void **backend_handle, logevent(raw->frontend, buf); sfree(buf); } - addr = name_lookup(host, port, realhost); + addr = name_lookup(host, port, realhost, cfg); if ((err = sk_addr_error(addr)) != NULL) return err; @@ -113,7 +113,8 @@ static char *raw_init(void *frontend_handle, void **backend_handle, logevent(raw->frontend, buf); sfree(buf); } - raw->s = new_connection(addr, *realhost, port, 0, 1, nodelay, (Plug) raw); + raw->s = new_connection(addr, *realhost, port, 0, 1, nodelay, + (Plug) raw, cfg); if ((err = sk_socket_error(raw->s)) != NULL) return err; diff --git a/rlogin.c b/rlogin.c index afc3d2c3..8e5e6284 100644 --- a/rlogin.c +++ b/rlogin.c @@ -127,7 +127,7 @@ static char *rlogin_init(void *frontend_handle, void **backend_handle, logevent(rlogin->frontend, buf); sfree(buf); } - addr = name_lookup(host, port, realhost); + addr = name_lookup(host, port, realhost, cfg); if ((err = sk_addr_error(addr)) != NULL) return err; @@ -145,7 +145,7 @@ static char *rlogin_init(void *frontend_handle, void **backend_handle, sfree(buf); } rlogin->s = new_connection(addr, *realhost, port, 1, 0, - nodelay, (Plug) rlogin); + nodelay, (Plug) rlogin, cfg); if ((err = sk_socket_error(rlogin->s)) != NULL) return err; diff --git a/ssh.c b/ssh.c index dde5bfab..1b2e7e12 100644 --- a/ssh.c +++ b/ssh.c @@ -2055,7 +2055,7 @@ static char *connect_to_host(Ssh ssh, char *host, int port, * Try to find host. */ logeventf(ssh, "Looking up host \"%s\"", host); - addr = name_lookup(host, port, realhost); + addr = name_lookup(host, port, realhost, &ssh->cfg); if ((err = sk_addr_error(addr)) != NULL) return err; @@ -2068,7 +2068,8 @@ static char *connect_to_host(Ssh ssh, char *host, int port, logeventf(ssh, "Connecting to %s port %d", addrbuf, port); } ssh->fn = &fn_table; - ssh->s = new_connection(addr, *realhost, port, 0, 1, nodelay, (Plug) ssh); + ssh->s = new_connection(addr, *realhost, port, + 0, 1, nodelay, (Plug) ssh, &ssh->cfg); if ((err = sk_socket_error(ssh->s)) != NULL) { ssh->s = NULL; return err; @@ -3121,7 +3122,7 @@ static void ssh1_protocol(Ssh ssh, unsigned char *in, int inlen, int ispkt) if (sport && dport) { if (type == 'L') { pfd_addforward(host, dport, *saddr ? saddr : NULL, - sport, ssh, ssh->cfg.lport_acceptall); + sport, ssh, &ssh->cfg); logeventf(ssh, "Local port %.*s%.*s%.*s%.*s%d%.*s" " forwarding to %s:%.*s%.*s%d%.*s", (int)(*saddr?strlen(saddr):0), *saddr?saddr:NULL, @@ -3285,7 +3286,7 @@ static void ssh1_protocol(Ssh ssh, unsigned char *in, int inlen, int ispkt) c->ssh = ssh; if (x11_init(&c->u.x11.s, ssh->cfg.x11_display, c, - ssh->x11auth, NULL, -1) != NULL) { + ssh->x11auth, NULL, -1, &ssh->cfg) != NULL) { logevent("opening X11 forward connection failed"); sfree(c); send_packet(ssh, SSH1_MSG_CHANNEL_OPEN_FAILURE, @@ -3363,7 +3364,7 @@ static void ssh1_protocol(Ssh ssh, unsigned char *in, int inlen, int ispkt) sprintf(buf, "Received remote port open request for %s:%d", host, port); logevent(buf); - e = pfd_newconnect(&c->u.pfd.s, host, port, c); + e = pfd_newconnect(&c->u.pfd.s, host, port, c, &ssh->cfg); if (e != NULL) { char buf[256]; sprintf(buf, "Port open failed: %s", e); @@ -5185,7 +5186,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt) if (sport && dport) { if (type == 'L') { pfd_addforward(host, dport, *saddr ? saddr : NULL, - sport, ssh, ssh->cfg.lport_acceptall); + sport, ssh, &ssh->cfg); logeventf(ssh, "Local port %.*s%.*s%.*s%.*s%d%.*s" " forwarding to %s:%.*s%.*s%d%.*s", (int)(*saddr?strlen(saddr):0), *saddr?saddr:NULL, @@ -5746,7 +5747,8 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt) if (!ssh->X11_fwd_enabled) error = "X11 forwarding is not enabled"; else if (x11_init(&c->u.x11.s, ssh->cfg.x11_display, c, - ssh->x11auth, addrstr, port) != NULL) { + ssh->x11auth, addrstr, port, + &ssh->cfg) != NULL) { error = "Unable to open an X11 connection"; } else { c->type = CHAN_X11; @@ -5765,7 +5767,7 @@ static void do_ssh2_authconn(Ssh ssh, unsigned char *in, int inlen, int ispkt) error = "Remote port is not recognised"; } else { char *e = pfd_newconnect(&c->u.pfd.s, realpf->dhost, - realpf->dport, c); + realpf->dport, c, &ssh->cfg); logeventf(ssh, "Received remote port open request" " for %s:%d", realpf->dhost, realpf->dport); if (e != NULL) { diff --git a/ssh.h b/ssh.h index 56f9f261..29c3c40a 100644 --- a/ssh.h +++ b/ssh.h @@ -256,9 +256,10 @@ void *new_sock_channel(void *handle, Socket s); void ssh_send_port_open(void *channel, char *hostname, int port, char *org); /* Exports from portfwd.c */ -extern char *pfd_newconnect(Socket * s, char *hostname, int port, void *c); +extern char *pfd_newconnect(Socket * s, char *hostname, int port, void *c, + const Config *cfg); extern char *pfd_addforward(char *desthost, int destport, char *srcaddr, - int port, void *backhandle, int acceptall); + int port, void *backhandle, const Config *cfg); extern void pfd_close(Socket s); extern int pfd_send(Socket s, char *data, int len); extern void pfd_confirm(Socket s); @@ -266,7 +267,8 @@ extern void pfd_unthrottle(Socket s); extern void pfd_override_throttle(Socket s, int enable); /* Exports from x11fwd.c */ -extern char *x11_init(Socket *, char *, void *, void *, const char *, int); +extern char *x11_init(Socket *, char *, void *, void *, const char *, int, + const Config *); extern void x11_close(Socket); extern int x11_send(Socket, char *, int); extern void *x11_invent_auth(char *, int, char *, int, int); diff --git a/telnet.c b/telnet.c index 2d87b310..53ad1804 100644 --- a/telnet.c +++ b/telnet.c @@ -689,7 +689,7 @@ static char *telnet_init(void *frontend_handle, void **backend_handle, logevent(telnet->frontend, buf); sfree(buf); } - addr = name_lookup(host, port, realhost); + addr = name_lookup(host, port, realhost, &telnet->cfg); if ((err = sk_addr_error(addr)) != NULL) return err; @@ -707,7 +707,7 @@ static char *telnet_init(void *frontend_handle, void **backend_handle, sfree(buf); } telnet->s = new_connection(addr, *realhost, port, 0, 1, - nodelay, (Plug) telnet); + nodelay, (Plug) telnet, &telnet->cfg); if ((err = sk_socket_error(telnet->s)) != NULL) return err; diff --git a/unix/uxnet.c b/unix/uxnet.c index 6b8729e3..08da8f42 100644 --- a/unix/uxnet.c +++ b/unix/uxnet.c @@ -117,7 +117,7 @@ char *error_string(int error) return strerror(error); } -SockAddr sk_namelookup(char *host, char **canonicalname) +SockAddr sk_namelookup(const char *host, char **canonicalname) { SockAddr ret = smalloc(sizeof(struct SockAddr_tag)); unsigned long a; @@ -200,7 +200,7 @@ SockAddr sk_namelookup(char *host, char **canonicalname) return ret; } -SockAddr sk_nonamelookup(char *host) +SockAddr sk_nonamelookup(const char *host) { SockAddr ret = smalloc(sizeof(struct SockAddr_tag)); ret->error = NULL; diff --git a/winnet.c b/winnet.c index f2e84548..56d1500f 100644 --- a/winnet.c +++ b/winnet.c @@ -224,7 +224,7 @@ char *winsock_error_string(int error) } } -SockAddr sk_namelookup(char *host, char **canonicalname) +SockAddr sk_namelookup(const char *host, char **canonicalname) { SockAddr ret = smalloc(sizeof(struct SockAddr_tag)); unsigned long a; @@ -362,7 +362,7 @@ SockAddr sk_namelookup(char *host, char **canonicalname) return ret; } -SockAddr sk_nonamelookup(char *host) +SockAddr sk_nonamelookup(const char *host) { SockAddr ret = smalloc(sizeof(struct SockAddr_tag)); ret->error = NULL; diff --git a/x11fwd.c b/x11fwd.c index 135c0347..52e678b3 100644 --- a/x11fwd.c +++ b/x11fwd.c @@ -227,7 +227,7 @@ int x11_get_screen_number(char *display) * also, fills the SocketsStructure */ char *x11_init(Socket * s, char *display, void *c, void *auth, - const char *peeraddr, int peerport) + const char *peeraddr, int peerport, const Config *cfg) { static const struct plug_function_table fn_table = { x11_closing, @@ -269,7 +269,7 @@ char *x11_init(Socket * s, char *display, void *c, void *auth, /* * Try to find host. */ - addr = name_lookup(host, port, &dummy_realhost); + addr = name_lookup(host, port, &dummy_realhost, cfg); if ((err = sk_addr_error(addr)) != NULL) return err; @@ -285,7 +285,8 @@ char *x11_init(Socket * s, char *display, void *c, void *auth, pr->throttled = pr->throttle_override = 0; pr->c = c; - pr->s = *s = new_connection(addr, dummy_realhost, port, 0, 1, 0, (Plug) pr); + pr->s = *s = new_connection(addr, dummy_realhost, port, + 0, 1, 0, (Plug) pr, cfg); if ((err = sk_socket_error(*s)) != NULL) { sfree(pr); return err;