Method Compute

en_ops/e_where_equal.cc:52–90

        OP_REQUIRES(context, lib != NULL, errors::Unknown("Unable to load sgx.so!"));
    }
    void Compute(OpKernelContext *context) override
    {
        const Tensor &input1 = context->input(0);
        auto input1_flat = input1.flat<float>();

        const Tensor &input2 = context->input(1);
        auto input2_flat = input2.flat<float>();

        const Tensor &cond1 = context->input(2);
        auto cond1_flat = cond1.flat<float>();

        const Tensor &cond2 = context->input(3);
        auto cond2_flat = cond2.flat<float>();

        const TensorShape &input_shape = input1.shape();

        Tensor *output = NULL;
        OP_REQUIRES_OK(context, context->allocate_output(0, input_shape, &output));
        auto output_flat = output->flat<float>();
        int N = input1_flat.size() / times_;
        int n1 = 1;
        int n2 = 1;
        if (cond1_flat.size() > 1)
        {
            n1 = cond1_flat.size() / times_;
        }
        if (cond2_flat.size() > 1)
        {
            n2 = cond2_flat.size() / times_;
        }

        unsigned long int eid_ = (eid_high_ << 32) + eid_low_;
        typedef void (*function)(unsigned long int eid, float *input1, float *input2, float *cond1, float *cond2, int N, int n1, int n2, float *output);
        dlerror();
        function where_equal_kernel = (function)dlsym(lib, "where_equal");
        const char *dlsym_error = dlerror();
        OP_REQUIRES(context, !dlsym_error, errors::Unknown("loading of where_equal failed: ", dlsym_error));
        where_equal_kernel(eid_, (float *)input1_flat.data(), (float *)input2_flat.data(), (float *)cond1_flat.data(), (float *)cond2_flat.data(), N, n1, n2, (float *)output_flat.data());
    };

private:
    void *lib;