test nintendo switch thread limit

main.cpp

#ifdef __SWITCH__
#include <switch.h>
#include <switch/kernel/condvar.h>
#include <switch/kernel/mutex.h>
#else
// fake libnx function
int appletMainLoop(){return 1;}
void consoleInit(void * i){return;}
void consoleUpdate(void * i){return;}
void consoleExit(void * i){return;}
void socketInitializeDefault(){return;};
#endif

// memcpy
#include <cstring>
// hto ..
#include <unistd.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <netinet/in.h>
// addrinfo
#include <netdb.h>
#include <stdio.h>
#include <pthread.h>
#include <errno.h>
// malloc
#include <cstdlib>

pthread_cond_t condition;
pthread_mutex_t mutex;
pthread_barrier_t barrier;

#define DEBUG(msg, ...)do{ \
	pthread_mutex_lock(&mutex); \
	printf("%s [%s:%d] " msg "\n", __FILE__, __func__, __LINE__, ## __VA_ARGS__); \
	pthread_cond_signal(&condition); \
	pthread_mutex_unlock(&mutex); \
	}while(0)

typedef struct data {
	int index;
} Data;

typedef struct test {
	pthread_t thread_id;
	Data *data;
} Test;


static void set_timeout(struct timespec *timeout, uint64_t ms_from_now)
{
    clock_gettime(CLOCK_MONOTONIC, timeout);
    timeout->tv_sec += ms_from_now / 1000;
    timeout->tv_nsec += (ms_from_now % 1000) * 1000000;
    if(timeout->tv_nsec > 1000000000)
    {
        timeout->tv_sec += timeout->tv_nsec / 1000000000;
        timeout->tv_nsec %= 1000000000;
    }
}

void *test(void *vargp){
	Data *d = (Data*) vargp;
	pthread_barrier_wait(&barrier);
	int loop = 0;
	while(1){
		loop++;
		DEBUG("data %d %d\n", d->index, loop);
		pthread_barrier_wait(&barrier);
	}
}

int print_thread_list(){
	int out_num_threads = 0;
	svcGetThreadList(&out_num_threads, NULL, 0, INVALID_HANDLE);
	printf("GetThreadList %d\n", out_num_threads);
	consoleUpdate(NULL);
	return out_num_threads;
}

int test_thread_limit(){
	int64_t out;
	svcGetResourceLimitLimitValue(&out, INVALID_HANDLE, LimitableResource_Threads);
	// are privileges required ?
	printf("GetResourceLimitLimitValue LimitableResource_Threads %ld\n", out);
	consoleUpdate(NULL);
	return out;
}

int main(int arg, char ** argv)
{
    consoleInit(NULL);
    //setsysInitialize();
    //socketInitializeDefault();

	printf("start\n");
	printf("Create Thread\n");

	static struct timespec timeout = {0, 0};
	uint64_t ms_from_now = 5000;
	int r = 0;

	int base_count = print_thread_list();
	test_thread_limit();
	sleep(3);

    pthread_condattr_t attr;
    r = pthread_condattr_init(&attr);
	if(r != 0){
		printf("failed to init attr");
	}
	r = pthread_condattr_setclock(&attr, CLOCK_MONOTONIC);
	if(r != 0){
		printf("failed to setclock attr");
	}
	r = pthread_cond_init(&condition, &attr);
	if(r != 0){
		printf("failed cond init");
	}

	pthread_attr_t t_attr;
	pthread_attr_init(&t_attr);
	//size_t base;
	//pthread_attr_getstacksize(&t_attr, &base);
	//pthread_attr_setstacksize(&t_attr, 8388608);
	//printf("Thread stacksize %d\n", base);

	// OK
	//int count = 68;
	// KO
	int count = 69;
	pthread_barrier_init(&barrier, NULL, count);

	Test tests[count] = { 0 };
	for(int i=0; i<count; i++){
		tests[i].data = (Data *) malloc(sizeof(Data));
		tests[i].data->index = i;
		int r = pthread_create(&(tests[i].thread_id), &t_attr, test,(void*) tests[i].data);
		switch(r){
			case 0: break;
			case EAGAIN:
       			printf("EAGAIN Insufficient resources to create another thread.");
				consoleUpdate(NULL); sleep(10);
				break;
			case EINVAL:
				printf("EINVAL Invalid settings in attr.");
				consoleUpdate(NULL); sleep(10);
				break;
			case EPERM:
				printf("EPERM  No permission to set the scheduling policy and parameters specified in attr.");
				consoleUpdate(NULL); sleep(10);
				break;
			default:
				continue;
		}
	}
	int new_count = print_thread_list();
	printf("base count %d new count %d diff %d\n", base_count, new_count, new_count - base_count);
	consoleUpdate(NULL);
	sleep(3);

	while(1){
        pthread_mutex_lock(&mutex);
		set_timeout(&timeout, ms_from_now);
	    r = pthread_cond_timedwait(&condition, &mutex, &timeout);
        pthread_mutex_unlock(&mutex);
	    if(r == ETIMEDOUT)
	    {
			printf("ETIMEDOUT\n");
	    } else if( r != 0 ) {
			printf("Error\n");
		}
		consoleUpdate(NULL);
	}

	for(int i=0; i<count; i++){
		pthread_join(tests[i].thread_id, NULL);
	}
	consoleExit(NULL);
}

