Truxton etl set thread safe - Revision history

Sam at 07:56, 5 December 2020

2020-12-05T07:56:40Z

Sam at 10:51, 10 June 2020

2020-06-10T10:51:31Z

Sam: Created page with "This API tells Truxton that your code is designed to be thread-safe. =Syntax= void truxton_etl_set_thread_safe( uint64_t etl_handle, uint16_t threa..."

2020-05-26T12:25:39Z

Created page with "This API tells Truxton that your code is designed to be thread-safe. =Syntax= <syntaxhighlight lang="C"> void truxton_etl_set_thread_safe( uint64_t etl_handle, uint16_t threa..."

New page

This API tells Truxton that your code is designed to be thread-safe.

=Syntax=
<syntaxhighlight lang="C">
void truxton_etl_set_thread_safe( uint64_t etl_handle, uint16_t thread_safe )
</syntaxhighlight>

=Parameters=
==<code>etl_handle</code>==

The handle created by the [[truxton_etl_create]] call.

==<code>thread_safe</code>==
When set to a non-zero value, it will tell Truxton that your code is written in a thread-safe manner.
Calling this API with zero tells Truxton that you are a single-threaded application.

=Remarks=

By default, Truxton assumes that ETL processes are single threaded and not thread-safe.

=Sample=

<syntaxhighlight lang="C" highlight="16">
#include <TruxtonCAPI.h>

void main( void )
{
char file_id[ 65 ];

int exit_loop = 0;

uint64_t message = 0;
uint64_t app = truxton_etl_create();

truxton_etl_set_application_name( app, "Sample C ETL" );
truxton_etl_set_stage_number( app, 42 );
truxton_etl_set_queue_name( app, "SampleC" );

truxton_etl_set_thread_safe( app, 0 );

while( exit_loop == 0 )
{
message = truxton_etl_get_message( app );

if ( message != 0 )
{
// Do something with the message

memset( file_id, 0x00, sizeof( file_id ) );
truxton_message_get_file_id( message, file_id, sizeof( file_id ) );

printf( "Received file id %s\n", file_id );

truxton_message_destroy( message );
}
else
{
exit_loop = 1;
}
}

truxton_etl_destroy( app );
}
</syntaxhighlight>

@@ Line 2: / Line 2: @@
 =Syntax=
-<syntaxhighlight lang="C">
+<source lang="C">
 void truxton_etl_set_thread_safe( uint64_t etl_handle, uint16_t thread_safe );
-</syntaxhighlight>
+</source>
 =Parameters=
@@ Line 19: / Line 19: @@
 =Sample=
-<syntaxhighlight lang="C" highlight="16">
+<source lang="C" highlight="14">
 #include <TruxtonCAPI.h>
@@ Line 25: / Line 25: @@
+{
      char file_id[ 65 ];
      uint64_t message = 0;
@@ Line 37: / Line 35: @@
      truxton_etl_set_thread_safe( app, 0 );
-     while( exit_loop == 0 )
+    // Pause here until we get a message from the "SampleC" message queue
+     {
-         message = truxton_etl_get_message( app );
+         // Do something with the message
-         if ( message != 0 )
+         memset( file_id, 0x00, sizeof( file_id ) );
+         truxton_message_get_file_id( message, file_id, sizeof( file_id ) );
-            memset( file_id, 0x00, sizeof( file_id ) );
+        printf( "Received file id %s\n", file_id );
-            printf( "Received file id %s\n", file_id );
+        truxton_message_destroy( message );
-            truxton_message_destroy( message );
+        // Pause here until we get another message from the "SampleC" message queue
+         message = truxton_etl_get_message( app );
+     }
      truxton_etl_destroy( app );
+}
-</syntaxhighlight>
+</source>