search for: sync_data

...read error: Connection reset by peer ------------------------------------ c:\Rsync\rsyncd.conf on testor has [cdrive] path = c: ------------------------------------ The same setup works fine if I have another AIX machine in place of testor as the source. admx::nkapoor> rsync -v nkapoor@mm1x:: Sync_Data Directory for rsyncd server (/home/sync_data) ------------------------------------ Your kind help will be greatly appreciated. Nishi

...ndle): >+ while nbd_handle.poll(0) == 1: >+ pass >+ >+ >+# Block until all AIO commands on the handle have finished. >+def wait_for_aio_commands_to_finish(nbd_handle): >+ while nbd_handle.aio_in_flight() > 0: >+ nbd_handle.poll(-1) >+ >+ > def sync_data(): > state = State().instance > for key, disk in state['disks'].items(): >@@ -491,25 +511,28 @@ def sync_data(): > (block['length'], block['offset'])) > # Optimize for memory usage, maybe? >...

This is based on top of: https://github.com/nertpinx/v2v-conversion-host/commit/0bb2efdcacd975a2cae7380080991ac7fc238d2b The first 4 patches are fairly uncontroversial miscellaneous cleanups. Patch 5 is the interesting one. (Note it doesn't quite work yet, so it's for discussion only.) Patch 5 converts the inner loop to use asynchronous libnbd calls. performance improves quite a bit for

...t blocking. +def process_aio_requests(nbd_handle): + while nbd_handle.poll(0) == 1: + pass + + +# Block until all AIO commands on the handle have finished. +def wait_for_aio_commands_to_finish(nbd_handle): + while nbd_handle.aio_in_flight() > 0: + nbd_handle.poll(-1) + + def sync_data(): state = State().instance for key, disk in state['disks'].items(): @@ -491,25 +511,28 @@ def sync_data(): (block['length'], block['offset'])) # Optimize for memory usage, maybe? os.pwrite(fd, [0] *...

...int CSpeexDecoderThread::SpeexUserCallback(SpeexBits *bits, void *state, void *data){ ... // read the array index of the corresponding sync structure int index = speex_bits_unpack_unsigned(bits, 8); SendNotifyMessage(l_sdthread->m_hWnd, USER_PLAYBACK_MESSAGE, SYNC_DATA, LPARAM(index)); return 0; } inline int speex_bits_init_buffer_ex(SpeexBits *bits, void *buff, int buf_size){ if (buff == NULL || buf_size == 0) return -1; memset(bits, 0, sizeof(SpeexBits)); bits->bytes = (char*)buff;...

...t; >+ pass > >+ > >+ > >+# Block until all AIO commands on the handle have finished. > >+def wait_for_aio_commands_to_finish(nbd_handle): > >+ while nbd_handle.aio_in_flight() > 0: > >+ nbd_handle.poll(-1) > >+ > >+ > >def sync_data(): > > state = State().instance > > for key, disk in state['disks'].items(): > >@@ -491,25 +511,28 @@ def sync_data(): > > (block['length'], block['offset'])) > > # Optimize for memory usage, may...

...of rsync in script failed. Debug option "--log-file=/tmp/rlog" show this: 2011/01/28 21:50:02 [5150] Unexpected remote arg: ????-???:?????-???.mp3 2011/01/28 21:50:02 [5150] rsync error: syntax or usage error (code 1) at main.c(1204) [sender=3.0.7] Standard output show: 21:45:27 ~ $ ./sync_data sent 204728 bytes received 373 bytes 410202.00 bytes/sec total size is 21420077981 speedup is 104436.73 Unexpected remote arg: \#345\#261\#261\#344\#270\#234\#345\#277\#253\#344\#271\#246-\#345\#205\#253\#345\#262\#224\#350\#267\#257:\#346\#255\#246\#346\#235\#276\#350\#243\#205\#345\#252\#263\#...

...xBits *bits, void > *state, > void *data){ > ... > > // read the array index of the corresponding sync structure > int index = speex_bits_unpack_unsigned(bits, 8); > > SendNotifyMessage(l_sdthread->m_hWnd, USER_PLAYBACK_MESSAGE, > SYNC_DATA, > LPARAM(index)); > > return 0; > } > > inline int speex_bits_init_buffer_ex(SpeexBits *bits, void *buff, int > buf_size){ > > if (buff == NULL || buf_size == 0) > return -1; > > memset(bits, 0...

.... } int CSpeexDecoderThread::SpeexUserCallback(SpeexBits *bits, void *state, void *data){ int length = speex_bits_unpack_unsigned(bits, 4); int inedx = speex_bits_unpack_unsigned(bits, length * 8); <p> SendNotifyMessage(l_sdthread->m_hWnd, USER_PLAYBACK_MESSAGE, SYNC_DATA, LPARAM(index)); return 0; } <p><p><p><p><p><p><p><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&...

hello, i switched to use the encoder.processData() and encoder.getProcessedData() of jspeex. however it looks to me like a memory leak ... memory usage is increasing very fast and there is no visible stop ... after about five minutes java.lang.OutOfMemory occurs. I think it must be the jspeex component, because before i added jspeex to my app usage was constant at about 5mb. is it possible