Commit Graph

4138 Commits

Author SHA1 Message Date
Julien Viet
d625c10d6b Minor improvement of executeBlocking methods with futures 2019-10-29 14:49:22 +01:00
Julien Viet
39d0fed1cd Fix test not passing for domain sockets due to not using the correct address in client 2019-10-29 09:58:32 +01:00
Julien Viet
034ef54098 Expose client context internally 2019-10-28 18:22:19 +01:00
Julien Viet
471b3a32fb Use context futures in Vert.x API - fixes #3164 2019-10-28 14:05:05 +01:00
Julien Viet
6defdbfb94 Context promise/future - fixes #3163 2019-10-28 14:01:47 +01:00
Julien Viet
7dcfa8c80f Add an execute(T,Handler<T>) method on ContextInternal to execute a context task from anywhere 2019-10-28 12:47:37 +01:00
Julien Viet
80e1cc7e85 Rework HTTP client 2019-10-25 11:14:02 +02:00
Julien Viet
a655b9b4c4 Obtain context in HttpClientRequest when the request is created and not at connect time 2019-10-25 10:49:42 +02:00
Julien Viet
48751f950a Improve Netty promise/future listener adapter and use it when possible 2019-10-25 10:49:42 +02:00
Julien Viet
707ad8c1bb NetSocketInternal#writeMessage(Object) should return a Future<Void> and not be fluent 2019-10-25 10:32:38 +02:00
Julien Ponge
1ab9884cb2 Update copyright notices
This also:

1. updates copyright to 2011-2019,
2. adds missing headers,
3. harmonizes to "Contributors to the Eclipse Foundation"
   (replacing a "Copyright Red Hat, Inc." by that is correct).

