search for: packetsize

...+#include <unistd.h> +#include <errno.h> +#include <poll.h> +#include <time.h> +#include <assert.h> + +#include <libnbd.h> + +/* The single NBD handle. */ +static struct nbd_handle *nbd; + +/* Buffers used for the test. */ +static char *in, *out; +static int64_t packetsize; + +static int +try_deadlock (void *arg) +{ + struct pollfd fds[1]; + struct nbd_connection *conn; + char buf[512]; + size_t i, j; + int64_t handles[2]; + size_t in_flight; /* counts number of requests in flight */ + int dir, r, cmd; + bool want_to_send; + + /* The single thread &qu...

...+#include <errno.h> +#include <poll.h> +#include <time.h> +#include <assert.h> +#include <signal.h> + +#include <libnbd.h> + +/* The single NBD handle. */ +static struct nbd_handle *nbd; + +/* Buffers used for the test. */ +static char *in, *out; +static int64_t packetsize; + +static int +try_deadlock (void *arg) +{ + struct pollfd fds[1]; + struct nbd_connection *conn; + size_t i; + int64_t handles[2], done; + size_t in_flight; /* counts number of requests in flight */ + int dir, r; + + /* The single thread "owns" the connection. */ + conn =...

This might not be the final solution, but it certainly seems to solve a deadlock for me that I could trigger by using 'nbdkit --filter=noparallel memory 512k' and calling nbd_aio_pread for a request larger than 256k (enough for the Linux kernel to block the server until libnbd read()s), immediately followed by nbd_aio_pwrite for a request larger than 256k (enough to block libnbd until the

On v1, we discussed whether cmds_to_issue needed to be a list, since it never had more than one element. I played with the idea of making it a list, and allowing the client to queue up new commands regardless of whether the state machine is currently in READY. I also polished up the tmp demo into a bit more full-fledged example file, worth including since it also let me discover a hard-to-hit race

Since v2: - rebase to Rich's new API calls - more refactoring in patch 1 (retitled) - new patches 3 and 4 - fix data corruption in patch 6 (was 4) - more tweaks to the reproducer example (including using new API from 3) Eric Blake (7): lib: Refactor command_common() to do more common work commands: Allow for a command queue commands: Expose FIFO ordering of server completions

...oder_ctl( SpeexEncoderState, SPEEX_GET_FRAME_SIZE , &FrameSize ); FLOAT Src[VOICE_FRAME_SIZE]; appMemzero( Src, sizeof(Src) ); char Dest[VOICE_FRAME_SIZE]; peex_bits_init( SpeexEncoderBits ); speex_bits_reset( SpeexEncoderBits ); speex_encode( SpeexEncoderState, Src, SpeexEncoderBits ); INT PacketSize = speex_bits_write( SpeexEncoderBits, Dest, VOICE_FRAME_SIZE ); check( FrameSize == VOICE_FRAME_SIZE ); check( PacketSize == FVoicePacket::Size ); peex_bits_reset( SpeexEncoderBits ); speex_encode( SpeexEncoderState, Src, SpeexEncoderBits ); //<-- boom!!! Thanks, -- Daniel, Epic Games In...

I tried to compress 160 samples of random garbage (range 0-500.f) at 4kbps and got a crash in nb_encode -> forced_pitch_quant because start was -858993460 (== ol_pitch). -- Daniel, Epic Games Inc. --- >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'

...tched-read-write.c @@ -48,26 +48,22 @@ try_deadlock (void *arg) struct pollfd fds[1]; size_t i; int64_t handles[2], done; - size_t in_flight; /* counts number of requests in flight */ int dir, r; /* Issue commands. */ - in_flight = 0; handles[0] = nbd_aio_pread (nbd, in, packetsize, 0, 0); if (handles[0] == -1) { fprintf (stderr, "%s\n", nbd_get_error ()); goto error; } - in_flight++; handles[1] = nbd_aio_pwrite (nbd, out, packetsize, packetsize, 0); if (handles[1] == -1) { fprintf (stderr, "%s\n", nbd_get_error ()); goto e...

...ill want a followup patch to better document Closure vs. OClosure on which callbacks do not allow a NULL fn in libnbd-api.3). > +++ b/examples/batched-read-write.c > @@ -53,12 +53,13 @@ try_deadlock (void *arg) > > /* Issue commands. */ > cookies[0] = nbd_aio_pread (nbd, in, packetsize, 0, > - NULL, NULL, 0); > + NBD_NULL_CALLBACK(completion), 0); A bit more verbose, but the macro cuts it down from something even longer to type. I can live with this conversion. > +++ b/examples/glib-main-loop.c > @@ -384,7 +...