Makefile

#---------------------------------------------------------------------------------
.SUFFIXES:
#---------------------------------------------------------------------------------

ifeq ($(strip $(DEVKITPRO)),)
$(error "Please set DEVKITPRO in your environment. export DEVKITPRO=<path to>/devkitpro")
endif

TOPDIR ?= $(CURDIR)
include $(DEVKITPRO)/libnx/switch_rules

#---------------------------------------------------------------------------------
# TARGET is the name of the output
# BUILD is the directory where object files & intermediate files will be placed
# SOURCES is a list of directories containing source code
# DATA is a list of directories containing data files
# INCLUDES is a list of directories containing header files
# ROMFS is the directory containing data to be added to RomFS, relative to the Makefile (Optional)
#
# NO_ICON: if set to anything, do not use icon.
# NO_NACP: if set to anything, no .nacp file is generated.
# APP_TITLE is the name of the app stored in the .nacp file (Optional)
# APP_AUTHOR is the author of the app stored in the .nacp file (Optional)
# APP_VERSION is the version of the app stored in the .nacp file (Optional)
# APP_TITLEID is the titleID of the app stored in the .nacp file (Optional)
# ICON is the filename of the icon (.jpg), relative to the project folder.
#   If not set, it attempts to use one of the following (in this order):
#     - <Project name>.jpg
#     - icon.jpg
#     - <libnx folder>/default_icon.jpg
#
# CONFIG_JSON is the filename of the NPDM config file (.json), relative to the project folder.
#   If not set, it attempts to use one of the following (in this order):
#     - <Project name>.json
#     - config.json
#   If a JSON file is provided or autodetected, an ExeFS PFS0 (.nsp) is built instead
#   of a homebrew executable (.nro). This is intended to be used for sysmodules.
#   NACP building is skipped as well.
#---------------------------------------------------------------------------------
TARGET		:=	$(notdir $(CURDIR))
BUILD		:=	build
SOURCES		:=	./
DATA		:=	data
INCLUDES	:=	include
#ROMFS	:=	romfs

#---------------------------------------------------------------------------------
# options for code generation
#---------------------------------------------------------------------------------
ARCH	:=	-march=armv8-a+crc+crypto -mtune=cortex-a57 -mtp=soft -fPIE

CFLAGS	:=	-g -Wall -O2 -ffunction-sections \
			$(ARCH) $(DEFINES)

CFLAGS	+=	-D__SWITCH__ $(INCLUDE) `sdl2-config --cflags` -pthread

CXXFLAGS	:= $(CFLAGS) -fno-rtti -fno-exceptions

ASFLAGS	:=	-g $(ARCH)
LDFLAGS	=	-specs=$(DEVKITPRO)/libnx/switch.specs -g $(ARCH) -pthread -Wl,-Map,$(notdir $*.map)

LIBS	:=  -lpthread -lnx

#---------------------------------------------------------------------------------
# list of directories containing libraries, this must be the top level containing
# include and lib
#---------------------------------------------------------------------------------
LIBDIRS	:= $(PORTLIBS) $(LIBNX)


#---------------------------------------------------------------------------------
# no real need to edit anything past this point unless you need to add additional
# rules for different file extensions
#---------------------------------------------------------------------------------
ifneq ($(BUILD),$(notdir $(CURDIR)))
#---------------------------------------------------------------------------------

export OUTPUT	:=	$(CURDIR)/$(TARGET)
export TOPDIR	:=	$(CURDIR)

export VPATH	:=	$(foreach dir,$(SOURCES),$(CURDIR)/$(dir)) \
			$(foreach dir,$(DATA),$(CURDIR)/$(dir))

export DEPSDIR	:=	$(CURDIR)/$(BUILD)

