}

	return existingPlugin, nil
}

func (p *plugin) NodePrepareResources(
	ctx context.Context,
	req *drapb.NodePrepareResourcesRequest,
	opts ...grpc.CallOption,
) (*drapb.NodePrepareResourcesResponse, error) {
	logger := klog.FromContext(ctx)
	logger.V(4).Info(log("calling NodePrepareResources rpc"), "request", req)

	conn, err := p.getOrCreateGRPCConn()
	if err != nil {
		return nil, err

			if claimInfo.isPrepared() {
				return nil
			}

			// This saved claim will be used to update ClaimInfo cache
			// after NodePrepareResources GRPC succeeds
			resourceClaims[claimInfo.ClaimUID] = resourceClaim

			// Loop through all plugins and prepare for calling NodePrepareResources.
			for _, resourceHandle := range claimInfo.ResourceHandles {
				claim := &drapb.Claim{
					Namespace:      claimInfo.Namespace,

)

type fakeV1alpha3GRPCServer struct {
	drapbv1alpha3.UnimplementedNodeServer
}

var _ drapbv1alpha3.NodeServer = &fakeV1alpha3GRPCServer{}

func (f *fakeV1alpha3GRPCServer) NodePrepareResources(ctx context.Context, in *drapbv1alpha3.NodePrepareResourcesRequest) (*drapbv1alpha3.NodePrepareResourcesResponse, error) {

	unprepareResourceCalls     atomic.Uint32
	prepareResourcesResponse   *drapbv1.NodePrepareResourcesResponse
	unprepareResourcesResponse *drapbv1.NodeUnprepareResourcesResponse
}

func (s *fakeDRADriverGRPCServer) NodePrepareResources(ctx context.Context, req *drapbv1.NodePrepareResourcesRequest) (*drapbv1.NodePrepareResourcesResponse, error) {
	s.prepareResourceCalls.Add(1)

	if s.timeout != nil {
		time.Sleep(*s.timeout)
	}