Fix merge problem with dbfwfilter
Code was duplicated in the merge and the old function names were used.
This commit is contained in:
@ -2358,13 +2358,6 @@ routeQuery(MXS_FILTER *instance, MXS_FILTER_SESSION *session, GWBUF *queue)
|
|||||||
type = qc_get_type_mask(queue);
|
type = qc_get_type_mask(queue);
|
||||||
}
|
}
|
||||||
|
|
||||||
uint32_t type = 0;
|
|
||||||
|
|
||||||
if (modutil_is_SQL(queue) || modutil_is_SQL_prepare(queue))
|
|
||||||
{
|
|
||||||
type = qc_get_type(queue);
|
|
||||||
}
|
|
||||||
|
|
||||||
if (modutil_is_SQL(queue) && modutil_count_statements(queue) > 1)
|
if (modutil_is_SQL(queue) && modutil_count_statements(queue) > 1)
|
||||||
{
|
{
|
||||||
GWBUF* err = gen_dummy_error(my_session, "This filter does not support "
|
GWBUF* err = gen_dummy_error(my_session, "This filter does not support "
|
||||||
@ -2374,8 +2367,8 @@ routeQuery(MXS_FILTER *instance, MXS_FILTER_SESSION *session, GWBUF *queue)
|
|||||||
my_session->errmsg = NULL;
|
my_session->errmsg = NULL;
|
||||||
rval = dcb->func.write(dcb, err);
|
rval = dcb->func.write(dcb, err);
|
||||||
}
|
}
|
||||||
else if (QUERY_IS_TYPE(type, QUERY_TYPE_PREPARE_STMT) ||
|
else if (qc_query_is_type(type, QUERY_TYPE_PREPARE_STMT) ||
|
||||||
QUERY_IS_TYPE(type, QUERY_TYPE_PREPARE_NAMED_STMT) ||
|
qc_query_is_type(type, QUERY_TYPE_PREPARE_NAMED_STMT) ||
|
||||||
modutil_is_SQL_prepare(queue))
|
modutil_is_SQL_prepare(queue))
|
||||||
{
|
{
|
||||||
GWBUF* err = gen_dummy_error(my_session, "This filter does not support "
|
GWBUF* err = gen_dummy_error(my_session, "This filter does not support "
|
||||||
|
|||||||
Reference in New Issue
Block a user