Subversion Repositories or1k

/*

 *  cancelrun.c,v 1.4 2002/07/05 18:13:18 joel Exp

 */

#if HAVE_CONFIG_H

#include "config.h"

#endif

#include <pthread.h>

#include <errno.h>

#include <rtems/system.h>

#include <rtems/score/chain.h>

#include <rtems/score/isr.h>

#include <rtems/score/thread.h>

#include <rtems/score/wkspace.h>

#include <rtems/posix/cancel.h>

#include <rtems/posix/pthread.h>

#include <rtems/posix/threadsup.h>

/*PAGE

 *

 *  _POSIX_Threads_cancel_run

 *

 */

#if !defined(PTHREAD_CANCELED)

#warning "PTHREAD_CANCELED NOT DEFINED -- patch newlib"

#define PTHREAD_CANCELED ((void *) -1)

#endif

void _POSIX_Threads_cancel_run(

  Thread_Control *the_thread

)

{

  POSIX_Cancel_Handler_control      *handler;

  Chain_Control                     *handler_stack;

  POSIX_API_Control                 *thread_support;

  ISR_Level                          level;

  thread_support = the_thread->API_Extensions[ THREAD_API_POSIX ];

  handler_stack = &thread_support->Cancellation_Handlers;

  thread_support->cancelability_state = PTHREAD_CANCEL_DISABLE;

  while ( !_Chain_Is_empty( handler_stack ) ) {

    _ISR_Disable( level );

      handler = (POSIX_Cancel_Handler_control *) _Chain_Tail( handler_stack );

      _Chain_Extract_unprotected( &handler->Node );

    _ISR_Enable( level );

    (*handler->routine)( handler->arg );

    _Workspace_Free( handler );

  }

  /* Now we can delete the thread */

  the_thread->Wait.return_argument = (unsigned32 *)PTHREAD_CANCELED;

  _Thread_Close(

    _Objects_Get_information( the_thread->Object.id ),

    the_thread

  );

  _POSIX_Threads_Free( the_thread );

}