async_tasks_manager.h

Go to the documentation of this file.

/*
 * async_task_manager.h
 *
 *  Created on: 12 May 2017
 *      Author: billy
 */
 
#ifndef CORE_SERVER_TASK_INCLUDE_ASYNC_TASKS_MANAGER_H_
#define CORE_SERVER_TASK_INCLUDE_ASYNC_TASKS_MANAGER_H_
 
 
#include "async_task.h"
#include "count_async_task.h"
#include "system_async_task.h"
 
 
/* forward declaration */
struct AsyncTasksManagerEventConsumer;
 
 
typedef struct AsyncTasksManager
{
  LinkedList *atm_tasks_p;
 
  SyncData *atm_sync_p;
 
 
  struct CountAsyncTask *atm_monitor_p;
 
  struct AsyncTasksManagerEventConsumer *atm_consumer_p;
 
 
  bool (*atm_cleanup_fn) (void *data_p);
 
  void *atm_cleanup_data_p;
 
  bool atm_in_use_flag;
} AsyncTasksManager;
 
 
typedef struct AsyncTasksManagerEventConsumer
{
  EventConsumer atmec_base_consumer;
 
  AsyncTasksManager *atmec_tasks_manager_p;
} AsyncTasksManagerEventConsumer;
 
 
 
 
 
 
 
#ifdef __cplusplus
extern "C"
{
#endif
 
 
GRASSROOTS_TASK_API AsyncTasksManager *AllocateAsyncTasksManager (const char * const name_s, bool (*cleanup_fn) (void *data_p), void *cleanup_data_p);
 
 
GRASSROOTS_TASK_API void FreeAsyncTasksManager (AsyncTasksManager *manager_p);
 
 
GRASSROOTS_TASK_API bool AddAsyncTaskToAsyncTasksManager (AsyncTasksManager *manager_p, AsyncTask *task_p, MEM_FLAG mem);
 
 
GRASSROOTS_TASK_API SystemAsyncTask *AllocateSystemAsyncTaskFromAsyncTasksManager (AsyncTasksManager *manager_p, ServiceJob *std_service_job_p, char *std_command_line_s, void (*on_success_callback_fn) (ServiceJob *job_p));
 
GRASSROOTS_TASK_API AsyncTasksManagerEventConsumer *AllocateAsyncTasksManagerEventConsumer (void (*consumer_fn) (EventConsumer *consumer_p, struct AsyncTask *task_p), AsyncTasksManager *manager_p);
 
 
GRASSROOTS_TASK_API void FreeAsyncTasksManagerEventConsumer (AsyncTasksManagerEventConsumer *consumer_p);
 
 
GRASSROOTS_TASK_API void PrepareAsyncTasksManager (AsyncTasksManager *manager_p, const int32 initial_counter_value);
 
 
GRASSROOTS_TASK_API bool StartAsyncTaskManagerWorkers (AsyncTasksManager *manager_p);
 
 
GRASSROOTS_TASK_API bool RunAsyncTasksManagerTasks (AsyncTasksManager *manager_p);
 
 
GRASSROOTS_TASK_API bool IsAsyncTaskManagerRunning (const AsyncTasksManager *manager_p);
 
 
 
GRASSROOTS_TASK_API void IncrementAsyncTaskManagerCount (AsyncTasksManager *manager_p);
 
 
#ifdef __cplusplus
}
#endif
 
#endif /* CORE_SERVER_TASK_INCLUDE_ASYNC_TASKS_MANAGER_H_ */