Home
last modified time | relevance | path

Searched refs:Util (Results 1 – 10 of 10) sorted by relevance

/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerWholeText.java33 import nginx.unit.websocket.Util;
67 if (Util.isPrimitive(type)) { in PojoMessageHandlerWholeText()
102 return Util.coerceToType(primitiveType, message); in decode()
H A DPojoMethodMapping.java49 import nginx.unit.websocket.Util;
50 import nginx.unit.websocket.Util.DecoderMatch;
79 List<DecoderEntry> decoders = Util.getDecoders(decoderClazzes); in PojoMethodMapping()
307 Util.coerceToType(type, "0"); in getPathParams()
354 result[i] = Util.coerceToType(type, value); in buildArgs()
454 } else if (Util.isPrimitive(types[i])) { in MessageHandlerInfo()
641 value = Util.coerceToType(pathParam.getType(), valueString); in getMessageHandlers()
/unit/src/java/nginx/unit/websocket/
H A DUtil.java60 public class Util { class
62 private static final StringManager sm = StringManager.getManager(Util.class);
66 private Util() { in Util() method in Util
170 return Util.getGenericType(MessageHandler.class, in getMessageType()
176 return Util.getGenericType(Decoder.class, decoder).getClazz(); in getDecoderType()
181 return Util.getGenericType(Encoder.class, encoder).getClazz(); in getEncoderType()
352 Util.getDecoderType(decoderClazz), decoderClazz); in getDecoders()
H A DPerMessageDeflate.java183 if (Util.isControl(opCode)) { in getMoreData()
187 if (!Util.isContinuation(opCode)) { in getMoreData()
244 if (Util.isControl(opCode)) { in validateRsv()
324 if (Util.isControl(opCode)) { in sendMessagePart()
H A DWsFrameBase.java159 if (Util.isControl(opCode)) { in processInitialHeader()
174 if (!Util.isContinuation(opCode)) { in processInitialHeader()
265 if (Util.isControl(opCode)) { in processRemainingHeader()
287 if (Util.isControl(opCode)) { in processData()
346 wsSession.onClose(new CloseReason(Util.getCloseCode(code), reason)); in processDataControl()
638 if (Util.isControl(opCode)) { in usePartial()
H A DWsRemoteEndpointImplBase.java410 if (Util.isControl(mp.getOpCode())) { in writeMessagePart()
418 boolean isText = Util.isText(mp.getOpCode()); in writeMessagePart()
444 mask = Util.generateMask(); in writeMessagePart()
542 if (encoder == null && Util.isPrimitive(obj.getClass())) { in sendObject()
597 if (encoder == null && Util.isPrimitive(obj.getClass())) { in sendObjectByCompletion()
660 Util.getEncoderType(encoderClazz), instance); in setEncoders()
H A DWsSession.java232 Class<?> target = Util.getMessageType(listener); in addMessageHandler()
265 Set<MessageHandlerResult> mhResults = Util.getMessageHandlers(target, listener, in doAddMessageHandler()
H A DWsWebSocketContainer.java461 Util.parseExtensionHeader(extensionsAgreed, extHeader); in connectToServerRecursive()
/unit/src/java/nginx/unit/websocket/server/
H A DUpgradeUtil.java47 import nginx.unit.websocket.Util;
113 Util.parseExtensionHeader(extensionsRequested, extHeaders.nextElement()); in doUpgrade()
/unit/auto/modules/
H A Djava429 src/java/nginx/unit/websocket/Util.java \