1

全部。一段时间以来，我一直在努力解决这个问题……我正在尝试整理一个基本上是 perlembed + perlcall 的示例，并且或多或少地从 evpsgi 中“借用”了它。问题是每 1000 次迭代它的大小就会增长大约 1MB。在长期运行的进程（这是我正在使用的用例）中运行时，这并不是最好的情况。

正如标题所述，如果我使用 valgrind 运行，它会报告没有泄漏的可能。我用 --trace-malloc=yes 运行，似乎只有在大量调用中最后才调用 free 。我知道这可能是 perl 的 MO，但如果它至少重新使用内存并且在操作系统终止进程之前不会增长，那就太好了。

sv_2mortal 的条目提到了一些关于缓冲区可被“窃取”的内容，但我已经在代码中添加了对 sv_2mortal 的调用，但没有任何变化。

事不宜迟，这里是代码。请原谅它的货物崇拜。提前致谢！

/*
 *
 * cc `perl -MExtUtils::Embed -e ccopts -e ldopts` -Wall -ggdb test_perl_2.c -o test_perl_2
 *
 * # test.psgi
 * use strict;
 * use warnings;
 * my $app = sub  {
 *     return [ 200, [ test => 1 ], [ sprintf( "%d: Hello!!! from %s\n", $$, __FILE__ ) ] ];
 * };
 *
 */

#include <stdio.h>
#include <EXTERN.h>               /* from the Perl distribution     */
#include <perl.h>                 /* from the Perl distribution     */

static PerlInterpreter *perlinterp;  /***    The Perl interpreter    ***/
static SV *app;

void do_stuff( void );
SV * get_stuff( void );
SV * call_stuff( SV * );

EXTERN_C void xs_init( pTHX );
EXTERN_C void boot_DynaLoader (pTHX_ CV* cv);
EXTERN_C void xs_init( pTHX ) {
    char *file = __FILE__;
    dXSUB_SYS;
    /* DynaLoader is a special case */
    newXS("DynaLoader::boot_DynaLoader", boot_DynaLoader, file);
}

int main( int argc, char **argv, char **env ) {
    char code[ 1024 ];
    char psgi[] = "test.psgi";
    char *embedding[] = { "", "-e", "0" };

    PERL_SYS_INIT3( &argc, &argv, &env );
    perlinterp = perl_alloc();
    PERL_SET_CONTEXT( perlinterp );
    perl_construct( perlinterp );
    perl_parse( perlinterp, xs_init, 3, embedding, (char **)NULL );
    PL_exit_flags |= PERL_EXIT_DESTRUCT_END;

    sprintf( code, "do '%s' or die $@", psgi );
    app = eval_pv( code, TRUE ); /* croak_on_error */

    do_stuff();

    PL_perl_destruct_level = 1;
    perl_destruct( perlinterp );
    perl_free( perlinterp );
    PERL_SYS_TERM();
    return 0;
}

void do_stuff( void ) {
    int body_lastindex, i, count;
    AV *response_av, *body_av;
    SV *stuff_sv, *response_sv, *status, *tmp_body_sv, *body_sv;

//  count = 10000;
    count = 10;
    while( count-- ) {

        ENTER;
        SAVETMPS;

        stuff_sv = get_stuff();
        response_sv = call_stuff( stuff_sv );

        if(
            NULL == response_sv ||
            ! SvROK( response_sv ) ||
            SvTYPE( SvRV( response_sv ) ) != SVt_PVAV
        ) {
            printf( "NULL == response_sv\n" );
            goto CLIENT_END;
        }

        response_av = (AV *)SvRV( response_sv );

        status = *av_fetch( response_av, 0, 0 );
        printf( "status = %ld\n", (long)SvIV( status ) );

        body_av = (AV *)SvRV( *av_fetch( response_av, 2, 0 ) );

        body_sv = newSV( 0 );

        body_lastindex = av_len( body_av );
        for( i = 0; i <= body_lastindex; i++ ) {
            tmp_body_sv = (SV *)*av_fetch( body_av, i, 0 );
            if( SvOK( tmp_body_sv ) ) {
                sv_catsv( body_sv, tmp_body_sv );
            }
        }
        printf( "body_sv = %s\n", SvPV_nolen( body_sv ) );

CLIENT_END:
        FREETMPS;
        LEAVE;
    }
}

