| 1 | /* | 
|---|
| 2 | Copyright (c) 2012, Broadcom Europe Ltd | 
|---|
| 3 | All rights reserved. | 
|---|
| 4 |  | 
|---|
| 5 | Redistribution and use in source and binary forms, with or without | 
|---|
| 6 | modification, are permitted provided that the following conditions are met: | 
|---|
| 7 | * Redistributions of source code must retain the above copyright | 
|---|
| 8 | notice, this list of conditions and the following disclaimer. | 
|---|
| 9 | * Redistributions in binary form must reproduce the above copyright | 
|---|
| 10 | notice, this list of conditions and the following disclaimer in the | 
|---|
| 11 | documentation and/or other materials provided with the distribution. | 
|---|
| 12 | * Neither the name of the copyright holder nor the | 
|---|
| 13 | names of its contributors may be used to endorse or promote products | 
|---|
| 14 | derived from this software without specific prior written permission. | 
|---|
| 15 |  | 
|---|
| 16 | THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND | 
|---|
| 17 | ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED | 
|---|
| 18 | WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE | 
|---|
| 19 | DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY | 
|---|
| 20 | DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES | 
|---|
| 21 | (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; | 
|---|
| 22 | LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND | 
|---|
| 23 | ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | 
|---|
| 24 | (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS | 
|---|
| 25 | SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | 
|---|
| 26 | */ | 
|---|
| 27 |  | 
|---|
| 28 | #ifndef MMAL_CONNECTION_H | 
|---|
| 29 | #define MMAL_CONNECTION_H | 
|---|
| 30 |  | 
|---|
| 31 | /** \defgroup MmalConnectionUtility Port connection utility | 
|---|
| 32 | * \ingroup MmalUtilities | 
|---|
| 33 | * The port connection utility functions can be used in place of common sequences | 
|---|
| 34 | * of calls to the MMAL API in order to process buffers being passed between two | 
|---|
| 35 | * ports. | 
|---|
| 36 | * | 
|---|
| 37 | * \section ProcessingConnectionBufferHeaders Processing connection buffer headers | 
|---|
| 38 | * Either in response to the client callback function being called, or simply on a | 
|---|
| 39 | * timer, the client will need to process the buffer headers of the connection | 
|---|
| 40 | * (unless tunneling is used). | 
|---|
| 41 | * | 
|---|
| 42 | * Buffer headers that are in the pool queue will need to be sent to the output port, | 
|---|
| 43 | * while buffer headers in the connection queue are sent to the input port. The | 
|---|
| 44 | * buffer headers in the connection queue may contain pixel data (the cmd field is | 
|---|
| 45 | * zero) or an event (the cmd field is non-zero). In general, pixel data buffer | 
|---|
| 46 | * headers need to be passed on, while event buffer headers are released. In the | 
|---|
| 47 | * case of the format changed event, mmal_connection_event_format_changed() can be | 
|---|
| 48 | * called before the event is released. | 
|---|
| 49 | * | 
|---|
| 50 | * Other, specialized use cases may also be implemented, such as getting and | 
|---|
| 51 | * immediately releasing buffer headers from the connection queue in order to | 
|---|
| 52 | * prevent their propagation. This could be used to drop out video, for example. | 
|---|
| 53 | * | 
|---|
| 54 | * \section TunnellingConnections Tunnelling connections | 
|---|
| 55 | * If the \ref MMAL_CONNECTION_FLAG_TUNNELLING flag is set when the connection is | 
|---|
| 56 | * created, MMAL tunneling will be used. This automates the passing of the buffer | 
|---|
| 57 | * headers between the output port and input port, and back again. It will also do | 
|---|
| 58 | * this as efficiently as possible, avoiding trips between the ARM and the VideoCore | 
|---|
| 59 | * if both components are implemented on the VideoCore. The consequence of this is | 
|---|
| 60 | * that there is no client callback made as buffer headers get transferred. | 
|---|
| 61 | * | 
|---|
| 62 | * The client can still monitor the control port of a component (usually a sink | 
|---|
| 63 | * component, such as video_render) for the end of stream, in order to know when to | 
|---|
| 64 | * dismantle the connection. | 
|---|
| 65 | * | 
|---|
| 66 | * \section ConnectionClientCallback Client callback | 
|---|
| 67 | * When not using tunnelling, the client callback function is called each time a | 
|---|
| 68 | * buffer arrives from a port (either input or output). | 
|---|
| 69 | * | 
|---|
| 70 | * \note The callback is made on a different thread from the one used by the | 
|---|
| 71 | * client to set up the connection, so care must be taken with thread safety. | 
|---|
| 72 | * One option is to raise a signal to the main client thread that queue processing | 
|---|
| 73 | * needs to be done, another is for the callback to perform the queue processing | 
|---|
| 74 | * itself. | 
|---|
| 75 | * | 
|---|
| 76 | * The client can also store an opaque pointer in the connection object, which is | 
|---|
| 77 | * never used by the MMAL code and is only meaningful to the client. | 
|---|
| 78 | * | 
|---|
| 79 | * @{ | 
|---|
| 80 | */ | 
|---|
| 81 |  | 
|---|
| 82 | #ifdef __cplusplus | 
|---|
| 83 | extern "C"{ | 
|---|
| 84 | #endif | 
|---|
| 85 |  | 
|---|
| 86 | /** \name Connection flags | 
|---|
| 87 | * \anchor connectionflags | 
|---|
| 88 | * The following flags describe the properties of the connection. */ | 
|---|
| 89 | /* @{ */ | 
|---|
| 90 | /** The connection is tunnelled. Buffer headers do not transit via the client but | 
|---|
| 91 | * directly from the output port to the input port. */ | 
|---|
| 92 | #define MMAL_CONNECTION_FLAG_TUNNELLING 0x1 | 
|---|
| 93 | /** Force the pool of buffer headers used by the connection to be allocated on the input port. */ | 
|---|
| 94 | #define MMAL_CONNECTION_FLAG_ALLOCATION_ON_INPUT 0x2 | 
|---|
| 95 | /** Force the pool of buffer headers used by the connection to be allocated on the output port. */ | 
|---|
| 96 | #define MMAL_CONNECTION_FLAG_ALLOCATION_ON_OUTPUT 0x4 | 
|---|
| 97 | /** Specify that the connection should not modify the buffer requirements. */ | 
|---|
| 98 | #define MMAL_CONNECTION_FLAG_KEEP_BUFFER_REQUIREMENTS 0x8 | 
|---|
| 99 | /** The connection is flagged as direct. This doesn't change the behaviour of | 
|---|
| 100 | * the connection itself but is used by the the graph utility to specify that | 
|---|
| 101 | * the buffer should be sent to the input port from with the port callback. */ | 
|---|
| 102 | #define MMAL_CONNECTION_FLAG_DIRECT 0x10 | 
|---|
| 103 | /** Specify that the connection should not modify the port formats. */ | 
|---|
| 104 | #define MMAL_CONNECTION_FLAG_KEEP_PORT_FORMATS 0x20 | 
|---|
| 105 | /* @} */ | 
|---|
| 106 |  | 
|---|
| 107 | /** Forward type definition for a connection */ | 
|---|
| 108 | typedef struct MMAL_CONNECTION_T MMAL_CONNECTION_T; | 
|---|
| 109 |  | 
|---|
| 110 | /** Definition of the callback used by a connection to signal back to the client | 
|---|
| 111 | * that a buffer header is available either in the pool or in the output queue. | 
|---|
| 112 | * | 
|---|
| 113 | * @param connection Pointer to the connection | 
|---|
| 114 | */ | 
|---|
| 115 | typedef void (*MMAL_CONNECTION_CALLBACK_T)(MMAL_CONNECTION_T *connection); | 
|---|
| 116 |  | 
|---|
| 117 | /** Structure describing a connection between 2 ports (1 output and 1 input port) */ | 
|---|
| 118 | struct MMAL_CONNECTION_T { | 
|---|
| 119 |  | 
|---|
| 120 | void *user_data;           /**< Field reserved for use by the client. */ | 
|---|
| 121 | MMAL_CONNECTION_CALLBACK_T callback; /**< Callback set by the client. */ | 
|---|
| 122 |  | 
|---|
| 123 | uint32_t is_enabled;       /**< Specifies whether the connection is enabled or not (Read Only). */ | 
|---|
| 124 |  | 
|---|
| 125 | uint32_t flags;            /**< Flags passed during the create call (Read Only). A bitwise | 
|---|
| 126 | * combination of \ref connectionflags "Connection flags" values. | 
|---|
| 127 | */ | 
|---|
| 128 | MMAL_PORT_T *in;           /**< Input port used for the connection (Read Only). */ | 
|---|
| 129 | MMAL_PORT_T *out;          /**< Output port used for the connection (Read Only). */ | 
|---|
| 130 |  | 
|---|
| 131 | MMAL_POOL_T *pool;         /**< Pool of buffer headers used by the output port (Read Only). */ | 
|---|
| 132 | MMAL_QUEUE_T *queue;       /**< Queue for the buffer headers produced by the output port (Read Only). */ | 
|---|
| 133 |  | 
|---|
| 134 | const char *name;          /**< Connection name (Read Only). Used for debugging purposes. */ | 
|---|
| 135 |  | 
|---|
| 136 | /* Used for debug / statistics */ | 
|---|
| 137 | int64_t time_setup;        /**< Time in microseconds taken to setup the connection. */ | 
|---|
| 138 | int64_t time_enable;       /**< Time in microseconds taken to enable the connection. */ | 
|---|
| 139 | int64_t time_disable;      /**< Time in microseconds taken to disable the connection. */ | 
|---|
| 140 | }; | 
|---|
| 141 |  | 
|---|
| 142 | /** Create a connection between two ports. | 
|---|
| 143 | * The connection shall include a pool of buffer headers suitable for the current format of | 
|---|
| 144 | * the output port. The format of the input port shall have been set to the same as that of | 
|---|
| 145 | * the input port. | 
|---|
| 146 | * Note that connections are reference counted and creating a connection automatically | 
|---|
| 147 | * acquires a reference to it (released when \ref mmal_connection_destroy is called). | 
|---|
| 148 | * | 
|---|
| 149 | * @param connection The address of a connection pointer that will be set to point to the created | 
|---|
| 150 | * connection. | 
|---|
| 151 | * @param out        The output port to use for the connection. | 
|---|
| 152 | * @param in         The input port to use for the connection. | 
|---|
| 153 | * @param flags      The flags specifying which type of connection should be created. | 
|---|
| 154 | *    A bitwise combination of \ref connectionflags "Connection flags" values. | 
|---|
| 155 | * @return MMAL_SUCCESS on success. | 
|---|
| 156 | */ | 
|---|
| 157 | MMAL_STATUS_T mmal_connection_create(MMAL_CONNECTION_T **connection, | 
|---|
| 158 | MMAL_PORT_T *out, MMAL_PORT_T *in, uint32_t flags); | 
|---|
| 159 |  | 
|---|
| 160 | /** Acquire a reference on a connection. | 
|---|
| 161 | * Acquiring a reference on a connection will prevent a connection from being destroyed until | 
|---|
| 162 | * the acquired reference is released (by a call to \ref mmal_connection_destroy). | 
|---|
| 163 | * References are internally counted so all acquired references need a matching call to | 
|---|
| 164 | * release them. | 
|---|
| 165 | * | 
|---|
| 166 | * @param connection connection to acquire | 
|---|
| 167 | */ | 
|---|
| 168 | void mmal_connection_acquire(MMAL_CONNECTION_T *connection); | 
|---|
| 169 |  | 
|---|
| 170 | /** Release a reference on a connection | 
|---|
| 171 | * Release an acquired reference on a connection. Triggers the destruction of the connection when | 
|---|
| 172 | * the last reference is being released. | 
|---|
| 173 | * \note This is in fact an alias of \ref mmal_connection_destroy which is added to make client | 
|---|
| 174 | * code clearer. | 
|---|
| 175 | * | 
|---|
| 176 | * @param connection connection to release | 
|---|
| 177 | * @return MMAL_SUCCESS on success | 
|---|
| 178 | */ | 
|---|
| 179 | MMAL_STATUS_T mmal_connection_release(MMAL_CONNECTION_T *connection); | 
|---|
| 180 |  | 
|---|
| 181 | /** Destroy a connection. | 
|---|
| 182 | * Release an acquired reference on a connection. Only actually destroys the connection when | 
|---|
| 183 | * the last reference is being released. | 
|---|
| 184 | * The actual destruction of the connection will start by disabling it, if necessary. | 
|---|
| 185 | * Any pool, queue, and so on owned by the connection shall then be destroyed. | 
|---|
| 186 | * | 
|---|
| 187 | * @param connection The connection to be destroyed. | 
|---|
| 188 | * @return MMAL_SUCCESS on success. | 
|---|
| 189 | */ | 
|---|
| 190 | MMAL_STATUS_T mmal_connection_destroy(MMAL_CONNECTION_T *connection); | 
|---|
| 191 |  | 
|---|
| 192 | /** Enable a connection. | 
|---|
| 193 | * The format of the two ports must have been committed before calling this function, | 
|---|
| 194 | * although note that on creation, the connection automatically copies and commits the | 
|---|
| 195 | * output port's format to the input port. | 
|---|
| 196 | * | 
|---|
| 197 | * The MMAL_CONNECTION_T::callback field must have been set if the \ref MMAL_CONNECTION_FLAG_TUNNELLING | 
|---|
| 198 | * flag was not specified on creation. The client may also set the MMAL_CONNECTION_T::user_data | 
|---|
| 199 | * in order to get a pointer passed, via the connection, to the callback. | 
|---|
| 200 | * | 
|---|
| 201 | * @param connection The connection to be enabled. | 
|---|
| 202 | * @return MMAL_SUCCESS on success. | 
|---|
| 203 | */ | 
|---|
| 204 | MMAL_STATUS_T mmal_connection_enable(MMAL_CONNECTION_T *connection); | 
|---|
| 205 |  | 
|---|
| 206 | /** Disable a connection. | 
|---|
| 207 | * | 
|---|
| 208 | * @param connection The connection to be disabled. | 
|---|
| 209 | * @return MMAL_SUCCESS on success. | 
|---|
| 210 | */ | 
|---|
| 211 | MMAL_STATUS_T mmal_connection_disable(MMAL_CONNECTION_T *connection); | 
|---|
| 212 |  | 
|---|
| 213 | /** Apply a format changed event to the connection. | 
|---|
| 214 | * This function can be used when the client is processing buffer headers and receives | 
|---|
| 215 | * a format changed event (\ref MMAL_EVENT_FORMAT_CHANGED). The connection is | 
|---|
| 216 | * reconfigured, changing the format of the ports, the number of buffer headers and | 
|---|
| 217 | * the size of the payload buffers as necessary. | 
|---|
| 218 | * | 
|---|
| 219 | * @param connection The connection to which the event shall be applied. | 
|---|
| 220 | * @param buffer The buffer containing a format changed event. | 
|---|
| 221 | * @return MMAL_SUCCESS on success. | 
|---|
| 222 | */ | 
|---|
| 223 | MMAL_STATUS_T mmal_connection_event_format_changed(MMAL_CONNECTION_T *connection, | 
|---|
| 224 | MMAL_BUFFER_HEADER_T *buffer); | 
|---|
| 225 |  | 
|---|
| 226 | #ifdef __cplusplus | 
|---|
| 227 | } | 
|---|
| 228 | #endif | 
|---|
| 229 |  | 
|---|
| 230 | /** @} */ | 
|---|
| 231 |  | 
|---|
| 232 | #endif /* MMAL_CONNECTION_H */ | 
|---|
| 233 |  | 
|---|