@@ -1565,9 +1565,9 @@ struct server_queue {
1565
1565
}
1566
1566
QUE_DBG (" new task, id = %d, front = %d\n " , task.id , front);
1567
1567
if (front) {
1568
- queue_tasks.push_front (task);
1568
+ queue_tasks.push_front (std::move ( task) );
1569
1569
} else {
1570
- queue_tasks.push_back (task);
1570
+ queue_tasks.push_back (std::move ( task) );
1571
1571
}
1572
1572
condition_tasks.notify_one ();
1573
1573
return task.id ;
@@ -1599,7 +1599,7 @@ struct server_queue {
1599
1599
void defer (server_task && task) {
1600
1600
std::unique_lock<std::mutex> lock (mutex_tasks);
1601
1601
QUE_DBG (" defer task, id = %d\n " , task.id );
1602
- queue_tasks_deferred.push_back (task);
1602
+ queue_tasks_deferred.push_back (std::move ( task) );
1603
1603
condition_tasks.notify_one ();
1604
1604
}
1605
1605
@@ -4450,7 +4450,7 @@ int main(int argc, char ** argv) {
4450
4450
int task_id = ctx_server.queue_tasks .get_new_id ();
4451
4451
{
4452
4452
server_task task (SERVER_TASK_TYPE_SET_LORA);
4453
- task.id = ctx_server. queue_tasks . get_new_id () ;
4453
+ task.id = task_id ;
4454
4454
task.set_lora = parse_lora_request (ctx_server.params_base .lora_adapters , body);
4455
4455
ctx_server.queue_results .add_waiting_task_id (task_id);
4456
4456
ctx_server.queue_tasks .post (std::move (task));
0 commit comments