Function connSocketSetReadHandler

src/connection.cpp:250–265

Register a read handler, to be called when the connection is readable. * If NULL, the existing handler is removed. */

 * If NULL, the existing handler is removed.
 */
static int connSocketSetReadHandler(connection *conn, ConnectionCallbackFunc func, bool fThreadSafe) {
    if (func == conn->read_handler) return C_OK;
    
    if (fThreadSafe)
        conn->flags |= CONN_FLAG_READ_THREADSAFE;
    else
        conn->flags &= ~CONN_FLAG_READ_THREADSAFE;

    conn->read_handler = func;
    if (!conn->read_handler)
        aeDeleteFileEvent(serverTL->el,conn->fd,AE_READABLE);
    else
        if (aeCreateFileEvent(serverTL->el,conn->fd,
                    AE_READABLE|AE_READ_THREADSAFE,conn->type->ae_handler,conn) == AE_ERR) return C_ERR;
    return C_OK;
}

static const char *connSocketGetLastError(connection *conn) {
    return strerror(conn->last_errno);