Changeset 62 for asp_wo_cfg/trunk/kernel/dataqueue.c
- Timestamp:
- Oct 19, 2013, 12:38:33 AM (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
asp_wo_cfg/trunk/kernel/dataqueue.c
r49 r62 6 6 * Copyright (C) 2000-2003 by Embedded and Real-Time Systems Laboratory 7 7 * Toyohashi Univ. of Technology, JAPAN 8 * Copyright (C) 2005-201 2by Embedded and Real-Time Systems Laboratory8 * Copyright (C) 2005-2013 by Embedded and Real-Time Systems Laboratory 9 9 * Graduate School of Information Science, Nagoya Univ., JAPAN 10 10 * … … 303 303 304 304 bool_t 305 send_data(DTQCB *p_dtqcb, intptr_t data, bool_t *p_ reqdsp)305 send_data(DTQCB *p_dtqcb, intptr_t data, bool_t *p_dspreq) 306 306 { 307 307 TCB *p_tcb; … … 310 310 p_tcb = (TCB *) queue_delete_next(&(p_dtqcb->rwait_queue)); 311 311 ((WINFO_DTQ *)(p_tcb->p_winfo))->data = data; 312 *p_ reqdsp= wait_complete(p_tcb);312 *p_dspreq = wait_complete(p_tcb); 313 313 return(true); 314 314 } 315 315 else if (p_dtqcb->count < p_dtqcb->p_dtqinib->dtqcnt) { 316 316 enqueue_data(p_dtqcb, data); 317 *p_ reqdsp= false;317 *p_dspreq = false; 318 318 return(true); 319 319 } … … 354 354 355 355 bool_t 356 receive_data(DTQCB *p_dtqcb, intptr_t *p_data, bool_t *p_ reqdsp)356 receive_data(DTQCB *p_dtqcb, intptr_t *p_data, bool_t *p_dspreq) 357 357 { 358 358 TCB *p_tcb; … … 365 365 data = ((WINFO_DTQ *)(p_tcb->p_winfo))->data; 366 366 enqueue_data(p_dtqcb, data); 367 *p_ reqdsp= wait_complete(p_tcb);367 *p_dspreq = wait_complete(p_tcb); 368 368 } 369 369 else { 370 *p_ reqdsp= false;370 *p_dspreq = false; 371 371 } 372 372 return(true); … … 375 375 p_tcb = (TCB *) queue_delete_next(&(p_dtqcb->swait_queue)); 376 376 *p_data = ((WINFO_DTQ *)(p_tcb->p_winfo))->data; 377 *p_ reqdsp= wait_complete(p_tcb);377 *p_dspreq = wait_complete(p_tcb); 378 378 return(true); 379 379 } … … 395 395 DTQCB *p_dtqcb; 396 396 WINFO_DTQ winfo_dtq; 397 bool_t reqdsp;397 bool_t dspreq; 398 398 ER ercd; 399 399 … … 405 405 406 406 t_lock_cpu(); 407 if (send_data(p_dtqcb, data, & reqdsp)) {408 if ( reqdsp) {407 if (send_data(p_dtqcb, data, &dspreq)) { 408 if (dspreq) { 409 409 dispatch(); 410 410 } … … 436 436 { 437 437 DTQCB *p_dtqcb; 438 bool_t reqdsp;438 bool_t dspreq; 439 439 ER ercd; 440 440 … … 446 446 447 447 t_lock_cpu(); 448 if (send_data(p_dtqcb, data, & reqdsp)) {449 if ( reqdsp) {448 if (send_data(p_dtqcb, data, &dspreq)) { 449 if (dspreq) { 450 450 dispatch(); 451 451 } … … 473 473 { 474 474 DTQCB *p_dtqcb; 475 bool_t reqdsp;475 bool_t dspreq; 476 476 ER ercd; 477 477 … … 483 483 484 484 i_lock_cpu(); 485 if (send_data(p_dtqcb, data, & reqdsp)) {486 if ( reqdsp) {485 if (send_data(p_dtqcb, data, &dspreq)) { 486 if (dspreq) { 487 487 reqflg = true; 488 488 } … … 512 512 WINFO_DTQ winfo_dtq; 513 513 TMEVTB tmevtb; 514 bool_t reqdsp;514 bool_t dspreq; 515 515 ER ercd; 516 516 … … 523 523 524 524 t_lock_cpu(); 525 if (send_data(p_dtqcb, data, & reqdsp)) {526 if ( reqdsp) {525 if (send_data(p_dtqcb, data, &dspreq)) { 526 if (dspreq) { 527 527 dispatch(); 528 528 } … … 623 623 DTQCB *p_dtqcb; 624 624 WINFO_DTQ winfo_dtq; 625 bool_t reqdsp;625 bool_t dspreq; 626 626 ER ercd; 627 627 … … 633 633 634 634 t_lock_cpu(); 635 if (receive_data(p_dtqcb, p_data, & reqdsp)) {636 if ( reqdsp) {635 if (receive_data(p_dtqcb, p_data, &dspreq)) { 636 if (dspreq) { 637 637 dispatch(); 638 638 } … … 669 669 { 670 670 DTQCB *p_dtqcb; 671 bool_t reqdsp;671 bool_t dspreq; 672 672 ER ercd; 673 673 … … 679 679 680 680 t_lock_cpu(); 681 if (receive_data(p_dtqcb, p_data, & reqdsp)) {682 if ( reqdsp) {681 if (receive_data(p_dtqcb, p_data, &dspreq)) { 682 if (dspreq) { 683 683 dispatch(); 684 684 } … … 708 708 WINFO_DTQ winfo_dtq; 709 709 TMEVTB tmevtb; 710 bool_t reqdsp;710 bool_t dspreq; 711 711 ER ercd; 712 712 … … 719 719 720 720 t_lock_cpu(); 721 if (receive_data(p_dtqcb, p_data, & reqdsp)) {722 if ( reqdsp) {721 if (receive_data(p_dtqcb, p_data, &dspreq)) { 722 if (dspreq) { 723 723 dispatch(); 724 724 }
Note:
See TracChangeset
for help on using the changeset viewer.