Use rtems_task_exit()

Update #3530.
Update #3533.
This commit is contained in:
Sebastian Huber
2018-10-02 10:22:15 +02:00
parent e50e3f7087
commit f004b2b8dc
23 changed files with 38 additions and 39 deletions

View File

@@ -1500,7 +1500,7 @@ static void smsc9218i_transmit_task(void *arg)
rtems_bsdnet_semaphore_release();
/* Terminate self */
(void) rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}
#if defined(DEBUG)

View File

@@ -1569,6 +1569,6 @@ static void GT64260eth_daemon(void *arg)
* theoretically, that variable could already
* hold a newly created TID
*/
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}

View File

@@ -1694,7 +1694,7 @@ static void i82544EI_daemon(void *arg)
* theoretically, that variable could already
* hold a newly created TID
*/
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}
/*

View File

@@ -776,7 +776,7 @@ static void tsec_rxDaemon
* terminate daemon
*/
sc->rxDaemonTid = 0;
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}
/***************************************************************************\
@@ -1126,7 +1126,7 @@ static void tsec_txDaemon
* terminate daemon
*/
sc->txDaemonTid = 0;
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}
/***************************************************************************\

View File

@@ -908,7 +908,7 @@ ata_queue_task(rtems_task_argument arg)
default:
#if ATA_DEBUG
ata_printf("ata_queue_task: internal error\n");
rtems_task_delete (RTEMS_SELF);
rtems_task_exit();
#endif
rtems_fatal_error_occurred(RTEMS_INTERNAL_ERROR);
break;

View File

@@ -2745,7 +2745,7 @@ void grspw_work_func(rtems_id msgQ)
rtems_message_queue_delete(msgQ);
grspw_work_event(WORKTASK_EV_QUIT, message);
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}
STATIC void grspw_isr(void *data)

View File

@@ -2056,7 +2056,7 @@ ftpd_daemon(rtems_task_argument args RTEMS_UNUSED)
}
}
}
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}

View File

@@ -428,8 +428,7 @@ rtems_status_code rtems_event_system_receive(
* sc = rtems_event_transient_send(req->task_id);
* assert(sc == RTEMS_SUCCESSFUL);
*
* sc = rtems_task_delete(RTEMS_SELF);
* assert(sc == RTEMS_SUCCESSFUL);
* rtems_task_exit();
* }
*
* void issue_request_and_wait_for_completion(void)

View File

@@ -188,7 +188,7 @@ extern "C" {
#define RTEMS_CHECK_SC_TASK( sc, msg) \
if ((rtems_status_code) (sc) != RTEMS_SUCCESSFUL) { \
RTEMS_SYSLOG_ERROR_WITH_SC( sc, msg); \
(void) rtems_task_delete( RTEMS_SELF); \
rtems_task_exit(); \
return; \
} else { \
RTEMS_DEBUG_OK( msg); \
@@ -237,7 +237,7 @@ extern "C" {
#define RTEMS_CHECK_RV_TASK( rv, msg) \
if ((int) (rv) < 0) { \
RTEMS_SYSLOG_ERROR_WITH_RV( rv, msg); \
(void) rtems_task_delete( RTEMS_SELF); \
rtems_task_exit(); \
return; \
} else { \
RTEMS_DEBUG_OK( msg); \

View File

@@ -2643,7 +2643,7 @@ rtems_bdbuf_swapout_worker_task (rtems_task_argument arg)
free (worker);
rtems_task_delete (RTEMS_SELF);
rtems_task_exit();
}
/**
@@ -2746,7 +2746,7 @@ rtems_bdbuf_swapout_task (rtems_task_argument arg)
free (transfer);
rtems_task_delete (RTEMS_SELF);
rtems_task_exit();
}
static void
@@ -2979,7 +2979,7 @@ rtems_bdbuf_read_ahead_task (rtems_task_argument arg)
rtems_bdbuf_unlock_cache ();
}
rtems_task_delete (RTEMS_SELF);
rtems_task_exit();
}
void rtems_bdbuf_get_device_stats (const rtems_disk_device *dd,

View File

@@ -1926,7 +1926,7 @@ static rtems_task rtems_termios_txdaemon(rtems_task_argument argument)
);
if ((the_event & TERMIOS_TX_TERMINATE_EVENT) != 0) {
tty->txTaskId = 0;
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}
/*
@@ -1974,7 +1974,7 @@ static rtems_task rtems_termios_rxdaemon(rtems_task_argument argument)
);
if ((the_event & TERMIOS_RX_TERMINATE_EVENT) != 0) {
tty->rxTaskId = 0;
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}
/*

View File

@@ -1691,7 +1691,7 @@ rtems_debugger_events(rtems_task_argument arg)
if (rtems_debugger_verbose())
rtems_debugger_printf("rtems-db: events finishing\n");
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}
static int
@@ -1913,7 +1913,7 @@ rtems_debugger_main(rtems_task_argument arg)
rtems_debugger->server_finished = true;
rtems_debugger_unlock();
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}
int

View File

@@ -3105,7 +3105,7 @@ rtems_filesystem_location_info_t old;
rtems_filesystem_current->location = old;
}
rtems_binary_semaphore_post(&rpa->sync);
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}

View File

@@ -495,7 +495,7 @@ rtems_cpuusage_top_thread (rtems_task_argument arg)
data->thread_active = false;
rtems_task_delete (RTEMS_SELF);
rtems_task_exit();
}
void rtems_cpu_usage_top_with_plugin(

View File

@@ -182,7 +182,7 @@ rtems_monitor_server_task(
}
failed:
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}

View File

@@ -97,7 +97,7 @@ rtems_stdio_redirect_reader(rtems_task_argument arg)
sr->state |= RTEMS_STDIO_REDIRECT_FINISHED;
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}
rtems_stdio_redirect*

View File

@@ -680,7 +680,7 @@ static rtems_task rtems_shell_task(rtems_task_argument task_argument)
rtems_shell_main_loop( shell_env );
if (wake_on_end != RTEMS_INVALID_ID)
rtems_event_send (wake_on_end, RTEMS_EVENT_1);
rtems_task_delete( RTEMS_SELF );
rtems_task_exit();
}
static bool rtems_shell_init_user_env(void)

View File

@@ -796,7 +796,7 @@ dhcp_task (rtems_task_argument _sdl)
dhcp_task_id = 0;
printf ("dhcpc: exiting lease renewal task.\n");
rtems_task_delete( RTEMS_SELF);
rtems_task_exit();
}

View File

@@ -326,7 +326,7 @@ static void dhcp_monitor_task (rtems_task_argument ifp_arg)
error_out:
printf("Stopping dhcp monitoring application.\n");
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}
/*

View File

@@ -63,7 +63,7 @@ static rtems_task rtems_portmapper (rtems_task_argument unused)
rtems_rpc_task_init ();
if ((sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP)) < 0) {
perror("portmap cannot create socket");
rtems_task_delete (RTEMS_SELF);
rtems_task_exit();
}
addr.sin_addr.s_addr = 0;
@@ -72,13 +72,13 @@ static rtems_task rtems_portmapper (rtems_task_argument unused)
if (bind(sock, (struct sockaddr *)&addr, len) != 0) {
perror("portmap cannot bind");
close (sock);
rtems_task_delete (RTEMS_SELF);
rtems_task_exit();
}
if ((xprt = svcudp_create(sock)) == (SVCXPRT *)NULL) {
fprintf(stderr, "couldn't do udp_create\n");
close (sock);
rtems_task_delete (RTEMS_SELF);
rtems_task_exit();
}
/* make an entry for ourself */
pml = (struct pmaplist *)malloc(sizeof(struct pmaplist));
@@ -92,18 +92,18 @@ static rtems_task rtems_portmapper (rtems_task_argument unused)
if ((sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP)) < 0) {
perror("portmap cannot create socket");
close (sock);
rtems_task_delete (RTEMS_SELF);
rtems_task_exit();
}
if (bind(sock, (struct sockaddr *)&addr, len) != 0) {
perror("portmap cannot bind");
close (sock);
rtems_task_delete (RTEMS_SELF);
rtems_task_exit();
}
if ((xprt = svctcp_create(sock, RPCSMALLMSGSIZE, RPCSMALLMSGSIZE))
== (SVCXPRT *)NULL) {
fprintf(stderr, "couldn't do tcp_create\n");
close (sock);
rtems_task_delete (RTEMS_SELF);
rtems_task_exit();
}
/* make an entry for ourself */
pml = (struct pmaplist *)malloc(sizeof(struct pmaplist));
@@ -119,7 +119,7 @@ static rtems_task rtems_portmapper (rtems_task_argument unused)
svc_run();
fprintf(stderr, "run_svc returned unexpectedly\n");
close (sock);
rtems_task_delete (RTEMS_SELF);
rtems_task_exit();
}
static struct pmaplist *

