summaryrefslogtreecommitdiffstats
path: root/contrib/libs/libevent/buffer_iocp.c
diff options
context:
space:
mode:
authorkikht <[email protected]>2022-02-10 16:45:14 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:45:14 +0300
commit194cae0e8855b11be2005e1eff12c660c3ee9774 (patch)
treeed29c437b616690880c017855ebe0be34fdf81a2 /contrib/libs/libevent/buffer_iocp.c
parent49116032d905455a7b1c994e4a696afc885c1e71 (diff)
Restoring authorship annotation for <[email protected]>. Commit 1 of 2.
Diffstat (limited to 'contrib/libs/libevent/buffer_iocp.c')
-rw-r--r--contrib/libs/libevent/buffer_iocp.c42
1 files changed, 21 insertions, 21 deletions
diff --git a/contrib/libs/libevent/buffer_iocp.c b/contrib/libs/libevent/buffer_iocp.c
index 2af0c49cc64..e5a4b762921 100644
--- a/contrib/libs/libevent/buffer_iocp.c
+++ b/contrib/libs/libevent/buffer_iocp.c
@@ -30,8 +30,8 @@
This module implements overlapped read and write functions for evbuffer
objects on Windows.
*/
-#include "event2/event-config.h"
-#include "evconfig-private.h"
+#include "event2/event-config.h"
+#include "evconfig-private.h"
#include "event2/buffer.h"
#include "event2/buffer_compat.h"
@@ -44,7 +44,7 @@
#include "mm-internal.h"
#include <winsock2.h>
-#include <winerror.h>
+#include <winerror.h>
#include <windows.h>
#include <stdio.h>
@@ -89,13 +89,13 @@ pin_release(struct evbuffer_overlapped *eo, unsigned flag)
for (i = 0; i < eo->n_buffers; ++i) {
EVUTIL_ASSERT(chain);
next = chain->next;
- evbuffer_chain_unpin_(chain, flag);
+ evbuffer_chain_unpin_(chain, flag);
chain = next;
}
}
void
-evbuffer_commit_read_(struct evbuffer *evbuf, ev_ssize_t nBytes)
+evbuffer_commit_read_(struct evbuffer *evbuf, ev_ssize_t nBytes)
{
struct evbuffer_overlapped *buf = upcast_evbuffer(evbuf);
struct evbuffer_chain **chainp;
@@ -130,13 +130,13 @@ evbuffer_commit_read_(struct evbuffer *evbuf, ev_ssize_t nBytes)
evbuf->total_len += nBytes;
evbuf->n_add_for_cb += nBytes;
- evbuffer_invoke_callbacks_(evbuf);
+ evbuffer_invoke_callbacks_(evbuf);
- evbuffer_decref_and_unlock_(evbuf);
+ evbuffer_decref_and_unlock_(evbuf);
}
void
-evbuffer_commit_write_(struct evbuffer *evbuf, ev_ssize_t nBytes)
+evbuffer_commit_write_(struct evbuffer *evbuf, ev_ssize_t nBytes)
{
struct evbuffer_overlapped *buf = upcast_evbuffer(evbuf);
@@ -146,11 +146,11 @@ evbuffer_commit_write_(struct evbuffer *evbuf, ev_ssize_t nBytes)
evbuffer_drain(evbuf, nBytes);
pin_release(buf,EVBUFFER_MEM_PINNED_W);
buf->write_in_progress = 0;
- evbuffer_decref_and_unlock_(evbuf);
+ evbuffer_decref_and_unlock_(evbuf);
}
struct evbuffer *
-evbuffer_overlapped_new_(evutil_socket_t fd)
+evbuffer_overlapped_new_(evutil_socket_t fd)
{
struct evbuffer_overlapped *evo;
@@ -158,7 +158,7 @@ evbuffer_overlapped_new_(evutil_socket_t fd)
if (!evo)
return NULL;
- LIST_INIT(&evo->buffer.callbacks);
+ LIST_INIT(&evo->buffer.callbacks);
evo->buffer.refcnt = 1;
evo->buffer.last_with_datap = &evo->buffer.first;
@@ -169,7 +169,7 @@ evbuffer_overlapped_new_(evutil_socket_t fd)
}
int
-evbuffer_launch_write_(struct evbuffer *buf, ev_ssize_t at_most,
+evbuffer_launch_write_(struct evbuffer *buf, ev_ssize_t at_most,
struct event_overlapped *ol)
{
struct evbuffer_overlapped *buf_o = upcast_evbuffer(buf);
@@ -205,7 +205,7 @@ evbuffer_launch_write_(struct evbuffer *buf, ev_ssize_t at_most,
for (i=0; i < MAX_WSABUFS && chain; ++i, chain=chain->next) {
WSABUF *b = &buf_o->buffers[i];
b->buf = (char*)( chain->buffer + chain->misalign );
- evbuffer_chain_pin_(chain, EVBUFFER_MEM_PINNED_W);
+ evbuffer_chain_pin_(chain, EVBUFFER_MEM_PINNED_W);
if ((size_t)at_most > chain->off) {
/* XXXX Cast is safe for now, since win32 has no
@@ -222,7 +222,7 @@ evbuffer_launch_write_(struct evbuffer *buf, ev_ssize_t at_most,
}
buf_o->n_buffers = i;
- evbuffer_incref_(buf);
+ evbuffer_incref_(buf);
if (WSASend(buf_o->fd, buf_o->buffers, i, &bytesSent, 0,
&ol->overlapped, NULL)) {
int error = WSAGetLastError();
@@ -243,7 +243,7 @@ done:
}
int
-evbuffer_launch_read_(struct evbuffer *buf, size_t at_most,
+evbuffer_launch_read_(struct evbuffer *buf, size_t at_most,
struct event_overlapped *ol)
{
struct evbuffer_overlapped *buf_o = upcast_evbuffer(buf);
@@ -266,11 +266,11 @@ evbuffer_launch_read_(struct evbuffer *buf, size_t at_most,
buf_o->n_buffers = 0;
memset(buf_o->buffers, 0, sizeof(buf_o->buffers));
- if (evbuffer_expand_fast_(buf, at_most, MAX_WSABUFS) == -1)
+ if (evbuffer_expand_fast_(buf, at_most, MAX_WSABUFS) == -1)
goto done;
evbuffer_freeze(buf, 0);
- nvecs = evbuffer_read_setup_vecs_(buf, at_most,
+ nvecs = evbuffer_read_setup_vecs_(buf, at_most,
vecs, MAX_WSABUFS, &chainp, 1);
for (i=0;i<nvecs;++i) {
WSABUF_FROM_EVBUFFER_IOV(
@@ -283,12 +283,12 @@ evbuffer_launch_read_(struct evbuffer *buf, size_t at_most,
npin=0;
for ( ; chain; chain = chain->next) {
- evbuffer_chain_pin_(chain, EVBUFFER_MEM_PINNED_R);
+ evbuffer_chain_pin_(chain, EVBUFFER_MEM_PINNED_R);
++npin;
}
EVUTIL_ASSERT(npin == nvecs);
- evbuffer_incref_(buf);
+ evbuffer_incref_(buf);
if (WSARecv(buf_o->fd, buf_o->buffers, nvecs, &bytesRead, &flags,
&ol->overlapped, NULL)) {
int error = WSAGetLastError();
@@ -309,14 +309,14 @@ done:
}
evutil_socket_t
-evbuffer_overlapped_get_fd_(struct evbuffer *buf)
+evbuffer_overlapped_get_fd_(struct evbuffer *buf)
{
struct evbuffer_overlapped *buf_o = upcast_evbuffer(buf);
return buf_o ? buf_o->fd : -1;
}
void
-evbuffer_overlapped_set_fd_(struct evbuffer *buf, evutil_socket_t fd)
+evbuffer_overlapped_set_fd_(struct evbuffer *buf, evutil_socket_t fd)
{
struct evbuffer_overlapped *buf_o = upcast_evbuffer(buf);
EVBUFFER_LOCK(buf);