URL https://opencores.org/ocsvn/or1k/or1k/trunk

Subversion Repositories or1k

[/] [or1k/] [trunk/] [rtems-20020807/] [cpukit/] [rtems/] [src/] [semflush.c] - Blame information for rev 1780

Go to most recent revision | Details | Compare with Previous | View Log


/*
 *  rtems_semaphore_flush
 *
 *  DESCRIPTION:
 *
 *  This package is the implementation of the flush directive
 *  of the Semaphore Manager.
 *
 *  COPYRIGHT (c) 1989-1999.
 *  On-Line Applications Research Corporation (OAR).
 *
 *  The license and distribution terms for this file may be
 *  found in the file LICENSE in this distribution or at
 *  http://www.OARcorp.com/rtems/license.html.
 *
 *  semflush.c,v 1.5 2000/01/05 22:19:21 joel Exp
 */
 
#include <rtems/system.h>
#include <rtems/rtems/status.h>
#include <rtems/rtems/support.h>
#include <rtems/rtems/attr.h>
#include <rtems/score/isr.h>
#include <rtems/score/object.h>
#include <rtems/rtems/options.h>
#include <rtems/rtems/sem.h>
#include <rtems/score/coremutex.h>
#include <rtems/score/coresem.h>
#include <rtems/score/states.h>
#include <rtems/score/thread.h>
#include <rtems/score/threadq.h>
#if defined(RTEMS_MULTIPROCESSING)
#include <rtems/score/mpci.h>
#endif
#include <rtems/score/sysstate.h>
 
#include <rtems/score/interr.h>
 
/*PAGE
 *
 *  rtems_semaphore_flush
 *
 *  This directive allows a thread to flush the threads
 *  pending on the semaphore.
 *
 *  Input parameters:
 *    id         - semaphore id
 *
 *  Output parameters:
 *    RTEMS_SUCCESSFUL - if successful
 *    error code        - if unsuccessful
 */
 
#if defined(RTEMS_MULTIPROCESSING)
#define SEND_OBJECT_WAS_DELETED _Semaphore_MP_Send_object_was_deleted
#else
#define SEND_OBJECT_WAS_DELETED NULL
#endif
 
rtems_status_code rtems_semaphore_flush(
  Objects_Id      id
)
{
  register Semaphore_Control *the_semaphore;
  Objects_Locations           location;
 
  the_semaphore = _Semaphore_Get( id, &location );
  switch ( location ) {
 
    case OBJECTS_REMOTE:
#if defined(RTEMS_MULTIPROCESSING)
      _Thread_Dispatch();
      return RTEMS_ILLEGAL_ON_REMOTE_OBJECT;
#endif
 
    case OBJECTS_ERROR:
      return RTEMS_INVALID_ID;
 
    case OBJECTS_LOCAL:
      if ( !_Attributes_Is_counting_semaphore(the_semaphore->attribute_set) ) {
        _CORE_mutex_Flush(
          &the_semaphore->Core_control.mutex,
          SEND_OBJECT_WAS_DELETED,
          CORE_MUTEX_STATUS_UNSATISFIED_NOWAIT
        );
      } else {
        _CORE_semaphore_Flush(
          &the_semaphore->Core_control.semaphore,
          SEND_OBJECT_WAS_DELETED,
          CORE_SEMAPHORE_STATUS_UNSATISFIED_NOWAIT
        );
      }
      _Thread_Enable_dispatch();
      return RTEMS_SUCCESSFUL;
  }
 
  return RTEMS_INTERNAL_ERROR;   /* unreached - only to remove warnings */
}

