Subversion Repositories HelenOS

Rev

Rev 3445 | Rev 3495 | Go to most recent revision | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 3445 Rev 3494
1
/*
1
/*
2
 * Copyright (c) 2008 Jiri Svoboda
2
 * Copyright (c) 2008 Jiri Svoboda
3
 * All rights reserved.
3
 * All rights reserved.
4
 *
4
 *
5
 * Redistribution and use in source and binary forms, with or without
5
 * Redistribution and use in source and binary forms, with or without
6
 * modification, are permitted provided that the following conditions
6
 * modification, are permitted provided that the following conditions
7
 * are met:
7
 * are met:
8
 *
8
 *
9
 * - Redistributions of source code must retain the above copyright
9
 * - Redistributions of source code must retain the above copyright
10
 *   notice, this list of conditions and the following disclaimer.
10
 *   notice, this list of conditions and the following disclaimer.
11
 * - Redistributions in binary form must reproduce the above copyright
11
 * - Redistributions in binary form must reproduce the above copyright
12
 *   notice, this list of conditions and the following disclaimer in the
12
 *   notice, this list of conditions and the following disclaimer in the
13
 *   documentation and/or other materials provided with the distribution.
13
 *   documentation and/or other materials provided with the distribution.
14
 * - The name of the author may not be used to endorse or promote products
14
 * - The name of the author may not be used to endorse or promote products
15
 *   derived from this software without specific prior written permission.
15
 *   derived from this software without specific prior written permission.
16
 *
16
 *
17
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
17
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
18
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
18
 * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
19
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
19
 * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
20
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
20
 * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
21
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
21
 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
22
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
22
 * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
23
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
23
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
24
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
25
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
25
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
26
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26
 * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
27
 */
27
 */
28
 
28
 
29
/** @addtogroup genericipc
29
/** @addtogroup genericipc
30
 * @{
30
 * @{
31
 */
31
 */
32
/** @file
32
/** @file
33
 */
33
 */
34
 
34
 
35
#include <synch/synch.h>
35
#include <synch/synch.h>
36
#include <synch/spinlock.h>
36
#include <synch/spinlock.h>
37
#include <synch/mutex.h>
37
#include <synch/mutex.h>
38
#include <ipc/ipc.h>
38
#include <ipc/ipc.h>
39
#include <ipc/ipcrsc.h>
39
#include <ipc/ipcrsc.h>
40
#include <arch.h>
40
#include <arch.h>
41
#include <errno.h>
41
#include <errno.h>
42
#include <debug.h>
42
#include <debug.h>
43
#include <udebug/udebug_ipc.h>
43
#include <udebug/udebug_ipc.h>
44
#include <ipc/kbox.h>
44
#include <ipc/kbox.h>
45
 
45
 
