interfaces/polar-runtime-service-thread-sync.c

/* Internal API: @synchronized() support service interface for polar-objc.
   Copyright (C) 2022-2025 Michael Malicoat <[email protected]>
 
   This file is part of polar-objc.
 
   polar-objc is free software; you can redistribute it and/or modify it under the terms of the GNU General Public
   License as published by the Free Software Foundation; either version 3, or (at your option) any later version.
 
   polar-objc is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied
   warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for more
   details.
 
   You should have received a copy of the GNU General Public License along with this program; see the file LICENSE.  If
   not, see <http://www.gnu.org/licenses/>.
*/
 
// Private =============================================================================================================
 
enum
{
  POLAR_RTSQ_THREAD_SYNC_BEGIN = 0,
  POLAR_RTSQ_THREAD_SYNC_END,
 
  // Sentinel value
  POLAR_RTSQ_THREAD_SYNC_LAST
};
 
struct polar_rtsq_thread_sync_begin
{
  intptr_t result;
  void *object_target;
};
 
struct polar_rtsq_thread_sync_end
{
  intptr_t result;
  void *object_target;
};
 
// Public ==============================================================================================================
 
// objc_sync_enter(object) => polar_runtime_thread_sync_begin(object)
POLAR_FUNCTION_INTERNAL intptr_t
polar_runtime_thread_sync_begin( void *object_target )
{
  struct polar_rtsq_thread_sync_begin request_data;
 
  assert( object_target != NULL );
  assert( thrd_current() != polar_id_rts_thread );
 
  request_data.result = OBJC_THREAD_SYNC_FAILED;
  request_data.object_target = object_target;
 
  polar_runtime_service_request(POLAR_SERVICE_THREAD_SYNC, POLAR_RTSQ_THREAD_SYNC_BEGIN, &request_data);
 
  return request_data.result;
}
 
// objc_sync_exit(object) => polar_runtime_thread_sync_end(object)
POLAR_FUNCTION_INTERNAL intptr_t
polar_runtime_thread_sync_end( void *object_target )
{
  struct polar_rtsq_thread_sync_end request_data;
 
  assert( object_target != NULL );
  assert( thrd_current() != polar_id_rts_thread );
 
  request_data.result = OBJC_THREAD_SYNC_FAILED;
  request_data.object_target = object_target;
 
  polar_runtime_service_request(POLAR_SERVICE_THREAD_SYNC, POLAR_RTSQ_THREAD_SYNC_END, &request_data);
 
  return request_data.result;
}