| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you under the Apache License, Version 2.0 (the |
| * "License"); you may not use this file except in compliance |
| * with the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, |
| * software distributed under the License is distributed on an |
| * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY |
| * KIND, either express or implied. See the License for the |
| * specific language governing permissions and limitations |
| * under the License. |
| */ |
| |
| #ifndef qd_router_core_event_types |
| #define qd_router_core_event_types 1 |
| |
| typedef struct qdrc_event_subscription_t qdrc_event_subscription_t; |
| |
| #include "router_core_private.h" |
| |
| #endif |
| |
| #ifndef qd_router_core_events |
| #define qd_router_core_events 1 |
| |
| #include "qpid/dispatch/ctools.h" |
| |
| typedef uint32_t qdrc_event_t; |
| |
| /** |
| * QDRC_EVENT_CONN_OPENED A connection has opened |
| * QDRC_EVENT_CONN_CLOSED A connection has closed |
| * QDRC_EVENT_CONN_EDGE_ESTABLISHED An edge connection has been established |
| * QDRC_EVENT_CONN_EDGE_LOST An edge connection has been lost |
| * QDRC_EVENT_CONN_IR_ESTABLISHED (not implemented) |
| * QDRC_EVENT_CONN_IR_LOST (not implemented) |
| * |
| * QDRC_EVENT_LINK_IN_ATTACHED (not implemented) |
| * QDRC_EVENT_LINK_IN_DETACHED (not implemented) |
| * QDRC_EVENT_LINK_OUT_ATTACHED (not implemented) |
| * QDRC_EVENT_LINK_OUT_DETACHED (not implemented) |
| * QDRC_EVENT_LINK_EDGE_DATA_ATTACHED An edge-data link has been attached (incoming only) |
| * QDRC_EVENT_LINK_EDGE_DATA_DETACHED An edge-data link has been detached (incoming only) |
| * |
| * QDRC_EVENT_ADDR_ADDED (not implemented) |
| * QDRC_EVENT_ADDR_REMOVED (not implemented) |
| * QDRC_EVENT_ADDR_BECAME_LOCAL_DEST An address transitioned from zero to one local destination |
| * QDRC_EVENT_ADDR_NO_LONGER_LOCAL_DEST An address transitioned from one to zero local destinations |
| * QDRC_EVENT_ADDR_BECAME_DEST An address transitioned from zero to one destination |
| * QDRC_EVENT_ADDR_NO_LONGER_DEST An address transitioned from one to zero destinations |
| * QDRC_EVENT_ADDR_ONE_LOCAL_DEST An address transitioned from N destinations to one local dest |
| * QDRC_EVENT_ADDR_TWO_DEST An address transisioned from one local dest to two destinations |
| * QDRC_EVENT_ADDR_BECAME_SOURCE An address transitioned from zero to one local source (inlink) |
| * QDRC_EVENT_ADDR_NO_LONGER_SOURCE An address transitioned from one to zero local sources (inlink) |
| * QDRC_EVENT_ADDR_TWO_SOURCE An address transitioned from one to two local sources (inlink) |
| * QDRC_EVENT_ADDR_ONE_SOURCE An address transitioned from two to one local sources (inlink) |
| * |
| * QDRC_EVENT_ROUTER_ADDED A remote router has been discovered |
| * QDRC_EVENT_ROUTER_REMOVED A remote router has been lost |
| * QDRC_EVENT_ROUTER_MOBILE_FLUSH A remote router needs its mobile addresses unmapped |
| * QDRC_EVENT_ROUTER_MOBILE_SEQ_ADVANCED A remote router's mobile sequence advanced past our version of the sequence |
| */ |
| |
| #define QDRC_EVENT_CONN_OPENED 0x00000001 |
| #define QDRC_EVENT_CONN_CLOSED 0x00000002 |
| #define QDRC_EVENT_CONN_EDGE_ESTABLISHED 0x00000004 |
| #define QDRC_EVENT_CONN_EDGE_LOST 0x00000008 |
| #define QDRC_EVENT_CONN_IR_ESTABLISHED 0x00000010 |
| #define QDRC_EVENT_CONN_IR_LOST 0x00000020 |
| #define _QDRC_EVENT_CONN_RANGE 0x0000003F |
| |
| #define QDRC_EVENT_LINK_IN_ATTACHED 0x00000040 |
| #define QDRC_EVENT_LINK_IN_DETACHED 0x00000080 |
| #define QDRC_EVENT_LINK_OUT_ATTACHED 0x00000100 |
| #define QDRC_EVENT_LINK_OUT_DETACHED 0x00000200 |
| #define QDRC_EVENT_LINK_EDGE_DATA_ATTACHED 0x00000400 |
| #define QDRC_EVENT_LINK_EDGE_DATA_DETACHED 0x00000800 |
| #define _QDRC_EVENT_LINK_RANGE 0x00000FC0 |
| |
| #define QDRC_EVENT_ADDR_ADDED 0x00001000 |
| #define QDRC_EVENT_ADDR_REMOVED 0x00002000 |
| #define QDRC_EVENT_ADDR_BECAME_LOCAL_DEST 0x00004000 |
| #define QDRC_EVENT_ADDR_NO_LONGER_LOCAL_DEST 0x00008000 |
| #define QDRC_EVENT_ADDR_BECAME_DEST 0x00010000 |
| #define QDRC_EVENT_ADDR_NO_LONGER_DEST 0x00020000 |
| #define QDRC_EVENT_ADDR_ONE_LOCAL_DEST 0x00040000 |
| #define QDRC_EVENT_ADDR_TWO_DEST 0x00080000 |
| #define QDRC_EVENT_ADDR_BECAME_SOURCE 0x00100000 |
| #define QDRC_EVENT_ADDR_NO_LONGER_SOURCE 0x00200000 |
| #define QDRC_EVENT_ADDR_TWO_SOURCE 0x00400000 |
| #define QDRC_EVENT_ADDR_ONE_SOURCE 0x00800000 |
| #define _QDRC_EVENT_ADDR_RANGE 0x00FFF000 |
| |
| #define QDRC_EVENT_ROUTER_ADDED 0x01000000 |
| #define QDRC_EVENT_ROUTER_REMOVED 0x02000000 |
| #define QDRC_EVENT_ROUTER_MOBILE_FLUSH 0x04000000 |
| #define QDRC_EVENT_ROUTER_MOBILE_SEQ_ADVANCED 0x08000000 |
| #define _QDRC_EVENT_ROUTER_RANGE 0x0F000000 |
| |
| |
| /** |
| * Callbacks - Connection, Link, and Address event notifications |
| * |
| * @param context The opaque context provided in the mobile address binding |
| * @param event_type The type of event being raised |
| * @param conn/link/addr The object involved in the event |
| */ |
| typedef void (*qdrc_connection_event_t) (void *context, |
| qdrc_event_t event_type, |
| qdr_connection_t *conn); |
| |
| typedef void (*qdrc_link_event_t) (void *context, |
| qdrc_event_t event_type, |
| qdr_link_t *link); |
| |
| typedef void (*qdrc_address_event_t) (void *context, |
| qdrc_event_t event_type, |
| qdr_address_t *addr); |
| |
| typedef void (*qdrc_router_event_t) (void *context, |
| qdrc_event_t event_type, |
| qdr_node_t *router); |
| |
| /** |
| * qdrc_event_subscribe_CT |
| * |
| * Subscribe to receive a set of event types for connections, links, or addresses. |
| * |
| * @param core Pointer to the router core object |
| * @param events Logical OR of the set of events that the caller wishes to receive |
| * @param on_conn_event Callback for connection events, must be non-null if there are connection events in 'events' |
| * @param on_link_event Callback for link events, must be non-null if there are link events in 'events' |
| * @param on_addr_event Callback for address events, must be non-null if there are address events in 'events' |
| * @param context The opaque context that will be passed back with the raised events |
| * @return Pointer to an object that tracks the subscription |
| */ |
| qdrc_event_subscription_t *qdrc_event_subscribe_CT(qdr_core_t *core, |
| qdrc_event_t events, |
| qdrc_connection_event_t on_conn_event, |
| qdrc_link_event_t on_link_event, |
| qdrc_address_event_t on_addr_event, |
| qdrc_router_event_t on_router_event, |
| void *context); |
| |
| /** |
| * qdrc_event_unsubscribe_CT |
| * |
| * Cancel an active subscription |
| * |
| * @param core Pointer to the router core object |
| * @param sub Pointer to the subscription returned by the subscribe function |
| */ |
| void qdrc_event_unsubscribe_CT(qdr_core_t *core, qdrc_event_subscription_t *sub); |
| |
| |
| //===================================================================================== |
| // Private functions, not part of the API |
| //===================================================================================== |
| |
| DEQ_DECLARE(qdrc_event_subscription_t, qdrc_event_subscription_list_t); |
| |
| void qdrc_event_conn_raise(qdr_core_t *core, qdrc_event_t event, qdr_connection_t *conn); |
| void qdrc_event_link_raise(qdr_core_t *core, qdrc_event_t event, qdr_link_t *link); |
| void qdrc_event_addr_raise(qdr_core_t *core, qdrc_event_t event, qdr_address_t *addr); |
| void qdrc_event_router_raise(qdr_core_t *core, qdrc_event_t event, qdr_node_t *router); |
| |
| #endif |