46
void ipc_kbox_cleanup(void)
46
void ipc_kbox_cleanup(void)
47
{
47
{
-
 
48
    ipl_t ipl;
48
    bool have_kb_thread;
49
    bool have_kb_thread;
49
 
50
 
50
    /* Only hold kb_cleanup_lock while setting kb_finished - this is enough */
51
    /* Only hold kb_cleanup_lock while setting kb_finished - this is enough */
51
    mutex_lock(&TASK->kb_cleanup_lock);
52
    mutex_lock(&TASK->kb_cleanup_lock);
52
    TASK->kb_finished = true;
53
    TASK->kb_finished = true;
53
    mutex_unlock(&TASK->kb_cleanup_lock);
54
    mutex_unlock(&TASK->kb_cleanup_lock);
54
 
55
 
55
    have_kb_thread = (TASK->kb_thread != NULL);
56
    have_kb_thread = (TASK->kb_thread != NULL);
56
 
57
 
57
    /* From now on nobody will try to connect phones or attach kbox threads */
58
    /* From now on nobody will try to connect phones or attach kbox threads */
58
 
59
 
59
    /*
60
    /*
60
     * Disconnect all phones connected to our kbox. Passing true for
61
     * Disconnect all phones connected to our kbox. Passing true for
61
     * notify_box causes a HANGUP message to be inserted for each
62
     * notify_box causes a HANGUP message to be inserted for each
62
     * disconnected phone. This ensures the kbox thread is going to
63
     * disconnected phone. This ensures the kbox thread is going to
63
     * wake up and terminate.
64
     * wake up and terminate.
64
     */
65
     */
65
    ipc_answerbox_slam_phones(&TASK->kernel_box, have_kb_thread);
66
    ipc_answerbox_slam_phones(&TASK->kernel_box, have_kb_thread);
-
 
67
 
-
 
68
    /*
-
 
69
     * If the task was being debugged, clean up debugging session.
-
 
70
     * This is necessarry as slamming the phones won't force
-
 
71
     * kbox thread to clean it up since sender != debugger.
-
 
72
     */
-
 
73
    ipl = interrupts_disable();
-
 
74
    spinlock_lock(&TASK->lock);
-
 
75
    udebug_task_cleanup(TASK);
-
 
76
    spinlock_unlock(&TASK->lock);
-
 
77
    interrupts_restore(ipl);
66
   
78
   
67
    if (have_kb_thread) {
79
    if (have_kb_thread) {
68
        LOG("join kb_thread..\n");
80
        LOG("join kb_thread..\n");
69
        thread_join(TASK->kb_thread);
81
        thread_join(TASK->kb_thread);
70
        thread_detach(TASK->kb_thread);
82
        thread_detach(TASK->kb_thread);
71
        LOG("join done\n");
83
        LOG("join done\n");
72
        TASK->kb_thread = NULL;
84
        TASK->kb_thread = NULL;
73
    }
85
    }
74
 
86
 
75
    /* Answer all messages in 'calls' and 'dispatched_calls' queues */
87
    /* Answer all messages in 'calls' and 'dispatched_calls' queues */
76
    spinlock_lock(&TASK->kernel_box.lock);
88
    spinlock_lock(&TASK->kernel_box.lock);
77
    ipc_cleanup_call_list(&TASK->kernel_box.dispatched_calls);
89
    ipc_cleanup_call_list(&TASK->kernel_box.dispatched_calls);
78
    ipc_cleanup_call_list(&TASK->kernel_box.calls);
90
    ipc_cleanup_call_list(&TASK->kernel_box.calls);
79
    spinlock_unlock(&TASK->kernel_box.lock);
91
    spinlock_unlock(&TASK->kernel_box.lock);
80
}
92
}
81
 
93
 
82
 
94
 
