Home
last modified time | relevance | path

Searched refs:maxMessageSize (Results 1 – 10 of 10) sorted by path

/unit/src/java/javax/websocket/
H A DOnMessage.java27 long maxMessageSize() default -1; in maxMessageSize() method
/unit/src/java/nginx/unit/websocket/
H A DWsFrameBase.java378 long maxMessageSize = ((WrappedMessageHandler) textMsgHandler).getMaxMessageSize(); in sendMessageText() local
379 if (maxMessageSize > -1 && messageBufferText.remaining() > maxMessageSize) { in sendMessageText()
383 Long.valueOf(maxMessageSize)))); in sendMessageText()
568 long maxMessageSize = ((WrappedMessageHandler) binaryMsgHandler).getMaxMessageSize(); in sendMessageBinary() local
569 if (maxMessageSize > -1 && msg.remaining() > maxMessageSize) { in sendMessageBinary()
573 Long.valueOf(maxMessageSize)))); in sendMessageBinary()
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerBase.java46 protected final long maxMessageSize; field in PojoMessageHandlerBase
50 int indexSession, long maxMessageSize) { in PojoMessageHandlerBase() argument
66 this.maxMessageSize = maxMessageSize; in PojoMessageHandlerBase()
109 return maxMessageSize; in getMaxMessageSize()
H A DPojoMessageHandlerPartialBase.java43 long maxMessageSize) { in PojoMessageHandlerPartialBase() argument
45 indexSession, maxMessageSize); in PojoMessageHandlerPartialBase()
H A DPojoMessageHandlerPartialBinary.java32 int indexBoolean, int indexSession, long maxMessageSize) { in PojoMessageHandlerPartialBinary() argument
34 indexSession, maxMessageSize); in PojoMessageHandlerPartialBinary()
H A DPojoMessageHandlerPartialText.java31 int indexBoolean, int indexSession, long maxMessageSize) { in PojoMessageHandlerPartialText() argument
33 indexSession, maxMessageSize); in PojoMessageHandlerPartialText()
H A DPojoMessageHandlerWholeBase.java39 boolean convert, int indexSession, long maxMessageSize) { in PojoMessageHandlerWholeBase() argument
41 indexSession, maxMessageSize); in PojoMessageHandlerWholeBase()
H A DPojoMessageHandlerWholeBinary.java52 boolean isForInputStream, long maxMessageSize) { in PojoMessageHandlerWholeBinary() argument
54 indexSession, maxMessageSize); in PojoMessageHandlerWholeBinary()
57 if (maxMessageSize > -1 && maxMessageSize > session.getMaxBinaryMessageBufferSize()) { in PojoMessageHandlerWholeBinary()
58 if (maxMessageSize > Integer.MAX_VALUE) { in PojoMessageHandlerWholeBinary()
62 session.setMaxBinaryMessageBufferSize((int) maxMessageSize); in PojoMessageHandlerWholeBinary()
H A DPojoMessageHandlerWholeText.java52 long maxMessageSize) { in PojoMessageHandlerWholeText() argument
54 indexSession, maxMessageSize); in PojoMessageHandlerWholeText()
57 if (maxMessageSize > -1 && maxMessageSize > session.getMaxTextMessageBufferSize()) { in PojoMessageHandlerWholeText()
58 if (maxMessageSize > Integer.MAX_VALUE) { in PojoMessageHandlerWholeText()
62 session.setMaxTextMessageBufferSize((int) maxMessageSize); in PojoMessageHandlerWholeText()
H A DPojoMethodMapping.java382 private long maxMessageSize = -1; field in PojoMethodMapping.MessageHandlerInfo
592 maxMessageSize = m.getAnnotation(OnMessage.class).maxMessageSize(); in MessageHandlerInfo()
659 indexSession, maxMessageSize); in getMessageHandlers()
664 indexSession, maxMessageSize); in getMessageHandlers()
669 true, indexSession, false, maxMessageSize); in getMessageHandlers()
674 false, indexSession, false, maxMessageSize); in getMessageHandlers()
679 true, indexSession, true, maxMessageSize); in getMessageHandlers()
687 maxMessageSize); in getMessageHandlers()
707 indexBoolean, indexSession, maxMessageSize); in getMessageHandlers()
712 indexBoolean, indexSession, maxMessageSize); in getMessageHandlers()
[all …]