368 lines
12 KiB
Diff
368 lines
12 KiB
Diff
commit 7b7d83c571ceb3050969359817d4145600f14ae8
|
|
Author: Ingo Franzki <ifranzki@linux.ibm.com>
|
|
Date: Fri Apr 9 17:07:31 2021 +0200
|
|
|
|
Check CKF_LIBRARY_CANT_CREATE_OS_THREADS at C_Initialize
|
|
|
|
Fail if flag CKF_LIBRARY_CANT_CREATE_OS_THREADS is set at C_Initialize,
|
|
and event support is enabled (this is the default). We need to use pthreads
|
|
for the event thread, so we can't work if CKF_LIBRARY_CANT_CREATE_OS_THREADS
|
|
is set. Fail with CKR_NEED_TO_CREATE_THREADS if so.
|
|
|
|
The event support can be globally disabled using keyword 'disable-event-support'
|
|
in opencryptoki.conf. This disables pkcsslots to accept admin connections,
|
|
and it does not monitor for AP UDEV events (on s390 platform). No event
|
|
thread is started in the opencryptoki processes, thus we can accept if flag
|
|
CKF_LIBRARY_CANT_CREATE_OS_THREADS is set in that case.
|
|
|
|
Signed-off-by: Ingo Franzki <ifranzki@linux.ibm.com>
|
|
|
|
diff --git a/man/man5/opencryptoki.conf.5.in b/man/man5/opencryptoki.conf.5.in
|
|
index 71218f79..7dc676ab 100644
|
|
--- a/man/man5/opencryptoki.conf.5.in
|
|
+++ b/man/man5/opencryptoki.conf.5.in
|
|
@@ -10,8 +10,16 @@ pkcs#11 slots. At startup, the pkcsslotd daemon parses this file to
|
|
determine which slots will be made available.
|
|
|
|
.SH SYNTAX
|
|
-This file is made up of slot descriptions. Each slot description
|
|
-is composed of a slot number, brackets and key-value pairs.
|
|
+This file is made up of optional global definitions, and slot descriptions.
|
|
+
|
|
+The following global definitions are valid:
|
|
+
|
|
+.TP
|
|
+.BR disable-event-support
|
|
+If this keyword is specified the openCryptoki event support is disabled.
|
|
+
|
|
+.P
|
|
+Each slot description is composed of a slot number, brackets and key-value pairs.
|
|
|
|
slot number
|
|
{
|
|
diff --git a/usr/include/slotmgr.h b/usr/include/slotmgr.h
|
|
index e37368a5..451a8cf1 100644
|
|
--- a/usr/include/slotmgr.h
|
|
+++ b/usr/include/slotmgr.h
|
|
@@ -99,6 +99,7 @@ typedef struct {
|
|
LW_SHM_TYPE *shm_addr; // token specific shm address
|
|
} Slot_Info_t;
|
|
|
|
+#define FLAG_EVENT_SUPPORT_DISABLED 0x01
|
|
|
|
#ifdef PKCS64
|
|
|
|
@@ -200,6 +201,7 @@ typedef struct {
|
|
|
|
typedef struct {
|
|
uint8 num_slots;
|
|
+ uint8 flags;
|
|
CK_INFO_64 ck_info;
|
|
Slot_Info_t_64 slot_info[NUMBER_SLOTS_MANAGED];
|
|
} Slot_Mgr_Socket_t;
|
|
@@ -214,6 +216,7 @@ typedef struct {
|
|
|
|
typedef struct {
|
|
uint8 num_slots;
|
|
+ uint8 flags;
|
|
CK_INFO ck_info;
|
|
Slot_Info_t slot_info[NUMBER_SLOTS_MANAGED];
|
|
} Slot_Mgr_Socket_t;
|
|
diff --git a/usr/lib/api/api_interface.c b/usr/lib/api/api_interface.c
|
|
index 2873a20a..6517ca6c 100644
|
|
--- a/usr/lib/api/api_interface.c
|
|
+++ b/usr/lib/api/api_interface.c
|
|
@@ -308,7 +308,8 @@ void parent_fork_after()
|
|
return;
|
|
|
|
/* Restart the event thread in the parent when fork is complete */
|
|
- if (Anchor->event_thread == 0)
|
|
+ if ((Anchor->SocketDataP.flags & FLAG_EVENT_SUPPORT_DISABLED) == 0 &&
|
|
+ Anchor->event_thread == 0)
|
|
start_event_thread();
|
|
}
|
|
|
|
@@ -2752,13 +2753,7 @@ CK_RV C_Initialize(CK_VOID_PTR pVoid)
|
|
goto error;
|
|
}
|
|
}
|
|
- // If we EVER need to create threads from this library we must
|
|
- // check the Flags for the Can_Create_OS_Threads flag
|
|
- // Right now the library DOES NOT create threads and therefore this
|
|
- // check is irrelavant.
|
|
- if (pArg->flags & CKF_LIBRARY_CANT_CREATE_OS_THREADS) {
|
|
- TRACE_DEVEL("Can't create OS threads...This is OK\n");
|
|
- }
|
|
+
|
|
// Since this is an initialization path, we will be verbose in the
|
|
// code rather than efficient.
|
|
//
|
|
@@ -2848,7 +2843,21 @@ CK_RV C_Initialize(CK_VOID_PTR pVoid)
|
|
rc = CKR_FUNCTION_FAILED;
|
|
goto error_shm;
|
|
}
|
|
- // Initialize structure values
|
|
+
|
|
+ if (pVoid != NULL) {
|
|
+ pArg = (CK_C_INITIALIZE_ARGS *) pVoid;
|
|
+
|
|
+ if ((Anchor->SocketDataP.flags & FLAG_EVENT_SUPPORT_DISABLED) == 0 &&
|
|
+ (pArg->flags & CKF_LIBRARY_CANT_CREATE_OS_THREADS) != 0) {
|
|
+ TRACE_ERROR("Flag CKF_LIBRARY_CANT_CREATE_OS_THREADS is set and "
|
|
+ "event support is enabled\n");
|
|
+ OCK_SYSLOG(LOG_ERR, "C_Initialize: Application specified that "
|
|
+ "library can't create OS threads. PKCS11 Module requires "
|
|
+ "to create threads when event support is enabled.\n");
|
|
+ rc = CKR_NEED_TO_CREATE_THREADS;
|
|
+ goto error;
|
|
+ }
|
|
+ }
|
|
|
|
//Register with pkcsslotd
|
|
if (!API_Register()) {
|
|
@@ -2867,7 +2876,8 @@ CK_RV C_Initialize(CK_VOID_PTR pVoid)
|
|
}
|
|
|
|
/* Start event receiver thread */
|
|
- if (start_event_thread() != 0) {
|
|
+ if ((Anchor->SocketDataP.flags & FLAG_EVENT_SUPPORT_DISABLED) == 0 &&
|
|
+ start_event_thread() != 0) {
|
|
TRACE_ERROR("Failed to start event thread\n");
|
|
|
|
// unload all the STDLL's from the application
|
|
diff --git a/usr/lib/common/configparser.h b/usr/lib/common/configparser.h
|
|
index 13ca648d..b3c32496 100644
|
|
--- a/usr/lib/common/configparser.h
|
|
+++ b/usr/lib/common/configparser.h
|
|
@@ -35,6 +35,7 @@ typedef int (*end_slot_f)(void *private);
|
|
typedef int (*key_str_f)(void *private, int tok, const char *val);
|
|
typedef int (*key_vers_f)(void *private, int tok, unsigned int vers);
|
|
typedef void (*eolcomment_f)(void *private, const char *comment);
|
|
+typedef void (*disab_event_supp_f)(void *private);
|
|
/*
|
|
* Report an error. If the error is not reported by the parser itself
|
|
* but via one of the parse functions, \c parsermsg will be \c NULL.
|
|
@@ -52,6 +53,7 @@ typedef void (*error_f)(void *private, int line, const char *parsermsg);
|
|
*/
|
|
struct parsefuncs {
|
|
ockversion_f version;
|
|
+ disab_event_supp_f disab_event_supp;
|
|
eol_f eol;
|
|
begin_slot_f begin_slot;
|
|
end_slot_f end_slot;
|
|
diff --git a/usr/lib/common/lexer.l b/usr/lib/common/lexer.l
|
|
index b35a0b72..38cbcb70 100644
|
|
--- a/usr/lib/common/lexer.l
|
|
+++ b/usr/lib/common/lexer.l
|
|
@@ -69,6 +69,7 @@ extern char *configparse_strdup(const char *s);
|
|
|
|
version return OCKVERSION;
|
|
slot return SLOT;
|
|
+disable-event-support return DISABLE_EVENT_SUPPORT;
|
|
|
|
[^\"= \t\n]+ {
|
|
yylval.str = configparse_strdup(yytext);
|
|
diff --git a/usr/lib/common/parser.y b/usr/lib/common/parser.y
|
|
index 86806fcb..40c3994d 100644
|
|
--- a/usr/lib/common/parser.y
|
|
+++ b/usr/lib/common/parser.y
|
|
@@ -65,7 +65,7 @@ int lookup_keyword(const char *key);
|
|
int err;
|
|
}
|
|
|
|
-%token EQUAL DOT SLOT EOL OCKVERSION BEGIN_DEF END_DEF
|
|
+%token EQUAL DOT SLOT EOL OCKVERSION BEGIN_DEF END_DEF DISABLE_EVENT_SUPPORT
|
|
%token <str> STRING
|
|
%token <str> KEYWORD
|
|
%token <num> INTEGER
|
|
@@ -81,6 +81,7 @@ config_file:
|
|
|
|
sections:
|
|
version_def eolcomment
|
|
+ | disable_event_support_def eolcomment
|
|
| SLOT INTEGER BEGIN_DEF
|
|
{
|
|
if (parsefuncs->begin_slot && parsefuncs->begin_slot(parsedata, $2, 0)) {
|
|
@@ -125,6 +126,13 @@ version_def:
|
|
}
|
|
configparse_freestringsfrom($2);
|
|
}
|
|
+
|
|
+disable_event_support_def:
|
|
+ DISABLE_EVENT_SUPPORT
|
|
+ {
|
|
+ if (parsefuncs->disab_event_supp)
|
|
+ parsefuncs->disab_event_supp(parsedata);
|
|
+ }
|
|
|
|
line_def:
|
|
STRING EQUAL TOKVERSION
|
|
diff --git a/usr/sbin/pkcsslotd/pkcsslotd.h b/usr/sbin/pkcsslotd/pkcsslotd.h
|
|
index d7edcb3c..1dd0bac9 100644
|
|
--- a/usr/sbin/pkcsslotd/pkcsslotd.h
|
|
+++ b/usr/sbin/pkcsslotd/pkcsslotd.h
|
|
@@ -88,7 +88,7 @@ int XProcLock(void);
|
|
int XProcUnLock(void);
|
|
int CreateXProcLock(void);
|
|
|
|
-int init_socket_server();
|
|
+int init_socket_server(int event_support_disabled);
|
|
int term_socket_server();
|
|
int init_socket_data(Slot_Mgr_Socket_t *sp);
|
|
int socket_connection_handler(int timeout_secs);
|
|
diff --git a/usr/sbin/pkcsslotd/slotmgr.c b/usr/sbin/pkcsslotd/slotmgr.c
|
|
index efbfe8fd..3b328a6c 100644
|
|
--- a/usr/sbin/pkcsslotd/slotmgr.c
|
|
+++ b/usr/sbin/pkcsslotd/slotmgr.c
|
|
@@ -34,6 +34,7 @@ int shmid;
|
|
key_t tok;
|
|
Slot_Info_t_64 sinfo[NUMBER_SLOTS_MANAGED];
|
|
unsigned int NumberSlotsInDB = 0;
|
|
+int event_support_disabled = 0;
|
|
|
|
Slot_Info_t_64 *psinfo;
|
|
|
|
@@ -467,6 +468,13 @@ static int slotmgr_key_vers(void *private, int tok, unsigned int vers)
|
|
return 1;
|
|
}
|
|
|
|
+static void slotmgr_disab_event_supp(void *private)
|
|
+{
|
|
+ UNUSED(private);
|
|
+
|
|
+ event_support_disabled = 1;
|
|
+}
|
|
+
|
|
static void slotmgr_parseerror(void *private, int line, const char *parsermsg)
|
|
{
|
|
struct parse_data *d = (struct parse_data *)private;
|
|
@@ -480,6 +488,7 @@ static struct parsefuncs slotmgr_parsefuncs = {
|
|
.end_slot = slotmgr_end_slot,
|
|
.key_str = slotmgr_key_str,
|
|
.key_vers = slotmgr_key_vers,
|
|
+ .disab_event_supp = slotmgr_disab_event_supp,
|
|
.parseerror = slotmgr_parseerror
|
|
};
|
|
|
|
@@ -568,7 +577,7 @@ int main(int argc, char *argv[], char *envp[])
|
|
if (!XProcUnLock())
|
|
return 4;
|
|
|
|
- if (!init_socket_server()) {
|
|
+ if (!init_socket_server(event_support_disabled)) {
|
|
DestroyMutexes();
|
|
DetachFromSharedMemory();
|
|
DestroySharedMemory();
|
|
@@ -582,6 +591,8 @@ int main(int argc, char *argv[], char *envp[])
|
|
DestroySharedMemory();
|
|
return 6;
|
|
}
|
|
+ if (event_support_disabled)
|
|
+ socketData.flags |= FLAG_EVENT_SUPPORT_DISABLED;
|
|
|
|
/* Create customized token directories */
|
|
psinfo = &socketData.slot_info[0];
|
|
diff --git a/usr/sbin/pkcsslotd/socket_server.c b/usr/sbin/pkcsslotd/socket_server.c
|
|
index 41408670..3aa40267 100644
|
|
--- a/usr/sbin/pkcsslotd/socket_server.c
|
|
+++ b/usr/sbin/pkcsslotd/socket_server.c
|
|
@@ -139,12 +139,12 @@ struct event_info {
|
|
};
|
|
|
|
static int epoll_fd = -1;
|
|
-static struct listener_info proc_listener;
|
|
+static struct listener_info proc_listener = { .socket = -1 };
|
|
static DL_NODE *proc_connections = NULL;
|
|
-static struct listener_info admin_listener;
|
|
+static struct listener_info admin_listener = { .socket = -1 };
|
|
static DL_NODE *admin_connections = NULL;
|
|
#ifdef WITH_LIBUDEV
|
|
-static struct udev_mon udev_mon;
|
|
+static struct udev_mon udev_mon = { .socket = -1 };
|
|
#endif
|
|
static DL_NODE *pending_events = NULL;
|
|
static unsigned long pending_events_count = 0;
|
|
@@ -1620,6 +1620,9 @@ static void udev_mon_term(struct udev_mon *udev_mon)
|
|
if (udev_mon == NULL)
|
|
return;
|
|
|
|
+ if (udev_mon->socket < 0)
|
|
+ return;
|
|
+
|
|
epoll_ctl(epoll_fd, EPOLL_CTL_DEL, udev_mon->socket, NULL);
|
|
if (udev_mon->udev != NULL)
|
|
udev_unref(udev_mon->udev);
|
|
@@ -1636,6 +1639,7 @@ int init_socket_data(Slot_Mgr_Socket_t *socketData)
|
|
{
|
|
unsigned int processed = 0;
|
|
|
|
+ socketData->flags = 0;
|
|
PopulateCKInfo(&(socketData->ck_info));
|
|
socketData->num_slots = NumberSlotsInDB;
|
|
PopulateSlotInfo(socketData->slot_info, &processed);
|
|
@@ -1692,7 +1696,7 @@ int socket_connection_handler(int timeout_secs)
|
|
return TRUE;
|
|
}
|
|
|
|
-int init_socket_server()
|
|
+int init_socket_server(int event_support_disabled)
|
|
{
|
|
int err;
|
|
|
|
@@ -1710,18 +1714,20 @@ int init_socket_server()
|
|
return FALSE;
|
|
}
|
|
|
|
- if (!listener_create(ADMIN_SOCKET_FILE_PATH, &admin_listener,
|
|
- admin_new_conn, NUMBER_ADMINS_ALLOWED)) {
|
|
- term_socket_server();
|
|
- return FALSE;
|
|
- }
|
|
+ if (!event_support_disabled) {
|
|
+ if (!listener_create(ADMIN_SOCKET_FILE_PATH, &admin_listener,
|
|
+ admin_new_conn, NUMBER_ADMINS_ALLOWED)) {
|
|
+ term_socket_server();
|
|
+ return FALSE;
|
|
+ }
|
|
|
|
#ifdef WITH_LIBUDEV
|
|
- if (!udev_mon_init(UDEV_SUBSYSTEM_AP, &udev_mon)) {
|
|
- term_socket_server();
|
|
- return FALSE;
|
|
- }
|
|
+ if (!udev_mon_init(UDEV_SUBSYSTEM_AP, &udev_mon)) {
|
|
+ term_socket_server();
|
|
+ return FALSE;
|
|
+ }
|
|
#endif
|
|
+ }
|
|
|
|
DbgLog(DL0, "%s: Socket server started", __func__);
|
|
|
|
diff --git a/usr/sbin/pkcstok_migrate/pkcstok_migrate.c b/usr/sbin/pkcstok_migrate/pkcstok_migrate.c
|
|
index 7c225730..94fd1196 100644
|
|
--- a/usr/sbin/pkcstok_migrate/pkcstok_migrate.c
|
|
+++ b/usr/sbin/pkcstok_migrate/pkcstok_migrate.c
|
|
@@ -2066,6 +2066,13 @@ static int parseupdate_ockversion(void *private, const char *version)
|
|
return 0;
|
|
}
|
|
|
|
+static void parseupdate_disab_event_supp(void *private)
|
|
+{
|
|
+ struct parseupdate *u = (struct parseupdate *)private;
|
|
+
|
|
+ fprintf(u->f, "disable-event-support");
|
|
+}
|
|
+
|
|
static void parseupdate_eol(void *private)
|
|
{
|
|
struct parseupdate *u = (struct parseupdate *)private;
|
|
@@ -2124,6 +2131,7 @@ static void parseupdate_eolcomment(void *private, const char *comment)
|
|
|
|
static struct parsefuncs parseupdatefuncs = {
|
|
.version = parseupdate_ockversion,
|
|
+ .disab_event_supp = parseupdate_disab_event_supp,
|
|
.eol = parseupdate_eol,
|
|
.begin_slot = parseupdate_begin_slot,
|
|
.end_slot = parseupdate_end_slot,
|