| 441 | } |
| 442 | |
| 443 | int RunQueueJob(hb_handle_t *h, hb_dict_t *job_dict) |
| 444 | { |
| 445 | if (job_dict == NULL) |
| 446 | { |
| 447 | return -1; |
| 448 | } |
| 449 | |
| 450 | char * json_job; |
| 451 | json_job = hb_value_get_json(job_dict); |
| 452 | hb_value_free(&job_dict); |
| 453 | if (json_job == NULL) |
| 454 | { |
| 455 | fprintf(stderr, "Error in setting up job! Aborting.\n"); |
| 456 | return -1; |
| 457 | } |
| 458 | |
| 459 | hb_add_json(h, json_job); |
| 460 | free(json_job); |
| 461 | job_running = 1; |
| 462 | hb_start( h ); |
| 463 | |
| 464 | EventLoop(h, NULL); |
| 465 | |
| 466 | return 0; |
| 467 | } |
| 468 | |
| 469 | int RunQueue(hb_handle_t *h, const char *queue_import_name) |
| 470 | { |
no test coverage detected