source: asp3_tinet_ecnl_rx/trunk/asp3_dcre/tinet/netinet/udpn_usrreq_nblk.c@ 364

Last change on this file since 364 was 364, checked in by coas-nagasima, 5 years ago

TINETとSocket APIなどを更新
  • Property svn:eol-style set to native
  • Property svn:mime-type set to text/x-csrc;charset=UTF-8
File size: 12.4 KB
Line 
1/*
2 * TINET (UDP/IP Protocol Stack)
3 *
4 * Copyright (C) 2001-2017 by Dep. of Computer Science and Engineering
5 * Tomakomai National College of Technology, JAPAN
6 *
7 * 上記著作権者は，以下の (1)～(4) の条件か，Free Software Foundation
8 * によって公表されている GNU General Public License の Version 2 に記
9 * 述されている条件を満たす場合に限り，本ソフトウェア（本ソフトウェア
10 * を改変したものを含む．以下同じ）を使用・複製・改変・再配布（以下，
11 * 利用と呼ぶ）することを無償で許諾する．
12 * (1) 本ソフトウェアをソースコードの形で利用する場合には，上記の著作
13 * 権表示，この利用条件および下記の無保証規定が，そのままの形でソー
14 * スコード中に含まれていること．
15 * (2) 本ソフトウェアを，ライブラリ形式など，他のソフトウェア開発に使
16 * 用できる形で再配布する場合には，再配布に伴うドキュメント（利用
17 * 者マニュアルなど）に，上記の著作権表示，この利用条件および下記
18 * の無保証規定を掲載すること．
19 * (3) 本ソフトウェアを，機器に組み込むなど，他のソフトウェア開発に使
20 * 用できない形で再配布する場合には，次の条件を満たすこと．
21 * (a) 再配布に伴うドキュメント（利用者マニュアルなど）に，上記の著
22 * 作権表示，この利用条件および下記の無保証規定を掲載すること．
23 * (4) 本ソフトウェアの利用により直接的または間接的に生じるいかなる損
24 * 害からも，上記著作権者およびTOPPERSプロジェクトを免責すること．
25 *
26 * 本ソフトウェアは，無保証で提供されているものである．上記著作権者お
27 * よびTOPPERSプロジェクトは，本ソフトウェアに関して，その適用可能性も
28 * 含めて，いかなる保証も行わない．また，本ソフトウェアの利用により直
29 * 接的または間接的に生じたいかなる損害に関しても，その責任を負わない．
30 *
31 * @(#) $Id$
32 */
33
34/*
35 * Copyright (c) 1982, 1986, 1988, 1990, 1993, 1995
36 * The Regents of the University of California. All rights reserved.
37 *
38 * Redistribution and use in source and binary forms, with or without
39 * modification, are permitted provided that the following conditions
40 * are met:
41 * 1. Redistributions of source code must retain the above copyright
42 * notice, this list of conditions and the following disclaimer.
43 * 2. Redistributions in binary form must ceproduce the above copyright
44 * notice, this list of conditions and the following disclaimer in the
45 * documentation and/or other materials provided with the distribution.
46 * 3. All advertising materials mentioning features or use of this software
47 * must display the following acknowledgement:
48 * This product includes software developed by the University of
49 * California, Berkeley and its contributors.
50 * 4. Neither the name of the University nor the names of its contributors
51 * may be used to endorse or promote products derived from this software
52 * without specific prior written permission.
53 *
54 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
55 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
56 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
57 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
58 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
59 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
60 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
61 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
62 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
63 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
64 * SUCH DAMAGE.
65 *
66 * @(#)udp_usrreq.c 8.6 (Berkeley) 5/23/95
67 * $FreeBSD: src/sys/netinet/udp_usrreq.c,v 1.49.2.2 1999/08/29 16:29:58 peter Exp $
68 */
69
70#ifdef __udp_can_snd_nblk
71
72/*
73 * udp_can_snd -- ペンディングしている送信のキャンセル
74 */
75
76ER
77UDP_CAN_SND (T_UDP_CEP *cep, ER error)
78{
79 if (cep->snd_p_dstaddr != NULL) { /* ノンブロッキングコールでペンディング中 */
80 if (IS_PTR_DEFINED(cep->callback))
81
82#ifdef TCP_CFG_NON_BLOCKING_COMPAT14
83 (*cep->callback)(GET_UDP_CEPID(cep), TFN_UDP_SND_DAT, (void*)error);
84#else
85 (*cep->callback)(GET_UDP_CEPID(cep), TFN_UDP_SND_DAT, (void*)&error);
86#endif
87 else
88 error = E_OBJ;
89 cep->snd_p_dstaddr = NULL;
90 }
91 else if (cep->snd_tskid != TA_NULL) { /* 非ノンブロッキングコールでペンディング中 */
92
93#ifdef UDP_CFG_EXTENTIONS
94
95 /* 待ち中に発生したエラー情報を設定する。*/
96 cep->error = error;
97
98#endif /* of #ifdef UDP_CFG_EXTENTIONS */
99
100 error = rel_wai(cep->snd_tskid);
101 cep->snd_tskid = TA_NULL;
102 }
103 else /* どちらでもないならペンディングしていない */
104 error = EV_NOPND;
105
106 return error;
107 }
108
109#endif /* of #ifdef __udp_can_snd_nblk */
110
111#ifdef __udp_can_rcv_nblk
112
113/*
114 * udp_can_rcv -- ペンディングしている受信のキャンセル
115 */
116
117ER
118UDP_CAN_RCV (T_UDP_CEP *cep, ER error)
119{
120 if (cep->rcv_p_dstaddr != NULL) { /* ノンブロッキングコールでペンディング中 */
121 if (IS_PTR_DEFINED(cep->callback))
122
123#ifdef TCP_CFG_NON_BLOCKING_COMPAT14
124 (*cep->callback)(GET_UDP_CEPID(cep), TFN_UDP_CAN_CEP, (void*)error);
125#else
126 (*cep->callback)(GET_UDP_CEPID(cep), TFN_UDP_CAN_CEP, (void*)&error);
127#endif
128 else
129 error = E_OBJ;
130 cep->rcv_p_dstaddr = NULL;
131 }
132 else if (cep->rcv_tskid != TA_NULL) { /* 非ノンブロッキングコールでペンディング中 */
133
134#ifdef UDP_CFG_EXTENTIONS
135
136 /* 待ち中に発生したエラー情報を設定する。*/
137 cep->error = error;
138
139#endif /* of #ifdef UDP_CFG_EXTENTIONS */
140
141 error = rel_wai(cep->rcv_tskid);
142 cep->rcv_tskid = TA_NULL;
143 }
144 else /* どちらでもないならペンディングしていない */
145 error = EV_NOPND;
146
147 return error;
148 }
149
150#endif /* of #ifdef __udp_can_rcv_nblk */
151
152#ifdef __udp_snd_dat_nblk
153
154/*
155 * udp_snd_dat -- パケットの送信【標準機能】
156 */
157
158ER_UINT
159UDP_SND_DAT (ID cepid, T_IPEP *p_dstaddr, void *data, int_t len, TMO tmout)
160{
161 T_UDP_CEP *cep;
162 ER error;
163
164 /* p_dstaddr または data が NULL ならエラー */
165 if (p_dstaddr == NULL || data == NULL)
166 return E_PAR;
167
168 /* データ長をチェックする。*/
169 if (len < 0 || len + IP_HDR_SIZE + UDP_HDR_SIZE > IF_MTU)
170 return E_PAR;
171
172#if (API_PROTO == API_PROTO_IPV6) && !defined(API_CFG_IP4MAPPED_ADDR)
173
174 /*
175 * API が IPv6 で IPv4 射影アドレスが認められていないのにもかかわらず、
176 * IPv4 射影アドレスが指定されたらエラー
177 */
178 if (in6_is_addr_ipv4mapped(&p_dstaddr->ipaddr))
179 return E_PAR;
180
181#endif /* of #if (API_PROTO == API_PROTO_IPV6) && !defined(DAPI_CFG_IP4MAPPED_ADDR) */
182
183 /* UDP 通信端点 ID をチェックする。*/
184 if (!VALID_UDP_CEPID(cepid))
185 return E_ID;
186
187 /* UDP 通信端点を得る。*/
188 cep = GET_UDP_CEP(cepid);
189
190 /* UDP 通信端点をチェックする。*/
191 if (!VALID_UDP_CEP(cep))
192 return E_NOEXS;
193
194 /*
195 * 自ポート番号が UDP_PORTANY なら、自動で割り当てる。
196 */
197 if (cep->myaddr.portno == UDP_PORTANY) {
198 if ((error = UDP_ALLOC_AUTO_PORT(cep)) != E_OK)
199 return error;
200 }
201
202 /*
203 * タイムアウトをチェックする。
204 */
205 if (tmout == TMO_NBLK) { /* ノンブロッキングコール */
206
207 /* 通信端点をロックする。*/
208 syscall(wai_sem(cep->semid_lock));
209
210 if (cep->snd_p_dstaddr != NULL) {
211
212 /* ノンブロッキングコールでペンディング中 */
213 error = E_QOVR;
214
215 /* 通信端点をロックを解除する。*/
216 syscall(sig_sem(cep->semid_lock));
217 }
218 else if (cep->snd_tskid != TA_NULL) {
219
220 /* 非ノンブロッキングコールでペンディング中 */
221 error = E_OBJ;
222
223 /* 通信端点をロックを解除する。*/
224 syscall(sig_sem(cep->semid_lock));
225 }
226 else {
227
228 cep->snd_p_dstaddr = p_dstaddr;
229 cep->snd_data = data;
230 cep->snd_len = len;
231
232 /* 通信端点をロックを解除する。*/
233 syscall(sig_sem(cep->semid_lock));
234
235 cep->flags |= UDP_CEP_FLG_POST_OUTPUT;
236 sig_sem(SEM_UDP_POST_OUTPUT);
237 error = E_WBLK;
238 }
239 }
240 else { /* 非ノンブロッキングコール */
241
242 /* 通信端点をロックする。*/
243 syscall(wai_sem(cep->semid_lock));
244
245 if (cep->snd_p_dstaddr != NULL) {
246
247 /* ノンブロッキングコールでペンディング中 */
248 error = E_OBJ;
249
250 /* 通信端点をロックを解除する。*/
251 syscall(sig_sem(cep->semid_lock));
252 }
253 else if (cep->snd_tskid != TA_NULL) {
254
255 /* 非ノンブロッキングコールでペンディング中 */
256 error = E_QOVR;
257
258 /* 通信端点をロックを解除する。*/
259 syscall(sig_sem(cep->semid_lock));
260 }
261 else {
262
263 /* 現在のタスク識別子を記録する。*/
264 get_tid(&(cep->snd_tskid));
265
266 /* 通信端点をロックを解除する。*/
267 syscall(sig_sem(cep->semid_lock));
268
269 /* パケットを送信する。*/
270 error = UDP_SEND_DATA(cep, p_dstaddr, data, len, tmout);
271 }
272 }
273
274 return error;
275 }
276
277#endif /* of #ifdef __udp_snd_dat_nblk */
278
279#ifdef __udp_rcv_dat_nblk
280
281/*
282 * udp_rcv_dat -- パケットの受信【標準機能】
283 */
284
285ER_UINT
286UDP_RCV_DAT (ID cepid, T_IPEP *p_dstaddr, void *data, int_t len, TMO tmout)
287{
288 T_NET_BUF *input;
289 T_UDP_CEP *cep;
290 T_UDP_HDR *udph;
291 ER_UINT error;
292 uint_t ulen, uhoff;
293
294 /* p_dstaddr または data が NULL か、len < 0 ならエラー */
295 if (p_dstaddr == NULL || data == NULL || len < 0)
296 return E_PAR;
297
298 /* UDP 通信端点 ID をチェックする。*/
299 if (!VALID_UDP_CEPID(cepid))
300 return E_ID;
301
302 /* UDP 通信端点を得る。*/
303 cep = GET_UDP_CEP(cepid);
304
305 /* UDP 通信端点をチェックする。*/
306 if (!VALID_UDP_CEP(cep))
307 return E_NOEXS;
308
309 /*
310 * タイムアウトをチェックする。
311 */
312
313 if (tmout == TMO_NBLK) { /* ノンブロッキングコール */
314
315 /* 通信端点をロックする。*/
316 syscall(wai_sem(cep->semid_lock));
317
318 if (cep->rcv_p_dstaddr != NULL)
319
320 /* ノンブロッキングコールでペンディング中 */
321 error = E_QOVR;
322
323 else if (cep->rcv_tskid != TA_NULL)
324
325 /* 非ノンブロッキングコールでペンディング中 */
326 error = E_OBJ;
327 else {
328 cep->rcv_p_dstaddr = p_dstaddr;
329 cep->rcv_data = data;
330 cep->rcv_len = len;
331 error = E_WBLK;
332 }
333
334 /* 通信端点をロックを解除する。*/
335 syscall(sig_sem(cep->semid_lock));
336 return error;
337 }
338 else { /* 非ノンブロッキングコール */
339
340 /* 通信端点をロックする。*/
341 syscall(wai_sem(cep->semid_lock));
342
343 if (cep->rcv_p_dstaddr != NULL) {
344
345 /* ノンブロッキングコールでペンディング中 */
346 error = E_OBJ;
347
348 /* 通信端点をロックを解除する。*/
349 syscall(sig_sem(cep->semid_lock));
350 }
351 else if (cep->rcv_tskid != TA_NULL) {
352
353 /* 非ノンブロッキングコールでペンディング中 */
354 error = E_QOVR;
355
356 /* 通信端点をロックを解除する。*/
357 syscall(sig_sem(cep->semid_lock));
358 }
359 else {
360
361 /* 現在のタスク識別子を記録する。*/
362 get_tid(&(cep->rcv_tskid));
363
364 /* 通信端点をロックを解除する。*/
365 syscall(sig_sem(cep->semid_lock));
366
367 /* 入力があるまで待つ。*/
368 if (cep->cb_netbuf != NULL) {
369
370 /*
371 * ここにくる場合は、コールバック関数の中から
372 * udp_rcv_dat を呼び出していることになり、
373 * すでに入力済みである。
374 */
375 input = cep->cb_netbuf;
376 cep->cb_netbuf = NULL;
377 }
378 else if ((error = trcv_dtq(cep->rcvqid, (intptr_t*)&input, tmout)) != E_OK) {
379 cep->rcv_tskid = TA_NULL;
380 return error;
381 }
382
383 /* p_dstaddr を設定する。*/
384 uhoff = (uint_t)GET_UDP_HDR_OFFSET(input);
385 udph = GET_UDP_HDR(input, uhoff);
386 p_dstaddr->portno = ntohs(udph->sport);
387 IN_COPY_TO_HOST(&p_dstaddr->ipaddr, input);
388
389 /* データをバッファに移す。*/
390 ulen = ntohs(udph->ulen);
391 if (ulen - UDP_HDR_SIZE > len)
392 error = E_BOVR;
393 else {
394 len = (int_t)(ulen - UDP_HDR_SIZE);
395 error = (ER_UINT)(ulen - UDP_HDR_SIZE);
396 }
397
398 memcpy(data, GET_UDP_SDU(input, uhoff), (size_t)len);
399
400 syscall(rel_net_buf(input));
401
402 cep->rcv_tskid = TA_NULL;
403 }
404 return error;
405 }
406 }
407
408#endif /* of #ifdef __udp_rcv_dat_nblk */
Note: See TracBrowser for help on using the repository browser.