--- loncom/metadata_database/parse_activity_log.pl 2005/09/20 17:49:51 1.19 +++ loncom/metadata_database/parse_activity_log.pl 2005/09/20 18:01:01 1.20 @@ -2,7 +2,7 @@ # # The LearningOnline Network # -# $Id: parse_activity_log.pl,v 1.19 2005/09/20 17:49:51 matthew Exp $ +# $Id: parse_activity_log.pl,v 1.20 2005/09/20 18:01:01 matthew Exp $ # # Copyright Michigan State University Board of Trustees # @@ -492,15 +492,10 @@ sub process_courselog { if (length($chunk) > 20000) { # avoid putting too much data into the database # (usually an uploaded file or something similar) - $chunk = &escape($chunk); - if (! open(CHUNKFILE,">>$chunk_filename") || - ! print CHUNKFILE $timestamp.':'.$host.':'.$chunk.$/) { - # abort - close(CHUNKFILE); + if (! &savechunk(\$chunk,$timestamp,$host)) { close(IN); return undef; } - close(CHUNKFILE); next; } my $warningflag = ''; @@ -519,8 +514,12 @@ sub process_courselog { if ($action !~ /^(LOGIN|VIEW|POST|CSTORE|STORE)$/) { $warningflag .= 'action'; print $error_fh 'full log entry:'.$log.$/; - print $error_fh 'error on chunk:'.$chunk.$/; - $logthis->('(action) Unable to parse '.$/.$chunk.$/. + print $error_fh 'error on chunk (saving)'.$/; + if (! &savechunk(\$chunk,$timestamp,$host)) { + close(IN); + return undef; + } + $logthis->('(action) Unable to parse chunk'.$/. 'got '. 'time = '.$time.$/. 'res = '.$res.$/. @@ -557,6 +556,20 @@ sub process_courselog { } close IN; return $linecount; + ## + ## + sub savechunk { + my ($chunkref,$timestamp,$host) = @_; + my $chunk = &escape(${$chunkref}); + if (! open(CHUNKFILE,">>$chunk_filename") || + ! print CHUNKFILE $timestamp.':'.$host.':'.$chunk.$/) { + # abort + close(CHUNKFILE); + return 0; + } + close(CHUNKFILE); + return 1; + } }