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. */
| 2238 | * time to the current time. The NACK consumer will be set to the one |
| 2239 | * specified as argument of the function. */ |
| 2240 | streamNACK *streamCreateNACK(streamConsumer *consumer) { |
| 2241 | streamNACK *nack = (streamNACK*)zmalloc(sizeof(*nack), MALLOC_SHARED); |
| 2242 | nack->delivery_time = mstime(); |
| 2243 | nack->delivery_count = 1; |
| 2244 | nack->consumer = consumer; |
| 2245 | return nack; |
| 2246 | } |
| 2247 | |
| 2248 | /* Free a NACK entry. */ |
| 2249 | void streamFreeNACK(streamNACK *na) { |
no test coverage detected