| 1151 | } |
| 1152 | |
| 1153 | int connTLSSetReadHandler(connection *conn, ConnectionCallbackFunc func, bool fThreadSafe) { |
| 1154 | serverAssert(((tls_connection*)conn)->el == serverTL->el); |
| 1155 | conn->read_handler = func; |
| 1156 | |
| 1157 | if (fThreadSafe) |
| 1158 | conn->flags |= CONN_FLAG_READ_THREADSAFE; |
| 1159 | else |
| 1160 | conn->flags &= ~CONN_FLAG_READ_THREADSAFE; |
| 1161 | |
| 1162 | updateSSLEvent((tls_connection *) conn); |
| 1163 | return C_OK; |
| 1164 | } |
| 1165 | |
| 1166 | static void setBlockingTimeout(tls_connection *conn, long long timeout) { |
| 1167 | anetBlock(NULL, conn->c.fd); |
nothing calls this directly
no test coverage detected