MCPcopy Create free account
hub / github.com/F-Stack/f-stack / connSetWriteHandlerWithBarrier

Function connSetWriteHandlerWithBarrier

app/redis-6.2.6/src/connection.h:174–176  ·  view source on GitHub ↗

Set a write handler, and possibly enable a write barrier, this flag is * cleared when write handler is changed or removed. * With barrier enabled, we never fire the event if the read handler already * fired in the same event loop iteration. Useful when you want to persist * things to disk before sending replies, and want to do that in a group fashion. */

Source from the content-addressed store, hash-verified

172 * fired in the same event loop iteration. Useful when you want to persist
173 * things to disk before sending replies, and want to do that in a group fashion. */
174static inline int connSetWriteHandlerWithBarrier(connection *conn, ConnectionCallbackFunc func, int barrier) {
175 return conn->type->set_write_handler(conn, func, barrier);
176}
177
178static inline void connClose(connection *conn) {
179 conn->type->close(conn);

Callers 2

clusterSendMessageFunction · 0.85

Calls

no outgoing calls

Tested by

no test coverage detected