search for: bytes_written

...it less bandwidth than specified, because it doesn't make up * for slow periods. But arguably this is a feature. In addition, we * ought to take the time used to write the data into account. + * + * During some phases of big transfers (file XXX is uptodate) this is + * called with a small bytes_written every time. As the kernel has to + * round small waits up to guarantee that we actually wait at least + * the requested number of microseconds, this can become grossly + * inaccurate. We therefore keep a cumulating number of microseconds + * to wait, and only actually perform the sleep when the rou...

...it less bandwidth than specified, because it doesn't make up * for slow periods. But arguably this is a feature. In addition, we * ought to take the time used to write the data into account. + * + * During some phases of big transfers (file XXX is uptodate) this is + * called with a small bytes_written every time. As the kernel has to + * round small waits up to guarantee that we actually wait at least + * the requested number of microseconds, this can become grossly + * inaccurate. We therefore keep a cumulating number of microseconds + * to wait, and only actually perform the sleep when the rou...

...copy of the GNU General Public License +# along with this program; if not, write to the Free Software +# Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA + +import select +import nbd + +disk_size = 512 * 1024 * 1024 +bs = 65536 +max_reads_in_flight = 16 +bytes_read = 0 +bytes_written = 0 + +def asynch_copy (src, dst): + size = src.get_size () + + # This is our reading position in the source. + soff = 0 + + # This callback is called when any pread from the source + # has completed. + writes = [] + def read_completed (buf, offset, error): + global byte...

...offset offset+=FRAME_SIZE; } //speex_encode( encoder_state, frame , bits ); /// write teh stream out. int bytes_to_write = speex_bits_nbytes( bits ); /// transform from float to char* to write. The termination code is acutomatically added to teh end of the stream. bytes_written = speex_bits_write( bits, destinantion_buffer, bytes_to_write ); /// return the amount of data writtne. printf( "bytes written %d\n" ,bytes_written ); return bytes_written; } and the decode. ... int Decode( SpeexBits *bits, char * input_bits, int data_in_length , char *...

