← Back to branch summary

~ubuntu-branches/ubuntu/precise/corosync/precise-proposed

« back to all changes in this revision

Viewing changes to exec/schedwrk.c

  • Committer: Bazaar Package Importer
  • Author(s): Ante Karamatic
  • Date: 2009-08-21 09:29:56 UTC
  • mfrom: (1.1.2 upstream)
  • Revision ID: james.westby@ubuntu.com-20090821092956-w9qxxxx3zeoh8dem
Tags: 1.0.0-4ubuntu2
* debian/control:
  - 'Ubuntu Developers' instead of 'Ubuntu Core Developers'
    as maintainer
  - Bump debhelper dependecy to 7

Show diffs side-by-side

added added

removed removed

Lines of Context:
exec/schedwrk.c
 
1
/*
 
2
 * Copyright (c) 2009 Red Hat, Inc.
 
3
 *
 
4
 * All rights reserved.
 
5
 *
 
6
 * Author: Steven Dake (sdake@redhat.com)
 
7
 *
 
8
 * This software licensed under BSD license, the text of which follows:
 
9
 *
 
10
 * Redistribution and use in source and binary forms, with or without
 
11
 * modification, are permitted provided that the following conditions are met:
 
12
 *
 
13
 * - Redistributions of source code must retain the above copyright notice,
 
14
 *   this list of conditions and the following disclaimer.
 
15
 * - Redistributions in binary form must reproduce the above copyright notice,
 
16
 *   this list of conditions and the following disclaimer in the documentation
 
17
 *   and/or other materials provided with the distribution.
 
18
 * - Neither the name of the MontaVista Software, Inc. nor the names of its
 
19
 *   contributors may be used to endorse or promote products derived from this
 
20
 *   software without specific prior written permission.
 
21
 *
 
22
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTIBUTORS "AS IS"
 
23
 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 
24
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 
25
 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
 
26
 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
 
27
 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
 
28
 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
 
29
 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
 
30
 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
 
31
 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF
 
32
 * THE POSSIBILITY OF SUCH DAMAGE.
 
33
 */
 
34
 
 
35
#include <config.h>
 
36
#include <corosync/totem/totempg.h>
 
37
#include <corosync/hdb.h>
 
38
#include "schedwrk.h"
 
39
 
 
40
static void (*serialize_lock) (void);
 
41
static void (*serialize_unlock) (void);
 
42
 
 
43
DECLARE_HDB_DATABASE (schedwrk_instance_database,NULL);
 
44
 
 
45
struct schedwrk_instance {
 
46
        int (*schedwrk_fn) (const void *);
 
47
        const void *context;
 
48
        void *callback_handle;
 
49
};
 
50
 
 
51
union u {
 
52
  hdb_handle_t h;
 
53
  const void *v;
 
54
};
 
55
static hdb_handle_t
 
56
void2handle (const void *v) { union u u; u.v = v; return u.h; }
 
57
static const void *
 
58
handle2void (hdb_handle_t h) { union u u; u.h = h; return u.v; }
 
59
 
 
60
static int schedwrk_do (enum totem_callback_token_type type, const void *context)
 
61
{
 
62
        hdb_handle_t handle = void2handle (context);
 
63
        struct schedwrk_instance *instance;
 
64
        int res;
 
65
 
 
66
        res = hdb_handle_get (&schedwrk_instance_database,
 
67
                hdb_nocheck_convert (handle),
 
68
                (void *)&instance);
 
69
        if (res != 0) {
 
70
                goto error_exit;
 
71
        }
 
72
 
 
73
        serialize_lock ();
 
74
        res = instance->schedwrk_fn (instance->context);
 
75
        serialize_unlock ();
 
76
 
 
77
        if (res == 0) {
 
78
                hdb_handle_destroy (&schedwrk_instance_database, hdb_nocheck_convert (handle));
 
79
        }
 
80
        hdb_handle_put (&schedwrk_instance_database,
 
81
                hdb_nocheck_convert (handle));
 
82
        return (res);
 
83
 
 
84
error_exit:
 
85
        return (-1);
 
86
}
 
87
 
 
88
void schedwrk_init (
 
89
        void (*serialize_lock_fn) (void),
 
90
        void (*serialize_unlock_fn) (void))
 
91
{
 
92
        serialize_lock = serialize_lock_fn;
 
93
        serialize_unlock = serialize_unlock_fn;
 
94
}
 
95
 
 
96
int schedwrk_create (
 
97
        hdb_handle_t *handle,
 
98
        int (schedwrk_fn) (const void *),
 
99
        const void *context)
 
100
{
 
101
        struct schedwrk_instance *instance;
 
102
        int res;
 
103
 
 
104
        res = hdb_handle_create (&schedwrk_instance_database,
 
105
                sizeof (struct schedwrk_instance), handle);
 
106
        if (res != 0) {
 
107
                goto error_exit;
 
108
        }
 
109
        res = hdb_handle_get (&schedwrk_instance_database, *handle,
 
110
                (void *)&instance);
 
111
        if (res != 0) {
 
112
                goto error_destroy;
 
113
        }
 
114
 
 
115
        totempg_callback_token_create (
 
116
                &instance->callback_handle,
 
117
                TOTEM_CALLBACK_TOKEN_SENT,
 
118
                1,
 
119
                schedwrk_do,
 
120
                handle2void (*handle));
 
121
 
 
122
        instance->schedwrk_fn = schedwrk_fn;
 
123
        instance->context = context;
 
124
 
 
125
        hdb_handle_put (&schedwrk_instance_database, *handle);
 
126
 
 
127
        return (0);
 
128
 
 
129
error_destroy:
 
130
        hdb_handle_destroy (&schedwrk_instance_database, *handle);
 
131
 
 
132
error_exit:
 
133
        return (-1);
 
134
}
 
135
 
 
136
void schedwrk_destroy (hdb_handle_t handle)
 
137
{
 
138
        hdb_handle_destroy (&schedwrk_instance_database, handle);
 
139
}