| 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 | |