1
0
mirror of git://git.gnupg.org/gnupg.git synced 2024-11-09 21:28:51 +01:00

agent:daemon: Add an argument to specify requiring socket connection.

* agent/agent.h (daemon_start): Add REQ_SOCK argument.
* agent/call-daemon.c (daemon_start): Support specifying a socket
connection.
* agent/call-scd.c (start_scd): Connection don't care.
* agent/call-tpm2d.c (start_tpm2d): Likewise.

--

GnuPG-bug-id: 7151
Signed-off-by: NIIBE Yutaka <gniibe@fsij.org>
This commit is contained in:
NIIBE Yutaka 2024-06-27 15:26:25 +09:00
parent d98521b934
commit 5d980802ac
No known key found for this signature in database
GPG Key ID: 640114AF89DE6054
4 changed files with 13 additions and 5 deletions

View File

@ -709,7 +709,7 @@ gpg_error_t agent_card_ecc_kem (ctrl_t ctrl, const unsigned char *ecc_ct,
size_t ecc_point_len, unsigned char *ecc_ecdh); size_t ecc_point_len, unsigned char *ecc_ecdh);
/*-- call-daemon.c --*/ /*-- call-daemon.c --*/
gpg_error_t daemon_start (enum daemon_type type, ctrl_t ctrl); gpg_error_t daemon_start (enum daemon_type type, ctrl_t ctrl, int req_sock);
assuan_context_t daemon_type_ctx (enum daemon_type type, ctrl_t ctrl); assuan_context_t daemon_type_ctx (enum daemon_type type, ctrl_t ctrl);
gpg_error_t daemon_unlock (enum daemon_type type, ctrl_t ctrl, gpg_error_t rc); gpg_error_t daemon_unlock (enum daemon_type type, ctrl_t ctrl, gpg_error_t rc);
void initialize_module_daemon (void); void initialize_module_daemon (void);

View File

@ -211,7 +211,7 @@ atfork_cb (void *opaque, int where)
* caller must call unlock_daemon after this function has returned * caller must call unlock_daemon after this function has returned
* success and the actual Assuan transaction been done. */ * success and the actual Assuan transaction been done. */
gpg_error_t gpg_error_t
daemon_start (enum daemon_type type, ctrl_t ctrl) daemon_start (enum daemon_type type, ctrl_t ctrl, int require_socket)
{ {
gpg_error_t err = 0; gpg_error_t err = 0;
const char *pgmname; const char *pgmname;
@ -243,6 +243,7 @@ daemon_start (enum daemon_type type, ctrl_t ctrl)
return gpg_error (GPG_ERR_INTERNAL); return gpg_error (GPG_ERR_INTERNAL);
} }
again:
/* We need to serialize the access to scd_local_list and primary_scd_ctx. */ /* We need to serialize the access to scd_local_list and primary_scd_ctx. */
rc = npth_mutex_lock (&start_daemon_lock); rc = npth_mutex_lock (&start_daemon_lock);
if (rc) if (rc)
@ -275,7 +276,7 @@ daemon_start (enum daemon_type type, ctrl_t ctrl)
/* Check whether the pipe server has already been started and in /* Check whether the pipe server has already been started and in
this case either reuse a lingering pipe connection or establish a this case either reuse a lingering pipe connection or establish a
new socket based one. */ new socket based one. */
if (g->primary_ctx && g->primary_ctx_reusable) if (g->primary_ctx && g->primary_ctx_reusable && !require_socket)
{ {
ctx = g->primary_ctx; ctx = g->primary_ctx;
g->primary_ctx_reusable = 0; g->primary_ctx_reusable = 0;
@ -466,6 +467,7 @@ daemon_start (enum daemon_type type, ctrl_t ctrl)
leave: leave:
xfree (abs_homedir); xfree (abs_homedir);
abs_homedir = NULL;
if (err) if (err)
{ {
rc = npth_mutex_unlock (&start_daemon_lock); rc = npth_mutex_unlock (&start_daemon_lock);
@ -482,6 +484,12 @@ daemon_start (enum daemon_type type, ctrl_t ctrl)
rc = npth_mutex_unlock (&start_daemon_lock); rc = npth_mutex_unlock (&start_daemon_lock);
if (rc) if (rc)
log_error ("failed to release the start_daemon lock: %s\n", strerror (rc)); log_error ("failed to release the start_daemon lock: %s\n", strerror (rc));
if (require_socket && g->primary_ctx == ctx)
{
daemon_unlock (type, ctrl, 0);
goto again;
}
} }
return err; return err;
} }

View File

@ -94,7 +94,7 @@ struct inq_needpin_parm_s
static int static int
start_scd (ctrl_t ctrl) start_scd (ctrl_t ctrl)
{ {
return daemon_start (DAEMON_SCD, ctrl); return daemon_start (DAEMON_SCD, ctrl, 0);
} }

View File

@ -16,7 +16,7 @@
static int static int
start_tpm2d (ctrl_t ctrl) start_tpm2d (ctrl_t ctrl)
{ {
return daemon_start (DAEMON_TPM2D, ctrl); return daemon_start (DAEMON_TPM2D, ctrl, 0);
} }
static int static int