83
static void kbox_thread_proc(void *arg)
95
static void kbox_thread_proc(void *arg)
84
{
96
{
85
    call_t *call;
97
    call_t *call;
86
    int method;
98
    int method;
87
    bool done;
99
    bool done;
88
    ipl_t ipl;
100
    ipl_t ipl;
89
 
101
 
90
    (void)arg;
102
    (void)arg;
91
    LOG("kbox_thread_proc()\n");
103
    LOG("kbox_thread_proc()\n");
92
    done = false;
104
    done = false;
93
 
105
 
94
    while (!done) {
106
    while (!done) {
95
        call = ipc_wait_for_call(&TASK->kernel_box, SYNCH_NO_TIMEOUT,
107
        call = ipc_wait_for_call(&TASK->kernel_box, SYNCH_NO_TIMEOUT,
96
            SYNCH_FLAGS_NONE);
108
            SYNCH_FLAGS_NONE);
97
 
109
 
98
        if (call != NULL) {
110
        if (call != NULL) {
99
            method = IPC_GET_METHOD(call->data);
111
            method = IPC_GET_METHOD(call->data);
100
 
112
 
101
            if (method == IPC_M_DEBUG_ALL) {
113
            if (method == IPC_M_DEBUG_ALL) {
102
                udebug_call_receive(call);
114
                udebug_call_receive(call);
103
            }
115
            }
104
 
116
 
105
            if (method == IPC_M_PHONE_HUNGUP) {
117
            if (method == IPC_M_PHONE_HUNGUP) {
106
                LOG("kbox: handle hangup message\n");
118
                LOG("kbox: handle hangup message\n");
107
 
119
 
108
                /* Was it our debugger, who hung up? */
120
                /* Was it our debugger, who hung up? */
109
                if (call->sender == TASK->udebug.debugger) {
121
                if (call->sender == TASK->udebug.debugger) {
110
                    /* Terminate debugging session (if any) */
122
                    /* Terminate debugging session (if any) */
111
                    LOG("kbox: terminate debug session\n");
123
                    LOG("kbox: terminate debug session\n");
112
                    ipl = interrupts_disable();
124
                    ipl = interrupts_disable();
113
                    spinlock_lock(&TASK->lock);
125
                    spinlock_lock(&TASK->lock);
114
                    udebug_task_cleanup(TASK);
126
                    udebug_task_cleanup(TASK);
115
                    spinlock_unlock(&TASK->lock);
127
                    spinlock_unlock(&TASK->lock);
116
                    interrupts_restore(ipl);
128
                    interrupts_restore(ipl);
117
                } else {
129
                } else {
118
                    LOG("kbox: was not debugger\n");
130
                    LOG("kbox: was not debugger\n");
119
                }
131
                }
120
 
132
 
121
                LOG("kbox: continue with hangup message\n");
133
                LOG("kbox: continue with hangup message\n");
122
                IPC_SET_RETVAL(call->data, 0);
134
                IPC_SET_RETVAL(call->data, 0);
123
                ipc_answer(&TASK->kernel_box, call);
135
                ipc_answer(&TASK->kernel_box, call);
124
 
136
 
125
                ipl = interrupts_disable();
137
                ipl = interrupts_disable();
126
                spinlock_lock(&TASK->lock);
138
                spinlock_lock(&TASK->lock);
127
                spinlock_lock(&TASK->answerbox.lock);
139
                spinlock_lock(&TASK->answerbox.lock);
128
                if (list_empty(&TASK->answerbox.connected_phones)) {
140
                if (list_empty(&TASK->answerbox.connected_phones)) {
-
 
141
                    /*
129
                    /* Last phone has been disconnected */
142
                     * Last phone has been disconnected.
-
 
143
                     */
-
 
144
 
-
 
145
                    /* Detach thread so it gets freed. */
-
 
146
                    thread_detach(TASK->kb_thread);
130
                    TASK->kb_thread = NULL;
147
                    TASK->kb_thread = NULL;
131
                    done = true;
148
                    done = true;
132
                    LOG("phone list is empty\n");
149
                    LOG("phone list is empty\n");
133
                }
150
                }
134
                spinlock_unlock(&TASK->answerbox.lock);
151
                spinlock_unlock(&TASK->answerbox.lock);
135
                spinlock_unlock(&TASK->lock);
152
                spinlock_unlock(&TASK->lock);
136
                interrupts_restore(ipl);
153
                interrupts_restore(ipl);
137
            }
154
            }
138
        }
155
        }
139
    }
156
    }
140
 
157
 
141
    LOG("kbox: finished\n");
158
    LOG("kbox: finished\n");
142
}
159
}
143
 
160
 
144
 
161
 
145
/**
162
/**
146
 * Connect phone to a task kernel-box specified by id.
163
 * Connect phone to a task kernel-box specified by id.
147
 *
164
 *
148
 * Note that this is not completely atomic. For optimisation reasons,
165
 * Note that this is not completely atomic. For optimisation reasons,
149
 * The task might start cleaning up kbox after the phone has been connected
166
 * The task might start cleaning up kbox after the phone has been connected
150
 * and before a kbox thread has been created. This must be taken into account
167
 * and before a kbox thread has been created. This must be taken into account
151
 * in the cleanup code.
168
 * in the cleanup code.
152
 *
169
 *
153
 * @return      Phone id on success, or negative error code.
170
 * @return      Phone id on success, or negative error code.
154
 */
171
 */
