Hi
----- Original Message -----
> On 10/09/2017 06:55 PM, Marc-André Lureau wrote:
> > This simplifies a bit locality handling, and argument passing, and
> > could pave the way to queuing requests (if that makes sense).
>
> We won't queue requests. The TPM interfaces all send one request and
> expect the driver to wait until the response comes back.
Even on different localities? (I am not familiar enough with that part)
>
> >
> > Signed-off-by: Marc-André Lureau <marcandre.lur...@redhat.com>
>
> Reviewed-by: Stefan Berger <stef...@linux.vnet.ibm.com>
>
> > ---
> > hw/tpm/tpm_int.h | 1 +
> > include/sysemu/tpm_backend.h | 16 +++++++++++++---
> > backends/tpm.c | 6 +++---
> > hw/tpm/tpm_emulator.c | 29 +++++++++++++++--------------
> > hw/tpm/tpm_passthrough.c | 24 +++++-------------------
> > hw/tpm/tpm_tis.c | 18 +++++++++++++-----
> > 6 files changed, 50 insertions(+), 44 deletions(-)
> >
> > diff --git a/hw/tpm/tpm_int.h b/hw/tpm/tpm_int.h
> > index f2f285b3cc..6d7b3dc850 100644
> > --- a/hw/tpm/tpm_int.h
> > +++ b/hw/tpm/tpm_int.h
> > @@ -26,6 +26,7 @@ struct TPMState {
> >
> > uint8_t locty_number;
> > TPMLocality *locty_data;
> > + TPMBackendCmd cmd;
> >
> > char *backend;
> > TPMBackend *be_driver;
> > diff --git a/include/sysemu/tpm_backend.h b/include/sysemu/tpm_backend.h
> > index 9c83a512e1..3bb90be3de 100644
> > --- a/include/sysemu/tpm_backend.h
> > +++ b/include/sysemu/tpm_backend.h
> > @@ -30,7 +30,16 @@
> > typedef struct TPMBackendClass TPMBackendClass;
> > typedef struct TPMBackend TPMBackend;
> >
> > -typedef void (TPMRecvDataCB)(TPMState *, bool selftest_done);
> > +typedef void (TPMRecvDataCB)(TPMState *);
> > +
> > +typedef struct TPMBackendCmd {
> > + uint8_t locty;
> > + const uint8_t *in;
> > + uint32_t in_len;
> > + uint8_t *out;
> > + uint32_t out_len;
> > + bool selftest_done;
> > +} TPMBackendCmd;
> >
> > struct TPMBackend {
> > Object parent;
> > @@ -76,7 +85,7 @@ struct TPMBackendClass {
> >
> > void (*opened)(TPMBackend *s, Error **errp);
> >
> > - void (*handle_request)(TPMBackend *s);
> > + void (*handle_request)(TPMBackend *s, TPMBackendCmd *cmd);
> > };
> >
> > /**
> > @@ -121,11 +130,12 @@ bool tpm_backend_had_startup_error(TPMBackend *s);
> > /**
> > * tpm_backend_deliver_request:
> > * @s: the backend to send the request to
> > + * @cmd: the command to deliver
> > *
> > * Send a request to the backend. The backend will then send the request
> > * to the TPM implementation.
> > */
> > -void tpm_backend_deliver_request(TPMBackend *s);
> > +void tpm_backend_deliver_request(TPMBackend *s, TPMBackendCmd *cmd);
> >
> > /**
> > * tpm_backend_reset:
> > diff --git a/backends/tpm.c b/backends/tpm.c
> > index 34e82085ec..dc7c831ff8 100644
> > --- a/backends/tpm.c
> > +++ b/backends/tpm.c
> > @@ -25,7 +25,7 @@ static void tpm_backend_worker_thread(gpointer data,
> > gpointer user_data)
> > TPMBackendClass *k = TPM_BACKEND_GET_CLASS(s);
> >
> > assert(k->handle_request != NULL);
> > - k->handle_request(s);
> > + k->handle_request(s, (TPMBackendCmd *)data);
> > }
> >
> > static void tpm_backend_thread_end(TPMBackend *s)
> > @@ -76,9 +76,9 @@ bool tpm_backend_had_startup_error(TPMBackend *s)
> > return s->had_startup_error;
> > }
> >
> > -void tpm_backend_deliver_request(TPMBackend *s)
> > +void tpm_backend_deliver_request(TPMBackend *s, TPMBackendCmd *cmd)
> > {
> > - g_thread_pool_push(s->thread_pool, NULL, NULL);
> > + g_thread_pool_push(s->thread_pool, cmd, NULL);
> > }
> >
> > void tpm_backend_reset(TPMBackend *s)
> > diff --git a/hw/tpm/tpm_emulator.c b/hw/tpm/tpm_emulator.c
> > index 4fe405353a..788ab9876d 100644
> > --- a/hw/tpm/tpm_emulator.c
> > +++ b/hw/tpm/tpm_emulator.c
> > @@ -172,28 +172,29 @@ static int tpm_emulator_set_locality(TPMEmulator
> > *tpm_emu, uint8_t locty_number)
> > return 0;
> > }
> >
> > -static void tpm_emulator_handle_request(TPMBackend *tb)
> > +static void tpm_emulator_handle_request(TPMBackend *tb, TPMBackendCmd
> > *cmd)
> > {
> > TPMEmulator *tpm_emu = TPM_EMULATOR(tb);
> > - TPMLocality *locty = NULL;
> > - bool selftest_done = false;
> > Error *err = NULL;
> >
> > DPRINTF("processing TPM command");
> >
> > - locty = tb->tpm_state->locty_data;
> > - if (tpm_emulator_set_locality(tpm_emu,
> > - tb->tpm_state->locty_number) < 0 ||
> > - tpm_emulator_unix_tx_bufs(tpm_emu, locty->w_buffer.buffer,
> > - locty->w_offset, locty->r_buffer.buffer,
> > - locty->r_buffer.size, &selftest_done,
> > - &err) < 0) {
> > - tpm_util_write_fatal_error_response(locty->r_buffer.buffer,
> > - locty->r_buffer.size);
> > - error_report_err(err);
> > + if (tpm_emulator_set_locality(tpm_emu, tb->tpm_state->locty_number) <
> > 0) {
> > + goto error;
> > + }
> > +
> > + if (tpm_emulator_unix_tx_bufs(tpm_emu, cmd->in, cmd->in_len,
> > + cmd->out, cmd->out_len,
> > + &cmd->selftest_done, &err) < 0) {
> > + goto error;
> > }
> >
> > - tb->recv_data_callback(tb->tpm_state, selftest_done);
> > + tb->recv_data_callback(tb->tpm_state);
> > + return;
> > +
> > +error:
> > + tpm_util_write_fatal_error_response(cmd->out, cmd->out_len);
> > + error_report_err(err);
> > }
> >
> > static int tpm_emulator_probe_caps(TPMEmulator *tpm_emu)
> > diff --git a/hw/tpm/tpm_passthrough.c b/hw/tpm/tpm_passthrough.c
> > index 0ae4596932..93d72b8e9e 100644
> > --- a/hw/tpm/tpm_passthrough.c
> > +++ b/hw/tpm/tpm_passthrough.c
> > @@ -137,30 +137,16 @@ err_exit:
> > return ret;
> > }
> >
> > -static int tpm_passthrough_unix_transfer(TPMPassthruState *tpm_pt,
> > - const TPMLocality *locty_data,
> > - bool *selftest_done)
> > -{
> > - return tpm_passthrough_unix_tx_bufs(tpm_pt,
> > - locty_data->w_buffer.buffer,
> > - locty_data->w_offset,
> > - locty_data->r_buffer.buffer,
> > - locty_data->r_buffer.size,
> > - selftest_done);
> > -}
> > -
> > -static void tpm_passthrough_handle_request(TPMBackend *tb)
> > +static void tpm_passthrough_handle_request(TPMBackend *tb, TPMBackendCmd
> > *cmd)
> > {
> > TPMPassthruState *tpm_pt = TPM_PASSTHROUGH(tb);
> > - bool selftest_done = false;
> >
> > - DPRINTF("tpm_passthrough: processing command\n");
> > + DPRINTF("tpm_passthrough: processing command %p\n", cmd);
> >
> > - tpm_passthrough_unix_transfer(tpm_pt,
> > - tb->tpm_state->locty_data,
> > - &selftest_done);
> > + tpm_passthrough_unix_tx_bufs(tpm_pt, cmd->in, cmd->in_len,
> > + cmd->out, cmd->out_len,
> > &cmd->selftest_done);
> >
> > - tb->recv_data_callback(tb->tpm_state, selftest_done);
> > + tb->recv_data_callback(tb->tpm_state);
> > }
> >
> > static void tpm_passthrough_reset(TPMBackend *tb)
> > diff --git a/hw/tpm/tpm_tis.c b/hw/tpm/tpm_tis.c
> > index 345a4fbee5..ffed7bfaf9 100644
> > --- a/hw/tpm/tpm_tis.c
> > +++ b/hw/tpm/tpm_tis.c
> > @@ -215,7 +215,15 @@ static void tpm_tis_tpm_send(TPMState *s, uint8_t
> > locty)
> > */
> > tis->loc[locty].state = TPM_TIS_STATE_EXECUTION;
> >
> > - tpm_backend_deliver_request(s->be_driver);
> > + s->cmd = (TPMBackendCmd) {
> > + .locty = locty,
> > + .in = s->locty_data->w_buffer.buffer,
> > + .in_len = s->locty_data->w_offset,
> > + .out = s->locty_data->r_buffer.buffer,
> > + .out_len = s->locty_data->r_buffer.size
> > + };
> > +
> > + tpm_backend_deliver_request(s->be_driver, &s->cmd);
> > }
> >
> > /* raise an interrupt if allowed */
> > @@ -352,7 +360,7 @@ static void tpm_tis_receive_bh(void *opaque)
> > {
> > TPMState *s = opaque;
> > TPMTISEmuState *tis = &s->s.tis;
> > - uint8_t locty = s->locty_number;
> > + uint8_t locty = s->cmd.locty;
> >
> > tpm_tis_sts_set(&tis->loc[locty],
> > TPM_TIS_STS_VALID | TPM_TIS_STS_DATA_AVAILABLE);
> > @@ -371,11 +379,11 @@ static void tpm_tis_receive_bh(void *opaque)
> > /*
> > * Callback from the TPM to indicate that the response was received.
> > */
> > -static void tpm_tis_receive_cb(TPMState *s,
> > - bool is_selftest_done)
> > +static void tpm_tis_receive_cb(TPMState *s)
> > {
> > TPMTISEmuState *tis = &s->s.tis;
> > - uint8_t locty = s->locty_number;
> > + bool is_selftest_done = s->cmd.selftest_done;
> > + uint8_t locty = s->cmd.locty;
> > uint8_t l;
> >
> > if (is_selftest_done) {
>
>
>
