Whamcloud - gitweb
i=liang,b=13065:
[fs/lustre-release.git] / lnet / lnet / lib-me.c
1 /* -*- mode: c; c-basic-offset: 8; indent-tabs-mode: nil; -*-
2  * vim:expandtab:shiftwidth=8:tabstop=8:
3  *
4  * GPL HEADER START
5  *
6  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
7  *
8  * This program is free software; you can redistribute it and/or modify
9  * it under the terms of the GNU General Public License version 2 only,
10  * as published by the Free Software Foundation.
11  *
12  * This program is distributed in the hope that it will be useful, but
13  * WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
15  * General Public License version 2 for more details (a copy is included
16  * in the LICENSE file that accompanied this code).
17  *
18  * You should have received a copy of the GNU General Public License
19  * version 2 along with this program; If not, see
20  * http://www.sun.com/software/products/lustre/docs/GPLv2.pdf
21  *
22  * Please contact Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,
23  * CA 95054 USA or visit www.sun.com if you need additional information or
24  * have any questions.
25  *
26  * GPL HEADER END
27  */
28 /*
29  * Copyright  2008 Sun Microsystems, Inc. All rights reserved
30  * Use is subject to license terms.
31  */
32 /*
33  * This file is part of Lustre, http://www.lustre.org/
34  * Lustre is a trademark of Sun Microsystems, Inc.
35  *
36  * lnet/lnet/lib-me.c
37  *
38  * Match Entry management routines
39  */
40
41 #define DEBUG_SUBSYSTEM S_LNET
42
43 #include <lnet/lib-lnet.h>
44
45 int
46 LNetMEAttach(unsigned int portal,
47              lnet_process_id_t match_id,
48              __u64 match_bits, __u64 ignore_bits,
49              lnet_unlink_t unlink, lnet_ins_pos_t pos,
50              lnet_handle_me_t *handle)
51 {
52         lnet_me_t     *me;
53
54         LASSERT (the_lnet.ln_init);
55         LASSERT (the_lnet.ln_refcount > 0);
56
57         if ((int)portal >= the_lnet.ln_nportals)
58                 return -EINVAL;
59
60         me = lnet_me_alloc();
61         if (me == NULL)
62                 return -ENOMEM;
63
64         LNET_LOCK();
65
66         me->me_portal = portal;
67         me->me_match_id = match_id;
68         me->me_match_bits = match_bits;
69         me->me_ignore_bits = ignore_bits;
70         me->me_unlink = unlink;
71         me->me_md = NULL;
72
73         lnet_initialise_handle (&me->me_lh, LNET_COOKIE_TYPE_ME);
74
75         if (pos == LNET_INS_AFTER)
76                 list_add_tail(&me->me_list, &(the_lnet.ln_portals[portal].ptl_ml));
77         else
78                 list_add(&me->me_list, &(the_lnet.ln_portals[portal].ptl_ml));
79
80         lnet_me2handle(handle, me);
81
82         LNET_UNLOCK();
83
84         return 0;
85 }
86
87 int
88 LNetMEInsert(lnet_handle_me_t current_meh,
89              lnet_process_id_t match_id,
90              __u64 match_bits, __u64 ignore_bits,
91              lnet_unlink_t unlink, lnet_ins_pos_t pos,
92              lnet_handle_me_t *handle)
93 {
94         lnet_me_t     *current_me;
95         lnet_me_t     *new_me;
96
97         LASSERT (the_lnet.ln_init);
98         LASSERT (the_lnet.ln_refcount > 0);
99
100         new_me = lnet_me_alloc();
101         if (new_me == NULL)
102                 return -ENOMEM;
103
104         LNET_LOCK();
105
106         current_me = lnet_handle2me(&current_meh);
107         if (current_me == NULL) {
108                 lnet_me_free (new_me);
109
110                 LNET_UNLOCK();
111                 return -ENOENT;
112         }
113
114         new_me->me_portal = current_me->me_portal;
115         new_me->me_match_id = match_id;
116         new_me->me_match_bits = match_bits;
117         new_me->me_ignore_bits = ignore_bits;
118         new_me->me_unlink = unlink;
119         new_me->me_md = NULL;
120
121         lnet_initialise_handle (&new_me->me_lh, LNET_COOKIE_TYPE_ME);
122
123         if (pos == LNET_INS_AFTER)
124                 list_add(&new_me->me_list, &current_me->me_list);
125         else
126                 list_add_tail(&new_me->me_list, &current_me->me_list);
127
128         lnet_me2handle(handle, new_me);
129
130         LNET_UNLOCK();
131
132         return 0;
133 }
134
135 int
136 LNetMEUnlink(lnet_handle_me_t meh)
137 {
138         lnet_me_t    *me;
139         lnet_libmd_t *md;
140         lnet_event_t  ev;
141
142         LASSERT (the_lnet.ln_init);
143         LASSERT (the_lnet.ln_refcount > 0);
144
145         LNET_LOCK();
146
147         me = lnet_handle2me(&meh);
148         if (me == NULL) {
149                 LNET_UNLOCK();
150                 return -ENOENT;
151         }
152
153         md = me->me_md;
154         if (md != NULL &&
155             md->md_eq != NULL &&
156             md->md_refcount == 0) {
157                 lnet_build_unlink_event(md, &ev);
158                 lnet_enq_event_locked(md->md_eq, &ev);
159         }
160
161         lnet_me_unlink(me);
162
163         LNET_UNLOCK();
164         return 0;
165 }
166
167 /* call with LNET_LOCK please */
168 void
169 lnet_me_unlink(lnet_me_t *me)
170 {
171         list_del (&me->me_list);
172
173         if (me->me_md != NULL) {
174                 me->me_md->md_me = NULL;
175                 lnet_md_unlink(me->me_md);
176         }
177
178         lnet_invalidate_handle (&me->me_lh);
179         lnet_me_free(me);
180 }
181
182 #if 0
183 static void
184 lib_me_dump(lnet_me_t *me)
185 {
186         CWARN("Match Entry %p ("LPX64")\n", me,
187               me->me_lh.lh_cookie);
188
189         CWARN("\tMatch/Ignore\t= %016lx / %016lx\n",
190               me->me_match_bits, me->me_ignore_bits);
191
192         CWARN("\tMD\t= %p\n", me->md);
193         CWARN("\tprev\t= %p\n",
194               list_entry(me->me_list.prev, lnet_me_t, me_list));
195         CWARN("\tnext\t= %p\n",
196               list_entry(me->me_list.next, lnet_me_t, me_list));
197 }
198 #endif