aboutsummaryrefslogtreecommitdiffstats
path: root/contrib/libs/libevent/event_iocp.c
diff options
context:
space:
mode:
authorkikht <kikht@yandex-team.ru>2022-02-10 16:45:14 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:14 +0300
commit778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (patch)
treebe835aa92c6248212e705f25388ebafcf84bc7a1 /contrib/libs/libevent/event_iocp.c
parent194cae0e8855b11be2005e1eff12c660c3ee9774 (diff)
downloadydb-778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5.tar.gz
Restoring authorship annotation for <kikht@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'contrib/libs/libevent/event_iocp.c')
-rw-r--r--contrib/libs/libevent/event_iocp.c28
1 files changed, 14 insertions, 14 deletions
diff --git a/contrib/libs/libevent/event_iocp.c b/contrib/libs/libevent/event_iocp.c
index 9acaf650cc..6b2a2e15ef 100644
--- a/contrib/libs/libevent/event_iocp.c
+++ b/contrib/libs/libevent/event_iocp.c
@@ -23,7 +23,7 @@
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
* THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
-#include "evconfig-private.h"
+#include "evconfig-private.h"
#ifndef _WIN32_WINNT
/* Minimum required for InitializeCriticalSectionAndSpinCount */
@@ -46,7 +46,7 @@
#define NOTIFICATION_KEY ((ULONG_PTR)-1)
void
-event_overlapped_init_(struct event_overlapped *o, iocp_callback cb)
+event_overlapped_init_(struct event_overlapped *o, iocp_callback cb)
{
memset(o, 0, sizeof(struct event_overlapped));
o->cb = cb;
@@ -61,9 +61,9 @@ handle_entry(OVERLAPPED *o, ULONG_PTR completion_key, DWORD nBytes, int ok)
}
static void
-loop(void *port_)
+loop(void *port_)
{
- struct event_iocp_port *port = port_;
+ struct event_iocp_port *port = port_;
long ms = port->ms;
HANDLE p = port->port;
@@ -99,7 +99,7 @@ loop(void *port_)
}
int
-event_iocp_port_associate_(struct event_iocp_port *port, evutil_socket_t fd,
+event_iocp_port_associate_(struct event_iocp_port *port, evutil_socket_t fd,
ev_uintptr_t key)
{
HANDLE h;
@@ -151,7 +151,7 @@ init_extension_functions(struct win32_extension_fns *ext)
const GUID connectex = WSAID_CONNECTEX;
const GUID getacceptexsockaddrs = WSAID_GETACCEPTEXSOCKADDRS;
SOCKET s = socket(AF_INET, SOCK_STREAM, 0);
- if (s == EVUTIL_INVALID_SOCKET)
+ if (s == EVUTIL_INVALID_SOCKET)
return;
ext->AcceptEx = get_extension_function(s, &acceptex);
ext->ConnectEx = get_extension_function(s, &connectex);
@@ -165,7 +165,7 @@ init_extension_functions(struct win32_extension_fns *ext)
static struct win32_extension_fns the_extension_fns;
const struct win32_extension_fns *
-event_get_win32_extension_fns_(void)
+event_get_win32_extension_fns_(void)
{
return &the_extension_fns;
}
@@ -173,7 +173,7 @@ event_get_win32_extension_fns_(void)
#define N_CPUS_DEFAULT 2
struct event_iocp_port *
-event_iocp_port_launch_(int n_cpus)
+event_iocp_port_launch_(int n_cpus)
{
struct event_iocp_port *port;
int i;
@@ -224,7 +224,7 @@ err:
}
static void
-event_iocp_port_unlock_and_free_(struct event_iocp_port *port)
+event_iocp_port_unlock_and_free_(struct event_iocp_port *port)
{
DeleteCriticalSection(&port->lock);
CloseHandle(port->port);
@@ -247,7 +247,7 @@ event_iocp_notify_all(struct event_iocp_port *port)
}
int
-event_iocp_shutdown_(struct event_iocp_port *port, long waitMsec)
+event_iocp_shutdown_(struct event_iocp_port *port, long waitMsec)
{
DWORD ms = INFINITE;
int n;
@@ -265,7 +265,7 @@ event_iocp_shutdown_(struct event_iocp_port *port, long waitMsec)
n = port->n_live_threads;
LeaveCriticalSection(&port->lock);
if (n == 0) {
- event_iocp_port_unlock_and_free_(port);
+ event_iocp_port_unlock_and_free_(port);
return 0;
} else {
return -1;
@@ -273,7 +273,7 @@ event_iocp_shutdown_(struct event_iocp_port *port, long waitMsec)
}
int
-event_iocp_activate_overlapped_(
+event_iocp_activate_overlapped_(
struct event_iocp_port *port, struct event_overlapped *o,
ev_uintptr_t key, ev_uint32_t n)
{
@@ -284,9 +284,9 @@ event_iocp_activate_overlapped_(
}
struct event_iocp_port *
-event_base_get_iocp_(struct event_base *base)
+event_base_get_iocp_(struct event_base *base)
{
-#ifdef _WIN32
+#ifdef _WIN32
return base->iocp;
#else
return NULL;