Home
last modified time | relevance | path

Searched refs:type (Results 1 – 25 of 128) sorted by relevance

123456

/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoPathParam.java29 private final Class<?> type; field in PojoPathParam
33 public PojoPathParam(Class<?> type, String name) { in PojoPathParam() argument
34 this.type = type; in PojoPathParam()
40 return type; in getType()
H A DPojoMethodMapping.java286 Class<?> type = types[i]; in getPathParams() local
287 if (type.equals(Session.class)) { in getPathParams()
290 type.equals(EndpointConfig.class)) { in getPathParams()
293 && type.equals(Throwable.class)) { in getPathParams()
297 type.equals(CloseReason.class)) { in getPathParams()
307 Util.coerceToType(type, "0"); in getPathParams()
341 Class<?> type = pathParams[i].getType(); in buildArgs() local
342 if (type.equals(Session.class)) { in buildArgs()
346 } else if (type.equals(Throwable.class)) { in buildArgs()
348 } else if (type.equals(CloseReason.class)) { in buildArgs()
[all …]
H A DLocalStrings.properties17 pojoEndpointBase.onCloseFail=Failed to call onClose method of POJO end point for POJO of type [{0}]
19 pojoEndpointBase.onErrorFail=Failed to call onError method of POJO end point for POJO of type [{0}]
20 pojoEndpointBase.onOpenFail=Failed to call onOpen method of POJO end point for POJO of type [{0}]
21 pojoEndpointServer.getPojoInstanceFail=Failed to create instance of POJO of type [{0}]
22 pojoMethodMapping.decodePathParamFail=Failed to decode path parameter value [{0}] to expected type …
28 pojoMethodMapping.invalidDecoder=The specified decoder of type [{0}] could not be instantiated
33 pojoMethodMapping.paramWithoutAnnotation=A parameter of type [{0}] was found on method[{1}] of clas…
H A DPojoMessageHandlerWholeText.java66 Class<?> type = method.getParameterTypes()[indexPayload]; in PojoMessageHandlerWholeText() local
67 if (Util.isPrimitive(type)) { in PojoMessageHandlerWholeText()
68 primitiveType = type; in PojoMessageHandlerWholeText()
/unit/src/java/nginx/unit/websocket/
H A DMessageHandlerResult.java24 private final MessageHandlerResultType type; field in MessageHandlerResult
28 MessageHandlerResultType type) { in MessageHandlerResult() argument
30 this.type = type; in MessageHandlerResult()
40 return type; in getType()
H A DUtil.java185 private static <T> TypeResult getGenericType(Class<T> type, in getGenericType() argument
308 if (type.equals(String.class)) { in coerceToType()
310 } else if (type.equals(boolean.class) || type.equals(Boolean.class)) { in coerceToType()
312 } else if (type.equals(byte.class) || type.equals(Byte.class)) { in coerceToType()
314 } else if (type.equals(char.class) || type.equals(Character.class)) { in coerceToType()
316 } else if (type.equals(double.class) || type.equals(Double.class)) { in coerceToType()
318 } else if (type.equals(float.class) || type.equals(Float.class)) { in coerceToType()
320 } else if (type.equals(int.class) || type.equals(Integer.class)) { in coerceToType()
322 } else if (type.equals(long.class) || type.equals(Long.class)) { in coerceToType()
324 } else if (type.equals(short.class) || type.equals(Short.class)) { in coerceToType()
[all …]
/unit/src/
H A Dnxt_conf_validation.c55 nxt_conf_vldt_type_t type:32; member
246 .type = NXT_CONF_VLDT_OBJECT,
446 .type = NXT_CONF_VLDT_STRING
1218 if ((1 << value_type) & type) { in nxt_conf_vldt_type()
1224 n = nxt_popcount(type); in nxt_conf_vldt_type()
1233 t = __builtin_ffs(type) - 1; in nxt_conf_vldt_type()
1253 type = type & ~(1 << t); in nxt_conf_vldt_type()
1325 nxt_str_t *type; member
1377 *ctx->type = *name; in nxt_conf_vldt_mtypes_type()
2322 nxt_str_t type; in nxt_conf_vldt_app() local
[all …]
H A Dnxt_service.c102 if (nxt_strcmp(s->type, service->type) != 0) { in nxt_service_add()
111 service->type, service->name); in nxt_service_add()
131 nxt_service_get(nxt_array_t *services, const char *type, const char *name) in nxt_service_get() argument
146 if (nxt_strcmp(s->type, type) == 0) { in nxt_service_get()
162 type, (name != NULL) ? ":" : "", name); in nxt_service_get()
H A Dnxt_thread.h33 #define nxt_thread_extern_data(type, tsd) \ argument
34 NXT_EXPORT extern __thread type tsd
36 #define nxt_thread_declare_data(type, tsd) \ argument
37 __thread type tsd
66 #define nxt_thread_extern_data(type, tsd) \ argument
69 #define nxt_thread_declare_data(type, tsd) \ argument
70 nxt_thread_specific_data_t tsd = { { (nxt_atomic_int_t) -1, sizeof(type) } }
H A Dnxt_service.h12 const char *type; member
19 ((s)->type == NULL)
25 NXT_EXPORT const void *nxt_service_get(nxt_array_t *services, const char *type,
H A Dnxt_clang.h201 #define nxt_container_of(p, type, field) \ argument
202 (type *) ((u_char *) (p) - offsetof(type, field))
209 #define nxt_value_at(type, p, offset) \ argument
210 *(type *) ((u_char *) p + offset)
H A Dnxt_vector.c23 vector->type = NXT_VECTOR_EMBEDDED; in nxt_vector_create()
40 vector->type = NXT_VECTOR_INITED; in nxt_vector_init()
51 switch (vector->type) { in nxt_vector_destroy()
107 if (vector->type == NXT_VECTOR_EMBEDDED) { in nxt_vector_add()
108 vector->type = NXT_VECTOR_DESCRETE; in nxt_vector_add()
H A Dnxt_conf.c405 switch (value->type) { in nxt_conf_type()
462 switch (value->type) { in nxt_conf_get_path()
594 switch (map[i].type) { in nxt_conf_map_object()
617 switch (map[i].type) { in nxt_conf_map_object()
826 switch (root->type) { in nxt_conf_op_compile()
965 switch (src->type) { in nxt_conf_copy_value()
991 dst->type = src->type; in nxt_conf_copy_value()
1091 dst->type = src->type; in nxt_conf_copy_array()
1221 dst->type = src->type; in nxt_conf_copy_object()
2212 switch (value->type) { in nxt_conf_json_length()
[all …]
H A Dnxt_port.c50 nxt_process_type_t type) in nxt_port_new() argument
66 port->type = type; in nxt_port_new()
93 port->id, port->type); in nxt_port_close()
130 port->id, port->type); in nxt_port_release()
177 if (nxt_fast_path(msg->port_msg.type < NXT_PORT_MSG_MAX)) { in nxt_port_handler()
180 msg->port->socket.fd, msg->port_msg.type, in nxt_port_handler()
184 handlers[msg->port_msg.type](task, msg); in nxt_port_handler()
190 msg->port->socket.fd, msg->port_msg.type); in nxt_port_handler()
220 if (nxt_proc_send_matrix[port->type][new_port->type]) { in nxt_port_send_new_port()
251 msg->type = new_port->type; in nxt_port_send_port()
[all …]
H A Dnxt_application.c27 nxt_app_type_t type; member
146 .type = NXT_PROCESS_APP,
337 nxt_app_type_t type; in nxt_discovery_module() local
369 type = nxt_app_parse_type(app->type.start, app->type.length); in nxt_discovery_module()
371 if (type == NXT_APP_UNKNOWN) { in nxt_discovery_module()
384 if (type == module[i].type in nxt_discovery_module()
401 module->type = type; in nxt_discovery_module()
448 to->type = from->type; in nxt_discovery_module()
934 nxt_app_type_t type; in nxt_app_lang_module() local
954 if (type == NXT_APP_UNKNOWN) { in nxt_app_lang_module()
[all …]
H A Dnxt_application.h35 nxt_app_type_t type; member
93 nxt_str_t type; member
126 nxt_str_t type; member
H A Dnxt_upstream_round_robin.c102 sa->type = SOCK_STREAM; in nxt_upstream_round_robin_create()
116 upstream->type.round_robin = urr; in nxt_upstream_round_robin_create()
141 urrcf = upstream->type.round_robin; in nxt_upstream_round_robin_joint_create()
151 u->type.round_robin = urr; in nxt_upstream_round_robin_joint_create()
175 round_robin = us->upstream->type.round_robin; in nxt_upstream_round_robin_server_get()
H A Dnxt_cert.c102 char *type, *header; in nxt_cert_bio() local
134 nxt_debug(task, "PEM type: \"%s\"", type); in nxt_cert_bio()
146 if (nxt_strcmp(type, PEM_STRING_PKCS8) == 0) { in nxt_cert_bio()
151 if (nxt_strcmp(type, PEM_STRING_PKCS8INF) == 0) { in nxt_cert_bio()
187 if (nxt_strcmp(type, PEM_STRING_X509) == 0 in nxt_cert_bio()
219 OPENSSL_free(type); in nxt_cert_bio()
754 if (name->type != GEN_DNS) { in nxt_cert_alt_names_details()
769 if (name->type != GEN_DNS) { in nxt_cert_alt_names_details()
1084 recv_port = rt->port_by_type[rt->type]; in nxt_cert_store_get()
1132 nxt_port_msg_type_t type; in nxt_cert_store_get_handler() local
[all …]
H A Dnxt_queue.h193 #define nxt_queue_link_data(lnk, type, link) \ argument
194 nxt_container_of(lnk, type, link)
203 #define nxt_queue_each(elt, queue, type, link) \ argument
212 elt = nxt_queue_link_data(_lnk, type, link); \
/unit/pkg/deb/debian/
H A Dunit.example.config4 "type": "php",
11 "type": "python",
18 "type": "external",
23 "type": "perl",
/unit/pkg/rpm/rpmbuild/SOURCES/
H A Dunit.example.config4 "type": "php",
11 "type": "python",
18 "type": "external",
23 "type": "perl",
/unit/test/node/websockets/mirror/
H A Dapp.js19 if (message.type === 'utf8') {
21 } else if (message.type === 'binary') {
/unit/src/java/nginx/unit/
H A DResponse.java722 contentTypeHeader = type; in setCharacterEncoding()
724 setContentType(req_info_ptr, type.getBytes(ISO_8859_1)); in setCharacterEncoding()
757 public void setContentType(String type) in setContentType() argument
759 trace("setContentType: " + type); in setContentType()
765 if (type == null) { in setContentType()
772 String charset = MimeTypes.getCharsetFromContentType(type); in setContentType()
773 String ctype = MimeTypes.getContentTypeWithoutCharset(type); in setContentType()
781 type = ctype + ";charset=" + characterEncoding; in setContentType()
785 type = type + ";charset=" + characterEncoding; in setContentType()
791 contentTypeHeader = type; in setContentType()
[all …]
/unit/test/node/loader/es_modules_websocket_indirect/
H A Dmodule.mjs21 if (message.type === 'utf8') {
23 } else if (message.type === 'binary') {
/unit/test/node/loader/es_modules_websocket/
H A Dapp.mjs21 if (message.type === 'utf8') {
23 } else if (message.type === 'binary') {

123456