SV * get_stuff( void ) {
    HV *stuff_hv;
//    stuff_hv = (HV *)sv_2mortal((SV *)newHV());
    stuff_hv = newHV();

    if( NULL == hv_store( stuff_hv, "SCRIPT_NAME", strlen( "SCRIPT_NAME" ), newSVpv( "", 0 ), 0 ) ) {
        croak( "hv_store( 'SCRIPT_NAME' )" );
    }

    if( NULL == hv_store( stuff_hv, "REQUEST_METHOD", strlen( "REQUEST_METHOD" ), newSVpv( "GET", 3 ), 0 ) ) {
        croak( "hv_store( 'REQUEST_METHOD' )" );
    }

    if( NULL == hv_store( stuff_hv, "REQUEST_URI", strlen( "REQUEST_URI" ), newSVpv( "/abc?def", 8 ), 0 ) ) {
        croak( "hv_store( 'REQUEST_URI' )" );
    }

    if( NULL == hv_store( stuff_hv, "PATH_INFO", strlen( "PATH_INFO" ), newSVpv( "/abc", 4 ), 0 ) ) {
        croak( "hv_store( 'PATH_INFO' )" );
    }

    if( NULL == hv_store( stuff_hv, "QUERY_STRING", strlen( "QUERY_STRING" ), newSVpv( "def", 3 ), 0 ) ) {
        croak( "hv_store( 'QUERY_STRING' )" );
    }

    return newRV_inc( (SV *)stuff_hv );
}

SV * call_stuff( SV *stuff_sv ) {
    SV *response_sv;
    int count;

//  printf( "REQUEST_URI = %s\n", SvPV_nolen( *hv_fetch( (HV *)SvRV( stuff_sv ), "REQUEST_URI", strlen( "REQUEST_URI" ), 0 ) ) );

    dSP;
    ENTER;
    SAVETMPS;
    PUSHMARK( SP );
    XPUSHs( stuff_sv ); // stuff_sv is not mortal.
    PUTBACK;
    count = call_sv( app, G_EVAL | G_SCALAR | G_KEEPERR );
    SPAGAIN;
    if( SvTRUE( ERRSV ) ) {
        response_sv = NULL;
        fprintf( stderr, "FATAL: %s", SvPV_nolen( ERRSV ) );
        /* CLEAR_ERRSV() is only available 5.8.9 or later */
        if( SvMAGICAL( ERRSV ) ) {
            mg_free( ERRSV );
            mg_clear( ERRSV );
        }
        sv_setpvn_mg( ERRSV, "", 0 );
        POPs; // causes "warning: value computed is not used"
    }
    else if( count > 0 ) {
        response_sv = POPs; // is this mortal?
        SvREFCNT_inc( response_sv );
    } else {
        response_sv = NULL;
    }

    PUTBACK;
    FREETMPS;
    LEAVE;
    return response_sv;
}
4

1 回答 1

4

你不释放任何东西！你从 Perl 得到一个标量，然后你自己创建了两个，但没有一个被释放。

泄漏 1

你有：

HV *stuff_hv;
stuff_hv = newHV();
return newRV_inc( (SV *)stuff_hv );

有两个问题：

  • 您正在创建一个 refcnt 为 2 的 HV。

    更改newRV_inc为newRV_noinc。

  • 你永远不会释放它（或者作为凡人从 XS 函数中返回它）。

    完成后使用SvREFCNT_dec( stuff_sv )，也许在调用call_stuff.

泄漏 2

你有：

body_sv = newSV( 0 );

同样，该标量没有相应的释放。你需要

SvREFCNT_dec( body_sv );

之后printf。

泄漏 3

你有：

response_sv = POPs; // is this mortal?
SvREFCNT_inc( response_sv );

它是否会死并不重要。如果它是，您需要声明它的所有权，所以它inc是合适的。但是当你完成它时，你必须稍后释放它。

 SvREFCNT_dec( response_sv );
于 2012-11-01T01:50:11.167 回答