Signed-off-by: Julien Ponge <julien.ponge@gmail.com>
2019-10-24 15:09:37 +02:00
Julien Viet
8dbface343 Merge pull request #3158 from vietj/event-bus-iso
Event bus improvements
2019-10-23 20:05:01 +02:00
Julien Viet
474b35eb48 Introduce specific classes to split behavior/state between MessageConsumer implementation and ReplyHandler implementations delegating to HandlerRegistration 2019-10-23 18:47:13 +02:00
Julien Viet
157f59dcf4 Remove src field from MessageImpl as it can be avoided 2019-10-20 09:22:30 +02:00
Julien Viet
64ee11b0a1 Improve event bus tracing so that the response is traced when it is sent 2019-10-20 09:20:18 +02:00
Julien Viet
dcf3174cab Add address on HandlerHolder 2019-10-20 09:20:18 +02:00
Julien Viet
deadcc1f93 Remove unecessary method param 2019-10-20 09:20:18 +02:00
Julien Viet
c6dd46d10c Move the replier message info on the replied message itself 2019-10-20 09:20:18 +02:00
Julien Viet
a06aa2a296 Reply address is never set in MessageImpl constructor 2019-10-20 09:20:18 +02:00
Julien Viet
05067ca881 Move sender metrics/tracing concerns to OutboundDeliveryContext 2019-10-20 09:20:18 +02:00
Julien Viet
79c13877b9 Make OutboundDeliveryContext not anymore an inner class of EventBus 2019-10-20 09:20:18 +02:00
Julien Viet
d6869caa0b Use promise first in EventBus instead of async result handler 2019-10-20 09:20:18 +02:00
Julien Viet
bbaf418793 Set the handler registration context when it is created instead of delaying it to when the consumer handler is set 2019-10-20 09:20:18 +02:00
Julien Viet
42cdd34b47 Make consumer metric update from EventBus to HandlerRegistration 2019-10-20 09:20:06 +02:00
Julien Viet
9a31e2439a Rename io.vertx.core.impl.NetSocketInternal to io.vertx.core.net.impl.NetSocketInternal - fixes #3152 2019-10-17 22:57:13 +02:00
Julien Viet
12fa90e87c Restrict tests for native transport in CI as now job fails due to time limit exceeded 2019-10-16 14:16:29 +02:00
Julien Viet
2fca36d31b Netty upgrade to 4.1.42.Final - see https://github.com/eclipse-vertx/vert.x/issues/3146 2019-10-16 11:37:15 +02:00
Julien Viet
733c1e097b WebSocket writePing/writePong should return a Future<Void> and accept an overloaded async result handler 2019-10-15 14:25:33 +02:00
Julien Viet
c429731ae2 MessageConsumer unregister() should return a Future<Void> 2019-10-15 14:25:33 +02:00
Julien Viet
9824a7f34f Remove useless future() construction 2019-10-15 14:25:33 +02:00
Julien Viet
11f4e9942c Revert "Detect and print deadlocks in JVM when blocked thread checker detects a blocked thread"
This reverts commit 8580977000.
2019-10-15 13:52:00 +02:00
Julien Viet
aaf5fd72e6 Fix synchronisation regression leading to potential deadlock 2019-10-15 13:51:30 +02:00
Julien Viet
8580977000 Detect and print deadlocks in JVM when blocked thread checker detects a blocked thread 2019-10-15 13:28:48 +02:00
Julien Viet
ceb1bf116b Provide the Future#flatMap method as alias of Future#compose method - closes #3145 2019-10-15 12:43:48 +02:00
Julien Viet
95f82b52bd Extend Future#compose to allow remapping errors - closes #3144 2019-10-15 12:33:03 +02:00
Kowalczyk
9391ea39bd 2934 make compressed http2 request possible
Signed-off-by: Kowalczyk <bkowalczyyk@gmail.com>
2019-10-15 11:56:12 +02:00
Julien Viet
9c87fdfda0 Use Netty future/promise in AsyncResolveConnectHelper to remove unecessary concurrency - fixes #3142 2019-10-15 11:13:58 +02:00
Julien Viet
d97c6ccad8 Improve usage of synchronization in HttpClientRequest 2019-10-14 10:41:00 +02:00
Julien Viet
1018724a96 Do not lock the handler calls in AsyncFile - see #3140 2019-10-14 10:09:27 +02:00
Julien Viet
62efc9835d Remove succeeded/failed Promise creation - see #3139 2019-10-14 00:10:46 +02:00
Julien Viet
e9d0de74e0 Return the empty succeeded future when for succeeded null futures 2019-10-13 19:44:35 +02:00
Julien Viet
34ffa169f0 EventBus consumer should register pending replies context close hooks when the context is associated with a deployment - see #3138 2019-10-13 19:44:35 +02:00
Julien Viet
ade55c28c8 ServerWebSocket asynchrone handshake method should consume a future instead of a promise - see #3137 2019-10-13 19:44:35 +02:00
Thomas Segismont
1d76a3f20c Merge pull request #3067 from MitchAman/master
Make CLI options case sensitive for short names (#2844).
2019-10-09 10:45:31 +02:00
Mitch Aman
a3cb5dadeb Update docs to reflect case-sensitivity changes for options (#2844).
Signed-off-by: Mitch Aman <mitch.aman845@gmail.com>
2019-10-09 02:32:18 -04:00
Julien Viet
01d8e47dcf NPE on WebSocket reject - see #3131 2019-10-07 14:03:31 +02:00
Julien Viet
6f9f621cb0 Avoid unecessary string concat on hot path 2019-10-03 11:52:09 +02:00
Julien Viet
f79563be39 Adjustements 2019-10-02 18:10:14 +02:00
swinterberger
c592b7eb7d Fix imports
Signed-off-by: swinterberger <sean.winterberger@gmail.com>
2019-10-02 18:08:55 +02:00
swinterberger
c8e2f00876 I suppose there is no reason to return the full response, just return the headers
Signed-off-by: swinterberger <sean.winterberger@gmail.com>
2019-10-02 18:08:05 +02:00