fwtcp.c revision 1c08b0ec28ca5c600c21c0ab5a53cae73f1c821d
/* -*- indent-tabs-mode: nil; -*- */
#define LOG_GROUP LOG_GROUP_NAT_SERVICE
#include "winutils.h"
#include "proxy.h"
#include "proxy_pollmgr.h"
#include "portfwd.h"
#include "pxtcp.h"
#ifndef RT_OS_WINDOWS
#include <stdio.h>
#include <poll.h>
#include <err.h> /* BSD'ism */
#else
#include <stdio.h>
#include "winpoll.h"
#endif
/**
*/
struct fwtcp {
/**
* Our poll manager handler.
*/
struct pollmgr_handler pmhdl;
/**
* Forwarding specification.
*/
/**
* Listening socket.
*/
/**
* Mailbox for new inbound connections.
*
* XXX: since we have single producer and single consumer we can
* use lockless ringbuf like for pxtcp.
*/
struct tcpip_msg msg_connect;
struct tcpip_msg msg_delete;
/**
* Linked list entry.
*/
};
/* poll manager callback for fwtcp listening socket */
/* lwip thread callbacks called via proxy_lwip_post() */
static void fwtcp_pcb_connect(void *);
static void fwtcp_pcb_delete(void *);
/**
* Linked list of active fwtcp forwarders.
*/
void
fwtcp_init(void)
{
return;
}
void
{
return;
}
/* fwtcp_create has put fwtcp on the linked list */
}
void
{
break;
}
}
return;
}
/* let pending msg_connect be processed before we delete fwtcp */
}
struct fwtcp *
{
int status;
if (lsock == INVALID_SOCKET) {
perror("socket");
return NULL;
}
return NULL;
}
return (NULL);
}
do { \
} while (0)
if (status < 0) {
return NULL;
}
fwtcp_list = fwtcp;
return fwtcp;
}
int
{
struct sockaddr_storage ss;
void *peer_addr;
int status;
if (newsock == INVALID_SOCKET) {
return POLLIN;
}
}
else { /* PF_INET6 */
}
{
char addrbuf[sizeof "ffff:ffff:ffff:ffff:ffff:ffff:255.255.255.255"];
const char *addrstr;
DPRINTF(("<--- TCP %s%s%s:%d\n",
peer_port));
}
#endif /* DPRINTF */
return POLLIN;
}
if (status < 0) {
return POLLIN;
}
return POLLIN;
}
return POLLIN;
}
void
fwtcp_pcb_connect(void *arg)
{
return;
}
if (timo == SYS_MBOX_EMPTY) {
return;
}
/* hand off to pxtcp */
}
static void
fwtcp_pcb_delete(void *arg)
{
void *data;
}