Line No.	Rev	Author	Line
1	1026	ivang	`/*`
2			`* rtems_semaphore_flush`
3			`*`
4			`* DESCRIPTION:`
5			`*`
6			`* This package is the implementation of the flush directive`
7			`* of the Semaphore Manager.`
8			`*`
9			`* COPYRIGHT (c) 1989-1999.`
10			`* On-Line Applications Research Corporation (OAR).`
11			`*`
12			`* The license and distribution terms for this file may be`
13			`* found in the file LICENSE in this distribution or at`
14			`* http://www.OARcorp.com/rtems/license.html.`
15			`*`
16			`* semflush.c,v 1.5 2000/01/05 22:19:21 joel Exp`
17			`*/`
18
19			`#include <rtems/system.h>`
20			`#include <rtems/rtems/status.h>`
21			`#include <rtems/rtems/support.h>`
22			`#include <rtems/rtems/attr.h>`
23			`#include <rtems/score/isr.h>`
24			`#include <rtems/score/object.h>`
25			`#include <rtems/rtems/options.h>`
26			`#include <rtems/rtems/sem.h>`
27			`#include <rtems/score/coremutex.h>`
28			`#include <rtems/score/coresem.h>`
29			`#include <rtems/score/states.h>`
30			`#include <rtems/score/thread.h>`
31			`#include <rtems/score/threadq.h>`
32			`#if defined(RTEMS_MULTIPROCESSING)`
33			`#include <rtems/score/mpci.h>`
34			`#endif`
35			`#include <rtems/score/sysstate.h>`
36
37			`#include <rtems/score/interr.h>`
38
39			`/*PAGE`
40			`*`
41			`* rtems_semaphore_flush`
42			`*`
43			`* This directive allows a thread to flush the threads`
44			`* pending on the semaphore.`
45			`*`
46			`* Input parameters:`
47			`* id - semaphore id`
48			`*`
49			`* Output parameters:`
50			`* RTEMS_SUCCESSFUL - if successful`
51			`* error code - if unsuccessful`
52			`*/`
53
54			`#if defined(RTEMS_MULTIPROCESSING)`
55			`#define SEND_OBJECT_WAS_DELETED _Semaphore_MP_Send_object_was_deleted`
56			`#else`
57			`#define SEND_OBJECT_WAS_DELETED NULL`
58			`#endif`
59
60			`rtems_status_code rtems_semaphore_flush(`
61			`Objects_Id id`
62			`)`
63			`{`
64			`register Semaphore_Control *the_semaphore;`
65			`Objects_Locations location;`
66
67			`the_semaphore = _Semaphore_Get( id, &location );`
68			`switch ( location ) {`
69
70			`case OBJECTS_REMOTE:`
71			`#if defined(RTEMS_MULTIPROCESSING)`
72			`_Thread_Dispatch();`
73			`return RTEMS_ILLEGAL_ON_REMOTE_OBJECT;`
74			`#endif`
75
76			`case OBJECTS_ERROR:`
77			`return RTEMS_INVALID_ID;`
78
79			`case OBJECTS_LOCAL:`
80			`if ( !_Attributes_Is_counting_semaphore(the_semaphore->attribute_set) ) {`
81			`_CORE_mutex_Flush(`
82			`&the_semaphore->Core_control.mutex,`
83			`SEND_OBJECT_WAS_DELETED,`
84			`CORE_MUTEX_STATUS_UNSATISFIED_NOWAIT`
85			`);`
86			`} else {`
87			`_CORE_semaphore_Flush(`
88			`&the_semaphore->Core_control.semaphore,`
89			`SEND_OBJECT_WAS_DELETED,`
90			`CORE_SEMAPHORE_STATUS_UNSATISFIED_NOWAIT`
91			`);`
92			`}`
93			`_Thread_Enable_dispatch();`
94			`return RTEMS_SUCCESSFUL;`
95			`}`
96
97			`return RTEMS_INTERNAL_ERROR; /* unreached - only to remove warnings */`
98			`}`

Browse

Tools

Subversion Repositories or1k

[/] [or1k/] [trunk/] [rtems-20020807/] [cpukit/] [rtems/] [src/] [semflush.c] - Blame information for rev 1780