File: set_num_additional_processors.c

package info (click to toggle)
fis-gtm 6.3-007-1
  • links: PTS, VCS
  • area: main
  • in suites: buster
  • size: 36,284 kB
  • sloc: ansic: 328,861; asm: 5,182; csh: 5,102; sh: 1,918; awk: 291; makefile: 69; sed: 13
file content (97 lines) | stat: -rwxr-xr-x 2,732 bytes parent folder | download | duplicates (4)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
/****************************************************************
 *								*
 * Copyright (c) 2001-2015 Fidelity National Information	*
 * Services, Inc. and/or its subsidiaries. All rights reserved.	*
 *								*
 *	This source code contains the intellectual property	*
 *	of its copyright holder(s), and is made available	*
 *	under a license.  If you do not know the terms of	*
 *	the license, please stop and do not read further.	*
 *								*
 ****************************************************************/

#include "mdef.h"

#include "gtm_signal.h"	/* needed for VSIG_ATOMIC_T */
#ifndef __MVS__
#include <sys/param.h>

#ifdef __hpux
#include <sys/pstat.h>
#else
#include "gtm_unistd.h"
#endif
#else  /* __MVS__ */
#define CVT_ADDR                       0x10  	/* -> to CVT */
#define OFFSET_IN_CVT_OF_CSD_ADDR      0x294  	/* CVT+294 -> CSD */
#define OFFSET_IN_CSD_OF_NUM_CPUS_ADDR 0x0a   	/* CSD+a #cpus online */
#define TYPE_OF_NUM_CPUS               short
#endif
#include "send_msg.h"
#include "gtmio.h"
#include "have_crit.h"
#include "eintr_wrappers.h"
#include "set_num_additional_processors.h"
#ifdef DEBUG
#include "io.h"
#include "gtm_stdio.h"
#include "wcs_sleep.h"
#include "wbox_test_init.h"
#include "deferred_signal_handler.h"
#endif

GBLREF int	num_additional_processors;

error_def(ERR_NUMPROCESSORS);

void set_num_additional_processors(void)
{
	long			numcpus;
#	ifdef __hpux
	intrpt_state_t		prev_intrpt_state;
	struct pst_dynamic	psd;
	DEFER_INTERRUPTS(INTRPT_IN_SET_NUM_ADD_PROCS, prev_intrpt_state);

#		ifdef DEBUG
		if (gtm_white_box_test_case_enabled
			&& (WBTEST_SYSCONF_WRAPPER == gtm_white_box_test_case_number))
		{
			DBGFPF((stderr, "will sleep indefinitely now\n"));
			while (TRUE)
				LONG_SLEEP(60);
		}
#		endif
	if (pstat_getdynamic(&psd, SIZEOF(psd), (size_t)1, 0) == -1)
	{
		send_msg_csa(CSA_ARG(NULL) VARLSTCNT(1) ERR_NUMPROCESSORS);
                numcpus = 1;
        }
	else
		numcpus = psd.psd_proc_cnt;
	ENABLE_INTERRUPTS(INTRPT_IN_SET_NUM_ADD_PROCS, prev_intrpt_state);
#	else
#	  ifdef __MVS__
#	    ifdef DEBUG
	DEFER_INTERRUPTS(INTRPT_IN_SET_NUM_ADD_PROCS);
	if (gtm_white_box_test_case_enabled
		&& (WBTEST_SYSCONF_WRAPPER == gtm_white_box_test_case_number))
	{
		DBGFPF((stderr, "will sleep indefinitely now\n"));
		while (TRUE)
			LONG_SLEEP(60);
	}
	ENABLE_INTERRUPTS(INTRPT_IN_SET_NUM_ADD_PROCS);
#	    endif
	numcpus = *(TYPE_OF_NUM_CPUS *)((*(int *)((*(int *)CVT_ADDR) + OFFSET_IN_CVT_OF_CSD_ADDR))
			+ OFFSET_IN_CSD_OF_NUM_CPUS_ADDR);
#	  else
	SYSCONF(_SC_NPROCESSORS_ONLN, numcpus);
	if (numcpus == -1)
	{
		send_msg_csa(CSA_ARG(NULL) VARLSTCNT(1) ERR_NUMPROCESSORS);
		numcpus = 1;
	}
#	  endif
#	endif
	num_additional_processors = (int)(numcpus - 1);
}