File Manager

003 File Manager

Current Path: /usr/src/contrib/libevent

📁 ..
📄 ChangeLog(98.8 KB)
📄 ChangeLog-1.4(16.96 KB)
📄 ChangeLog-2.0(81.39 KB)
📄 Doxyfile(9.97 KB)
📄 LICENSE(4.42 KB)
📄 Makefile.am(8.64 KB)
📄 Makefile.in(143.63 KB)
📄 Makefile.nmake(2.29 KB)
📁 WIN32-Code
📄 aclocal.m4(41.44 KB)
📄 arc4random.c(12.83 KB)
📄 autogen.sh(431 B)
📄 buffer.c(80.31 KB)
📄 buffer_iocp.c(8.44 KB)
📄 bufferevent-internal.h(18.05 KB)
📄 bufferevent.c(25.49 KB)
📄 bufferevent_async.c(17.75 KB)
📄 bufferevent_filter.c(17.58 KB)
📄 bufferevent_openssl.c(38.57 KB)
📄 bufferevent_pair.c(9.6 KB)
📄 bufferevent_ratelim.c(29.51 KB)
📄 bufferevent_sock.c(18.37 KB)
📄 changelist-internal.h(4.52 KB)
📁 compat
📄 compile(7.16 KB)
📄 config.guess(41.93 KB)
📄 config.h.in(14.02 KB)
📄 config.sub(35.14 KB)
📄 configure(525.2 KB)
📄 configure.ac(23.97 KB)
📄 defer-internal.h(2.7 KB)
📄 depcomp(23.01 KB)
📄 devpoll.c(7.7 KB)
📄 epoll.c(14.37 KB)
📄 epoll_sub.c(2.33 KB)
📄 epolltable-internal.h(40.4 KB)
📄 evbuffer-internal.h(12.51 KB)
📄 evconfig-private.h(1.33 KB)
📄 evconfig-private.h.in(1.21 KB)
📄 evdns.c(127.4 KB)
📄 event-internal.h(16.85 KB)
📄 event.c(100.49 KB)
📄 event_iocp.c(7.52 KB)
📄 event_rpcgen.py(54.33 KB)
📄 event_tagging.c(14.3 KB)
📄 evmap-internal.h(4.78 KB)
📄 evmap.c(28.2 KB)
📄 evport.c(11.72 KB)
📄 evrpc-internal.h(5.58 KB)
📄 evrpc.c(28.68 KB)
📄 evsignal-internal.h(2.57 KB)
📄 evthread-internal.h(13.99 KB)
📄 evthread.c(13.42 KB)
📄 evthread_pthread.c(4.84 KB)
📄 evthread_win32.c(8.39 KB)
📄 evutil.c(69 KB)
📄 evutil_rand.c(5.08 KB)
📄 evutil_time.c(16.69 KB)
📄 ht-internal.h(28.5 KB)
📄 http-internal.h(5.78 KB)
📄 http.c(120.9 KB)
📁 include
📄 install-sh(14.33 KB)
📄 iocp-internal.h(7.52 KB)
📄 ipv6-internal.h(2.46 KB)
📄 kqueue-internal.h(1.94 KB)
📄 kqueue.c(14.36 KB)
📄 libevent.pc.in(317 B)
📄 libevent_core.pc.in(281 B)
📄 libevent_extra.pc.in(284 B)
📄 libevent_openssl.pc.in(372 B)
📄 libevent_pthreads.pc.in(384 B)
📄 listener.c(20.83 KB)
📄 log-internal.h(3.14 KB)
📄 log.c(5.51 KB)
📄 ltmain.sh(316.49 KB)
📁 m4
📄 make-event-config.sed(588 B)
📄 minheap-internal.h(6.78 KB)
📄 missing(6.71 KB)
📄 mm-internal.h(3.32 KB)
📄 openssl-compat.h(974 B)
📄 poll.c(7.99 KB)
📄 ratelim-internal.h(4 KB)
📁 sample
📄 select.c(8.5 KB)
📄 signal.c(12.22 KB)
📄 strlcpy-internal.h(366 B)
📄 strlcpy.c(2.52 KB)
📁 test
📄 test-driver(4.53 KB)
📄 time-internal.h(3 KB)
📄 util-internal.h(15.54 KB)
📄 whatsnew-2.0.txt(25.73 KB)
📄 whatsnew-2.1.txt(32.6 KB)
📄 win32select.c(10.29 KB)

Editing: buffer_iocp.c

/*
 * Copyright (c) 2009-2012 Niels Provos and Nick Mathewson
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. The name of the author may not be used to endorse or promote products
 *    derived from this software without specific prior written permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 */

