Home
last modified time | relevance | path

Searched refs:result (Results 1 – 25 of 37) sorted by relevance

12

/unit/src/java/javax/websocket/
H A DContainerProvider.java37 WebSocketContainer result = null; in getWebSocketContainer() local
42 while (result == null && iter.hasNext()) { in getWebSocketContainer()
43 result = iter.next().getContainer(); in getWebSocketContainer()
47 if (result == null) { in getWebSocketContainer()
53 result = clazz.getConstructor().newInstance(); in getWebSocketContainer()
59 return result; in getWebSocketContainer()
H A DSendHandler.java21 void onResult(SendResult result); in onResult() argument
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerBase.java70 protected final void processResult(Object result) { in processResult() argument
71 if (result == null) { in processResult()
77 if (result instanceof String) { in processResult()
78 remoteEndpoint.sendText((String) result); in processResult()
79 } else if (result instanceof ByteBuffer) { in processResult()
80 remoteEndpoint.sendBinary((ByteBuffer) result); in processResult()
81 } else if (result instanceof byte[]) { in processResult()
82 remoteEndpoint.sendBinary(ByteBuffer.wrap((byte[]) result)); in processResult()
84 remoteEndpoint.sendObject(result); in processResult()
H A DPojoMessageHandlerPartialBase.java69 Object result = null; in onMessage() local
71 result = method.invoke(pojo, parameters); in onMessage()
75 processResult(result); in onMessage()
H A DPojoMessageHandlerWholeBase.java78 Object result = null; in onMessage() local
80 result = method.invoke(pojo, parameters); in onMessage()
84 processResult(result); in onMessage()
H A DPojoMethodMapping.java267 Set<MessageHandler> result = new HashSet<>(); in getMessageHandlers() local
272 return result; in getMessageHandlers()
288 result[i] = new PojoPathParam(type, null); in getPathParams()
319 if (result[i] == null) { in getPathParams()
331 return result; in getPathParams()
339 Object[] result = new Object[pathParams.length]; in buildArgs() local
343 result[i] = session; in buildArgs()
345 result[i] = config; in buildArgs()
347 result[i] = throwable; in buildArgs()
349 result[i] = closeReason; in buildArgs()
[all …]
/unit/src/java/nginx/unit/websocket/
H A DFutureToSendHandler.java41 private volatile AtomicReference<SendResult> result = new AtomicReference<>(null); field in FutureToSendHandler
51 public void onResult(SendResult result) { in onResult() argument
52 this.result.compareAndSet(null, result); in onResult()
85 if (result.get().getException() != null) { in get()
86 throw new ExecutionException(result.get().getException()); in get()
107 if (result.get().getException() != null) { in get()
108 throw new ExecutionException(result.get().getException()); in get()
H A DUtil.java160 sr.nextBytes(result); in generateMask()
165 return result; in generateMask()
233 if (result.getClazz() != null && result.getDimension() > 0) { in getGenericType()
236 return result; in getGenericType()
277 return result; in getTypeParameter()
357 return result; in getDecoders()
374 results.add(result); in getMessageHandlers()
379 results.add(result); in getMessageHandlers()
384 results.add(result); in getMessageHandlers()
398 results.add(result); in getMessageHandlers()
[all …]
H A DAsyncChannelWrapperSecure.java425 resultStatus = result.getStatus(); in checkResult()
432 if (wrap && result.bytesConsumed() != 0) { in checkResult()
447 private volatile T result = null; field in AsyncChannelWrapperSecure.WrapperFuture
460 public void complete(T result) { in complete() argument
461 this.result = result; in complete()
464 handler.completed(result, attachment); in complete()
499 return result; in get()
513 return result; in get()
542 Long result = wrapped.get(); in get() local
547 return Integer.valueOf(result.intValue()); in get()
[all …]
H A DWsWebSocketContainer.java628 return result; in getOpenSessions()
706 return result; in generateExtensionHeaders()
736 result = addHeader(result, entry.getKey(), entry.getValue()); in createRequest()
740 result.put(CRLF); in createRequest()
742 result.flip(); in createRequest()
744 return result; in createRequest()
750 return result; in addHeader()
753 result = putWithExpand(result, key.getBytes(StandardCharsets.ISO_8859_1)); in addHeader()
756 result = putWithExpand(result, CRLF); in addHeader()
758 return result; in addHeader()
[all …]
H A DWsRemoteEndpointImplBase.java386 handler.onResult(result); in endMessage()
782 handler.onResult(result); in onResult()
783 } else if(!result.isOK()) { in onResult()
784 handler.onResult(result); in onResult()
888 if (result.isOK()) { in onResult()
896 handler.onResult(result); in onResult()
917 if (result.isOK()) { in onResult()
920 handler.onResult(result); in onResult()
1213 if (result.isOK()) { in onResult()
1216 handler.onResult(result); in onResult()
[all …]
H A DWsFrameBase.java286 boolean result; in processData()
288 result = processDataControl(); in processData()
291 result = swallowInput(); in processData()
293 result = processDataText(); in processData()
297 result = swallowInput(); in processData()
299 result = processDataBinary(); in processData()
303 return result; in processData()
671 long result = 0; in byteArrayToLong() local
673 result = result + ((b[i] & 0xFF) << shift); in byteArrayToLong()
676 return result; in byteArrayToLong()
H A DPerMessageDeflate.java270 Extension result = new WsExtension(NAME); in getExtensionResponse() local
272 List<Extension.Parameter> params = result.getParameters(); in getExtensionResponse()
289 return result; in getExtensionResponse()
460 int result = uncompressedMessagePart.getRsv(); in getRsv() local
462 result += RSV_BITMASK; in getRsv()
465 return result; in getRsv()
/unit/src/java/nginx/unit/websocket/server/
H A DWsWriteTimeout.java85 boolean result = endpoints.add(endpoint); in register()
86 if (result) { in register()
96 boolean result = endpoints.remove(endpoint); in unregister()
97 if (result) { in unregister()
H A DDefaultServerEndpointConfigurator.java67 List<Extension> result = new ArrayList<>(); in getNegotiatedExtensions() local
70 result.add(request); in getNegotiatedExtensions()
73 return result; in getNegotiatedExtensions()
H A DUpgradeUtil.java198 List<Transformation> result = new ArrayList<>(negotiatedExtensions.size()); in createTransformations() local
216 result.add(transformation); in createTransformations()
219 return result; in createTransformations()
267 List<String> result = new ArrayList<>(); in getTokensFromHeader() local
273 result.add(token.trim()); in getTokensFromHeader()
276 return result; in getTokensFromHeader()
H A DUriTemplate.java105 Map<String,String> result = new HashMap<>(); in match() local
129 result.put(targetSegment.getValue(), in match()
134 return result; in match()
/unit/test/perl/errors_print/
H A Dpsgi.pl4 my $result = $environ->{'psgi.errors'}->print('Error in application');
6 return ['200', ['Content-Length' => '1'], [$result]];
/unit/src/
H A Dnxt_sha1.c94 result[0] = (u_char) (ctx->a >> 24); in nxt_sha1_final()
96 result[2] = (u_char) (ctx->a >> 8); in nxt_sha1_final()
97 result[3] = (u_char) ctx->a; in nxt_sha1_final()
100 result[6] = (u_char) (ctx->b >> 8); in nxt_sha1_final()
101 result[7] = (u_char) ctx->b; in nxt_sha1_final()
104 result[10] = (u_char) (ctx->c >> 8); in nxt_sha1_final()
105 result[11] = (u_char) ctx->c; in nxt_sha1_final()
108 result[14] = (u_char) (ctx->d >> 8); in nxt_sha1_final()
109 result[15] = (u_char) ctx->d; in nxt_sha1_final()
112 result[18] = (u_char) (ctx->e >> 8); in nxt_sha1_final()
[all …]
H A Dnxt_sha1.h21 NXT_EXPORT void nxt_sha1_final(u_char result[20], nxt_sha1_t *ctx);
/unit/src/java/javax/websocket/server/
H A DServerEndpointConfig.java167 Configurator result = null; in loadDefault() local
173 while (result == null && iter.hasNext()) { in loadDefault()
174 result = iter.next(); in loadDefault()
178 if (result == null) { in loadDefault()
184 result = clazz.getConstructor().newInstance(); in loadDefault()
190 return result; in loadDefault()
/unit/src/perl/
H A Dnxt_perl_psgi.c75 SV *result);
336 SV *result; in nxt_perl_psgi_call_var_application() local
356 result = POPs; in nxt_perl_psgi_call_var_application()
357 SvREFCNT_inc(result); in nxt_perl_psgi_call_var_application()
363 return result; in nxt_perl_psgi_call_var_application()
371 SV *result; in nxt_perl_psgi_call_method() local
389 result = NULL; in nxt_perl_psgi_call_method()
399 return result; in nxt_perl_psgi_call_method()
763 array = (AV *) SvRV(result); in nxt_perl_psgi_result_status()
1233 if (nxt_fast_path(SvOK(result) != 0 && SvROK(result) != 0)) { in nxt_perl_psgi_request_handler()
[all …]
/unit/src/ruby/
H A Dnxt_ruby.c61 VALUE result);
63 VALUE result, nxt_int_t status);
67 VALUE result);
664 VALUE env, result; in nxt_ruby_rack_app_run() local
684 if (nxt_slow_path(TYPE(result) != T_ARRAY)) { in nxt_ruby_rack_app_run()
691 if (nxt_slow_path(RARRAY_LEN(result) != 3)) { in nxt_ruby_rack_app_run()
712 rc = nxt_ruby_rack_result_body(req, result); in nxt_ruby_rack_app_run()
719 return result; in nxt_ruby_rack_app_run()
803 status = rb_ary_entry(result, 0); in nxt_ruby_rack_result_status()
837 headers = rb_ary_entry(result, 1); in nxt_ruby_rack_result_headers()
[all …]
/unit/src/test/
H A Dnxt_clone_test.c22 nxt_int_t result; member
408 if (tc->result == NXT_OK && level == NXT_LOG_DEBUG) { in nxt_clone_test_log_handler()
543 if (ret != tc->result) { in nxt_clone_test_map_assert()
545 "return %d instead of %d (map: %V)", ret, tc->result, in nxt_clone_test_map_assert()
H A Dnxt_http_parse_test.c27 nxt_int_t result; member
41 nxt_int_t result; member
567 if (rc != test->result) { in nxt_http_parse_test()
571 &test->request, rc, test->result); in nxt_http_parse_test()
803 if (rc != data->fields.result) { in nxt_http_parse_test_fields()
807 request, rc, data->fields.result); in nxt_http_parse_test_fields()

12