... | ... | @@ -144,6 +144,14 @@ QueryWorker4::run(): |
|
|
while (query_params = getNextQuery()) {
|
|
|
xid = query_params->xid
|
|
|
|
|
|
// Handle basic LeaseQuery queries
|
|
|
if (query_params->isBasicLQ()) {
|
|
|
basic_response = LeaseQueryImpl4::processQuery(query_params, DONT_SEND);
|
|
|
bulk_response = wrapBasicResponse(xid, basic_response);
|
|
|
connection_->pushToSend(bulk_response);
|
|
|
continue;
|
|
|
}
|
|
|
|
|
|
// Start the bulk lease query based on dequeued parameters.
|
|
|
bulk_query = BulkLeaseQuery(query_params);
|
|
|
status = bulk_query->start();
|
... | ... | |