Displaying 8 results from an estimated 8 matches for "most_in_flight".
2019 Jun 04
0
[PATCH libnbd v2 4/4] examples: Add concurrent writer example.
..._status {
+ size_t i; /* Thread index, 0 .. NR_MULTI_CONN-1 */
+ int argc; /* Command line parameters. */
+ char **argv;
+ int status; /* Return status. */
+ unsigned requests; /* Total number of requests made. */
+ unsigned most_in_flight; /* Most requests seen in flight. */
+};
+
+static void *start_reader_thread (void *arg);
+
+int
+main (int argc, char *argv[])
+{
+ struct nbd_handle *nbd;
+ pthread_t threads[NR_MULTI_CONN];
+ struct thread_status status[NR_MULTI_CONN];
+ size_t i;
+ int err;
+ unsigned requests, most_...
2019 Jun 03
0
[PATCH libnbd discussion only 5/5] examples: Add concurrent writer example.
..._status {
+ size_t i; /* Thread index, 0 .. NR_MULTI_CONN-1 */
+ int argc; /* Command line parameters. */
+ char **argv;
+ int status; /* Return status. */
+ unsigned requests; /* Total number of requests made. */
+ unsigned most_in_flight; /* Most requests seen in flight. */
+};
+
+static void *start_reader_thread (void *arg);
+
+int
+main (int argc, char *argv[])
+{
+ struct nbd_handle *nbd;
+ pthread_t reader_threads[NR_MULTI_CONN];
+ struct reader_status reader_status[NR_MULTI_CONN];
+ size_t i;
+ int err;
+ unsigned r...
2019 Jun 04
0
[PATCH libnbd v2 1/4] examples, tests: Remove want_to_send / ready logic, increase limit on cmds in flight.
...else
+ handle = nbd_aio_pread (nbd, buf, sizeof buf, offset, 0);
+ if (handle == -1) {
+ fprintf (stderr, "%s\n", nbd_get_error ());
+ goto error;
+ }
+ handles[in_flight] = handle;
+ i--;
+ in_flight++;
+ if (in_flight > status->most_in_flight)
+ status->most_in_flight = in_flight;
+ }
fds[0].fd = nbd_aio_get_fd (nbd);
- fds[0].events = want_to_send ? POLLOUT : 0;
+ fds[0].events = 0;
fds[0].revents = 0;
dir = nbd_aio_get_direction (nbd);
if ((dir & LIBNBD_AIO_DIRECTION_READ) != 0)
@@ -266,30...
2019 Jun 29
0
[libnbd PATCH 1/6] api: Add nbd_aio_in_flight
...- buf_size);
cmd = rand () & 1;
if (cmd == 0) {
@@ -263,10 +262,14 @@ start_thread (void *arg)
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;
+ for (i = 0; i < MAX_IN_FLIGHT; i++) {
+ if (handles[i] == 0) {
+ handles[i] = handle;
+ break;
+ }
+ }
+ if (nbd_aio_in_flight (nbd) > status->most_in_flight)
+ status->most_in_flig...
2019 Jun 04
9
[PATCH libnbd v2 0/4] api: Implement concurrent writer.
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
2019 Jun 03
10
[PATCH libnbd discussion only 0/5] api: Implement concurrent writer.
This works, but there's no time saving and I'm still investigating
whether it does what I think it does. Nevertheless I thought I would
post it because it (probably) implements the idea I had last night
outlined in:
https://www.redhat.com/archives/libguestfs/2019-June/msg00010.html
The meat of the change is patch 4. Patch 5 is an example which I
would probably fold into patch 4 for
2019 Jun 29
19
[libnbd PATCH 0/6] new APIs: aio_in_flight, aio_FOO_notify
I still need to wire in the use of *_notify functions into nbdkit to
prove whether it makes the code any faster or easier to maintain, but
at least the added example shows one good use case for the new API.
Eric Blake (6):
api: Add nbd_aio_in_flight
generator: Allow DEAD state actions to run
generator: Allow Int64 in callbacks
states: Prepare for aio notify callback
api: Add new
2019 May 23
2
[PATCH libnbd] api: Get rid of nbd_connection.
This isn't quite finished because not all of the tests or examples
have been updated, but it demonstrates an idea: Should we forget about
the concept of having multiple connections managed under a single
handle?
In this patch there is a single ‘struct nbd_handle *’ which manages a
single state machine and connection (and therefore no nbd_connection).
To connect to a multi-conn server you must