1 #ifndef PROTON_DRIVER_H
2 #define PROTON_DRIVER_H 1
147 const char *port,
void* context);
218 const char *port,
void* context);
PN_EXTERN pn_listener_t * pn_listener(pn_driver_t *driver, const char *host, const char *port, void *context)
pn_listener - the server API
struct pn_connection_t pn_connection_t
An AMQP Connection object.
Definition: types.h:111
PN_EXTERN void pn_connector_close(pn_connector_t *connector)
Close the socket used by the connector.
PN_EXTERN void pn_connector_set_context(pn_connector_t *connector, void *context)
Assign a new application context to the connector.
pn_activate_criteria_t
Definition: driver.h:55
PN_EXTERN void pn_connector_set_connection(pn_connector_t *connector, pn_connection_t *connection)
Assign the AMQP Connection associated with the connector.
PN_EXTERN pn_driver_t * pn_driver(void)
Construct a driver.
PN_EXTERN void * pn_listener_context(pn_listener_t *listener)
Access the application context that is associated with the listener.
PN_EXTERN bool pn_connector_closed(pn_connector_t *connector)
Determine if the connector is closed.
struct pn_driver_t pn_driver_t
Definition: driver.h:51
PN_EXTERN void pn_connector_free(pn_connector_t *connector)
Destructor for the given connector.
PN_EXTERN void pn_connector_activate(pn_connector_t *connector, pn_activate_criteria_t criteria)
Activate a connector when a criteria is met.
PN_EXTERN pn_listener_t * pn_connector_listener(pn_connector_t *connector)
Access the listener which opened this connector.
PN_EXTERN pn_connection_t * pn_connector_connection(pn_connector_t *connector)
Access the AMQP Connection associated with the connector.
struct pn_listener_t pn_listener_t
Definition: driver.h:52
PN_EXTERN pn_listener_t * pn_listener_head(pn_driver_t *driver)
Access the head listener for a driver.
PN_EXTERN void pn_listener_free(pn_listener_t *listener)
Frees the given listener.
PN_EXTERN void pn_listener_set_context(pn_listener_t *listener, void *context)
struct pn_sasl_t pn_sasl_t
Definition: sasl.h:48
PN_EXTERN pn_transport_t * pn_connector_transport(pn_connector_t *connector)
Access the transport used by this connector.
PN_EXTERN const char * pn_connector_name(const pn_connector_t *connector)
Access the name of the connector.
PN_EXTERN pn_sasl_t * pn_connector_sasl(pn_connector_t *connector)
Access the Authentication and Security context of the connector.
PN_EXTERN pn_connector_t * pn_listener_accept(pn_listener_t *listener)
Accept a connection that is pending on the listener.
PN_EXTERN void * pn_connector_context(pn_connector_t *connector)
Access the application context that is associated with the connector.
PN_EXTERN pn_listener_t * pn_driver_listener(pn_driver_t *driver)
Get the next listener with pending data in the driver.
PN_EXTERN void pn_listener_close(pn_listener_t *listener)
Close the socket used by the listener.
PN_EXTERN void pn_driver_free(pn_driver_t *driver)
Free the driver allocated via pn_driver, and all associated listeners and connectors.
PN_EXTERN void pn_driver_trace(pn_driver_t *driver, pn_trace_t trace)
Set the tracing level for the given driver.
PN_EXTERN pn_connector_t * pn_connector(pn_driver_t *driver, const char *host, const char *port, void *context)
pn_connector - the client API
struct pn_connector_t pn_connector_t
Definition: driver.h:53
The selectable API provides an interface for integration with third party event loops.
int pn_trace_t
Holds the trace flags for an AMQP transport.
Definition: transport.h:57
API for the SASL Secure Transport Layer.
PN_EXTERN int pn_driver_wait(pn_driver_t *driver, int timeout)
Wait for an active connector or listener.
#define PN_EXTERN
Definition: import_export.h:53
PN_EXTERN void pn_listener_trace(pn_listener_t *listener, pn_trace_t trace)
PN_EXTERN pn_connector_t * pn_connector_next(pn_connector_t *connector)
Access the next connector.
PN_EXTERN void pn_connector_process(pn_connector_t *connector)
Service the given connector.
PN_EXTERN void pn_connector_trace(pn_connector_t *connector, pn_trace_t trace)
Set the tracing level for the given connector.
PN_EXTERN pn_connector_t * pn_connector_head(pn_driver_t *driver)
Access the head connector for a driver.
struct pn_transport_t pn_transport_t
An AMQP Transport object.
Definition: types.h:255
PN_EXTERN int pn_driver_errno(pn_driver_t *d)
Return the most recent error code.
PN_EXTERN pn_listener_t * pn_listener_next(pn_listener_t *listener)
Access the next listener.
PN_EXTERN int pn_driver_wakeup(pn_driver_t *driver)
Force pn_driver_wait() to return.
PN_EXTERN bool pn_connector_activated(pn_connector_t *connector, pn_activate_criteria_t criteria)
Return the activation status of the connector for a criteria.
PN_EXTERN pn_connector_t * pn_driver_connector(pn_driver_t *driver)
Get the next active connector in the driver.
API for using SSL with the Transport Layer.
PN_EXTERN const char * pn_driver_error(pn_driver_t *d)
Return the most recent error text for d.