source: rubycfg_asp/trunk/asp_dcre/tinet/netinet/udpn_usrreq.c@ 313

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

ソースを追加
  • Property svn:eol-style set to native
  • Property svn:keywords set to Id
  • Property svn:mime-type set to text/x-csrc
File size: 20.0 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 * 上記著作権者
8は，以下の (1)～(4) の条件か，Free Software Foundation
9 * によってå…
10¬è¡¨ã•ã‚Œã¦ã„ã‚‹ GNU General Public License の Version 2 に記
11 * 述されている条件を満たす場合に限り，本ソフトウェア（本ソフトウェア
12 * を改変したものを含む．以下同じ）を使用・複製・改変・再é…
13å¸ƒï¼ˆä»¥ä¸‹ï¼Œ
14 * 利用と呼ぶ）することを無償で許諾する．
15 * (1) 本ソフトウェアをソースコードの形で利用する場合には，上記の著作
16 * 権表示，この利用条件および下記の無保証規定が，そのままの形でソー
17 * スコード中に含まれていること．
18 * (2) 本ソフトウェアを，ライブラリ形式など，他のソフトウェア開発に使
19 * 用できる形で再é…
20å¸ƒã™ã‚‹å ´åˆã«ã¯ï¼Œå†é…
21å¸ƒã«ä¼´ã†ãƒ‰ã‚­ãƒ¥ãƒ¡ãƒ³ãƒˆï¼ˆåˆ©ç”¨
22 * 者
23マニュアルなど）に，上記の著作権表示，この利用条件および下記
24 * の無保証規定を掲載すること．
25 * (3) 本ソフトウェアを，機器に組み込むなど，他のソフトウェア開発に使
26 * 用できない形で再é…
27å¸ƒã™ã‚‹å ´åˆã«ã¯ï¼Œæ¬¡ã®æ¡ä»¶ã‚’満たすこと．
28 * (a) 再é…
29å¸ƒã«ä¼´ã†ãƒ‰ã‚­ãƒ¥ãƒ¡ãƒ³ãƒˆï¼ˆåˆ©ç”¨è€…
30マニュアルなど）に，上記の著
31 * 作権表示，この利用条件および下記の無保証規定を掲載すること．
32 * (4) 本ソフトウェアの利用により直接的または間接的に生じるいかなる損
33 * 害からも，上記著作権者
34およびTOPPERSプロジェクトをå…
35è²¬ã™ã‚‹ã“と．
36 *
37 * 本ソフトウェアは，無保証で提供されているものである．上記著作権者
38お
39 * よびTOPPERSプロジェクトは，本ソフトウェアに関して，その適用可能性も
40 * 含めて，いかなる保証も行わない．また，本ソフトウェアの利用により直
41 * 接的または間接的に生じたいかなる損害に関しても，その責任を負わない．
42 *
43 * @(#) $Id: udpn_usrreq.c 313 2017-07-23 04:50:32Z coas-nagasima $
44 */
45
46/*
47 * Copyright (c) 1982, 1986, 1988, 1990, 1993, 1995
48 * The Regents of the University of California. All rights reserved.
49 *
50 * Redistribution and use in source and binary forms, with or without
51 * modification, are permitted provided that the following conditions
52 * are met:
53 * 1. Redistributions of source code must retain the above copyright
54 * notice, this list of conditions and the following disclaimer.
55 * 2. Redistributions in binary form must ceproduce the above copyright
56 * notice, this list of conditions and the following disclaimer in the
57 * documentation and/or other materials provided with the distribution.
58 * 3. All advertising materials mentioning features or use of this software
59 * must display the following acknowledgement:
60 * This product includes software developed by the University of
61 * California, Berkeley and its contributors.
62 * 4. Neither the name of the University nor the names of its contributors
63 * may be used to endorse or promote products derived from this software
64 * without specific prior written permission.
65 *
66 * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
67 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
68 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
69 * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
70 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
71 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
72 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
73 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
74 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
75 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
76 * SUCH DAMAGE.
77 *
78 * @(#)udp_usrreq.c 8.6 (Berkeley) 5/23/95
79 * $FreeBSD: src/sys/netinet/udp_usrreq.c,v 1.49.2.2 1999/08/29 16:29:58 peter Exp $
80 */
81
82#ifdef __udp_send_data
83
84/*
85 * udp_send_data -- パケット送信の主要部
86 */
87
88ER_UINT
89UDP_SEND_DATA (T_UDP_CEP *cep, T_IPEP *p_dstaddr, void *data, int_t len, TMO tmout)
90{
91 T_NET_BUF *output;
92 T_UDP_HDR *udph;
93 SYSTIM before, after;
94 ER error = E_OK;
95
96#ifdef UDP_CFG_OUT_CHECKSUM
97 uint16_t sum;
98#endif /* of #ifdef UDP_CFG_OUT_CHECKSUM */
99
100 NET_COUNT_UDP(net_count_udp.out_octets, len);
101 NET_COUNT_UDP(net_count_udp.out_packets, 1);
102
103 /* IP データグラム割り当ての時間を tmout から減ずる。*/
104 if (!(tmout == TMO_POL || tmout == TMO_FEVR))
105 syscall(get_tim(&before));
106
107 /* IP データグラムを割り当てる。*/
108 if ((error = IN_GET_DATAGRAM(&output, (uint_t)(UDP_HDR_SIZE + len), 0,
109 &p_dstaddr->ipaddr,
110 &cep->myaddr.ipaddr,
111 IPPROTO_UDP, IP_DEFTTL,
112 NBA_SEARCH_ASCENT, tmout)) != E_OK)
113 goto err_ret;
114
115 /* IP データグラム割り当ての時間を tmout から減ずる。*/
116 if (!(tmout == TMO_POL || tmout == TMO_FEVR)) {
117 syscall(get_tim(&after));
118 if (after - before > tmout) {
119 syscall(rel_net_buf(output));
120 error = E_TMOUT;
121 goto err_ret;
122 }
123 tmout -= (TMO)(after - before);
124 }
125
126 /* UDP ヘッダに情
127報を設定する。*/
128 udph = GET_UDP_HDR(output, IF_IP_UDP_HDR_OFFSET(output));
129 udph->sport = htons(cep->myaddr.portno);
130 udph->dport = htons(p_dstaddr->portno);
131 udph->ulen = htons(UDP_HDR_SIZE + len);
132 udph->sum = 0;
133
134 /* データをコピーする。*/
135 memcpy((void*)GET_UDP_SDU(output, IF_IP_UDP_HDR_OFFSET(output)), data, (size_t)len);
136
137#ifdef UDP_CFG_OUT_CHECKSUM
138
139 sum = IN_CKSUM(output, IPPROTO_UDP, IF_IP_UDP_HDR_OFFSET(output), (uint_t)(UDP_HDR_SIZE + len));
140
141 /* 計算したチェックサムの値が 0 なら 0xffff をå…
142¥ã‚Œã‚‹ã€‚*/
143 if (sum == 0)
144 sum = 0xffff;
145 udph->sum = sum;
146
147#endif /* of #ifdef UDP_CFG_OUT_CHECKSUM */
148
149 /* ネットワークバッファ長を調整する。*/
150 output->len = (uint16_t)(IF_IP_UDP_HDR_SIZE(output) + len);
151
152 /* ネットワーク層 (IP) の出力関数を呼び出す。*/
153 if ((error = IP_OUTPUT(output, tmout)) == E_OK) {
154 NET_COUNT_MIB(udp_stats.udpOutDatagrams, 1);
155 cep->snd_tskid = TA_NULL;
156 return len;
157 }
158
159err_ret:
160 NET_COUNT_UDP(net_count_udp.out_err_packets, 1);
161 cep->snd_tskid = TA_NULL;
162 return error;
163 }
164
165#endif /* of #ifdef __udp_send_data */
166
167/*
168 * udp_cancel_cep -- ペンディングしている処理をキャンセルする。
169 *
170 * udp_can_cep から呼出されるメイン関数
171 */
172
173#ifdef __udp_can_cep
174
175static ER
176UDP_CANCEL_CEP (T_UDP_CEP *cep, FN fncd)
177{
178 ER error = E_OK, snd_err, rcv_err;
179
180 /* UDP 通信端点をチェックする。*/
181 if (!VALID_UDP_CEP(cep))
182 return E_NOEXS;
183
184 /* API 機能コードをチェックする。*/
185 if (!VALID_TFN_UDP_CAN(fncd))
186 return E_PAR;
187
188 /* 通信端点をロックする。*/
189 syscall(wai_sem(cep->semid_lock));
190
191 if (fncd == TFN_UDP_ALL) { /* TFN_UDP_ALL の処理 */
192
193 snd_err = UDP_CAN_SND(cep, E_RLWAI);
194 rcv_err = UDP_CAN_RCV(cep, E_RLWAI);
195
196 /*
197 * snd_err と rcv_err のどちらも EV_NOPND
198 * なら、ペンディングしていないのでエラー
199 */
200 if (snd_err == EV_NOPND && rcv_err == EV_NOPND)
201 error = E_OBJ;
202 else {
203 if (snd_err == EV_NOPND)
204 snd_err = E_OK;
205 if (rcv_err == EV_NOPND)
206 rcv_err = E_OK;
207
208 if (snd_err != E_OK)
209 error = snd_err;
210 else if (rcv_err != E_OK)
211 error = rcv_err;
212 }
213 }
214 else if (fncd == TFN_UDP_SND_DAT) { /* 送信処理のキャンセル */
215 if ((error = UDP_CAN_SND(cep, E_RLWAI)) == EV_NOPND)
216 error = E_OBJ;
217 }
218 else if (fncd == TFN_UDP_RCV_DAT) { /* 受信処理のキャンセル */
219 if ((error = UDP_CAN_RCV(cep, E_RLWAI)) == EV_NOPND)
220 error = E_OBJ;
221 }
222 else
223 error = E_PAR;
224
225 /* 通信端点をロックを解除する。*/
226 syscall(sig_sem(cep->semid_lock));
227
228 return error;
229 }
230
231#endif /* of #ifdef __udp_can_cep */
232
233#if defined(SUPPORT_INET6) && (defined(SUPPORT_INET4) && TNUM_UDP4_CEPID > 0)
234
235#else /* of #if defined(SUPPORT_INET6) && (defined(SUPPORT_INET4) && TNUM_UDP4_CEPID > 0) */
236
237/*
238 * udp_can_cep -- ペンディングしている処理のキャンセル【標準機能】
239 */
240
241#ifdef __udp_can_cep
242
243ER
244udp_can_cep (ID cepid, FN fncd)
245{
246 T_UDP_CEP *cep;
247
248 /* UDP 通信端点 ID をチェックする。*/
249 if (!VALID_UDP_CEPID(cepid))
250 return E_ID;
251
252 /* UDP 通信端点を得る。*/
253 cep = GET_UDP_CEP(cepid);
254
255 /* メイン関数を呼び出す。*/
256 return UDP_CANCEL_CEP(cep, fncd);
257 }
258
259#endif /* of #ifdef __udp_can_cep */
260
261#endif /* of #if defined(SUPPORT_INET6) && (defined(SUPPORT_INET4) && TNUM_UDP4_CEPID > 0) */
262
263#ifdef UDP_CFG_EXTENTIONS
264
265/*
266 * udp_cre_cep -- UDP 通信端点の生成【拡張機能】
267 */
268
269#ifdef __udp_cre_cep
270
271ER
272UDP_CRE_CEP (ID cepid, T_UDPN_CCEP *pk_ccep)
273{
274 T_UDP_CEP *cep;
275 ER error;
276
277 /* UDP 通信端点 ID をチェックする。*/
278 if (!VALID_UDP_CEPID(cepid))
279 return E_ID;
280
281 /* pk_ccep が NULL ならエラー */
282 if (pk_ccep == NULL)
283 return E_PAR;
284
285#if (API_PROTO == API_PROTO_IPV6) && !defined(API_CFG_IP4MAPPED_ADDR)
286
287 /*
288 * API が IPv6 で IPv4 射影アドレスが認められていないのにもかかわらず、
289 * IPv4 射影アドレスが指定されたらエラー
290 */
291 if (in6_is_addr_ipv4mapped(&pk_ccep->myaddr.ipaddr))
292 return E_PAR;
293
294#endif /* of #if (API_PROTO == API_PROTO_IPV6) && !defined(DAPI_CFG_IP4MAPPED_ADDR) */
295
296 /* UDP 通信端点を得る。*/
297 cep = GET_UDP_CEP(cepid);
298
299 /* UDP 通信端点をチェックする。*/
300 if (VALID_UDP_CEP(cep))
301 return E_OBJ;
302
303 /* UDP 通信端点が、動的生成用でなければエラー */
304 if (!DYNAMIC_UDP_CEP(cep))
305 return E_ID;
306
307 /* 通信端点をロックする。*/
308 syscall(wai_sem(cep->semid_lock));
309
310 /*
311 * UDP 通信端点をチェックする。生成済みであればエラー
312 */
313 if (VALID_UDP_CEP(cep))
314 error = E_OBJ;
315 else {
316
317 /*
318 * 自ポート番号が UDP_PORTANY なら、自動で割り当てる。
319 */
320 if (pk_ccep->myaddr.portno == UDP_PORTANY)
321 error = UDP_ALLOC_AUTO_PORT(cep);
322 else
323 error = UDP_ALLOC_PORT(cep, pk_ccep->myaddr.portno);
324
325 if (error == E_OK) {
326
327 /* UDP 通信端点生成情
328報をコピーする。*/
329 cep->cepatr = pk_ccep->cepatr; /* 通信端点属性 */
330 cep->myaddr.ipaddr = pk_ccep->myaddr.ipaddr; /* 自分のアドレス */
331 cep->callback = (void*)pk_ccep->callback; /* コールバック */
332
333 /* UDP 通信端点を生成済みにする。*/
334 cep->flags |= UDP_CEP_FLG_VALID;
335 }
336 }
337
338 /* 通信端点のロックを解除する。*/
339 syscall(sig_sem(cep->semid_lock));
340
341 return error;
342 }
343
344#endif /* of #ifdef __udp_cre_cep */
345
346#ifdef __udp_del_cep
347
348/*
349 * udp_delete_cep -- UDP 通信端点を削除する。
350 *
351 * udp_del_cep から呼出されるメイン関数
352 */
353
354static ER
355UDP_DELETE_CEP (T_UDP_CEP *cep)
356{
357 ER error;
358
359 /* UDP 通信端点をチェックする。*/
360 if (!VALID_UDP_CEP(cep))
361 return E_NOEXS;
362
363 /* UDP 通信端点が、動的生成用でなければエラー */
364 if (!DYNAMIC_UDP_CEP(cep))
365 return E_ID;
366
367 /* 通信端点をロックする。*/
368 syscall(wai_sem(cep->semid_lock));
369
370 /*
371 * UDP 通信端点をチェックする。未生成の場合はエラー
372 * ・未生成。
373 */
374 if (!VALID_UDP_CEP(cep))
375 error = E_NOEXS;
376 else {
377 UDP_CAN_SND(cep, E_DLT);
378 UDP_CAN_RCV(cep, E_DLT);
379
380 /* UDP 通信端点を未生成にする。*/
381 cep->flags &= ~UDP_CEP_FLG_VALID;
382 error = E_OK;
383 }
384
385 /* 通信端点のロックを解除する。*/
386 syscall(sig_sem(cep->semid_lock));
387
388 return error;
389 }
390
391/*
392 * udp_del_cep -- UDP 通信端点の削除【拡張機能】
393 */
394
395ER
396UDP_DEL_CEP (ID cepid)
397{
398 T_UDP_CEP *cep;
399
400 /* UDP 通信端点 ID をチェックする。*/
401 if (!VALID_UDP_CEPID(cepid))
402 return E_ID;
403
404 /* UDP 通信端点を得る。*/
405 cep = GET_UDP_CEP(cepid);
406
407 /* メイン関数を呼び出す。*/
408 return UDP_DELETE_CEP(cep);
409 }
410
411#endif /* of #ifdef __udp_del_cep */
412
413#ifdef __udp_set_opt
414
415/*
416 * udp_set_option -- UDP 通信端点オプションを設定する。
417 *
418 * udp_set_opt から呼出されるメイン関数
419 */
420
421static ER
422UDP_SET_OPTION (T_UDP_CEP *cep, int_t optname, void *optval, int_t optlen)
423{
424 /* UDP 通信端点をチェックする。*/
425 if (!VALID_UDP_CEP(cep))
426 return E_NOEXS;
427
428 return E_PAR;
429 }
430
431/*
432 * udp_set_opt -- UDP 通信端点オプションの設定【拡張機能】
433 *
434 * 注意: 設定可能な UDP 通信端点オプションは無いため、E_PAR が返される。
435 */
436
437ER
438UDP_SET_OPT (ID cepid, int_t optname, void *optval, int_t optlen)
439{
440 T_UDP_CEP *cep;
441
442 /* UDP 通信端点 ID をチェックする。*/
443 if (!VALID_UDP_CEPID(cepid))
444 return E_ID;
445
446 /* UDP 通信端点を得る。*/
447 cep = GET_UDP_CEP(cepid);
448
449 /* メイン関数を呼び出す。*/
450 return UDP_SET_OPTION(cep, optname, optval, optlen);
451 }
452
453#endif /* of #ifdef __udp_set_opt */
454
455#ifdef __udp_get_opt
456
457/*
458 * udp_get_option -- UDP 通信端点オプションを獲得する。
459 *
460 * udp_get_opt から呼出されるメイン関数
461 */
462
463static ER
464UDP_GET_OPTION (T_UDP_CEP *cep, int_t optname, void *optval, int_t optlen)
465{
466 /* UDP 通信端点をチェックする。*/
467 if (!VALID_UDP_CEP(cep))
468 return E_NOEXS;
469
470 return E_PAR;
471 }
472
473/*
474 * udp_get_opt -- UDP 通信端点オプションの獲得【拡張機能】
475 *
476 * 注意: 設定可能な UDP 通信端点オプションは無いため、E_PAR が返される。
477 */
478
479ER
480UDP_GET_OPT (ID cepid, int_t optname, void *optval, int_t optlen)
481{
482 T_UDP_CEP *cep;
483
484 /* UDP 通信端点 ID をチェックする。*/
485 if (!VALID_UDP_CEPID(cepid))
486 return E_ID;
487
488 /* UDP 通信端点を得る。*/
489 cep = GET_UDP_CEP(cepid);
490
491 /* メイン関数を呼び出す。*/
492 return UDP_GET_OPTION(cep, optname, optval, optlen);
493 }
494
495#endif /* of #ifdef __udp_get_opt */
496
497#endif /* of #ifdef UDP_CFG_EXTENTIONS */
498
499#ifdef UDP_CFG_NON_BLOCKING
500
501#else /* of #ifdef UDP_CFG_NON_BLOCKING */
502
503#ifdef __udp_can_snd
504
505/*
506 * udp_can_snd -- ペンディングしている送信のキャンセル
507 */
508
509ER
510UDP_CAN_SND (T_UDP_CEP *cep, ER error)
511{
512 if (cep->snd_tskid != TA_NULL) { /* 非ノンブロッキングコールでペンディング中 */
513
514#ifdef UDP_CFG_EXTENTIONS
515
516 /* 待
517ち中に発生したエラー情
518報を設定する。*/
519 cep->error = error;
520
521#endif /* of #ifdef UDP_CFG_EXTENTIONS */
522
523 error = rel_wai(cep->snd_tskid);
524 cep->snd_tskid = TA_NULL;
525 }
526 else /* どちらでもないならペンディングしていない */
527 error = EV_NOPND;
528
529 return error;
530 }
531
532#endif /* of #ifdef __udp_can_snd */
533
534#ifdef __udp_can_rcv
535
536/*
537 * udp_can_rcv -- ペンディングしている受信のキャンセル
538 */
539
540ER
541UDP_CAN_RCV (T_UDP_CEP *cep, ER error)
542{
543 if (cep->rcv_tskid != TA_NULL) { /* 非ノンブロッキングコールでペンディング中 */
544
545#ifdef UDP_CFG_EXTENTIONS
546
547 /* 待
548ち中に発生したエラー情
549報を設定する。*/
550 cep->error = error;
551
552#endif /* of #ifdef UDP_CFG_EXTENTIONS */
553
554 error = rel_wai(cep->rcv_tskid);
555 cep->rcv_tskid = TA_NULL;
556 }
557 else /* どちらでもないならペンディングしていない */
558 error = EV_NOPND;
559
560 return error;
561 }
562
563#endif /* of #ifdef __udp_can_rcv */
564
565#ifdef __udp_snd_dat
566
567/*
568 * udp_snd_dat -- パケットの送信【標準機能】
569 */
570
571ER_UINT
572UDP_SND_DAT (ID cepid, T_IPEP *p_dstaddr, void *data, int_t len, TMO tmout)
573{
574 T_UDP_CEP *cep;
575 ER error;
576
577 /* p_dstaddr または data が NULL か、tmout が TMO_NBLK ならエラー */
578 if (p_dstaddr == NULL || data == NULL || tmout == TMO_NBLK)
579 return E_PAR;
580
581 /* データ長をチェックする。*/
582 if (len < 0 || len + IP_HDR_SIZE + UDP_HDR_SIZE > IF_MTU)
583 return E_PAR;
584
585#if (API_PROTO == API_PROTO_IPV6) && !defined(API_CFG_IP4MAPPED_ADDR)
586
587 /*
588 * API が IPv6 で IPv4 射影アドレスが認められていないのにもかかわらず、
589 * IPv4 射影アドレスが指定されたらエラー
590 */
591 if (in6_is_addr_ipv4mapped(&p_dstaddr->ipaddr))
592 return E_PAR;
593
594#endif /* of #if (API_PROTO == API_PROTO_IPV6) && !defined(DAPI_CFG_IP4MAPPED_ADDR) */
595
596 /* UDP 通信端点 ID をチェックする。*/
597 if (!VALID_UDP_CEPID(cepid))
598 return E_ID;
599
600 /* UDP 通信端点を得る。*/
601 cep = GET_UDP_CEP(cepid);
602
603 /* UDP 通信端点をチェックする。*/
604 if (!VALID_UDP_CEP(cep))
605 return E_NOEXS;
606
607 /*
608 * 自ポート番号が UDP_PORTANY なら、自動で割り当てる。
609 */
610 if (cep->myaddr.portno == UDP_PORTANY) {
611 if ((error = UDP_ALLOC_AUTO_PORT(cep)) != E_OK)
612 return error;
613 }
614
615 /* 通信端点をロックする。*/
616 syscall(wai_sem(cep->semid_lock));
617
618 if (cep->snd_tskid != TA_NULL) {
619
620 /* 非ノンブロッキングコールでペンディング中 */
621 error = E_QOVR;
622
623 /* 通信端点をロックを解除する。*/
624 syscall(sig_sem(cep->semid_lock));
625 }
626 else {
627 /* 現在のタスク識別子を記録する。*/
628 get_tid(&(cep->snd_tskid));
629
630#ifdef UDP_CFG_EXTENTIONS
631
632 /* 待
633ち中に発生したエラー情
634報をリセットする。*/
635 cep->error = E_OK;
636
637#endif /* of #ifdef UDP_CFG_EXTENTIONS */
638
639 /* 通信端点をロックを解除する。*/
640 syscall(sig_sem(cep->semid_lock));
641
642 /* パケットを送信する。*/
643 error = UDP_SEND_DATA(cep, p_dstaddr, data, len, tmout);
644
645#ifdef UDP_CFG_EXTENTIONS
646
647 /* 待
648ち中に発生したエラー情
649報を返す。*/
650 if (error == E_RLWAI)
651 error = cep->error;
652
653#endif /* of #ifdef UDP_CFG_EXTENTIONS */
654 }
655
656 return error;
657 }
658
659#endif /* of #ifdef __udp_snd_dat */
660
661#ifdef __udp_rcv_dat
662
663/*
664 * udp_rcv_dat -- パケットの受信【標準機能】
665 */
666
667ER_UINT
668UDP_RCV_DAT (ID cepid, T_IPEP *p_dstaddr, void *data, int_t len, TMO tmout)
669{
670 T_NET_BUF *input;
671 T_UDP_CEP *cep;
672 T_UDP_HDR *udph;
673 ER_UINT error;
674 uint_t ulen, uhoff;
675
676 /* p_dstaddr または data が NULL 、len < 0 か、tmout が TMO_NBLK ならエラー */
677 if (p_dstaddr == NULL || data == NULL || len < 0 || tmout == TMO_NBLK)
678 return E_PAR;
679
680 /* UDP 通信端点 ID をチェックする。*/
681 if (!VALID_UDP_CEPID(cepid))
682 return E_ID;
683
684 /* UDP 通信端点を得る。*/
685 cep = GET_UDP_CEP(cepid);
686
687 /* UDP 通信端点をチェックする。*/
688 if (!VALID_UDP_CEP(cep))
689 return E_NOEXS;
690
691 /* 通信端点をロックする。*/
692 syscall(wai_sem(cep->semid_lock));
693
694 if (cep->rcv_tskid != TA_NULL) {
695
696 /* 非ノンブロッキングコールでペンディング中 */
697 error = E_QOVR;
698
699 /* 通信端点をロックを解除する。*/
700 syscall(sig_sem(cep->semid_lock));
701 }
702 else {
703
704 /* 現在のタスク識別子を記録する。*/
705 get_tid(&(cep->rcv_tskid));
706
707#ifdef UDP_CFG_EXTENTIONS
708
709 /* 待
710ち中に発生したエラー情
711報をリセットする。*/
712 cep->error = E_OK;
713
714#endif /* of #ifdef UDP_CFG_EXTENTIONS */
715
716 /* 通信端点をロックを解除する。*/
717 syscall(sig_sem(cep->semid_lock));
718
719 /* å…
720¥åŠ›ãŒã‚るまで待
721つ。*/
722 if (cep->cb_netbuf != NULL) {
723
724 /*
725 * ここにくる場合は、コールバック関数の中から
726 * udp_rcv_dat を呼び出していることになり、
727 * すでにå…
728¥åŠ›æ¸ˆã¿ã§ã‚る。
729 */
730 input = cep->cb_netbuf;
731 cep->cb_netbuf = NULL;
732 }
733 else if ((error = trcv_dtq(cep->rcvqid, (intptr_t*)&input, tmout)) != E_OK) {
734
735#ifdef UDP_CFG_EXTENTIONS
736
737 /* 待
738ち中に発生したエラー情
739報を返す。*/
740 if (error == E_RLWAI)
741 error = cep->error;
742
743#endif /* of #ifdef UDP_CFG_EXTENTIONS */
744
745 cep->rcv_tskid = TA_NULL;
746 return error;
747 }
748
749 /* p_dstaddr を設定する。*/
750 uhoff = (uint_t)GET_UDP_HDR_OFFSET(input);
751 udph = GET_UDP_HDR(input, uhoff);
752 p_dstaddr->portno = ntohs(udph->sport);
753 IN_COPY_TO_HOST(&p_dstaddr->ipaddr, input);
754
755 /* データをバッファに移す。*/
756 ulen = ntohs(udph->ulen);
757 if (ulen - UDP_HDR_SIZE > len)
758 error = E_BOVR;
759 else {
760 len = (uint_t)(ulen - UDP_HDR_SIZE);
761 error = (ER_UINT)(ulen - UDP_HDR_SIZE);
762 }
763
764 memcpy(data, GET_UDP_SDU(input, uhoff), (size_t)len);
765
766 syscall(rel_net_buf(input));
767
768 cep->rcv_tskid = TA_NULL;
769 }
770
771 return error;
772 }
773
774#endif /* of #ifdef __udp_rcv_dat */
775
776#endif /* of #ifdef UDP_CFG_NON_BLOCKING */
Note: See TracBrowser for help on using the repository browser.