/**
   @file buffer_iocp.c

This module implements overlapped read and write functions for evbuffer
   objects on Windows.
*/
#include "event2/event-config.h"
#include "evconfig-private.h"

#include "event2/buffer.h"
#include "event2/buffer_compat.h"
#include "event2/util.h"
#include "event2/thread.h"
#include "util-internal.h"
#include "evthread-internal.h"
#include "evbuffer-internal.h"
#include "iocp-internal.h"
#include "mm-internal.h"

#include <winsock2.h>
#include <windows.h>
#include <stdio.h>

#define MAX_WSABUFS 16

/** An evbuffer that can handle overlapped IO. */
struct evbuffer_overlapped {
	struct evbuffer buffer;
	/** The socket that we're doing overlapped IO on. */
	evutil_socket_t fd;

/** pending I/O type */
	unsigned read_in_progress : 1;
	unsigned write_in_progress : 1;

/** The first pinned chain in the buffer. */
	struct evbuffer_chain *first_pinned;

/** How many chains are pinned; how many of the fields in buffers
	 * are we using. */
	int n_buffers;
	WSABUF buffers[MAX_WSABUFS];
};

/** Given an evbuffer, return the correponding evbuffer structure, or NULL if
 * the evbuffer isn't overlapped. */
static inline struct evbuffer_overlapped *
upcast_evbuffer(struct evbuffer *buf)
{
	if (!buf || !buf->is_overlapped)
		return NULL;
	return EVUTIL_UPCAST(buf, struct evbuffer_overlapped, buffer);
}

/** Unpin all the chains noted as pinned in 'eo'. */
static void
pin_release(struct evbuffer_overlapped *eo, unsigned flag)
{
	int i;
	struct evbuffer_chain *next, *chain = eo->first_pinned;

for (i = 0; i < eo->n_buffers; ++i) {
		EVUTIL_ASSERT(chain);
		next = chain->next;
		evbuffer_chain_unpin_(chain, flag);
		chain = next;
	}
}

void
evbuffer_commit_read_(struct evbuffer *evbuf, ev_ssize_t nBytes)
{
	struct evbuffer_overlapped *buf = upcast_evbuffer(evbuf);
	struct evbuffer_chain **chainp;
	size_t remaining, len;
	unsigned i;

EVBUFFER_LOCK(evbuf);
	EVUTIL_ASSERT(buf->read_in_progress && !buf->write_in_progress);
	EVUTIL_ASSERT(nBytes >= 0); /* XXXX Can this be false? */

evbuffer_unfreeze(evbuf, 0);

chainp = evbuf->last_with_datap;
	if (!((*chainp)->flags & EVBUFFER_MEM_PINNED_R))
		chainp = &(*chainp)->next;
	remaining = nBytes;
	for (i = 0; remaining > 0 && i < (unsigned)buf->n_buffers; ++i) {
		EVUTIL_ASSERT(*chainp);
		len = buf->buffers[i].len;
		if (remaining < len)
			len = remaining;
		(*chainp)->off += len;
		evbuf->last_with_datap = chainp;
		remaining -= len;
		chainp = &(*chainp)->next;
	}

pin_release(buf, EVBUFFER_MEM_PINNED_R);

buf->read_in_progress = 0;

evbuf->total_len += nBytes;
	evbuf->n_add_for_cb += nBytes;

evbuffer_invoke_callbacks_(evbuf);

evbuffer_decref_and_unlock_(evbuf);
}

void
evbuffer_commit_write_(struct evbuffer *evbuf, ev_ssize_t nBytes)
{
	struct evbuffer_overlapped *buf = upcast_evbuffer(evbuf);

EVBUFFER_LOCK(evbuf);
	EVUTIL_ASSERT(buf->write_in_progress && !buf->read_in_progress);
	evbuffer_unfreeze(evbuf, 1);
	evbuffer_drain(evbuf, nBytes);
	pin_release(buf,EVBUFFER_MEM_PINNED_W);
	buf->write_in_progress = 0;
	evbuffer_decref_and_unlock_(evbuf);
}

struct evbuffer *
evbuffer_overlapped_new_(evutil_socket_t fd)
{
	struct evbuffer_overlapped *evo;

evo = mm_calloc(1, sizeof(struct evbuffer_overlapped));
	if (!evo)
		return NULL;

LIST_INIT(&evo->buffer.callbacks);
	evo->buffer.refcnt = 1;
	evo->buffer.last_with_datap = &evo->buffer.first;

evo->buffer.is_overlapped = 1;
	evo->fd = fd;

return &evo->buffer;
}

