代码拉取完成,页面将自动刷新
同步操作将从 liudengfeng/xkcptun 强制同步,此操作会覆盖自 Fork 仓库以来所做的任何修改,且无法恢复!!!
确定后同步将在后台操作,完成时将刷新页面,请耐心等待。
/********************************************************************\
* This program is free software; you can redistribute it and/or *
* modify it under the terms of the GNU General Public License as *
* published by the Free Software Foundation; either version 2 of *
* the License, or (at your option) any later version. *
* *
* This program is distributed in the hope that it will be useful, *
* but WITHOUT ANY WARRANTY; without even the implied warranty of *
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the *
* GNU General Public License for more details. *
* *
* You should have received a copy of the GNU General Public License*
* along with this program; if not, contact: *
* *
* Free Software Foundation Voice: +1-617-542-5942 *
* 59 Temple Place - Suite 330 Fax: +1-617-542-2652 *
* Boston, MA 02111-1307, USA gnu@gnu.org *
* *
\********************************************************************/
#include <string.h>
#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <errno.h>
#include <syslog.h>
#include <event2/bufferevent.h>
#include <event2/buffer.h>
#include <event2/listener.h>
#include <event2/util.h>
#include "xkcp_util.h"
#include "tcp_proxy.h"
#include "xkcp_client.h"
#include "debug.h"
extern iqueue_head xkcp_task_list;
static void
tcp_proxy_read_cb(struct bufferevent *bev, void *ctx)
{
struct xkcp_task *task = ctx;
ikcpcb *kcp = task->kcp;
xkcp_tcp_read_cb(bev, kcp);
xkcp_forward_all_data(&xkcp_task_list);
}
static void
tcp_proxy_event_cb(struct bufferevent *bev, short what, void *ctx)
{
xkcp_tcp_event_cb(bev, what, ctx);
}
void
tcp_proxy_accept_cb(struct evconnlistener *listener, evutil_socket_t fd,
struct sockaddr *a, int slen, void *param)
{
struct xkcp_proxy_param *p = param;
struct bufferevent *b_in = NULL;
struct event_base *base = evconnlistener_get_base(listener);
b_in = bufferevent_socket_new(base, fd,
BEV_OPT_CLOSE_ON_FREE|BEV_OPT_DEFER_CALLBACKS);
assert(b_in);
static int conv = 1;
ikcpcb *kcp_client = ikcp_create(conv, param);
xkcp_set_config_param(kcp_client);
conv++;
debug(LOG_INFO, "accept new client [%d] in, conv [%d]", fd, conv-1);
struct xkcp_task *task = malloc(sizeof(struct xkcp_task));
assert(task);
task->kcp = kcp_client;
task->bev = b_in;
task->sockaddr = &p->sockaddr;
add_task_tail(task, &xkcp_task_list);
bufferevent_setcb(b_in, tcp_proxy_read_cb, NULL, tcp_proxy_event_cb, task);
bufferevent_enable(b_in, EV_READ | EV_WRITE );
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。