ngcbSchedProc.c File Reference

#include <ngc/core/ngcbSched.h>

Classes
struct	ngcp_proc_t

Macros
#define	_GNU_SOURCE
#define	_REENTRANT

Typedefs
typedef void *(*	ngcbSCHED_PROC) (void *arg)

Functions
int	ngcbProcCreate (void(*process)(void *), int n, char *erms)
int	ngcbProcCreate2 (void(*process)(void *), int n, size_t stack, char *erms)
void	ngcbProcFree (int setId)
void	ngcbProcJoin (int setId)
int	ngcbProcStart (int setId)
int	ngcbProcWaitStart (int procId)
int	ngcbProcWaitTrigger (int procId)
int	ngcbProcAck (int procId)
int	ngcbProcTrigger (int setId)
int	ngcbProcWaitAck (int setId)
int	ngcbProcSync (int procId)

Detailed Description

Copyright

SPDX-FileCopyrightText: 2026 European Southern Observatory (ESO) SPDX-License-Identifier: LGPL-3.0-only

Macro Definition Documentation

_GNU_SOURCE

#define _GNU_SOURCE

_REENTRANT

#define _REENTRANT

Typedef Documentation

ngcbSCHED_PROC

typedef void *(* ngcbSCHED_PROC) (void *arg)

Function Documentation

ngcbProcAck()

int ngcbProcAck

(

int

procId

)

Acknowledge that the process is ready to get the next data.

ngcbProcCreate()

int ngcbProcCreate	(	void(*	calcProcess )(void *),
		int	n,
		char *	erms )

Create a set of n user defined calculation threads with default stack size (1M) using the ngcbProc... routines to synchronize.

ngcbProcCreate2()

int ngcbProcCreate2	(	void(*	calcProcess )(void *),
		int	n,
		size_t	stack,
		char *	erms )

Create a set of n user defined calculation threads using the ngcbProc... routines to synchronize. The stack size is given in bytes. When the stack size is set to zero then the system default value (1M) is used.

ngcbProcFree()

void ngcbProcFree

(

int

setId

)

Free all thread-resources in set.

ngcbProcJoin()

void ngcbProcJoin

(

int

setId

)

Join all threads in set.

ngcbProcStart()

int ngcbProcStart

(

int

setId

)

Perform synchronous start of a set of threads.

ngcbProcSync()

int ngcbProcSync

(

int

procId

)

Synchronize a set of threads created with ngcbProcCreate() from inside the threads.

ngcbProcTrigger()

int ngcbProcTrigger

(

int

setId

)

Send trigger to a set of threads.

ngcbProcWaitAck()

int ngcbProcWaitAck

(

int

setId

)

Wait for acknowledge from a set threads.

ngcbProcWaitStart()

int ngcbProcWaitStart

(

int

procId

)

Wait for start signal from main process.

ngcbProcWaitTrigger()

int ngcbProcWaitTrigger

(

int

procId

)

Wait for next trigger from main process.