1

すべて。私はしばらくの間これに頭をぶつけてきました...私は基本的にperlembed+perlcallと多かれ少なかれevpsgiからそれを「借りた」例をまとめようとしています。問題は、1000回の反復ごとにサイズが約1MB大きくなることです。これは、長期間有効なプロセスで実行する場合の最大の状況ではありません（これは私が使用しているユースケースです）。

タイトルにあるように、valgrindを使用して実行すると、リークの可能性はないと報告されます。--trace-malloc = yesを指定して実行しましたが、freeは、大量の呼び出しの最後にのみ呼び出されるようです。これはperlのMOかもしれないと理解していますが、少なくともメモリを再利用し、OSがプロセスを終了するまで成長しなかったとしたらいいでしょう。

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からスカラーを取得し、自分で2つ作成しますが、いずれも解放されません。

リーク1

あなたが持っている：

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

それに関する2つの問題：

  • 反射率が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 に答える