Mirrors_Framework/rtems
1
0
Fork 0
mirror of https://gitlab.rtems.org/rtems/rtos/rtems.git synced 2026-09-24 21:31:00 +08:00
Code Issues Packages Projects Releases Wiki Activity

record: Introduce _Record_Drain()

Browse Source 
This allows its use in crash dump procedures.

Update #3665.
This commit is contained in:
Sebastian Huber
2019-08-30 08:46:17 +02:00
parent 58bd67bb35
commit d78082ce76
2 changed files with 54 additions and 39 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cpukit/include/rtems/record.h
+7
View File
@@ -1054,6 +1054,13 @@ typedef void ( *rtems_record_drain_visitor )(
void *arg
);
void _Record_Drain(
Record_Control *control,
uint32_t cpu_index,
rtems_record_drain_visitor visitor,
void *arg
);
/**
* @brief Drains the record items on all processors.
*
cpukit/libtrace/record/record.c
+47 -39
View File
@@ -88,6 +88,51 @@ void rtems_record_produce_n(
rtems_record_commit( &context );
}
void _Record_Drain(
Record_Control *control,
uint32_t cpu_index,
rtems_record_drain_visitor visitor,
void *arg
)
{
unsigned int tail;
unsigned int head;
tail = _Record_Tail( control );
head = _Atomic_Load_uint( &control->head, ATOMIC_ORDER_ACQUIRE );
if ( tail == head ) {
return;
}
control->tail = head;
control->Header[ 0 ].event = RTEMS_RECORD_PROCESSOR;
control->Header[ 0 ].data = cpu_index;
control->Header[ 1 ].event = RTEMS_RECORD_PER_CPU_TAIL;
control->Header[ 1 ].data = tail;
control->Header[ 2 ].event = RTEMS_RECORD_PER_CPU_HEAD;
control->Header[ 2 ].data = head;
( *visitor )( control->Header, RTEMS_ARRAY_SIZE( control->Header ), arg );
if ( _Record_Is_overflow( control, tail, head ) ) {
tail = head + 1;
}
tail = _Record_Index( control, tail );
head = _Record_Index( control, head );
if ( tail < head ) {
( *visitor )( &control->Items[ tail ], head - tail, arg );
} else {
( *visitor )( &control->Items[ tail ], control->mask + 1 - tail, arg );
if ( head > 0 ) {
( *visitor )( &control->Items[ 0 ], head, arg );
}
}
}
void rtems_record_drain( rtems_record_drain_visitor visitor, void *arg )
{
uint32_t cpu_max;
@@ -96,46 +141,9 @@ void rtems_record_drain( rtems_record_drain_visitor visitor, void *arg )
cpu_max = rtems_configuration_get_maximum_processors();
for ( cpu_index = 0; cpu_index < cpu_max; ++cpu_index ) {
Per_CPU_Control *cpu;
Record_Control *control;
unsigned int tail;
unsigned int head;
Per_CPU_Control *cpu;
cpu = _Per_CPU_Get_by_index( cpu_index );
control = cpu->record;
tail = _Record_Tail( control );
head = _Atomic_Load_uint( &control->head, ATOMIC_ORDER_ACQUIRE );
if ( tail == head ) {
continue;
}
control->tail = head;
control->Header[ 0 ].event = RTEMS_RECORD_PROCESSOR;
control->Header[ 0 ].data = cpu_index;
control->Header[ 1 ].event = RTEMS_RECORD_PER_CPU_TAIL;
control->Header[ 1 ].data = tail;
control->Header[ 2 ].event = RTEMS_RECORD_PER_CPU_HEAD;
control->Header[ 2 ].data = head;
( *visitor )( control->Header, RTEMS_ARRAY_SIZE( control->Header ), arg );
if ( _Record_Is_overflow( control, tail, head ) ) {
tail = head + 1;
}
tail = _Record_Index( control, tail );
head = _Record_Index( control, head );
if ( tail < head ) {
( *visitor )( &control->Items[ tail ], head - tail, arg );
} else {
( *visitor )( &control->Items[ tail ], control->mask + 1 - tail, arg );
if ( head > 0 ) {
( *visitor )( &control->Items[ 0 ], head, arg );
}
}
_Record_Drain( cpu->record, cpu_index, visitor, arg );
}
}