search for: bytes_received

Hi all, Is any way to logs tcp connection (not packets)? something like this: src_IP dst_Ip, srcPort, dst_port bytes_send bytes_received? Any netfilter extension? 2 issue: eth0------- connection 1 NET ---------gw (linux) eth1--------connection 2 Real bandwitch on connection 1 and connection 2 is depend on different things (ie weather) How to detect that connec...

...ORTSIZE - sizeof buf); + cmd = rand () & 1; + if (cmd == 0) { + handle = nbd_aio_pwrite (nbd, buf, sizeof buf, offset, 0); + status->bytes_sent += sizeof buf; + } + else { + handle = nbd_aio_pread (nbd, buf, sizeof buf, offset, 0); + status->bytes_received += sizeof buf; + } + if (handle == -1) { + fprintf (stderr, "%s\n", nbd_get_error ()); + goto error; + } + handles[in_flight] = handle; + in_flight++; + if (in_flight > status->most_in_flight) + status->most_in_flight = in_flight...

...cookie = nbd_aio_pwrite (nbd, buf, buf_size, offset, NULL, NULL, 0); status->bytes_sent += buf_size; } else { - cookie = nbd_aio_pread (nbd, buf, buf_size, offset, 0); + cookie = nbd_aio_pread (nbd, buf, buf_size, offset, NULL, NULL, 0); status->bytes_received += buf_size; } if (cookie == -1) { diff --git a/tests/aio-parallel.c b/tests/aio-parallel.c index b6a0682..fb4d695 100644 --- a/tests/aio-parallel.c +++ b/tests/aio-parallel.c @@ -271,12 +271,12 @@ start_thread (void *arg) + (rand () % (status->length[i] - BUFFERSIZE));...

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

...), 0); status->bytes_sent += buf_size; } else { - cookie = nbd_aio_pread (nbd, buf, buf_size, offset, NULL, NULL, 0); + cookie = nbd_aio_pread (nbd, buf, buf_size, offset, + NBD_NULL_CALLBACK(completion), 0); status->bytes_received += buf_size; } if (cookie == -1) { diff --git a/tests/aio-parallel.c b/tests/aio-parallel.c index fb4d695..f6f13e6 100644 --- a/tests/aio-parallel.c +++ b/tests/aio-parallel.c @@ -271,12 +271,14 @@ start_thread (void *arg) + (rand () % (status->length[i] - BUFFERSIZE));...

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

v1: https://www.redhat.com/archives/libguestfs/2019-June/msg00014.html I pushed a few bits which are uncontroversial. The main changes since v1 are: An extra patch removes the want_to_send / check for nbd_aio_is_ready in examples/threaded-reads-and-writes.c. This logic was wrong since commit 6af72b87 as was pointed out by Eric in his review. Comments and structure of

Patches 1 & 2 are rather complex, but the end result is that we pass closures + user_data + free function in single struct parameters as I described previously in this email: https://www.redhat.com/archives/libguestfs/2019-August/msg00210.html Patch 3 adds a convenient FREE_CALLBACK macro which seems a worthwhile simplification if you buy into 1 & 2. Patch 4 adds another macro which is