27 #ifndef _EVBUFFER_INTERNAL_H_
28 #define _EVBUFFER_INTERNAL_H_
34 #include "event2/event-config.h"
36 #include "util-internal.h"
37 #include "defer-internal.h"
42 #define EVBUFFER_CB_NODEFER 2
47 #include <sys/queue.h>
52 #if _EVENT_SIZEOF_VOID_P < 8
53 #define MIN_BUFFER_SIZE 512
55 #define MIN_BUFFER_SIZE 1024
109 #ifndef _EVENT_DISABLE_THREAD_SUPPORT
130 unsigned is_overlapped : 1;
173 #define EVBUFFER_MMAP 0x0001
174 #define EVBUFFER_SENDFILE 0x0002
175 #define EVBUFFER_REFERENCE 0x0004
176 #define EVBUFFER_IMMUTABLE 0x0008
179 #define EVBUFFER_MEM_PINNED_R 0x0010
180 #define EVBUFFER_MEM_PINNED_W 0x0020
181 #define EVBUFFER_MEM_PINNED_ANY (EVBUFFER_MEM_PINNED_R|EVBUFFER_MEM_PINNED_W)
184 #define EVBUFFER_DANGLING 0x0040
210 #define EVBUFFER_CHAIN_SIZE sizeof(struct evbuffer_chain)
212 #define EVBUFFER_CHAIN_EXTRA(t, c) (t *)((struct evbuffer_chain *)(c) + 1)
215 #define ASSERT_EVBUFFER_LOCKED(buffer) \
216 EVLOCK_ASSERT_LOCKED((buffer)->lock)
218 #define EVBUFFER_LOCK(buffer) \
220 EVLOCK_LOCK((buffer)->lock, 0); \
222 #define EVBUFFER_UNLOCK(buffer) \
224 EVLOCK_UNLOCK((buffer)->lock, 0); \
226 #define EVBUFFER_LOCK2(buffer1, buffer2) \
228 EVLOCK_LOCK2((buffer1)->lock, (buffer2)->lock, 0, 0); \
230 #define EVBUFFER_UNLOCK2(buffer1, buffer2) \
232 EVLOCK_UNLOCK2((buffer1)->lock, (buffer2)->lock, 0, 0); \
236 void _evbuffer_incref(
struct evbuffer *buf);
238 void _evbuffer_incref_and_lock(
struct evbuffer *buf);
241 void _evbuffer_chain_pin(
struct evbuffer_chain *chain,
unsigned flag);
243 void _evbuffer_chain_unpin(
struct evbuffer_chain *chain,
unsigned flag);
246 void _evbuffer_decref_and_unlock(
struct evbuffer *buffer);
250 int _evbuffer_expand_fast(
struct evbuffer *,
size_t,
int);
258 int _evbuffer_read_setup_vecs(
struct evbuffer *buf, ev_ssize_t howmuch,
263 #define WSABUF_FROM_EVBUFFER_IOV(i,ei) do { \
264 (i)->buf = (ei)->iov_base; \
265 (i)->len = (unsigned long)(ei)->iov_len; \
struct evbuffer_chain * first
The first chain in this buffer's linked list of chains.
Definition: evbuffer-internal.h:80
struct evbuffer_chain * last
The last chain in this buffer's linked list of chains.
Definition: evbuffer-internal.h:82
callback for a reference buffer; lets us know what to do with it when we're done with it...
Definition: evbuffer-internal.h:205
A single evbuffer callback for an evbuffer.
Definition: evbuffer-internal.h:60
unsigned flags
Set if special handling is required for this chain.
Definition: evbuffer-internal.h:172
void * lock
A lock used to mediate access to this buffer.
Definition: evbuffer-internal.h:111
union evbuffer_cb_entry::@9 cb
The callback function to invoke when this callback is called.
unsigned char * buffer
Usually points to the read-write memory belonging to this buffer allocated as part of the evbuffer_ch...
Definition: evbuffer-internal.h:192
struct deferred_cb_queue * cb_queue
Used to implement deferred callbacks.
Definition: evbuffer-internal.h:134
size_t total_len
Total amount of bytes stored in all chains.
Definition: evbuffer-internal.h:100
TAILQ_ENTRY(evbuffer_cb_entry) next
Structures to implement a doubly-linked queue of callbacks.
struct bufferevent * parent
The parent bufferevent object this evbuffer belongs to.
Definition: evbuffer-internal.h:151
TAILQ_HEAD(evbuffer_cb_queue, evbuffer_cb_entry) callbacks
A doubly-linked-list of callback functions.
size_t n_add_for_cb
Number of bytes we have added to the buffer since we last tried to invoke callbacks.
Definition: evbuffer-internal.h:104
Definition: evbuffer-internal.h:78
size_t off
Offset into buffer + misalign at which to start writing.
Definition: evbuffer-internal.h:169
void(* evbuffer_cb)(struct evbuffer *buffer, size_t old_len, size_t new_len, void *arg)
Type definition for a callback that is invoked whenever data is added or removed from an evbuffer...
Definition: buffer_compat.h:70
unsigned freeze_end
True iff we should not allow changes to the end of the buffer (appends)
Definition: evbuffer-internal.h:121
Definition: evbuffer-internal.h:199
size_t n_del_for_cb
Number of bytes we have removed from the buffer since we last tried to invoke callbacks.
Definition: evbuffer-internal.h:107
Common convenience functions for cross-platform portability and related socket manipulations.
struct deferred_cb deferred
A deferred_cb handle to make all of this buffer's callbacks invoked from the event loop...
Definition: evbuffer-internal.h:144
void * cbarg
Argument to pass to cb.
Definition: evbuffer-internal.h:71
unsigned deferred_cbs
True iff this evbuffer's callbacks are not invoked immediately upon a change in the buffer...
Definition: evbuffer-internal.h:127
int refcnt
A reference count on this evbuffer.
Definition: evbuffer-internal.h:140
ev_off_t misalign
unused space at the beginning of buffer or an offset into a file for sendfile buffers.
Definition: evbuffer-internal.h:164
unsigned own_lock
True iff we should free the lock field when we free this evbuffer.
Definition: evbuffer-internal.h:115
int fd
the fd associated with this chain
Definition: evbuffer-internal.h:200
unsigned freeze_start
True iff we should not allow changes to the front of the buffer (drains or prepends).
Definition: evbuffer-internal.h:118
ev_uint32_t flags
Currently set flags on this callback.
Definition: evbuffer-internal.h:73
void(* evbuffer_ref_cleanup_cb)(const void *data, size_t datalen, void *extra)
A cleanup function for a piece of memory added to an evbuffer by reference.
Definition: buffer.h:388
A deferred_cb is a callback that can be scheduled to run as part of an event_base's event_loop...
Definition: defer-internal.h:42
struct evbuffer_chain ** last_with_datap
Pointer to the next pointer pointing at the 'last_with_data' chain.
Definition: evbuffer-internal.h:97
struct evbuffer_chain * next
points to next buffer in the chain
Definition: evbuffer-internal.h:157
Shared implementation of a bufferevent.
Definition: bufferevent_struct.h:70
size_t buffer_len
total allocation available in the buffer field.
Definition: evbuffer-internal.h:160
Describes a single extent of memory inside an evbuffer.
Definition: buffer.h:125
A single item in an evbuffer.
Definition: evbuffer-internal.h:155
void(* evbuffer_cb_func)(struct evbuffer *buffer, const struct evbuffer_cb_info *info, void *arg)
Type definition for a callback that is invoked whenever data is added or removed from an evbuffer...
Definition: buffer.h:649
A deferred_cb_queue is a list of deferred_cb that we can add to and run.
Definition: defer-internal.h:54