int ret;
p = l->bind_conf->frontend;
- bind_tid_commit = l->rx.proto ? l->rx.proto->bind_tid_commit : NULL;
+ bind_tid_commit = l->rx.proto->bind_tid_commit;
/* if l->bind_conf->maxaccept is -1, then max_accept is UINT_MAX. It is
* not really illimited, but it is probably enough.
* reservation in the target ring.
*/
- if (l->rx.proto && l->rx.proto->bind_tid_prep) {
+ if (l->rx.proto->bind_tid_prep) {
if (l->rx.proto->bind_tid_prep(cli_conn, t)) {
/* Failed migration, stay on the same thread. */
goto local_accept;
*/
_HA_ATOMIC_INC(&activity[t].accq_full);
- if (l->rx.proto && l->rx.proto->bind_tid_reset)
+ if (l->rx.proto->bind_tid_reset)
l->rx.proto->bind_tid_reset(cli_conn);
}
#endif // USE_THREAD
/* This may be a shared socket that was paused by another process.
* Let's put it to pause in this case.
*/
- if (l->rx.proto && l->rx.proto->rx_listening(&l->rx) == 0) {
+ if (l->rx.proto->rx_listening(&l->rx) == 0) {
suspend_listener(l, 0, 0);
goto end;
}