tpm: move recv_data_callback to TPM interface

Simplify the TPM backend setup, move callback to TPM interface.

Signed-off-by: Marc-André Lureau <marcandre.lureau@redhat.com>
Reviewed-by: Stefan Berger <stefanb@linux.vnet.ibm.com>
Signed-off-by: Stefan Berger <stefanb@linux.vnet.ibm.com>
This commit is contained in:
Marc-André Lureau 2017-10-10 00:56:02 +02:00 committed by Stefan Berger
parent 698f5daa4a
commit 05a699985c
6 changed files with 15 additions and 15 deletions

View File

@ -44,11 +44,9 @@ enum TpmType tpm_backend_get_type(TPMBackend *s)
return k->type; return k->type;
} }
int tpm_backend_init(TPMBackend *s, TPMState *state, int tpm_backend_init(TPMBackend *s, TPMState *state)
TPMRecvDataCB *datacb)
{ {
s->tpm_state = state; s->tpm_state = state;
s->recv_data_callback = datacb;
s->had_startup_error = false; s->had_startup_error = false;
return 0; return 0;

View File

@ -176,6 +176,7 @@ static int tpm_emulator_set_locality(TPMEmulator *tpm_emu, uint8_t locty_number,
static void tpm_emulator_handle_request(TPMBackend *tb, TPMBackendCmd *cmd) static void tpm_emulator_handle_request(TPMBackend *tb, TPMBackendCmd *cmd)
{ {
TPMEmulator *tpm_emu = TPM_EMULATOR(tb); TPMEmulator *tpm_emu = TPM_EMULATOR(tb);
TPMIfClass *tic = TPM_IF_GET_CLASS(tb->tpm_state);
Error *err = NULL; Error *err = NULL;
DPRINTF("processing TPM command"); DPRINTF("processing TPM command");
@ -190,7 +191,7 @@ static void tpm_emulator_handle_request(TPMBackend *tb, TPMBackendCmd *cmd)
goto error; goto error;
} }
tb->recv_data_callback(tb->tpm_state); tic->request_completed(TPM_IF(tb->tpm_state));
return; return;
error: error:

View File

@ -29,6 +29,9 @@ typedef struct TPMIf {
typedef struct TPMIfClass { typedef struct TPMIfClass {
InterfaceClass parent_class; InterfaceClass parent_class;
/* run in thread pool by backend */
void (*request_completed)(TPMIf *obj);
} TPMIfClass; } TPMIfClass;
#define TPM_STANDARD_CMDLINE_OPTS \ #define TPM_STANDARD_CMDLINE_OPTS \

View File

@ -139,13 +139,14 @@ err_exit:
static void tpm_passthrough_handle_request(TPMBackend *tb, TPMBackendCmd *cmd) static void tpm_passthrough_handle_request(TPMBackend *tb, TPMBackendCmd *cmd)
{ {
TPMPassthruState *tpm_pt = TPM_PASSTHROUGH(tb); TPMPassthruState *tpm_pt = TPM_PASSTHROUGH(tb);
TPMIfClass *tic = TPM_IF_GET_CLASS(tb->tpm_state);
DPRINTF("tpm_passthrough: processing command %p\n", cmd); DPRINTF("tpm_passthrough: processing command %p\n", cmd);
tpm_passthrough_unix_tx_bufs(tpm_pt, cmd->in, cmd->in_len, tpm_passthrough_unix_tx_bufs(tpm_pt, cmd->in, cmd->in_len,
cmd->out, cmd->out_len, &cmd->selftest_done); cmd->out, cmd->out_len, &cmd->selftest_done);
tb->recv_data_callback(tb->tpm_state); tic->request_completed(TPM_IF(tb->tpm_state));
} }
static void tpm_passthrough_reset(TPMBackend *tb) static void tpm_passthrough_reset(TPMBackend *tb)

View File

@ -430,11 +430,10 @@ static void tpm_tis_receive_bh(void *opaque)
TPM_TIS_INT_DATA_AVAILABLE | TPM_TIS_INT_STS_VALID); TPM_TIS_INT_DATA_AVAILABLE | TPM_TIS_INT_STS_VALID);
} }
/* static void tpm_tis_request_completed(TPMIf *ti)
* Callback from the TPM to indicate that the response was received.
*/
static void tpm_tis_receive_cb(TPMState *s)
{ {
TPMState *s = TPM(ti);
bool is_selftest_done = s->cmd.selftest_done; bool is_selftest_done = s->cmd.selftest_done;
uint8_t locty = s->cmd.locty; uint8_t locty = s->cmd.locty;
uint8_t l; uint8_t l;
@ -1078,7 +1077,7 @@ static void tpm_tis_realizefn(DeviceState *dev, Error **errp)
s->be_driver->fe_model = TPM_MODEL_TPM_TIS; s->be_driver->fe_model = TPM_MODEL_TPM_TIS;
if (tpm_backend_init(s->be_driver, s, tpm_tis_receive_cb)) { if (tpm_backend_init(s->be_driver, s)) {
error_setg(errp, "tpm_tis: backend driver with id %s could not be " error_setg(errp, "tpm_tis: backend driver with id %s could not be "
"initialized", s->backend); "initialized", s->backend);
return; return;
@ -1110,11 +1109,13 @@ static void tpm_tis_initfn(Object *obj)
static void tpm_tis_class_init(ObjectClass *klass, void *data) static void tpm_tis_class_init(ObjectClass *klass, void *data)
{ {
DeviceClass *dc = DEVICE_CLASS(klass); DeviceClass *dc = DEVICE_CLASS(klass);
TPMIfClass *tc = TPM_IF_CLASS(klass);
dc->realize = tpm_tis_realizefn; dc->realize = tpm_tis_realizefn;
dc->props = tpm_tis_properties; dc->props = tpm_tis_properties;
dc->reset = tpm_tis_reset; dc->reset = tpm_tis_reset;
dc->vmsd = &vmstate_tpm_tis; dc->vmsd = &vmstate_tpm_tis;
tc->request_completed = tpm_tis_request_completed;
} }
static const TypeInfo tpm_tis_info = { static const TypeInfo tpm_tis_info = {

View File

@ -30,8 +30,6 @@
typedef struct TPMBackendClass TPMBackendClass; typedef struct TPMBackendClass TPMBackendClass;
typedef struct TPMBackend TPMBackend; typedef struct TPMBackend TPMBackend;
typedef void (TPMRecvDataCB)(TPMState *);
typedef struct TPMBackendCmd { typedef struct TPMBackendCmd {
uint8_t locty; uint8_t locty;
const uint8_t *in; const uint8_t *in;
@ -48,7 +46,6 @@ struct TPMBackend {
bool opened; bool opened;
TPMState *tpm_state; TPMState *tpm_state;
GThreadPool *thread_pool; GThreadPool *thread_pool;
TPMRecvDataCB *recv_data_callback;
bool had_startup_error; bool had_startup_error;
/* <public> */ /* <public> */
@ -106,8 +103,7 @@ enum TpmType tpm_backend_get_type(TPMBackend *s);
* *
* Returns 0 on success. * Returns 0 on success.
*/ */
int tpm_backend_init(TPMBackend *s, TPMState *state, int tpm_backend_init(TPMBackend *s, TPMState *state);
TPMRecvDataCB *datacb);
/** /**
* tpm_backend_startup_tpm: * tpm_backend_startup_tpm: