Function run_interpreter

numexpr3/interpreter.cpp:395–511

}

static int
run_interpreter(NumExprObject *self, NpyIter *iter, NpyIter *reduce_iter,
                     bool reduction_outer_loop, bool need_output_buffering,
                     int *pc_error)
{
        
    int returnValue;

    char *errorMessage = NULL;
    

    *pc_error = -1;
    
    // printf( "run_interpreter #1\n" );
    if ((gs.n_thread == 1) || gs.force_serial) {
        // Can do it as one "task"
        if (reduce_iter == NULL) {
            // Reset the iterator to allocate its buffers
            if(NpyIter_Reset(iter, NULL) != NPY_SUCCEED) return -1;

            // prepareSerial is a faster variant on prepareThreads.
            BENCH_TIME(0);
            returnValue = prepareSerial( self, iter, pc_error, &errorMessage );
            DIFF_TIME(0);
            // BENCH_TIME(1);
            if( returnValue != 0 ) return -1;

            // printf( "run_interpreter #3\n" );
            Py_BEGIN_ALLOW_THREADS
            BENCH_TIME(200);
            returnValue = vm_engine_iter_task(iter, self, 0, pc_error, &errorMessage); 
            DIFF_TIME(200);                           
            Py_END_ALLOW_THREADS
            // printf( "run_interpreter #5\n" );
            // finishThreads(iter);
        }
        else { // Reduction operation 
            if (reduction_outer_loop) { // Reduction on outer loop 
                char **dataPtr;
                NpyIter_IterNextFunc *iterNext;
                
                dataPtr = NpyIter_GetDataPtrArray(reduce_iter);
                iterNext = NpyIter_GetIterNext(reduce_iter, NULL);
                if (iterNext == NULL) {
                    return -1;
                }
                                    
                // get_temps_space( safeParams, BLOCK_SIZE1);
                returnValue = prepareThreads( self, iter, pc_error, &errorMessage );
                if( returnValue != 0 ) return -1;

                Py_BEGIN_ALLOW_THREADS
                do {
                    returnValue = NpyIter_ResetBasePointers(iter, dataPtr, &errorMessage);
                    if (returnValue >= 0) {
                        returnValue = vm_engine_iter_outer_reduce_task(iter,
                                                self,
                                                pc_error, &errorMessage);