int
evbuffer_launch_write_(struct evbuffer *buf, ev_ssize_t at_most,
		struct event_overlapped *ol)
{
	struct evbuffer_overlapped *buf_o = upcast_evbuffer(buf);
	int r = -1;
	int i;
	struct evbuffer_chain *chain;
	DWORD bytesSent;

if (!buf) {
		/* No buffer, or it isn't overlapped */
		return -1;
	}

EVBUFFER_LOCK(buf);
	EVUTIL_ASSERT(!buf_o->read_in_progress);
	if (buf->freeze_start || buf_o->write_in_progress)
		goto done;
	if (!buf->total_len) {
		/* Nothing to write */
		r = 0;
		goto done;
	} else if (at_most < 0 || (size_t)at_most > buf->total_len) {
		at_most = buf->total_len;
	}
	evbuffer_freeze(buf, 1);

buf_o->first_pinned = NULL;
	buf_o->n_buffers = 0;
	memset(buf_o->buffers, 0, sizeof(buf_o->buffers));

chain = buf_o->first_pinned = buf->first;

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);

if ((size_t)at_most > chain->off) {
			/* XXXX Cast is safe for now, since win32 has no
			   mmaped chains.  But later, we need to have this
			   add more WSAbufs if chain->off is greater than
			   ULONG_MAX */
			b->len = (unsigned long)chain->off;
			at_most -= chain->off;
		} else {
			b->len = (unsigned long)at_most;
			++i;
			break;
		}
	}

buf_o->n_buffers = i;
	evbuffer_incref_(buf);
	if (WSASend(buf_o->fd, buf_o->buffers, i, &bytesSent, 0,
		&ol->overlapped, NULL)) {
		int error = WSAGetLastError();
		if (error != WSA_IO_PENDING) {
			/* An actual error. */
			pin_release(buf_o, EVBUFFER_MEM_PINNED_W);
			evbuffer_unfreeze(buf, 1);
			evbuffer_free(buf); /* decref */
			goto done;
		}
	}

buf_o->write_in_progress = 1;
	r = 0;
done:
	EVBUFFER_UNLOCK(buf);
	return r;
}

int
evbuffer_launch_read_(struct evbuffer *buf, size_t at_most,
		struct event_overlapped *ol)
{
	struct evbuffer_overlapped *buf_o = upcast_evbuffer(buf);
	int r = -1, i;
	int nvecs;
	int npin=0;
	struct evbuffer_chain *chain=NULL, **chainp;
	DWORD bytesRead;
	DWORD flags = 0;
	struct evbuffer_iovec vecs[MAX_WSABUFS];

if (!buf_o)
		return -1;
	EVBUFFER_LOCK(buf);
	EVUTIL_ASSERT(!buf_o->write_in_progress);
	if (buf->freeze_end || buf_o->read_in_progress)
		goto done;

buf_o->first_pinned = NULL;
	buf_o->n_buffers = 0;
	memset(buf_o->buffers, 0, sizeof(buf_o->buffers));

if (evbuffer_expand_fast_(buf, at_most, MAX_WSABUFS) == -1)
		goto done;
	evbuffer_freeze(buf, 0);

nvecs = evbuffer_read_setup_vecs_(buf, at_most,
	    vecs, MAX_WSABUFS, &chainp, 1);
	for (i=0;i<nvecs;++i) {
		WSABUF_FROM_EVBUFFER_IOV(
			&buf_o->buffers[i],
			&vecs[i]);
	}

buf_o->n_buffers = nvecs;
	buf_o->first_pinned = chain = *chainp;

npin=0;
	for ( ; chain; chain = chain->next) {
		evbuffer_chain_pin_(chain, EVBUFFER_MEM_PINNED_R);
		++npin;
	}
	EVUTIL_ASSERT(npin == nvecs);

evbuffer_incref_(buf);
	if (WSARecv(buf_o->fd, buf_o->buffers, nvecs, &bytesRead, &flags,
		    &ol->overlapped, NULL)) {
		int error = WSAGetLastError();
		if (error != WSA_IO_PENDING) {
			/* An actual error. */
			pin_release(buf_o, EVBUFFER_MEM_PINNED_R);
			evbuffer_unfreeze(buf, 0);
			evbuffer_free(buf); /* decref */
			goto done;
		}
	}

buf_o->read_in_progress = 1;
	r = 0;
done:
	EVBUFFER_UNLOCK(buf);
	return r;
}

evutil_socket_t
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)
{
	struct evbuffer_overlapped *buf_o = upcast_evbuffer(buf);
	EVBUFFER_LOCK(buf);
	/* XXX is this right?, should it cancel current I/O operations? */
	if (buf_o)
		buf_o->fd = fd;
	EVBUFFER_UNLOCK(buf);
}

003 File Manager

Editing: buffer_iocp.c

Upload File

Create Folder