CFILES		:=	$(foreach dir,$(SOURCES),$(notdir $(wildcard $(dir)/*.c)))
CPPFILES	:=	$(foreach dir,$(SOURCES),$(notdir $(wildcard $(dir)/*.cpp)))
SFILES		:=	$(foreach dir,$(SOURCES),$(notdir $(wildcard $(dir)/*.s)))
BINFILES	:=	$(foreach dir,$(DATA),$(notdir $(wildcard $(dir)/*.*)))

#---------------------------------------------------------------------------------
# use CXX for linking C++ projects, CC for standard C
#---------------------------------------------------------------------------------
ifeq ($(strip $(CPPFILES)),)
#---------------------------------------------------------------------------------
	export LD	:=	$(CC)
#---------------------------------------------------------------------------------
else
#---------------------------------------------------------------------------------
	export LD	:=	$(CXX)
#---------------------------------------------------------------------------------
endif
#---------------------------------------------------------------------------------

export OFILES_BIN	:=	$(addsuffix .o,$(BINFILES))
export OFILES_SRC	:=	$(CPPFILES:.cpp=.o) $(CFILES:.c=.o) $(SFILES:.s=.o)
export OFILES 	:=	$(OFILES_BIN) $(OFILES_SRC)
export HFILES_BIN	:=	$(addsuffix .h,$(subst .,_,$(BINFILES)))

export INCLUDE	:=	$(foreach dir,$(INCLUDES),-I$(CURDIR)/$(dir)) \
			$(foreach dir,$(LIBDIRS),-I$(dir)/include) \
			-I$(CURDIR)/$(BUILD)

export LIBPATHS	:=	$(foreach dir,$(LIBDIRS),-L$(dir)/lib)

ifeq ($(strip $(CONFIG_JSON)),)
	jsons := $(wildcard *.json)
	ifneq (,$(findstring $(TARGET).json,$(jsons)))
		export APP_JSON := $(TOPDIR)/$(TARGET).json
	else
		ifneq (,$(findstring config.json,$(jsons)))
			export APP_JSON := $(TOPDIR)/config.json
		endif
	endif
else
	export APP_JSON := $(TOPDIR)/$(CONFIG_JSON)
endif

ifeq ($(strip $(ICON)),)
	icons := $(wildcard *.jpg)
	ifneq (,$(findstring $(TARGET).jpg,$(icons)))
		export APP_ICON := $(TOPDIR)/$(TARGET).jpg
	else
		ifneq (,$(findstring icon.jpg,$(icons)))
			export APP_ICON := $(TOPDIR)/icon.jpg
		endif
	endif
else
	export APP_ICON := $(TOPDIR)/$(ICON)
endif

ifeq ($(strip $(NO_ICON)),)
	export NROFLAGS += --icon=$(APP_ICON)
endif

ifeq ($(strip $(NO_NACP)),)
	export NROFLAGS += --nacp=$(CURDIR)/$(TARGET).nacp
endif

ifneq ($(APP_TITLEID),)
	export NACPFLAGS += --titleid=$(APP_TITLEID)
endif

ifneq ($(ROMFS),)
	export NROFLAGS += --romfsdir=$(CURDIR)/$(ROMFS)
endif

.PHONY: $(BUILD) clean all

#---------------------------------------------------------------------------------
all: $(BUILD)

$(BUILD):
	@[ -d $@ ] || mkdir -p $@
	@$(MAKE) --no-print-directory -C $(BUILD) -f $(CURDIR)/Makefile

#---------------------------------------------------------------------------------
clean:
	@echo clean ...
ifeq ($(strip $(APP_JSON)),)
	@rm -fr $(BUILD) $(TARGET).nro $(TARGET).nacp $(TARGET).elf
else
	@rm -fr $(BUILD) $(TARGET).nsp $(TARGET).nso $(TARGET).npdm $(TARGET).elf
endif


#---------------------------------------------------------------------------------
else
.PHONY:	all

DEPENDS	:=	$(OFILES:.o=.d)

#---------------------------------------------------------------------------------
# main targets
#---------------------------------------------------------------------------------
ifeq ($(strip $(APP_JSON)),)

all	:	$(OUTPUT).nro

ifeq ($(strip $(NO_NACP)),)
$(OUTPUT).nro	:	$(OUTPUT).elf $(OUTPUT).nacp
else
$(OUTPUT).nro	:	$(OUTPUT).elf
endif

else

all	:	$(OUTPUT).nsp

$(OUTPUT).nsp	:	$(OUTPUT).nso $(OUTPUT).npdm

$(OUTPUT).nso	:	$(OUTPUT).elf

endif

$(OUTPUT).elf	:	$(OFILES)

$(OFILES_SRC)	: $(HFILES_BIN)

#---------------------------------------------------------------------------------
# you need a rule like this for each extension you use as binary data
#---------------------------------------------------------------------------------
%.bin.o	%_bin.h :	%.bin
#---------------------------------------------------------------------------------
	@echo $(notdir $<)
	@$(bin2o)

-include $(DEPENDS)

#---------------------------------------------------------------------------------------
endif
#---------------------------------------------------------------------------------------