breeze/workflow
1
0
Fork 0
mirror of https://github.com/sogou/workflow.git synced 2026-02-08 01:33:17 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix typo

Browse Source
This commit is contained in:
Xie Han
2024-02-22 21:06:29 +08:00
parent 37a3aec078
commit afc0ac61ac
3 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/kernel_win/Communicator.cc
View File

@@ -644,7 +644,7 @@ int Communicator::bind(CommService *service)
service->ref = 1;
for (i = 0; i < this->handler_threads; i++)
{
auto *new_ctx = new AcceptConext(service);
auto *new_ctx = new AcceptContext(service);
data.operation = PD_OP_ACCEPT;
data.handle = (HANDLE)listen_sockfd;
@@ -1613,7 +1613,7 @@ void Communicator::handle_connect_result(struct poller_result *res)
void Communicator::handle_accept_result(struct poller_result *res)
{
AcceptConext *ctx = (AcceptConext *)res->data.context;
AcceptContext *ctx = (AcceptContext *)res->data.context;
CommService *service = (CommService *)ctx->service;
SOCKET sockfd = ctx->accept_sockfd;
CommConnEntry *entry;

4
src/kernel_win/WinPoller.cc
View File

@@ -240,7 +240,7 @@ int WinPoller::cancel_pending_io(HANDLE handle) const
static int __accept_io(IOCPData *iocp_data, int timeout)
{
AcceptConext *ctx = (AcceptConext *)iocp_data->data.context;
AcceptContext *ctx = (AcceptContext *)iocp_data->data.context;
DWORD dwBytes;
BOOL ret = AcceptEx((SOCKET)iocp_data->data.handle, ctx->accept_sockfd,
ctx->buf, 0, ACCEPT_ADDR_SIZE, ACCEPT_ADDR_SIZE,
@@ -415,7 +415,7 @@ int WinPoller::put_io(const struct poller_data *data, int timeout)
static void __accept_on_success(struct poller_result *res)
{
SOCKET listen_sockfd = (SOCKET)res->data.handle;
AcceptConext *ctx = (AcceptConext *)res->data.context;
AcceptContext *ctx = (AcceptContext *)res->data.context;
struct sockaddr *local;
struct sockaddr *remote;
int local_len = sizeof (struct sockaddr);

6
src/kernel_win/WinPoller.h
View File

@@ -51,7 +51,7 @@ struct poller_result
struct poller_data data;
};
class AcceptConext
class AcceptContext
{
public:
void *service;
@@ -61,14 +61,14 @@ public:
struct sockaddr *remote;
int remote_len;
AcceptConext(void *sc)
AcceptContext(void *sc)
{
service = sc;
buf = new char[ACCEPT_ADDR_SIZE * 2];
}
~AcceptConext()
~AcceptContext()
{
delete []buf;
}