2 #define PROTON_EVENT_H 1 25 #include <proton/import_export.h> 26 #include <proton/type_compat.h> 27 #include <proton/object.h> 310 PN_SELECTABLE_UPDATED,
311 PN_SELECTABLE_READABLE,
312 PN_SELECTABLE_WRITABLE,
314 PN_SELECTABLE_EXPIRED,
410 const pn_class_t *clazz,
void *context,
411 pn_event_type_t type);
The read side of the transport is closed, it will no longer read bytes from external IO...
Definition: event.h:301
Indicates that the both the head and tail of the transport are closed.
Definition: event.h:307
bool pn_collector_pop(pn_collector_t *collector)
Clear the head event on a collector.
The proactor becaome inactive: all listeners and connections are closed and their events processed...
Definition: event.h:353
pn_transport_t * pn_event_transport(pn_event_t *event)
Get the transport associated with an event.
const pn_class_t * pn_event_class(pn_event_t *event)
Get the class associated with the event context.
The local session endpoint has been opened.
Definition: event.h:168
void pn_collector_release(pn_collector_t *collector)
Release a collector.
pn_event_type_t
An event type.
Definition: event.h:80
The remote endpoint has closed the link.
Definition: event.h:223
pn_event_t * pn_collector_peek(pn_collector_t *collector)
Access the head event contained by a collector.
pn_event_type_t pn_event_type(pn_event_t *event)
Get the type of an event.
The flow control state for a link has changed.
Definition: event.h:241
pn_link_t * pn_event_link(pn_event_t *event)
Get the link associated with an event.
The connection has been unbound from its transport.
Definition: event.h:125
The local link endpoint has been detached.
Definition: event.h:229
Indicates the listener is ready to call pn_listener_accept() Events of this type point to the pn_list...
Definition: event.h:327
struct pn_transport_t pn_transport_t
An AMQP Transport object.
Definition: types.h:419
pn_delivery_t * pn_event_delivery(pn_event_t *event)
Get the delivery associated with an event.
The link has been created.
Definition: event.h:199
The local connection endpoint has been closed.
Definition: event.h:143
struct pn_link_t pn_link_t
An AMQP Link object.
Definition: types.h:305
struct pn_event_batch_t pn_event_batch_t
Experimental - A batch of events to handle.
Definition: event.h:544
pn_record_t * pn_event_attachments(pn_event_t *event)
Get any attachments associated with an event.
A delivery has been created or updated.
Definition: event.h:254
The connection has been bound to a transport.
Definition: event.h:119
The remote endpoint has detached the link.
Definition: event.h:235
Indicates that the tail of the transport has been closed.
Definition: event.h:295
Defined as a programming convenience.
Definition: event.h:85
pn_connection_wake() was called.
Definition: event.h:321
struct pn_collector_t pn_collector_t
An event collector.
Definition: types.h:407
pn_event_t * pn_collector_prev(pn_collector_t *collector)
Return the same event as the previous call to pn_collector_next()
struct pn_session_t pn_session_t
An AMQP Session object.
Definition: types.h:286
The connection has been created.
Definition: event.h:113
pn_collector_t * pn_collector(void)
Construct a collector.
Timeout set by pn_proactor_set_timeout() time limit expired.
Definition: event.h:345
The local session endpoint has been closed.
Definition: event.h:180
pn_connection_t * pn_event_connection(pn_event_t *event)
Get the connection associated with an event.
The local connection endpoint has been closed.
Definition: event.h:131
The session has been created.
Definition: event.h:162
void * pn_event_context(pn_event_t *event)
Get the context associated with an event.
struct pn_delivery_t pn_delivery_t
An AMQP Delivery object.
Definition: types.h:395
A reactor has been started.
Definition: event.h:90
The write side of the transport is closed, it will no longer produce bytes to write to external IO...
Definition: event.h:288
The remote endpoint has opened the connection.
Definition: event.h:137
The link has been freed and any outstanding processing has been completed.
Definition: event.h:248
pn_event_t * pn_collector_next(pn_collector_t *collector)
Return the next event to be handled.
void pn_collector_free(pn_collector_t *collector)
Free a collector.
A timer event has occurred.
Definition: event.h:106
The session has been freed and any outstanding processing has been completed.
Definition: event.h:193
The remote endpoint has opened the session.
Definition: event.h:174
Indicates that the "head" or writing end of the transport has been closed.
Definition: event.h:282
Indicates the listener has closed.
Definition: event.h:333
The remote endpoint has opened the link.
Definition: event.h:211
struct pn_connection_t pn_connection_t
An AMQP Connection object.
Definition: types.h:275
pn_event_t * pn_event_batch_next(pn_event_batch_t *batch)
Experimental - Remove the next event from the batch and return it.
const char * pn_event_type_name(pn_event_type_t type)
Get a human readable name for an event type.
Indicates pn_proactor_interrupt() was called to interrupt a proactor thread Events of this type point...
Definition: event.h:339
The local link endpoint has been opened.
Definition: event.h:205
pn_event_t * pn_collector_put(pn_collector_t *collector, const pn_class_t *clazz, void *context, pn_event_type_t type)
Place a new event on a collector.
A reactor has been stopped.
Definition: event.h:101
pn_session_t * pn_event_session(pn_event_t *event)
Get the session associated with an event.
bool pn_collector_more(pn_collector_t *collector)
Check if there are more events after the current event.
The transport has new data to read and/or write.
Definition: event.h:260
Indicates that a transport error has occurred.
Definition: event.h:275
The remote endpoint has closed the session.
Definition: event.h:186
The remote endpoint has closed the connection.
Definition: event.h:149
The connection has been freed and any outstanding processing has been completed.
Definition: event.h:156
The transport has authenticated, if this is received by a server the associated transport has authent...
Definition: event.h:268
struct pn_event_t pn_event_t
Notification of a state change in the protocol engine.
Definition: event.h:75
A reactor has no more events to process.
Definition: event.h:96
The local link endpoint has been closed.
Definition: event.h:217