Create a NACK entry setting the delivery count to 1 and the delivery * time to the current time. The NACK consumer will be set to the one * specified as argument of the function. */
| 2236 | * time to the current time. The NACK consumer will be set to the one |
| 2237 | * specified as argument of the function. */ |
| 2238 | streamNACK *streamCreateNACK(streamConsumer *consumer) { |
| 2239 | streamNACK *nack = zmalloc(sizeof(*nack)); |
| 2240 | nack->delivery_time = mstime(); |
| 2241 | nack->delivery_count = 1; |
| 2242 | nack->consumer = consumer; |
| 2243 | return nack; |
| 2244 | } |
| 2245 | |
| 2246 | /* Free a NACK entry. */ |
| 2247 | void streamFreeNACK(streamNACK *na) { |
no test coverage detected