Result:
found more than 674 distributions - search limited to the first 2001 files matching your query
( run in 0.725 )
Sereal-Decoder
view release on metacpan or search on metacpan
/* proceed, so be sure to properly set the TINFL_FLAG_HAS_MORE_INPUT flag. */
TINFL_STATUS_NEEDS_MORE_INPUT = 1,
/* This flag indicates the inflator definitely has 1 or more bytes of uncompressed data available, but it cannot write this data into the output buffer. */
/* Note if the source compressed data was corrupted it's possible for the inflator to return a lot of uncompressed data to the caller. I've been assuming you know how much uncompressed data to expect */
/* (either exact or worst case) and will stop calling the inflator and fail after receiving too much. In pure streaming scenarios where you have no idea how many bytes to expect this may not be possible */
/* so I may need to add some code to address this. */
TINFL_STATUS_HAS_MORE_OUTPUT = 2
} tinfl_status;
/* Initializes the decompressor to its initial state. */
MINIZ_EXPORT mz_bool mz_zip_reader_extract_file_to_cfile(mz_zip_archive *pZip, const char *pArchive_filename, MZ_FILE *pFile, mz_uint flags);
#endif
#if 0
/* TODO */
typedef void *mz_zip_streaming_extract_state_ptr;
mz_zip_streaming_extract_state_ptr mz_zip_streaming_extract_begin(mz_zip_archive *pZip, mz_uint file_index, mz_uint flags);
mz_uint64 mz_zip_streaming_extract_get_size(mz_zip_archive *pZip, mz_zip_streaming_extract_state_ptr pState);
mz_uint64 mz_zip_streaming_extract_get_cur_ofs(mz_zip_archive *pZip, mz_zip_streaming_extract_state_ptr pState);
mz_bool mz_zip_streaming_extract_seek(mz_zip_archive *pZip, mz_zip_streaming_extract_state_ptr pState, mz_uint64 new_ofs);
size_t mz_zip_streaming_extract_read(mz_zip_archive *pZip, mz_zip_streaming_extract_state_ptr pState, void *pBuf, size_t buf_size);
mz_bool mz_zip_streaming_extract_end(mz_zip_archive *pZip, mz_zip_streaming_extract_state_ptr pState);
#endif
/* This function compares the archive's local headers, the optional local zip64 extended information block, and the optional descriptor following the compressed data vs. the data in the central directory. */
/* It also validates that each file can be successfully uncompressed unless the MZ_ZIP_FLAG_VALIDATE_HEADERS_ONLY is specified. */
MINIZ_EXPORT mz_bool mz_zip_validate_file(mz_zip_archive *pZip, mz_uint file_index, mz_uint flags);
Sereal-Encoder
view release on metacpan or search on metacpan
/* proceed, so be sure to properly set the TINFL_FLAG_HAS_MORE_INPUT flag. */
TINFL_STATUS_NEEDS_MORE_INPUT = 1,
/* This flag indicates the inflator definitely has 1 or more bytes of uncompressed data available, but it cannot write this data into the output buffer. */
/* Note if the source compressed data was corrupted it's possible for the inflator to return a lot of uncompressed data to the caller. I've been assuming you know how much uncompressed data to expect */
/* (either exact or worst case) and will stop calling the inflator and fail after receiving too much. In pure streaming scenarios where you have no idea how many bytes to expect this may not be possible */
/* so I may need to add some code to address this. */
TINFL_STATUS_HAS_MORE_OUTPUT = 2
} tinfl_status;
/* Initializes the decompressor to its initial state. */
MINIZ_EXPORT mz_bool mz_zip_reader_extract_file_to_cfile(mz_zip_archive *pZip, const char *pArchive_filename, MZ_FILE *pFile, mz_uint flags);
#endif
#if 0
/* TODO */
typedef void *mz_zip_streaming_extract_state_ptr;
mz_zip_streaming_extract_state_ptr mz_zip_streaming_extract_begin(mz_zip_archive *pZip, mz_uint file_index, mz_uint flags);
mz_uint64 mz_zip_streaming_extract_get_size(mz_zip_archive *pZip, mz_zip_streaming_extract_state_ptr pState);
mz_uint64 mz_zip_streaming_extract_get_cur_ofs(mz_zip_archive *pZip, mz_zip_streaming_extract_state_ptr pState);
mz_bool mz_zip_streaming_extract_seek(mz_zip_archive *pZip, mz_zip_streaming_extract_state_ptr pState, mz_uint64 new_ofs);
size_t mz_zip_streaming_extract_read(mz_zip_archive *pZip, mz_zip_streaming_extract_state_ptr pState, void *pBuf, size_t buf_size);
mz_bool mz_zip_streaming_extract_end(mz_zip_archive *pZip, mz_zip_streaming_extract_state_ptr pState);
#endif
/* This function compares the archive's local headers, the optional local zip64 extended information block, and the optional descriptor following the compressed data vs. the data in the central directory. */
/* It also validates that each file can be successfully uncompressed unless the MZ_ZIP_FLAG_VALIDATE_HEADERS_ONLY is specified. */
MINIZ_EXPORT mz_bool mz_zip_validate_file(mz_zip_archive *pZip, mz_uint file_index, mz_uint flags);
Sereal-Path
view release on metacpan or search on metacpan
Iterator/zstd/common/xxhash.h view on Meta::CPAN
XXH_PUBLIC_API XXH64_state_t* XXH64_createState(void);
XXH_PUBLIC_API XXH_errorcode XXH64_freeState(XXH64_state_t* statePtr);
/* hash streaming */
XXH_PUBLIC_API XXH_errorcode XXH32_reset (XXH32_state_t* statePtr, unsigned int seed);
XXH_PUBLIC_API XXH_errorcode XXH32_update (XXH32_state_t* statePtr, const void* input, size_t length);
XXH_PUBLIC_API XXH32_hash_t XXH32_digest (const XXH32_state_t* statePtr);
Shout
view release on metacpan or search on metacpan
ex/example2.pl view on Meta::CPAN
###############################################################################
use vars qw{$Debug $Lame};
chomp( $Lame = `which lame` );
my $Bitrate=64;
my $Samplerate = 22050;
### Create a new streaming object
my $streamer = new Shout
host => "localhost",
port => 8000,
mount => "/example2",
password => "hackme",
Shuvgey
view release on metacpan or search on metacpan
lib/Shuvgey/Server.pm view on Meta::CPAN
'psgi.errors' => *STDERR,
'psgi.multithread' => FALSE,
'psgi.multiprocess' => FALSE,
'psgi.run_once' => FALSE,
'psgi.nonblocking' => TRUE,
'psgi.streaming' => FALSE,
'SCRIPT_NAME' => '',
'SERVER_NAME' => $host eq '0.0.0.0' ? $hostname : $host,
'SERVER_PORT' => $port,
'SERVER_PROTOCOL' => "HTTP/2",
SockJS
view release on metacpan or search on metacpan
lib/SockJS/Transport.pm view on Meta::CPAN
$class = 'XHRPolling';
}
elsif ($path eq 'xhr_send') {
$class = 'XHRSend';
}
elsif ($path eq 'xhr_streaming') {
$class = 'XHRStreaming';
}
if ($path eq 'jsonp') {
$class = 'JSONPPolling';
}
Socket-Class
view release on metacpan or search on metacpan
xs/sc_ssl/openssl/source/test/cms-test.pl view on Meta::CPAN
"-verify -in test.cms -inform DER "
. " -CAfile $smdir/smroot.pem -out smtst.txt -content smcont.txt"
],
[
"signed content test streaming BER format, RSA",
"-sign -in smcont.txt -outform DER -nodetach"
. " -stream -signer $smdir/smrsa1.pem -out test.cms",
"-verify -in test.cms -inform DER "
. " -CAfile $smdir/smroot.pem -out smtst.txt"
],
xs/sc_ssl/openssl/source/test/cms-test.pl view on Meta::CPAN
"-verify -in test2.cms -inform DER "
. " -CAfile $smdir/smroot.pem -out smtst.txt -content smcont.txt"
],
[
"signed content test streaming BER format, DSA key",
"-sign -in smcont.txt -outform DER -nodetach"
. " -stream -signer $smdir/smdsa1.pem -out test.cms",
"-verify -in test.cms -inform DER "
. " -CAfile $smdir/smroot.pem -out smtst.txt"
],
[
"signed content test streaming BER format, 2 DSA and 2 RSA keys",
"-sign -in smcont.txt -outform DER -nodetach"
. " -signer $smdir/smrsa1.pem -signer $smdir/smrsa2.pem"
. " -signer $smdir/smdsa1.pem -signer $smdir/smdsa2.pem"
. " -stream -out test.cms",
"-verify -in test.cms -inform DER "
. " -CAfile $smdir/smroot.pem -out smtst.txt"
],
[
"signed content test streaming BER format, 2 DSA and 2 RSA keys, no attributes",
"-sign -in smcont.txt -outform DER -noattr -nodetach"
. " -signer $smdir/smrsa1.pem -signer $smdir/smrsa2.pem"
. " -signer $smdir/smdsa1.pem -signer $smdir/smdsa2.pem"
. " -stream -out test.cms",
"-verify -in test.cms -inform DER "
. " -CAfile $smdir/smroot.pem -out smtst.txt"
],
[
"signed content test streaming S/MIME format, 2 DSA and 2 RSA keys",
"-sign -in smcont.txt -nodetach"
. " -signer $smdir/smrsa1.pem -signer $smdir/smrsa2.pem"
. " -signer $smdir/smdsa1.pem -signer $smdir/smdsa2.pem"
. " -stream -out test.cms",
"-verify -in test.cms " . " -CAfile $smdir/smroot.pem -out smtst.txt"
],
[
"signed content test streaming multipart S/MIME format, 2 DSA and 2 RSA keys",
"-sign -in smcont.txt"
. " -signer $smdir/smrsa1.pem -signer $smdir/smrsa2.pem"
. " -signer $smdir/smdsa1.pem -signer $smdir/smdsa2.pem"
. " -stream -out test.cms",
"-verify -in test.cms " . " -CAfile $smdir/smroot.pem -out smtst.txt"
],
[
"enveloped content test streaming S/MIME format, 3 recipients",
"-encrypt -in smcont.txt"
. " -stream -out test.cms"
. " $smdir/smrsa1.pem $smdir/smrsa2.pem $smdir/smrsa3.pem ",
"-decrypt -recip $smdir/smrsa1.pem -in test.cms -out smtst.txt"
],
[
"enveloped content test streaming S/MIME format, 3 recipients, 3rd used",
"-encrypt -in smcont.txt"
. " -stream -out test.cms"
. " $smdir/smrsa1.pem $smdir/smrsa2.pem $smdir/smrsa3.pem ",
"-decrypt -recip $smdir/smrsa3.pem -in test.cms -out smtst.txt"
],
[
"enveloped content test streaming S/MIME format, 3 recipients, key only used",
"-encrypt -in smcont.txt"
. " -stream -out test.cms"
. " $smdir/smrsa1.pem $smdir/smrsa2.pem $smdir/smrsa3.pem ",
"-decrypt -inkey $smdir/smrsa3.pem -in test.cms -out smtst.txt"
],
[
"enveloped content test streaming S/MIME format, AES-256 cipher, 3 recipients",
"-encrypt -in smcont.txt"
. " -aes256 -stream -out test.cms"
. " $smdir/smrsa1.pem $smdir/smrsa2.pem $smdir/smrsa3.pem ",
"-decrypt -recip $smdir/smrsa1.pem -in test.cms -out smtst.txt"
],
xs/sc_ssl/openssl/source/test/cms-test.pl view on Meta::CPAN
);
my @smime_cms_tests = (
[
"signed content test streaming BER format, 2 DSA and 2 RSA keys, keyid",
"-sign -in smcont.txt -outform DER -nodetach -keyid"
. " -signer $smdir/smrsa1.pem -signer $smdir/smrsa2.pem"
. " -signer $smdir/smdsa1.pem -signer $smdir/smdsa2.pem"
. " -stream -out test.cms",
"-verify -in test.cms -inform DER "
. " -CAfile $smdir/smroot.pem -out smtst.txt"
],
[
"signed content test streaming PEM format, 2 DSA and 2 RSA keys",
"-sign -in smcont.txt -outform PEM -nodetach"
. " -signer $smdir/smrsa1.pem -signer $smdir/smrsa2.pem"
. " -signer $smdir/smdsa1.pem -signer $smdir/smdsa2.pem"
. " -stream -out test.cms",
"-verify -in test.cms -inform PEM "
xs/sc_ssl/openssl/source/test/cms-test.pl view on Meta::CPAN
"-verify_receipt test2.cms -in test.cms"
. " -CAfile $smdir/smroot.pem"
],
[
"enveloped content test streaming S/MIME format, 3 recipients, keyid",
"-encrypt -in smcont.txt"
. " -stream -out test.cms -keyid"
. " $smdir/smrsa1.pem $smdir/smrsa2.pem $smdir/smrsa3.pem ",
"-decrypt -recip $smdir/smrsa1.pem -in test.cms -out smtst.txt"
],
[
"enveloped content test streaming PEM format, KEK",
"-encrypt -in smcont.txt -outform PEM -aes128"
. " -stream -out test.cms "
. " -secretkey 000102030405060708090A0B0C0D0E0F "
. " -secretkeyid C0FEE0",
"-decrypt -in test.cms -out smtst.txt -inform PEM"
. " -secretkey 000102030405060708090A0B0C0D0E0F "
. " -secretkeyid C0FEE0"
],
[
"enveloped content test streaming PEM format, KEK, key only",
"-encrypt -in smcont.txt -outform PEM -aes128"
. " -stream -out test.cms "
. " -secretkey 000102030405060708090A0B0C0D0E0F "
. " -secretkeyid C0FEE0",
"-decrypt -in test.cms -out smtst.txt -inform PEM"
. " -secretkey 000102030405060708090A0B0C0D0E0F "
],
[
"data content test streaming PEM format",
"-data_create -in smcont.txt -outform PEM -nodetach"
. " -stream -out test.cms",
"-data_out -in test.cms -inform PEM -out smtst.txt"
],
[
"encrypted content test streaming PEM format, 128 bit RC2 key",
"-EncryptedData_encrypt -in smcont.txt -outform PEM"
. " -rc2 -secretkey 000102030405060708090A0B0C0D0E0F"
. " -stream -out test.cms",
"-EncryptedData_decrypt -in test.cms -inform PEM "
. " -secretkey 000102030405060708090A0B0C0D0E0F -out smtst.txt"
],
[
"encrypted content test streaming PEM format, 40 bit RC2 key",
"-EncryptedData_encrypt -in smcont.txt -outform PEM"
. " -rc2 -secretkey 0001020304"
. " -stream -out test.cms",
"-EncryptedData_decrypt -in test.cms -inform PEM "
. " -secretkey 0001020304 -out smtst.txt"
],
[
"encrypted content test streaming PEM format, triple DES key",
"-EncryptedData_encrypt -in smcont.txt -outform PEM"
. " -des3 -secretkey 000102030405060708090A0B0C0D0E0F1011121314151617"
. " -stream -out test.cms",
"-EncryptedData_decrypt -in test.cms -inform PEM "
. " -secretkey 000102030405060708090A0B0C0D0E0F1011121314151617"
. " -out smtst.txt"
],
[
"encrypted content test streaming PEM format, 128 bit AES key",
"-EncryptedData_encrypt -in smcont.txt -outform PEM"
. " -aes128 -secretkey 000102030405060708090A0B0C0D0E0F"
. " -stream -out test.cms",
"-EncryptedData_decrypt -in test.cms -inform PEM "
. " -secretkey 000102030405060708090A0B0C0D0E0F -out smtst.txt"
xs/sc_ssl/openssl/source/test/cms-test.pl view on Meta::CPAN
);
my @smime_cms_comp_tests = (
[
"compressed content test streaming PEM format",
"-compress -in smcont.txt -outform PEM -nodetach"
. " -stream -out test.cms",
"-uncompress -in test.cms -inform PEM -out smtst.txt"
]
xs/sc_ssl/openssl/source/test/cms-test.pl view on Meta::CPAN
my ( $tnam, $rscmd, $rvcmd ) = @$smtst;
if ($ossl8)
{
# Skip smime resign: 0.9.8 smime doesn't support -resign
next if ($scmd =~ /smime/ && $rscmd =~ /-resign/);
# Disable streaming: option not supported in 0.9.8
$tnam =~ s/streaming//;
$rscmd =~ s/-stream//;
$rvcmd =~ s/-stream//;
}
system("$scmd$rscmd 2>cms.err 1>cms.out");
if ($?) {
Spark-Form
view release on metacpan or search on metacpan
lib/Spark/Form.pm view on Meta::CPAN
If it looks sufficiently like a field (implements Spark::Form::Field),
then it will add it to the list of fields. @rest will just become %kwargs
Uses 'field name' to locate it from the data passed in.
This is a B<streaming interface>, it returns the form itself.
=head2 validate
Validates the form. Sets C<valid> and then also returns the value.
=head2 data
Allows you to pass in a HashRef of data to populate the fields with before validation. Useful if you don't use a plugin to automatically populate the data.
This is a B<streaming interface>, it returns the form itself.
=head2 fields () => Fields
Returns a list of Fields in the form in their current order
Speech-Recognizer-SPX
view release on metacpan or search on metacpan
SPX/Server.pm view on Meta::CPAN
# -*- cperl -*-
use strict;
# Speech::Recognizer::SPX::Server: Perl module for writing PocketSphinx
# streaming audio servers.
# Copyright (c) 2000 Cepstral LLC.
#
# This module is free software; you can redistribute it and/or modify
# it under the same terms as Perl itself.
SPX/Server.pm view on Meta::CPAN
1;
__END__
=head1 NAME
Speech::Recognizer::SPX::Server - Perl module for writing streaming audio speech recognition servers using PocketSphinx
=head1 SYNOPSIS
my $sock = new IO::Socket(... blah blah blah ...);
my $log = new IO::File('server.log');
SPX/Server.pm view on Meta::CPAN
}
=head1 DESCRIPTION
This module encapsulates a bunch of the stuff needed to write a
PocketSphinx server which takes streaming audio as input on an arbitrary
filehandle. It's not meant to be flexible or transparent - if you
want that, then read the code and write your own server program using
just the Speech::Recognizer::SPX module.
The interface is vaguely object-oriented, but unfortunately it is
Speech-Rsynth
view release on metacpan or search on metacpan
# ifdef RSXS_DEBUG_STRING
printf("Say_String: done.\n", val);
# endif
#//---------------- speak to me streamingly
void
rsxs_Say_File(synth,file)
rsynth_synth_ptr synth
FILE *file
CODE:
Spellunker
view release on metacpan or search on metacpan
share/enable1.txt view on Meta::CPAN
mainsprings
mainstay
mainstays
mainstream
mainstreamed
mainstreaming
mainstreams
maintain
maintainabilities
maintainability
maintainable
share/enable1.txt view on Meta::CPAN
slipslops
slipsole
slipsoles
slipstream
slipstreamed
slipstreaming
slipstreams
slipt
slipup
slipups
slipware
share/enable1.txt view on Meta::CPAN
streamed
streamer
streamers
streamier
streamiest
streaming
streamings
streamlet
streamlets
streamline
streamlined
streamliner
Splunklib
view release on metacpan or search on metacpan
lib/Splunklib/Intersplunk.pm view on Meta::CPAN
required_fields => '',
requires_srinfo => 0,
retainsevents => 1,
run_in_preview => 1,
stderr_dest => 'log',
streaming => 1,
supports_multivalues => 1,
supports_rawargs => 1,
__mv_changes_colorder => '',
__mv_clear_required_fields => '',
__mv_enableheader => '',
lib/Splunklib/Intersplunk.pm view on Meta::CPAN
__mv_required_fields => '',
__mv_requires_srinfo => '',
__mv_retainsevents => '',
__mv_run_in_preview => '',
__mv_stderr_dest => '',
__mv_streaming => '',
__mv_supports_multivalues => '',
__mv_supports_rawargs => '',
};
my $header = '';
lib/Splunklib/Intersplunk.pm view on Meta::CPAN
#
# Example message header
#
# $messages = {
# streaming_preop' => '0',
# streaming' => '0',
# generating' => '0',
# retainsevents' => '0',
# requires_preop' => '0',
# generates_timeorder' => '0',
# overrides_timeorder' => '0',
Spreadsheet-Read
view release on metacpan or search on metacpan
0.77 - 22 Jan 2018, H.Merijn Brand
* Note possible name clashes with example/tool files
* Clipping and stripping more efficient
0.76 - 01 Jan 2018, H.Merijn Brand
* Allow streaming in xlscat
* Add --dump to xlscat
* Add error for opening ODS/SXC from reference
* It's 2018
0.75 - 09 Nov 2017, H.Merijn Brand
Spreadsheet-WriteExcel-Worksheet-SheetProtection
view release on metacpan or search on metacpan
SheetProtection.pm view on Meta::CPAN
use Spreadsheet::WriteExcel::Worksheet;
no strict 'refs';
## HACK ALERT!
## Add a _store_eof method to Spreadsheet::WriteExcel::Worksheet to be able to
## add the SHEETPROTECTION record when streaming out file
*{"Spreadsheet::WriteExcel::Worksheet::_store_eof"} = sub {
_store_sheet_protection(@_);
Spreadsheet::WriteExcel::BIFFwriter::_store_eof(@_);
} ;
Spreadsheet-WriteExcelXML
view release on metacpan or search on metacpan
lib/Spreadsheet/WriteExcelXML/XMLwriter.pm view on Meta::CPAN
The C<set_indentation()> method is used to define the style of indentation used in the output from C<Spreadsheet::WriteExcelXML::XMLwriter>. This is the only C<public> method of the module.
The default indentation style is four spaces. Calling C<set_indentation()> with C<undef> or no argument will set the indentation style back to the default.
A special case argument is the null string C<''>. In addition to not adding any indentation this also overrides any newline settings so that the output is as compact as possible and in the form of a single line. This is useful for saving space or whe...
The following example shows some of the options:
#!/usr/bin/perl -w
Starlet
view release on metacpan or search on metacpan
lib/Starlet/Server.pm view on Meta::CPAN
'psgi.errors' => *STDERR,
'psgi.url_scheme' => 'http',
'psgi.run_once' => Plack::Util::FALSE,
'psgi.multithread' => Plack::Util::FALSE,
'psgi.multiprocess' => $self->{is_multiprocess},
'psgi.streaming' => Plack::Util::TRUE,
'psgi.nonblocking' => Plack::Util::FALSE,
'psgix.input.buffered' => Plack::Util::TRUE,
'psgix.io' => $conn,
'psgix.harakiri' => 1,
'psgix.informational' => sub {
Starlight
view release on metacpan or search on metacpan
lib/Starlight/Server.pm view on Meta::CPAN
'psgi.errors' => *STDERR,
'psgi.url_scheme' => $self->{ssl} ? 'https' : 'http',
'psgi.run_once' => Plack::Util::FALSE,
'psgi.multithread' => $self->{is_multithread},
'psgi.multiprocess' => $self->{is_multiprocess},
'psgi.streaming' => Plack::Util::TRUE,
'psgi.nonblocking' => Plack::Util::FALSE,
'psgix.input.buffered' => Plack::Util::TRUE,
'psgix.io' => $conn,
'psgix.harakiri' => Plack::Util::TRUE,
};
Starman
view release on metacpan or search on metacpan
lib/Starman/Server.pm view on Meta::CPAN
SCRIPT_NAME => '',
'psgi.version' => [ 1, 1 ],
'psgi.errors' => *STDERR,
'psgi.url_scheme' => ($conn->NS_proto eq 'SSL' ? 'https' : 'http'),
'psgi.nonblocking' => Plack::Util::FALSE,
'psgi.streaming' => Plack::Util::TRUE,
'psgi.run_once' => Plack::Util::FALSE,
'psgi.multithread' => Plack::Util::FALSE,
'psgi.multiprocess' => Plack::Util::TRUE,
'psgix.io' => $conn,
'psgix.input.buffered' => Plack::Util::TRUE,
Starwoman
view release on metacpan or search on metacpan
lib/Starwoman/Server.pm view on Meta::CPAN
SCRIPT_NAME => '',
'psgi.version' => [ 1, 1 ],
'psgi.errors' => *STDERR,
'psgi.url_scheme' => ($conn->NS_proto eq 'SSL' ? 'https' : 'http'),
'psgi.nonblocking' => Plack::Util::FALSE,
'psgi.streaming' => Plack::Util::TRUE,
'psgi.run_once' => Plack::Util::FALSE,
'psgi.multithread' => Plack::Util::FALSE,
'psgi.multiprocess' => Plack::Util::TRUE,
'psgix.io' => $conn,
'psgix.input.buffered' => Plack::Util::TRUE,
Statistics-TopK
view release on metacpan or search on metacpan
lib/Statistics/TopK.pm view on Meta::CPAN
__END__
=head1 NAME
Statistics::TopK - Implementation of the top-k streaming algorithm
=head1 SYNOPSIS
use Statistics::TopK;
lib/Statistics/TopK.pm view on Meta::CPAN
my @top = $counter->top;
my %counts = $counter->counts;
=head1 DESCRIPTION
The C<Statistics::TopK> module implements the top-k streaming algorithm,
also know as the "heavy hitters" algorithm. It is designed to process
data streams and probabilistally calculate the C<k> most frequent items
while using limited memory.
A typical example would be to determine the top 10 IP addresses listed in an
Stor
view release on metacpan or search on metacpan
lib/Stor.pm view on Meta::CPAN
bucket => $self->bucket->bucket,
key => $hcp_key,
method => 'GET'
)->http_request;
# build Mojo request inside transaction for proper streaming
$c->app->ua->max_response_size(0);
my $tx = $c->app->ua->build_tx(GET => $http_request->uri->as_string);
for my $header_key ('authorization', 'date') {
$tx->req->headers->header($header_key => $http_request->headers->header($header_key));
}
StreamFinder
view release on metacpan or search on metacpan
lib/StreamFinder.pm view on Meta::CPAN
Please NOTE: StreamFinder is a module, NOT a standalone application. It is
designed to be used by other Perl applications. To create your own very simple
application just to fetch stream data manually, simply grab the code in the
B<SYNOPSIS> section above, save it to an executable text file, ie.
I<StreamFinder.pl>, and run it from the command line with a supported streaming
site URL as the argument. You can then edit it to tailor it to your needs.
The currently-supported websites are:
podcasts.apple.com podcasts (L<StreamFinder::Apple>),
bitchute.com videos (L<StreamFinder::Bitchute>),
lib/StreamFinder.pm view on Meta::CPAN
by any of the other submodules) for streams.
NOTE: StreamFinder::Google has been removed as Google Podcasts has shut down.
NOTE: StreamFinder::LinkTV has been removed as that site no longer provides
streams anymore but only links to the various (and diverse) streaming sites
that provide their own streams. Some may possibly work via
StreamFinder::Youtube or StreamFinder::AnyStream.
NOTE: StreamFinder::Goodpods has been removed, as that site has redone itself
in javascript as to no longer be scrapable for streams.
lib/StreamFinder.pm view on Meta::CPAN
data and mime type for downloading to local storage for use by your
application or preferred media player. NOTE: StreamFinder::Anystream is not
able to return much beyond the stream URLs it finds, but please see it's POD
documentation for details on what it is able to return.
If you have another streaming site that is not supported, first, make sure
you have B<youtube-dl> installed and see if B<StreamFinder::Youtube> can
successfully fetch any streams for it. If not, then please file a feature
request via email or the CPAN bug system, or (for faster service), provide a
Perl patch module / program source that can extract some or all of the
necessary information for streams on that site and I'll consider it! The
lib/StreamFinder.pm view on Meta::CPAN
Accepts a URL and creates and returns a new station, video, or
podcast object, or I<undef> if the URL is not a valid station or
no streams are found.
NOTE: Depending on the type of site being queried, the "station
object" can be either a streaming station, a video, or a podcast,
but works the same way (method calls, arguments, etc.).
NOTE: A full URL must be specified here, but if using any of the
subpackage modules directly instead, then either a full URL OR just
the station / video / podcast's site ID may be used! Reason being
Syntax-Highlight-Engine-Kate
view release on metacpan or search on metacpan
lib/Syntax/Highlight/Engine/Kate/Quake_Script.pm view on Meta::CPAN
'stopLimboMode',
'stopdemo',
'stoprecord',
'stopsound',
'stopul',
'streamingsound',
'stuffcmd',
'stuffcmds',
'sv',
'sv_allow_log',
'sv_allow_pings',
Syntax-Kamelon
view release on metacpan or search on metacpan
lib/Syntax/Kamelon/XML/idconsole.xml view on Meta::CPAN
<item> stopLimboMode </item>
<item> stopdemo </item>
<item> stoprecord </item>
<item> stopsound </item>
<item> stopul </item>
<item> streamingsound </item>
<item> stuffcmd </item>
<item> stuffcmds </item>
<item> sv </item>
<item> sv_allow_log </item>
<item> sv_allow_pings </item>
Sys-Sendfile-OSX
view release on metacpan or search on metacpan
lib/Sys/Sendfile/OSX.pm view on Meta::CPAN
my $rv = sendfile($local_fh, $socket_fh);
=head1 DESCRIPTION
The sendfile() function is a zero-copy function for transferring the
contents of a filehandle to a streaming socket.
As per the man pages, the sendfile() function was made available as of Mac
OS X 10.5.
=head1 Sys::Sendfile
TAP-Formatter-JUnit
view release on metacpan or search on metacpan
and the patience.
- Track and report timings for "(init)" and "(teardown)" of the test.
Without this, Hudson does not properly report on the total time needed
for a test suite (it calculates total time by adding up the constituent
tests, not by looking at the <testsuite> "time" attribute).
- Rewrite internals, switching from a streaming style to an iterative style
of processing the TAP. Same results, but easier to work with.
0.08 Thu Jul 15 23:44 PDT 2010
- RT#58838, "Error reporting on die or missing plan". Thanks to Colin
Robertson. Output compatible w/Hudson (so it now sees these as errors).
TAP-Formatter-JUnitREGRU
view release on metacpan or search on metacpan
and the patience.
- Track and report timings for "(init)" and "(teardown)" of the test.
Without this, Hudson does not properly report on the total time needed
for a test suite (it calculates total time by adding up the constituent
tests, not by looking at the <testsuite> "time" attribute).
- Rewrite internals, switching from a streaming style to an iterative style
of processing the TAP. Same results, but easier to work with.
0.08 Thu Jul 15 23:44 PDT 2010
- RT#58838, "Error reporting on die or missing plan". Thanks to Colin
Robertson. Output compatible w/Hudson (so it now sees these as errors).
TDB_FileX
view release on metacpan or search on metacpan
xxHash/xxhash.h view on Meta::CPAN
* return XXH32(string, length, seed);
* }
* @endcode
*
*
* @anchor streaming_example
* **Streaming**
*
* These groups of functions allow incremental hashing of unknown size, even
* more than what would fit in a size_t.
*
xxHash/xxhash.h view on Meta::CPAN
/* ****************************
* Common basic types
******************************/
#include <stddef.h> /* size_t */
/*!
* @brief Exit code for the streaming API.
*/
typedef enum {
XXH_OK = 0, /*!< OK */
XXH_ERROR /*!< Error */
} XXH_errorcode;
xxHash/xxhash.h view on Meta::CPAN
XXH_PUBLIC_API XXH_PUREF XXH32_hash_t XXH32 (const void* input, size_t length, XXH32_hash_t seed);
#ifndef XXH_NO_STREAM
/*!
* @typedef struct XXH32_state_s XXH32_state_t
* @brief The opaque state struct for the XXH32 streaming API.
*
* @see XXH32_state_s for details.
* @see @ref streaming_example "Streaming Example"
*/
typedef struct XXH32_state_s XXH32_state_t;
/*!
* @brief Allocates an @ref XXH32_state_t.
xxHash/xxhash.h view on Meta::CPAN
* @return An allocated pointer of @ref XXH32_state_t on success.
* @return `NULL` on failure.
*
* @note Must be freed with XXH32_freeState().
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_MALLOCF XXH32_state_t* XXH32_createState(void);
/*!
* @brief Frees an @ref XXH32_state_t.
*
xxHash/xxhash.h view on Meta::CPAN
*
* @return @ref XXH_OK.
*
* @note @p statePtr must be allocated with XXH32_createState().
*
* @see @ref streaming_example "Streaming Example"
*
*/
XXH_PUBLIC_API XXH_errorcode XXH32_freeState(XXH32_state_t* statePtr);
/*!
* @brief Copies one @ref XXH32_state_t to another.
xxHash/xxhash.h view on Meta::CPAN
* @return @ref XXH_OK on success.
* @return @ref XXH_ERROR on failure.
*
* @note This function resets and seeds a state. Call it before @ref XXH32_update().
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_errorcode XXH32_reset (XXH32_state_t* statePtr, XXH32_hash_t seed);
/*!
* @brief Consumes a block of @p input to an @ref XXH32_state_t.
xxHash/xxhash.h view on Meta::CPAN
* @return @ref XXH_OK on success.
* @return @ref XXH_ERROR on failure.
*
* @note Call this to incrementally consume blocks of data.
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_errorcode XXH32_update (XXH32_state_t* statePtr, const void* input, size_t length);
/*!
* @brief Returns the calculated hash value from an @ref XXH32_state_t.
xxHash/xxhash.h view on Meta::CPAN
*
* @note
* Calling XXH32_digest() will not affect @p statePtr, so you can update,
* digest, and update again.
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_PUREF XXH32_hash_t XXH32_digest (const XXH32_state_t* statePtr);
#endif /* !XXH_NO_STREAM */
/******* Canonical representation *******/
xxHash/xxhash.h view on Meta::CPAN
XXH_PUBLIC_API XXH_PUREF XXH64_hash_t XXH64(XXH_NOESCAPE const void* input, size_t length, XXH64_hash_t seed);
/******* Streaming *******/
#ifndef XXH_NO_STREAM
/*!
* @brief The opaque state struct for the XXH64 streaming API.
*
* @see XXH64_state_s for details.
* @see @ref streaming_example "Streaming Example"
*/
typedef struct XXH64_state_s XXH64_state_t; /* incomplete type */
/*!
* @brief Allocates an @ref XXH64_state_t.
xxHash/xxhash.h view on Meta::CPAN
* @return An allocated pointer of @ref XXH64_state_t on success.
* @return `NULL` on failure.
*
* @note Must be freed with XXH64_freeState().
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_MALLOCF XXH64_state_t* XXH64_createState(void);
/*!
* @brief Frees an @ref XXH64_state_t.
xxHash/xxhash.h view on Meta::CPAN
*
* @return @ref XXH_OK.
*
* @note @p statePtr must be allocated with XXH64_createState().
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_errorcode XXH64_freeState(XXH64_state_t* statePtr);
/*!
* @brief Copies one @ref XXH64_state_t to another.
xxHash/xxhash.h view on Meta::CPAN
* @return @ref XXH_OK on success.
* @return @ref XXH_ERROR on failure.
*
* @note This function resets and seeds a state. Call it before @ref XXH64_update().
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_errorcode XXH64_reset (XXH_NOESCAPE XXH64_state_t* statePtr, XXH64_hash_t seed);
/*!
* @brief Consumes a block of @p input to an @ref XXH64_state_t.
xxHash/xxhash.h view on Meta::CPAN
* @return @ref XXH_OK on success.
* @return @ref XXH_ERROR on failure.
*
* @note Call this to incrementally consume blocks of data.
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_errorcode XXH64_update (XXH_NOESCAPE XXH64_state_t* statePtr, XXH_NOESCAPE const void* input, size_t length);
/*!
* @brief Returns the calculated hash value from an @ref XXH64_state_t.
xxHash/xxhash.h view on Meta::CPAN
*
* @note
* Calling XXH64_digest() will not affect @p statePtr, so you can update,
* digest, and update again.
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_PUREF XXH64_hash_t XXH64_digest (XXH_NOESCAPE const XXH64_state_t* statePtr);
#endif /* !XXH_NO_STREAM */
/******* Canonical representation *******/
xxHash/xxhash.h view on Meta::CPAN
*
* When only 64 bits are needed, prefer invoking the _64bits variant, as it
* reduces the amount of mixing, resulting in faster speed on small inputs.
* It's also generally simpler to manipulate a scalar return type than a struct.
*
* The API supports one-shot hashing, streaming mode, and custom secrets.
*/
/*!
* @ingroup tuning
* @brief Possible values for @ref XXH_VECTOR.
xxHash/xxhash.h view on Meta::CPAN
/******* Streaming *******/
#ifndef XXH_NO_STREAM
/*
* Streaming requires state maintenance.
* This operation costs memory and CPU.
* As a consequence, streaming is slower than one-shot hashing.
* For better performance, prefer one-shot functions whenever applicable.
*/
/*!
* @brief The opaque state struct for the XXH3 streaming API.
*
* @see XXH3_state_s for details.
* @see @ref streaming_example "Streaming Example"
*/
typedef struct XXH3_state_s XXH3_state_t;
XXH_PUBLIC_API XXH_MALLOCF XXH3_state_t* XXH3_createState(void);
XXH_PUBLIC_API XXH_errorcode XXH3_freeState(XXH3_state_t* statePtr);
xxHash/xxhash.h view on Meta::CPAN
* @note
* - This function resets `statePtr` and generate a secret with default parameters.
* - Call this function before @ref XXH3_64bits_update().
* - Digest will be equivalent to `XXH3_64bits()`.
*
* @see @ref streaming_example "Streaming Example"
*
*/
XXH_PUBLIC_API XXH_errorcode XXH3_64bits_reset(XXH_NOESCAPE XXH3_state_t* statePtr);
/*!
xxHash/xxhash.h view on Meta::CPAN
* @note
* - This function resets `statePtr` and generate a secret from `seed`.
* - Call this function before @ref XXH3_64bits_update().
* - Digest will be equivalent to `XXH3_64bits_withSeed()`.
*
* @see @ref streaming_example "Streaming Example"
*
*/
XXH_PUBLIC_API XXH_errorcode XXH3_64bits_reset_withSeed(XXH_NOESCAPE XXH3_state_t* statePtr, XXH64_hash_t seed);
/*!
xxHash/xxhash.h view on Meta::CPAN
*
* @return @ref XXH_OK on success.
* @return @ref XXH_ERROR on failure.
*
* @note
* `secret` is referenced, it _must outlive_ the hash streaming session.
*
* Similar to one-shot API, `secretSize` must be >= @ref XXH3_SECRET_SIZE_MIN,
* and the quality of produced hash values depends on secret's entropy
* (secret's content should look like a bunch of random bytes).
* When in doubt about the randomness of a candidate `secret`,
* consider employing `XXH3_generateSecret()` instead (see below).
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_errorcode XXH3_64bits_reset_withSecret(XXH_NOESCAPE XXH3_state_t* statePtr, XXH_NOESCAPE const void* secret, size_t secretSize);
/*!
* @brief Consumes a block of @p input to an @ref XXH3_state_t.
xxHash/xxhash.h view on Meta::CPAN
* @return @ref XXH_OK on success.
* @return @ref XXH_ERROR on failure.
*
* @note Call this to incrementally consume blocks of data.
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_errorcode XXH3_64bits_update (XXH_NOESCAPE XXH3_state_t* statePtr, XXH_NOESCAPE const void* input, size_t length);
/*!
* @brief Returns the calculated XXH3 64-bit hash value from an @ref XXH3_state_t.
xxHash/xxhash.h view on Meta::CPAN
*
* @note
* Calling XXH3_64bits_digest() will not affect @p statePtr, so you can update,
* digest, and update again.
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_PUREF XXH64_hash_t XXH3_64bits_digest (XXH_NOESCAPE const XXH3_state_t* statePtr);
#endif /* !XXH_NO_STREAM */
/* note : canonical representation of XXH3 is the same as XXH64
xxHash/xxhash.h view on Meta::CPAN
/******* Streaming *******/
#ifndef XXH_NO_STREAM
/*
* Streaming requires state maintenance.
* This operation costs memory and CPU.
* As a consequence, streaming is slower than one-shot hashing.
* For better performance, prefer one-shot functions whenever applicable.
*
* XXH3_128bits uses the same XXH3_state_t as XXH3_64bits().
* Use already declared XXH3_createState() and XXH3_freeState().
*
* All reset and streaming functions have same meaning as their 64-bit counterpart.
*/
/*!
* @brief Resets an @ref XXH3_state_t to begin a new hash.
*
xxHash/xxhash.h view on Meta::CPAN
* @note
* - This function resets `statePtr` and generate a secret with default parameters.
* - Call it before @ref XXH3_128bits_update().
* - Digest will be equivalent to `XXH3_128bits()`.
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_errorcode XXH3_128bits_reset(XXH_NOESCAPE XXH3_state_t* statePtr);
/*!
* @brief Resets an @ref XXH3_state_t with 64-bit seed to begin a new hash.
xxHash/xxhash.h view on Meta::CPAN
* @note
* - This function resets `statePtr` and generate a secret from `seed`.
* - Call it before @ref XXH3_128bits_update().
* - Digest will be equivalent to `XXH3_128bits_withSeed()`.
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_errorcode XXH3_128bits_reset_withSeed(XXH_NOESCAPE XXH3_state_t* statePtr, XXH64_hash_t seed);
/*!
* @brief Resets an @ref XXH3_state_t with secret data to begin a new hash.
*
xxHash/xxhash.h view on Meta::CPAN
* @p statePtr must not be `NULL`.
*
* @return @ref XXH_OK on success.
* @return @ref XXH_ERROR on failure.
*
* `secret` is referenced, it _must outlive_ the hash streaming session.
* Similar to one-shot API, `secretSize` must be >= @ref XXH3_SECRET_SIZE_MIN,
* and the quality of produced hash values depends on secret's entropy
* (secret's content should look like a bunch of random bytes).
* When in doubt about the randomness of a candidate `secret`,
* consider employing `XXH3_generateSecret()` instead (see below).
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_errorcode XXH3_128bits_reset_withSecret(XXH_NOESCAPE XXH3_state_t* statePtr, XXH_NOESCAPE const void* secret, size_t secretSize);
/*!
* @brief Consumes a block of @p input to an @ref XXH3_state_t.
xxHash/xxhash.h view on Meta::CPAN
* Never **ever** access their members directly.
*/
/*!
* @internal
* @brief Structure for XXH32 streaming API.
*
* @note This is only defined when @ref XXH_STATIC_LINKING_ONLY,
* @ref XXH_INLINE_ALL, or @ref XXH_IMPLEMENTATION is defined. Otherwise it is
* an opaque type. This allows fields to safely be changed.
*
xxHash/xxhash.h view on Meta::CPAN
#ifndef XXH_NO_LONG_LONG /* defined when there is no 64-bit support */
/*!
* @internal
* @brief Structure for XXH64 streaming API.
*
* @note This is only defined when @ref XXH_STATIC_LINKING_ONLY,
* @ref XXH_INLINE_ALL, or @ref XXH_IMPLEMENTATION is defined. Otherwise it is
* an opaque type. This allows fields to safely be changed.
*
xxHash/xxhash.h view on Meta::CPAN
*/
#define XXH3_SECRET_DEFAULT_SIZE 192
/*!
* @internal
* @brief Structure for XXH3 streaming API.
*
* @note This is only defined when @ref XXH_STATIC_LINKING_ONLY,
* @ref XXH_INLINE_ALL, or @ref XXH_IMPLEMENTATION is defined.
* Otherwise it is an opaque type.
* Never use this definition in combination with dynamic library.
xxHash/xxhash.h view on Meta::CPAN
* When the @ref XXH3_state_t structure is merely emplaced on stack,
* it should be initialized with XXH3_INITSTATE() or a memset()
* in case its first reset uses XXH3_NNbits_reset_withSeed().
* This init can be omitted if the first reset uses default or _withSecret mode.
* This operation isn't necessary when the state is created with XXH3_createState().
* Note that this doesn't prepare the state for a streaming operation,
* it's still necessary to use XXH3_NNbits_reset*() afterwards.
*/
#define XXH3_INITSTATE(XXH3_state_ptr) \
do { \
XXH3_state_t* tmp_xxh3_state_ptr = (XXH3_state_ptr); \
xxHash/xxhash.h view on Meta::CPAN
* conservative and disables hacks that increase code size. It implies the
* options @ref XXH_NO_INLINE_HINTS == 1, @ref XXH_FORCE_ALIGN_CHECK == 0,
* and @ref XXH3_NEON_LANES == 8 if they are not already defined.
* - `XXH_SIZE_OPT` == 2: xxHash tries to make itself as small as possible.
* Performance may cry. For example, the single shot functions just use the
* streaming API.
*/
# define XXH_SIZE_OPT 0
/*!
* @def XXH_FORCE_ALIGN_CHECK
xxHash/xxhash.h view on Meta::CPAN
# define XXH_OLD_NAMES
# undef XXH_OLD_NAMES /* don't actually use, it is ugly. */
/*!
* @def XXH_NO_STREAM
* @brief Disables the streaming API.
*
* When xxHash is not inlined and the streaming functions are not used, disabling
* the streaming functions can improve code size significantly, especially with
* the @ref XXH3_family which tends to make constant folded copies of itself.
*/
# define XXH_NO_STREAM
# undef XXH_NO_STREAM /* don't actually */
#endif /* XXH_DOXYGEN */
xxHash/xxhash.h view on Meta::CPAN
#endif
}
/******* Hash streaming *******/
#ifndef XXH_NO_STREAM
/*! @ingroup XXH32_family */
XXH_PUBLIC_API XXH32_state_t* XXH32_createState(void)
{
return (XXH32_state_t*)XXH_malloc(sizeof(XXH32_state_t));
xxHash/xxhash.h view on Meta::CPAN
return XXH3_64bits_internal(input, length, seed, XXH3_kSecret, sizeof(XXH3_kSecret), NULL);
return XXH3_hashLong_64b_withSecret(input, length, seed, (const xxh_u8*)secret, secretSize);
}
/* === XXH3 streaming === */
#ifndef XXH_NO_STREAM
/*
* Malloc's a pointer that is always aligned to @align.
*
* This must be freed with `XXH_alignedFree()`.
xxHash/xxhash.h view on Meta::CPAN
* @return An allocated pointer of @ref XXH3_state_t on success.
* @return `NULL` on failure.
*
* @note Must be freed with XXH3_freeState().
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH3_state_t* XXH3_createState(void)
{
XXH3_state_t* const state = (XXH3_state_t*)XXH_alignedMalloc(sizeof(XXH3_state_t), 64);
if (state==NULL) return NULL;
xxHash/xxhash.h view on Meta::CPAN
*
* @return @ref XXH_OK.
*
* @note Must be allocated with XXH3_createState().
*
* @see @ref streaming_example "Streaming Example"
*/
XXH_PUBLIC_API XXH_errorcode XXH3_freeState(XXH3_state_t* statePtr)
{
XXH_alignedFree(statePtr);
return XXH_OK;
xxHash/xxhash.h view on Meta::CPAN
{
return XXH3_128bits_withSeed(input, len, seed);
}
/* === XXH3 128-bit streaming === */
#ifndef XXH_NO_STREAM
/*
* All initialization and update functions are identical to 64-bit streaming variant.
* The only difference is the finalization routine.
*/
/*! @ingroup XXH3_family */
XXH_PUBLIC_API XXH_errorcode
TUWF
view release on metacpan or search on metacpan
lib/TUWF.pod view on Meta::CPAN
send other headers B<after> generating the contents of the page. And as an
added bonus, your pages will be compressed more efficiently when output
compression is enabled.
On the other hand, this means that you can't use TUWF for applications that
require Websockets or other forms of streaming dynamic content (e.g. a chat
application), and you may get into memory issues when sending large files.
=item Everything is UTF-8.
All TUWF functions (with some exceptions) will only accept and return Unicode
TV-Mediathek
view release on metacpan or search on metacpan
lib/TV/Mediathek.pm view on Meta::CPAN
$self->log->debug( __PACKAGE__ . "->refresh_media end" );
}
# Local XML::Twig twig handler method for importing media to the database.
# Expects to receive a twig with the required statement handlers initialised.
# <Filme><Nr>0000</Nr><Sender>3Sat</Sender><Thema>3sat.full</Thema><Titel>Mediathek-Beiträge</Titel><Datum>04.09.2011</Datum><Zeit>19:23:11</Zeit><Url>http://wstreaming.zdf.de/3sat/veryhigh/110103_jazzbaltica2010ceu_musik.asx</Url><UrlOrg>http://wst...
sub _media_to_db {
my ( $t, $section ) = @_;
my %values;
###FIXME - get all children, not just by name
( run in 0.725 second using v1.01-cache-2.11-cpan-4face438c0f )