(inner pluginClient)
| 15 | } |
| 16 | |
| 17 | func newGuardedPluginClient(inner pluginClient) pluginClient { |
| 18 | client := &guardedPluginClient{inner: inner} |
| 19 | client.cond = sync.NewCond(&client.mu) |
| 20 | return client |
| 21 | } |
| 22 | |
| 23 | func (c *guardedPluginClient) Call(ctx context.Context, method string, request []byte) ([]byte, error) { |
| 24 | inner, errAcquire := c.acquire() |