...return -100; speex_encoder_ctl(enc_state, SPEEX_GET_FRAME_SIZE, &sz); return sz; } This returns 320 as the expected frame size. 1. I assume this is the block size I have to call the encoder with. int lib_speex_encode(short *samples, char*encoded_bytes) { // Encode the data int bytes_written; if(enc_state == NULL) return -100; speex_bits_reset(&bits); speex_encode_stereo_int(samples,320, &bits); bytes_written = speex_bits_write(&bits, encoded_bytes, 1024); return bytes_written; } This goes wrong. 1. Is speex_encode_stereo_int() the right thing to call w...

...FLAC++ API. I have some problems. In libFLAC API all OK. Unhandled exception at 0x00000000 in Test.exe: 0xC0000005: Access violation reading location 0x00000000. Call stack 00000000() Test.exe!FLAC::Encoder::File::progress_callback_(const FLAC__StreamEncoder * encoder=0x003571f8, unsigned __int64 bytes_written=2156194, unsigned __int64 samples_written=845544, unsigned int frames_written=734, unsigned int total_frames_estimate=0, void * client_data=0x0012fe1c) Line 507 + 0x2a bytes C++ Test.exe!file_write_callback_(const FLAC__StreamEncoder * encoder=0x003571f8, const unsigned char * buffer=0x0047daa8, un...

v1 was here: https://www.redhat.com/archives/libguestfs/2019-August/msg00103.html In v2 I've made several changes: - Fix Python callbacks so if they don't return something which is int-like, we assume they mean to return 0. - Add nbd.Buffer free() method. Read commit message in patch 2 to see what this is about. - Fixed the asynch copy test to deal with the unbelievably

...nsigned char FLAC_tagYear[] = {"2008"}; > static const unsigned char FLAC_tagGenre[] = {"Audio Track"}; > static const unsigned char defFileName[16] = {"encAUDIO.flac"}; > > static void progress_callback(const FLAC__StreamEncoder *encoder, > FLAC__uint64 bytes_written, FLAC__uint64 samples_written, unsigned > frames_written, unsigned total_frames_estimate, void *client_data); > > #define READSIZE 1024 > > static unsigned total_samples = 0; /* can use a 32-bit number due to WAVE > size limitations */ > static FLAC__byte buffer[READSIZE/*sampl...

Basically the same as this patch series, but for Python: https://www.redhat.com/archives/libguestfs/2019-August/msg00235.html plus adding the 590 asynch test at the end. Rich.

Hi, I've written an ao plugin for aRts, the soundserver that comes with KDE. Any chance of including this in the ao distribution ? Pretty please ? :) Sources and patches attached. This is a very simple plugin because it uses the easy-to-use 'artsc' C wrapper that aRts installs. configure.in.diff is for ao/configure.in Makefile.am.diff is for ao/src/plugins/Makefile.am Makefile.am

Hi I'm just posting this here in case someone is interested in building hivex on Windows (mingw32). The attached patch allows building the lib but not the tools (hivexsh etc..) as there are some more problems to solve. In short terms, this patch replaces file i/o functions and mmap(), munmap() with their win32api pendants. cu -- Unix _IS_ user friendly - it's just selective about

This doesn't yet work. However it does make me more convinced than ever that we really need to sort out persistent buffer lifetimes in the library (similar to what we did for closures). Rich.

...-53,11 +53,9 @@ let asynch_copy src dst = in (* This callback is called when any pwrite to the destination - * has completed. We have to manually free the buffer here - * as it is no longer used. + * has completed. *) let write_completed buf _ = - NBD.Buffer.free buf; bytes_written := !bytes_written + NBD.Buffer.size buf; (* By returning 1 here we auto-retire the pwrite command. *) 1 -- 2.22.0

This is a combination of these two earlier series: https://www.redhat.com/archives/libguestfs/2019-August/msg00235.html https://www.redhat.com/archives/libguestfs/2019-August/msg00240.html plus changes to allow .callback = NULL / .free != NULL, and to reduce the complexity of freeing callbacks. Although it's rather long there's nothing complex here. We might consider squashing some

...-53,11 +53,9 @@ let asynch_copy src dst = in (* This callback is called when any pwrite to the destination - * has completed. We have to manually free the buffer here - * as it is no longer used. + * has completed. *) let write_completed buf _ = - NBD.Buffer.free buf; bytes_written := !bytes_written + NBD.Buffer.size buf; (* By returning 1 here we auto-retire the pwrite command. *) 1 -- 2.22.0

the stack variable bytes_written is never initialized. Not that it matters - it is only incremented and never used later.... ;) <p>--- >8 ---- List archives: http://www.xiph.org/archives/ Ogg project homepage: http://www.xiph.org/ogg/ To unsubscribe from this list, send a message to 'speex-dev-request@xiph.org'...

I am doing some benchmarking of rsync. I am using the --bwlimit= option to throttle down rsync to predict its operation over slow communications links. I am using rsync 2.6.2 from the release site without any patches. I downloaded the release rather than pull from the CVS tree. I have 2 servers "wilber" (the remote archive) and "judy" (the local archive) connected with a gig

Hello! I cant get the bwlimit option working right. If i set this option over 400 kbyte per sec i still only get 400kbyte per sec, whether wich value i set. I try this option with a 100MB big file. I use a debian stable System with rsync version 2.5.6cvs protocol version 26. Can someone tell me how i can this get working? thx Rene dpkg -l "rsync*" ii rsync 2.5.5-0.1 fast remote

In this patch series we use the newly introduced free callback on the completion function to dererence the OCaml NBD.Buffer. I will make the same kind of change for Python later in a separate series. The completion function is always called at the C level, even if the OCaml program didn't use the optional argument. That's because the free callback doesn't run otherwise. There is a

...3.275981 STAT curr_items 10878 STAT total_items 11441 STAT bytes 2020180 STAT curr_connections 5 STAT total_connections 306 STAT connection_structures 11 STAT cmd_flush 0 STAT cmd_get 457326 STAT cmd_set 11441 STAT get_hits 412184 STAT get_misses 45142 STAT evictions 0 STAT bytes_read 22600329 STAT bytes_written 53036649 STAT limit_maxbytes 30064771072 STAT threads 5 STAT accepting_conns 1 STAT listen_disabled_num 0 Below are the configuration details and stacktrace: config/environment.rb (the important parts) ================================ config.action_controller.session_store = :mem_cache_store confi...