View File

@@ -72,7 +72,7 @@ static rtems_task pppTask(rtems_task_argument arg)
/* terminate myself */
rtems_pppd_taskid = 0;
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}
int rtems_pppd_initialize(void)

View File

@@ -766,7 +766,7 @@ bail:
rtems_task_delete( hp_task );
if ( ! (flags & SSE_TEST_NO_DEL) )
rtems_task_delete( RTEMS_SELF );
rtems_task_exit();
}
static void

View File

@@ -211,7 +211,7 @@ rtems_task_telnetd(void *task_argument)
if ((des_socket=socket(PF_INET,SOCK_STREAM,0))<0) {
perror("telnetd:socket");
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
};
setsockopt(des_socket,SOL_SOCKET,SO_KEEPALIVE,&i,sizeof(i));
@@ -222,12 +222,12 @@ rtems_task_telnetd(void *task_argument)
if ((bind(des_socket,&srv.sa,size_adr))<0) {
perror("telnetd:bind");
close(des_socket);
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
};
if ((listen(des_socket,5))<0) {
perror("telnetd:listen");
close(des_socket);
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
};
/* we don't redirect stdio as this probably
@@ -457,7 +457,7 @@ wrap_delete(rtems_task_argument arg)
*/
free(pwa);
t(a);
rtems_task_delete(RTEMS_SELF);
rtems_task_exit();
}
rtems_id