disconnect_client(client, true, "PQexec disallowed");
return false;
}
+ rfq_delta++;
+ break;
case 'F': /* FunctionCall */
+ rfq_delta++;
+ break;
/* request immediate response from server */
case 'S': /* Sync */
} else {
active += statlist_count(&login_client_list);
}
+ /* fallthrough */
case P_PAUSE:
if (!active)
admin_pause_done();
break;
case 'h':
usage(0, argv[0]);
+ break;
default:
usage(1, argv[0]);
+ break;
}
}
if (optind + 1 != argc) {
case CL_WAITING_LOGIN:
if (newstate == CL_ACTIVE)
newstate = CL_LOGIN;
+ /* fallthrough */
case CL_WAITING:
statlist_remove(&pool->waiting_client_list, &client->head);
break;
break;
case CL_WAITING:
client->wait_start = get_cached_time();
+ /* fallthrough */
case CL_WAITING_LOGIN:
statlist_append(&pool->waiting_client_list, &client->head);
break;
res = sbuf_call_proto(sbuf, SBUF_EV_PKT_CALLBACK);
if (!res)
return false;
+ /* fallthrough */
/* after callback, skip pkt */
case ACT_SKIP:
iobuf_tag_skip(io, avail);
case 'E': /* log & ignore errors */
log_server_error("S: error while executing exec_on_query", pkt);
+ /* fallthrough */
default: /* ignore rest */
sbuf_prepare_skip(sbuf, pkt->len);
return true;
disconnect_server(server, true, "invalid server parameter");
return false;
}
+ /* fallthrough */
case 'C': /* CommandComplete */
/* ErrorResponse and CommandComplete show end of copy mode */