@@ -477,10 +477,14 @@ JNIEXPORT jint JNICALL Java_de_kherud_llama_LlamaModel_requestCompletion(JNIEnv
477477 jlong server_handle = env->GetLongField (obj, f_model_pointer);
478478 auto *ctx_server = reinterpret_cast <server_context *>(server_handle); // NOLINT(*-no-int-to-ptr)
479479
480+ std::cout << " DEBUG " << 1 << std::endl;
481+
480482 std::string c_params = parse_jstring (env, jparams);
481483 json json_params = json::parse (c_params);
482484 const bool infill = json_params.contains (" input_prefix" ) || json_params.contains (" input_suffix" );
483485
486+ std::cout << " DEBUG " << 2 << std::endl;
487+
484488 if (json_params.value (" use_chat_template" , false ))
485489 {
486490 json chat;
@@ -489,8 +493,12 @@ JNIEXPORT jint JNICALL Java_de_kherud_llama_LlamaModel_requestCompletion(JNIEnv
489493 json_params[" prompt" ] = format_chat (ctx_server->model , ctx_server->params .chat_template , chat);
490494 }
491495
496+ std::cout << " DEBUG " << 3 << std::endl;
497+
492498 const int id_task = ctx_server->queue_tasks .get_new_id ();
499+ std::cout << " DEBUG " << 4 << std::endl;
493500 ctx_server->queue_results .add_waiting_task_id (id_task);
501+ std::cout << " DEBUG " << 5 << std::endl;
494502 ctx_server->request_completion (id_task, -1 , json_params, infill, false );
495503
496504 return id_task;
@@ -501,6 +509,7 @@ JNIEXPORT jobject JNICALL Java_de_kherud_llama_LlamaModel_receiveCompletion(JNIE
501509 jlong server_handle = env->GetLongField (obj, f_model_pointer);
502510 auto *ctx_server = reinterpret_cast <server_context *>(server_handle); // NOLINT(*-no-int-to-ptr)
503511
512+ std::cout << " DEBUG " << 8 << std::endl;
504513 server_task_result result = ctx_server->queue_results .recv (id_task);
505514
506515 if (result.error )
@@ -510,12 +519,14 @@ JNIEXPORT jobject JNICALL Java_de_kherud_llama_LlamaModel_receiveCompletion(JNIE
510519 env->ThrowNew (c_llama_error, response.c_str ());
511520 return nullptr ;
512521 }
522+ std::cout << " DEBUG " << 9 << std::endl;
513523
514524 std::string response = result.data [" content" ].get <std::string>();
515525 if (result.stop )
516526 {
517527 ctx_server->queue_results .remove_waiting_task_id (id_task);
518528 }
529+ std::cout << " DEBUG " << 10 << std::endl;
519530
520531 jobject o_probabilities = env->NewObject (c_hash_map, cc_hash_map);
521532 if (result.data .contains (" completion_probabilities" ))
@@ -536,6 +547,7 @@ JNIEXPORT jobject JNICALL Java_de_kherud_llama_LlamaModel_receiveCompletion(JNIE
536547 }
537548 }
538549 }
550+ std::cout << " DEBUG " << 11 << std::endl;
539551
540552 jbyteArray jbytes = parse_jbytes (env, response);
541553 return env->NewObject (c_output, cc_output, jbytes, o_probabilities, result.stop );
0 commit comments