/unit/src/java/nginx/unit/websocket/pojo/ |
H A D | PojoPathParam.java | 29 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 D | PojoMethodMapping.java | 286 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 D | LocalStrings.properties | 17 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 D | PojoMessageHandlerWholeText.java | 66 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 D | MessageHandlerResult.java | 24 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 D | Util.java | 185 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 D | nxt_conf_validation.c | 55 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 D | nxt_service.c | 102 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 D | nxt_thread.h | 33 #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 D | nxt_service.h | 12 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 D | nxt_clang.h | 201 #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 D | nxt_vector.c | 23 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 D | nxt_conf.c | 405 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 D | nxt_port.c | 50 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 D | nxt_application.c | 27 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 D | nxt_application.h | 35 nxt_app_type_t type; member 93 nxt_str_t type; member 126 nxt_str_t type; member
|
H A D | nxt_upstream_round_robin.c | 102 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 D | nxt_cert.c | 102 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 D | nxt_queue.h | 193 #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 D | unit.example.config | 4 "type": "php", 11 "type": "python", 18 "type": "external", 23 "type": "perl",
|
/unit/pkg/rpm/rpmbuild/SOURCES/ |
H A D | unit.example.config | 4 "type": "php", 11 "type": "python", 18 "type": "external", 23 "type": "perl",
|
/unit/test/node/websockets/mirror/ |
H A D | app.js | 19 if (message.type === 'utf8') { 21 } else if (message.type === 'binary') {
|
/unit/src/java/nginx/unit/ |
H A D | Response.java | 722 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 D | module.mjs | 21 if (message.type === 'utf8') { 23 } else if (message.type === 'binary') {
|
/unit/test/node/loader/es_modules_websocket/ |
H A D | app.mjs | 21 if (message.type === 'utf8') { 23 } else if (message.type === 'binary') {
|