...diff --git a/examples/batched-read-write.c b/examples/batched-read-write.c index d39a1e5..378c2e0 100644 --- a/examples/batched-read-write.c +++ b/examples/batched-read-write.c @@ -52,12 +52,13 @@ try_deadlock (void *arg) int r; /* Issue commands. */ - cookies[0] = nbd_aio_pread (nbd, in, packetsize, 0, 0); + cookies[0] = nbd_aio_pread (nbd, in, packetsize, 0, + NULL, NULL, 0); if (cookies[0] == -1) { fprintf (stderr, "%s\n", nbd_get_error ()); goto error; } - cookies[1] = nbd_aio_pwrite (nbd, out, packetsize, packetsize, 0); + cookies[...

...Is it possible to filter those ACK-packets (to eleminate problems with ADSL-connections) with IPtables? It wasn''t possible with IPchains, so u32 had to be used. Now there is this nice little --tcp-flags option. But I just don''t know if this is all I need. The u32 was checking for packetsize too. So if there is a eqivalent to the u32 ACK-filterrule, what would it look like? What I have found in the ML is this: ---- # Set ACK as prioritized traffic (ACK''s are less than 100 bytes) $IPTABLES -t mangle -A MANGLE_MARK -p tcp -m length --length :100 -j MARK --set-mark 1 $IPTABLES -...

This applies on top of the OClosure v2 series posted a few minutes ago. Rich.

openssh 7.6p1-lp150.7.4 on OpenSuse Leap 15 (both server and client) Hi all, first post to list, hopefully on-topic. Haven't found anything on the net, tried to ask at first in OpenSuse forums a while ago (https://forums.opensuse.org/showthread.php/533588-rsnapshot-rsync-massive-performance-decrease) and today opened a bug in OpenSuse's Bugzilla

...323(fd=44) [4]PAsteriskAudioDelay::PAsteriskAudioDelay: Object initialized. [4]PAsteriskAudioDelay::PAsteriskAudioDelay: Object initialized. [4]PAsteriskSoundChannel::PAsteriskSoundChannel: Object initialized. [3]PAsteriskSoundChannel::Open: os_handle 44, mediaFormat 8, frameTime 1 ms, frameNum 20, packetSize 160 [3]WrapH323EndPoint::OpenAudioChannel: Opened sound channel "Asterisk" for recording using 1x320 byte buffers. [3]WrapH323EndPoint::OpenAudioChannel: Direction => PLAYER, Buffer => 320 [2]WrapH323EndPoint::OpenAudioChannel: Media format: FrameSize 8, FrameTime 8, TimeUnits 8 [2]...

...482,10 +486,10 @@ static void MousevscOnReceive(struct hv_device *Device, struct vmpacket_descript break; } - PutInputDevice(Device); + put_input_device(Device); } -static void MousevscOnChannelCallback(void *Context) +static void mousevsc_on_channel_callback(void *Context) { const int packetSize = 0x100; int ret = 0; @@ -499,7 +503,7 @@ static void MousevscOnChannelCallback(void *Context) unsigned char *buffer = packet; int bufferlen = packetSize; - inputDevice = MustGetInputDevice(device); + inputDevice = must_get_input_device(device); if (!inputDevice) { pr_err("unabl...

...482,10 +486,10 @@ static void MousevscOnReceive(struct hv_device *Device, struct vmpacket_descript break; } - PutInputDevice(Device); + put_input_device(Device); } -static void MousevscOnChannelCallback(void *Context) +static void mousevsc_on_channel_callback(void *Context) { const int packetSize = 0x100; int ret = 0; @@ -499,7 +503,7 @@ static void MousevscOnChannelCallback(void *Context) unsigned char *buffer = packet; int bufferlen = packetSize; - inputDevice = MustGetInputDevice(device); + inputDevice = must_get_input_device(device); if (!inputDevice) { pr_err("unabl...

RFC because this is an API break, but we haven't declared stable API yet. If we like it, I'm working on using libnbd to implement the nbdkit-nbd plugin; knowing whether it is API version 0.1 or 0.2 will be useful. I also dabbled with allowing optional parameters in python, although my OCaml is weak enough that there may be cleaner ways to approach that. Eric Blake (4): api: Add flags

...ifetimes diff --git a/examples/batched-read-write.c b/examples/batched-read-write.c index 378c2e0..a6063af 100644 --- a/examples/batched-read-write.c +++ b/examples/batched-read-write.c @@ -53,12 +53,13 @@ try_deadlock (void *arg) /* Issue commands. */ cookies[0] = nbd_aio_pread (nbd, in, packetsize, 0, - NULL, NULL, 0); + NBD_NULL_CALLBACK(completion), 0); if (cookies[0] == -1) { fprintf (stderr, "%s\n", nbd_get_error ()); goto error; } - cookies[1] = nbd_aio_pwrite (nbd, out, packetsize, packetsize, NULL, NU...

...eresting fact about emacs I-search: It doesn't let you search for double spaces for some reason. > > +++ b/examples/batched-read-write.c > > @@ -53,12 +53,13 @@ try_deadlock (void *arg) > > > > /* Issue commands. */ > > cookies[0] = nbd_aio_pread (nbd, in, packetsize, 0, > > - NULL, NULL, 0); > > + NBD_NULL_CALLBACK(completion), 0); > > A bit more verbose, but the macro cuts it down from something even > longer to type. I can live with this conversion. I was trying to write a gene...

Hi all, As long as I can remember reading various articles/docs, they all say that telnet is not secure because all traffic is in clear text. Well, out of boredom, I try to sniff username and password from a telnet session. The command I use: tcpdump tcp port 23 -vvv -w test.txt Then I read the result: strings test.txt |`D |fD |fD 38400,38400 Red Hat Enterprise Linux ESD Ologin: D 5eE