#include "xbt/xbt_os_thread.h"
#include "xbt.h"
#include "xbt/log.h"
-XBT_LOG_NEW_DEFAULT_CATEGORY(sem_sched,"Messages specific for this sem example");
+XBT_LOG_NEW_DEFAULT_CATEGORY(sem_sched,
+ "Messages specific for this sem example");
#ifndef ENOBUFS
#define ENOBUFS 1024
#define MAX_ARG 30
#define MAX_ARGS 10
-typedef int (*pfn_func_t)(int, char**);
+typedef int (*pfn_func_t) (int, char **);
static int
-__next_ctx_ID = 0;
+ __next_ctx_ID = 0;
-typedef struct s_job
-{
- pfn_func_t func;
- int argc;
- char** argv;
-}s_job_t,* job_t;
+typedef struct s_job {
+ pfn_func_t func;
+ int argc;
+ char **argv;
+} s_job_t, *job_t;
-job_t
-job_new(pfn_func_t func, int argc, char** argv);
+job_t job_new(pfn_func_t func, int argc, char **argv);
-int
-job_execute(job_t job);
+int job_execute(job_t job);
-int
-job_free(job_t* ref);
+int job_free(job_t * ref);
/* an entry of the table of threads */
-typedef struct s_ctx
-{
- xbt_os_sem_t begin;
- xbt_os_sem_t end;
- int failure;
- job_t job;
- xbt_os_thread_t imp;
- int index;
-}s_ctx_t,* ctx_t;
-
-typedef struct s_shed
-{
- ctx_t* ctxs;
- int size;
- int capacity;
-}s_sched_t,* sched_t;
+typedef struct s_ctx {
+ xbt_os_sem_t begin;
+ xbt_os_sem_t end;
+ int failure;
+ job_t job;
+ xbt_os_thread_t imp;
+ int index;
+} s_ctx_t, *ctx_t;
+typedef struct s_shed {
+ ctx_t *ctxs;
+ int size;
+ int capacity;
+} s_sched_t, *sched_t;
-void
-schedule(ctx_t c);
-void
-unschedule(ctx_t c);
-void*
-ctx_function(void* param);
+void schedule(ctx_t c);
+void unschedule(ctx_t c);
-ctx_t
-ctx_new(job_t job);
+void *ctx_function(void *param);
-int
-ctx_free(ctx_t* ref);
+ctx_t ctx_new(job_t job);
-sched_t
-sched_new(int size);
+int ctx_free(ctx_t * ref);
-int
-sched_add_job(sched_t sched, job_t job);
+sched_t sched_new(int size);
-int
-sched_init(sched_t sched);
+int sched_add_job(sched_t sched, job_t job);
-int
-sched_schedule(sched_t sched);
+int sched_init(sched_t sched);
-int
-sched_clean(sched_t sched);
+int sched_schedule(sched_t sched);
-int
-sched_free(sched_t* ref);
+int sched_clean(sched_t sched);
-int
-job(int argc, char* argv[]);
+int sched_free(sched_t * ref);
-int
-main(int argc, char* argv[])
+int job(int argc, char *argv[]);
+
+int main(int argc, char *argv[])
{
- sched_t sched;
- int i, size;
- char** __argv;
- char arg[MAX_ARG] = {0};
-
-
- xbt_init(&argc, argv);
-
- if(argc != 2)
- {
- INFO1("Usage: %s job count",argv[0]);
- exit(EXIT_FAILURE);
- }
-
-
- size = atoi(argv[1]);
-
- /* create a new scheduler */
- sched = sched_new(size);
-
- if(!sched)
- {
- INFO1("sched_new() failed : errno %d",errno);
- exit(EXIT_FAILURE);
- }
-
- __argv = xbt_new0(char*,MAX_ARGS);
-
- for(i = 0; i < MAX_ARGS; i++)
- {
- sprintf(arg,"arg_%d",i);
- __argv[i] = strdup(arg);
- memset(arg,0,MAX_ARG);
-
- }
-
- for(i = 0; i < size; i++)
- sched_add_job(sched,job_new(job,(i < MAX_ARGS) ? i : MAX_ARGS,__argv));
-
- /* initialize the scheduler */
- if(sched_init(sched) < 0)
- {
- sched_free(&sched);
- INFO1("sched_init() failed : errno %d\n",errno);
- exit(EXIT_FAILURE);
- }
-
- /* schedule the jobs */
- if(sched_schedule(sched) < 0)
- {
- sched_free(&sched);
- INFO1("sched_init() failed : errno %d",errno);
- exit(EXIT_FAILURE);
- }
-
- /* cleanup */
- if(sched_clean(sched) < 0)
- {
- sched_free(&sched);
- INFO1("sched_init() failed : errno %d",errno);
- exit(EXIT_FAILURE);
- }
-
- /* destroy the scheduler */
- sched_free(&sched);
-
- INFO1("sem_sched terminated with exit code %d (success)",EXIT_SUCCESS);
-
- return EXIT_SUCCESS;
-
+ sched_t sched;
+ int i, size;
+ char **__argv;
+ char arg[MAX_ARG] = { 0 };
+
+
+ xbt_init(&argc, argv);
+
+ if (argc != 2) {
+ XBT_INFO("Usage: %s job count", argv[0]);
+ exit(EXIT_FAILURE);
+ }
+
+
+ size = atoi(argv[1]);
+
+ /* create a new scheduler */
+ sched = sched_new(size);
+
+ if (!sched) {
+ XBT_INFO("sched_new() failed : errno %d", errno);
+ exit(EXIT_FAILURE);
+ }
+
+ __argv = xbt_new0(char *, MAX_ARGS);
+
+ for (i = 0; i < MAX_ARGS; i++) {
+ sprintf(arg, "arg_%d", i);
+ __argv[i] = strdup(arg);
+ memset(arg, 0, MAX_ARG);
+
+ }
+
+ for (i = 0; i < size; i++)
+ sched_add_job(sched,
+ job_new(job, (i < MAX_ARGS) ? i : MAX_ARGS, __argv));
+
+ /* initialize the scheduler */
+ if (sched_init(sched) < 0) {
+ sched_free(&sched);
+ XBT_INFO("sched_init() failed : errno %d\n", errno);
+ exit(EXIT_FAILURE);
+ }
+
+ /* schedule the jobs */
+ if (sched_schedule(sched) < 0) {
+ sched_free(&sched);
+ XBT_INFO("sched_init() failed : errno %d", errno);
+ exit(EXIT_FAILURE);
+ }
+
+ /* cleanup */
+ if (sched_clean(sched) < 0) {
+ sched_free(&sched);
+ XBT_INFO("sched_init() failed : errno %d", errno);
+ exit(EXIT_FAILURE);
+ }
+
+ /* destroy the scheduler */
+ sched_free(&sched);
+
+ XBT_INFO("sem_sched terminated with exit code %d (success)", EXIT_SUCCESS);
+
+ return EXIT_SUCCESS;
+
}
-void*
-ctx_function(void* param)
+void *ctx_function(void *param)
{
- int i = 0;
- int exit_code = 1;
- ctx_t ctx = (ctx_t)param;
-
- INFO1("Hello i'm the owner of the context %d, i'm waiting for starting",ctx->index);
-
- unschedule(ctx);
-
- if(ctx->failure)
- {
- INFO1("0ups the scheduler initialization failed bye {%d}.",ctx->index);
- xbt_os_thread_exit(&exit_code);
- }
-
- INFO1("I'm the owner of the context %d : I'm started",ctx->index);
- INFO0("Wait a minute, I do my job");
-
- /* do its job */
- exit_code = job_execute(ctx->job);
-
- INFO1("Have finished my job, bye {%d}\n",ctx->index);
-
- xbt_os_sem_release(ctx->end);
-
- xbt_os_thread_exit(&exit_code);
+ int i = 0;
+ int exit_code = 1;
+ ctx_t ctx = (ctx_t) param;
+
+ XBT_INFO("Hello i'm the owner of the context %d, i'm waiting for starting",
+ ctx->index);
+
+ unschedule(ctx);
+
+ if (ctx->failure) {
+ XBT_INFO("0ups the scheduler initialization failed bye {%d}.",
+ ctx->index);
+ xbt_os_thread_exit(&exit_code);
+ }
+
+ XBT_INFO("I'm the owner of the context %d : I'm started", ctx->index);
+ XBT_INFO("Wait a minute, I do my job");
+
+ /* do its job */
+ exit_code = job_execute(ctx->job);
+
+ XBT_INFO("Have finished my job, bye {%d}\n", ctx->index);
+
+ xbt_os_sem_release(ctx->end);
+
+ xbt_os_thread_exit(&exit_code);
}
-void schedule(ctx_t c)
+void schedule(ctx_t c)
{
- xbt_os_sem_release(c->begin); /* allow C to go */
- xbt_os_sem_acquire(c->end); /* wait C's end */
+ xbt_os_sem_release(c->begin); /* allow C to go */
+ xbt_os_sem_acquire(c->end); /* wait C's end */
}
-void unschedule(ctx_t c)
+void unschedule(ctx_t c)
{
- xbt_os_sem_release(c->end); /* I'm done, dude */
- xbt_os_sem_acquire(c->begin); /* can I start again? */
+ xbt_os_sem_release(c->end); /* I'm done, dude */
+ xbt_os_sem_acquire(c->begin); /* can I start again? */
}
-ctx_t
-ctx_new(job_t job)
+ctx_t ctx_new(job_t job)
{
- ctx_t ctx = xbt_new0(s_ctx_t,1);
- ctx->index = ++__next_ctx_ID;
- ctx->begin = xbt_os_sem_init(0);
- ctx->end = xbt_os_sem_init(0);
- ctx->failure = 0;
- ctx->job = job;
-
- return ctx;
+ ctx_t ctx = xbt_new0(s_ctx_t, 1);
+ ctx->index = ++__next_ctx_ID;
+ ctx->begin = xbt_os_sem_init(0);
+ ctx->end = xbt_os_sem_init(0);
+ ctx->failure = 0;
+ ctx->job = job;
+
+ return ctx;
}
-int
-ctx_free(ctx_t* ref)
+int ctx_free(ctx_t * ref)
{
- ctx_t ctx;
- if(!(*ref))
- return EINVAL;
-
- ctx = *ref;
-
- xbt_os_sem_destroy(ctx->begin);
- xbt_os_sem_destroy(ctx->end);
- job_free(&(ctx->job));
- free(ctx);
- *ref = NULL;
-
- return 0;
+ ctx_t ctx;
+ if (!(*ref))
+ return EINVAL;
+
+ ctx = *ref;
+
+ xbt_os_sem_destroy(ctx->begin);
+ xbt_os_sem_destroy(ctx->end);
+ job_free(&(ctx->job));
+ free(ctx);
+ *ref = NULL;
+
+ return 0;
}
-sched_t
-sched_new(int size)
+sched_t sched_new(int size)
{
- sched_t sched;
-
- if(size <= 0)
- {
- errno = EINVAL;
- return NULL;
- }
-
- sched = xbt_new0(s_sched_t,1);
-
- if(!sched)
- {
- errno = ENOMEM;
- return NULL;
- }
-
- sched->ctxs = xbt_new0(ctx_t,size);
-
- if(!(sched->ctxs))
- {
- errno = ENOMEM;
- free(sched);
- return NULL;
- }
-
- sched->size = 0;
- sched->capacity = size;
-
- return sched;
+ sched_t sched;
+
+ if (size <= 0) {
+ errno = EINVAL;
+ return NULL;
+ }
+
+ sched = xbt_new0(s_sched_t, 1);
+
+ if (!sched) {
+ errno = ENOMEM;
+ return NULL;
+ }
+
+ sched->ctxs = xbt_new0(ctx_t, size);
+
+ if (!(sched->ctxs)) {
+ errno = ENOMEM;
+ free(sched);
+ return NULL;
+ }
+
+ sched->size = 0;
+ sched->capacity = size;
+
+ return sched;
}
-int
-sched_add_job(sched_t sched, job_t job)
+int sched_add_job(sched_t sched, job_t job)
{
- if(!sched || !job)
- return EINVAL;
-
- if(sched->capacity < sched->size)
- return ENOBUFS;
-
- sched->ctxs[(sched->size)++] = ctx_new(job);
-
- return 0;
+ if (!sched || !job)
+ return EINVAL;
+
+ if (sched->capacity < sched->size)
+ return ENOBUFS;
+
+ sched->ctxs[(sched->size)++] = ctx_new(job);
+
+ return 0;
}
-int
-sched_init(sched_t sched)
+int sched_init(sched_t sched)
{
- int i,j;
- int success = 1;
-
- if(!sched)
- return EINVAL;
-
- for(i = 0; i < sched->size; i++)
- {
- sched->ctxs[i]->imp = xbt_os_thread_create("thread",ctx_function,(void*)sched->ctxs[i]);
-
- xbt_os_sem_acquire(sched->ctxs[i]->end);
- }
-
- if(!success)
- {
- for(j = 0; j < i; j++)
- {
- sched->ctxs[j]->failure = 1;
- xbt_os_sem_release(sched->ctxs[j]->begin);
- }
-
- for(j = 0; j < i; j++)
- {
- xbt_os_thread_join(sched->ctxs[j]->imp,0);
-
- ctx_free(&(sched->ctxs[j]));
- }
-
- return -1;
-
- }
-
- return 0;
+ int i, j;
+ int success = 1;
+
+ if (!sched)
+ return EINVAL;
+
+ for (i = 0; i < sched->size; i++) {
+ sched->ctxs[i]->imp =
+ xbt_os_thread_create("thread", ctx_function,
+ (void *) sched->ctxs[i]);
+
+ xbt_os_sem_acquire(sched->ctxs[i]->end);
+ }
+
+ if (!success) {
+ for (j = 0; j < i; j++) {
+ sched->ctxs[j]->failure = 1;
+ xbt_os_sem_release(sched->ctxs[j]->begin);
+ }
+
+ for (j = 0; j < i; j++) {
+ xbt_os_thread_join(sched->ctxs[j]->imp, 0);
+
+ ctx_free(&(sched->ctxs[j]));
+ }
+
+ return -1;
+
+ }
+
+ return 0;
}
-int
-sched_schedule(sched_t sched)
+int sched_schedule(sched_t sched)
{
- int i;
-
- if(!sched)
- return EINVAL;
-
- for(i = 0; i < sched->size; i++)
- schedule(sched->ctxs[i]);
-
- return 0;
+ int i;
+
+ if (!sched)
+ return EINVAL;
+
+ for (i = 0; i < sched->size; i++)
+ schedule(sched->ctxs[i]);
+
+ return 0;
}
-int
-sched_clean(sched_t sched)
+int sched_clean(sched_t sched)
{
- int i;
-
- if(!sched)
- return EINVAL;
-
- for(i = 0; i < sched->size; i++)
- {
- xbt_os_thread_join(sched->ctxs[i]->imp,NULL);
-
- ctx_free(&(sched->ctxs[i]));
- }
-
- return 0;
+ int i;
+
+ if (!sched)
+ return EINVAL;
+
+ for (i = 0; i < sched->size; i++) {
+ xbt_os_thread_join(sched->ctxs[i]->imp, NULL);
+
+ ctx_free(&(sched->ctxs[i]));
+ }
+
+ return 0;
}
-int
-sched_free(sched_t* ref)
+int sched_free(sched_t * ref)
{
- if(*ref)
- return EINVAL;
-
- free(((sched_t)(*ref))->ctxs);
-
- *ref = NULL;
-
- return 0;
+ if (*ref)
+ return EINVAL;
+
+ free(((sched_t) (*ref))->ctxs);
+
+ *ref = NULL;
+
+ return 0;
}
-int
-job(int argc, char** argv)
+int job(int argc, char **argv)
{
- int i = 0;
-
- INFO0("I'm the job : I'm going to print all the args of my commande line");
-
- INFO1("-- Arguments (%d):",argc);
-
- for(i = 0; i < argc; i++)
- INFO2(" ---- [%i] %s",i,argv[i]);
-
- return 0;
+ int i = 0;
+
+ XBT_INFO
+ ("I'm the job : I'm going to print all the args of my commande line");
+
+ XBT_INFO("-- Arguments (%d):", argc);
+
+ for (i = 0; i < argc; i++)
+ XBT_INFO(" ---- [%i] %s", i, argv[i]);
+
+ return 0;
}
-job_t
-job_new(pfn_func_t func, int argc, char** argv)
+job_t job_new(pfn_func_t func, int argc, char **argv)
{
- job_t job;
- int i;
-
- /* todo check the parameters */
- job = xbt_new0(s_job_t,1);
-
- if(!job)
- {
- errno = ENOMEM;
- return NULL;
- }
-
- job->argv = xbt_new0(char*,argc);
-
- if(!(job->argv))
- {
- free(job);
- errno = ENOMEM;
- return NULL;
- }
-
- for(i = 0; i < argc; i++)
- job->argv[i] = strdup(argv[i]);
-
- job->func = func;
- job->argc = argc;
-
- return job;
+ job_t job;
+ int i;
+
+ /* todo check the parameters */
+ job = xbt_new0(s_job_t, 1);
+
+ if (!job) {
+ errno = ENOMEM;
+ return NULL;
+ }
+
+ job->argv = xbt_new0(char *, argc);
+
+ if (!(job->argv)) {
+ free(job);
+ errno = ENOMEM;
+ return NULL;
+ }
+
+ for (i = 0; i < argc; i++)
+ job->argv[i] = strdup(argv[i]);
+
+ job->func = func;
+ job->argc = argc;
+
+ return job;
}
-int
-job_execute(job_t job)
+int job_execute(job_t job)
{
- if(!job)
- return EINVAL;
-
- return (*(job->func))(job->argc, job->argv);
+ if (!job)
+ return EINVAL;
+
+ return job->func(job->argc, job->argv);
}
-int
-job_free(job_t* ref)
+int job_free(job_t * ref)
{
- job_t job;
- int i;
-
- if(!(*ref))
- return EINVAL;
-
- job = *ref;
-
- for(i = 0; i < job->argc; i++)
- free(job->argv[i]);
-
- free(job->argv);
- free(*ref);
- *ref = NULL;
-
- return 0;
-}
+ job_t job;
+ int i;
+
+ if (!(*ref))
+ return EINVAL;
+ job = *ref;
+ for (i = 0; i < job->argc; i++)
+ free(job->argv[i]);
+ free(job->argv);
+ free(*ref);
+ *ref = NULL;
+
+ return 0;
+}