155
int ipc_connect_kbox(task_id_t taskid)
172
int ipc_connect_kbox(task_id_t taskid)
156
{
173
{
157
    int newphid;
174
    int newphid;
158
    task_t *ta;
175
    task_t *ta;
159
    thread_t *kb_thread;
176
    thread_t *kb_thread;
160
    ipl_t ipl;
177
    ipl_t ipl;
161
 
178
 
162
    ipl = interrupts_disable();
179
    ipl = interrupts_disable();
163
    spinlock_lock(&tasks_lock);
180
    spinlock_lock(&tasks_lock);
164
 
181
 
165
    ta = task_find_by_id(taskid);
182
    ta = task_find_by_id(taskid);
166
    if (ta == NULL) {
183
    if (ta == NULL) {
167
        spinlock_unlock(&tasks_lock);
184
        spinlock_unlock(&tasks_lock);
168
        interrupts_restore(ipl);
185
        interrupts_restore(ipl);
169
        return ENOENT;
186
        return ENOENT;
170
    }
187
    }
171
 
188
 
172
    atomic_inc(&ta->refcount);
189
    atomic_inc(&ta->refcount);
173
 
190
 
174
    spinlock_unlock(&tasks_lock);
191
    spinlock_unlock(&tasks_lock);
175
    interrupts_restore(ipl);
192
    interrupts_restore(ipl);
176
 
193
 
177
    mutex_lock(&ta->kb_cleanup_lock);
194
    mutex_lock(&ta->kb_cleanup_lock);
178
 
195
 
179
    if (atomic_predec(&ta->refcount) == 0) {
196
    if (atomic_predec(&ta->refcount) == 0) {
180
        mutex_unlock(&ta->kb_cleanup_lock);
197
        mutex_unlock(&ta->kb_cleanup_lock);
181
        task_destroy(ta);
198
        task_destroy(ta);
182
        return ENOENT;
199
        return ENOENT;
183
    }
200
    }
184
 
201
 
185
    if (ta->kb_finished != false) {
202
    if (ta->kb_finished != false) {
186
        mutex_unlock(&ta->kb_cleanup_lock);
203
        mutex_unlock(&ta->kb_cleanup_lock);
187
        return EINVAL;
204
        return EINVAL;
188
    }
205
    }
189
 
206
 
190
    newphid = phone_alloc();
207
    newphid = phone_alloc();
191
    if (newphid < 0) {
208
    if (newphid < 0) {
192
        mutex_unlock(&ta->kb_cleanup_lock);
209
        mutex_unlock(&ta->kb_cleanup_lock);
193
        return ELIMIT;
210
        return ELIMIT;
194
    }
211
    }
195
 
212
 
196
    /* Connect the newly allocated phone to the kbox */
213
    /* Connect the newly allocated phone to the kbox */
197
    ipc_phone_connect(&TASK->phones[newphid], &ta->kernel_box);
214
    ipc_phone_connect(&TASK->phones[newphid], &ta->kernel_box);
198
 
215
 
199
    if (ta->kb_thread != NULL) {
216
    if (ta->kb_thread != NULL) {
200
        mutex_unlock(&ta->kb_cleanup_lock);
217
        mutex_unlock(&ta->kb_cleanup_lock);
201
        return newphid;
218
        return newphid;
202
    }
219
    }
203
 
220
 
204
    /* Create a kbox thread */
221
    /* Create a kbox thread */
205
    kb_thread = thread_create(kbox_thread_proc, NULL, ta, 0, "kbox", false);
222
    kb_thread = thread_create(kbox_thread_proc, NULL, ta, 0, "kbox", false);
206
    if (!kb_thread) {
223
    if (!kb_thread) {
207
        mutex_unlock(&ta->kb_cleanup_lock);
224
        mutex_unlock(&ta->kb_cleanup_lock);
208
        return ENOMEM;
225
        return ENOMEM;
209
    }
226
    }
210
 
227
 
211
    ta->kb_thread = kb_thread;
228
    ta->kb_thread = kb_thread;
212
    thread_ready(kb_thread);
229
    thread_ready(kb_thread);
213
 
230
 
214
    mutex_unlock(&ta->kb_cleanup_lock);
231
    mutex_unlock(&ta->kb_cleanup_lock);
215
 
232
 
216
    return newphid;
233
    return newphid;
217
}
234
}
218
 
235
 
219
/** @}
236
/** @}
220
 */
237
 */
221
 
238