| /unit/src/java/nginx/unit/websocket/ |
| H A D | DecoderEntry.java | 23 private final Class<?> clazz; field in DecoderEntry
26 public DecoderEntry(Class<?> clazz, in DecoderEntry() argument
28 this.clazz = clazz; in DecoderEntry()
33 return clazz; in getClazz()
|
| H A D | Util.java | 186 Class<? extends T> clazz) { in getGenericType() argument
291 if (clazz.isPrimitive()) { in isPrimitive()
294 clazz.equals(Byte.class) || in isPrimitive()
296 clazz.equals(Double.class) || in isPrimitive()
297 clazz.equals(Float.class) || in isPrimitive()
298 clazz.equals(Integer.class) || in isPrimitive()
299 clazz.equals(Long.class) || in isPrimitive()
300 clazz.equals(Short.class)) { in isPrimitive()
640 private final Class<?> clazz; field in Util.TypeResult
645 this.clazz= clazz; in TypeResult()
[all …]
|
| H A D | WsRemoteEndpointImplBase.java | 1098 private final Class<?> clazz; field in WsRemoteEndpointImplBase.EncoderEntry
1101 public EncoderEntry(Class<?> clazz, Encoder encoder) { in EncoderEntry() argument
1102 this.clazz = clazz; in EncoderEntry()
1107 return clazz; in getClazz()
|
| H A D | WsSession.java | 238 public <T> void addMessageHandler(Class<T> clazz, Partial<T> handler) in addMessageHandler() argument
240 doAddMessageHandler(clazz, handler); in addMessageHandler()
245 public <T> void addMessageHandler(Class<T> clazz, Whole<T> handler) in addMessageHandler() argument
247 doAddMessageHandler(clazz, handler); in addMessageHandler()
|
| H A D | WsWebSocketContainer.java | 174 public Session connectToServer(Class<? extends Endpoint> clazz, in connectToServer() argument
180 endpoint = clazz.getConstructor().newInstance(); in connectToServer()
183 "wsWebSocketContainer.endpointCreateFail", clazz.getName()), in connectToServer()
|
| /unit/src/java/nginx/unit/websocket/server/ |
| H A D | WsSci.java | 62 for (Class<?> clazz : clazzes) { in onStartup()
63 int modifiers = clazz.getModifiers(); in onStartup()
70 if (clazz.getName().startsWith(wsPackage)) { in onStartup()
73 if (ServerApplicationConfig.class.isAssignableFrom(clazz)) { in onStartup()
75 (ServerApplicationConfig) clazz.getConstructor().newInstance()); in onStartup()
77 if (Endpoint.class.isAssignableFrom(clazz)) { in onStartup()
80 (Class<? extends Endpoint>) clazz; in onStartup()
83 if (clazz.isAnnotationPresent(ServerEndpoint.class)) { in onStartup()
84 scannedPojoEndpoints.add(clazz); in onStartup()
119 for (Class<?> clazz : filteredPojoEndpoints) { in onStartup()
[all …]
|
| H A D | DefaultServerEndpointConfigurator.java | 33 public <T> T getEndpointInstance(Class<T> clazz) in getEndpointInstance() argument
36 return clazz.getConstructor().newInstance(); in getEndpointInstance()
|
| H A D | UpgradeUtil.java | 167 Class<?> clazz = sec.getEndpointClass(); in doUpgrade() local
168 if (Endpoint.class.isAssignableFrom(clazz)) { in doUpgrade()
170 clazz); in doUpgrade()
|
| /unit/src/java/javax/websocket/ |
| H A D | ContainerProvider.java | 50 Class<WebSocketContainer> clazz = in getWebSocketContainer() local
53 result = clazz.getConstructor().newInstance(); in getWebSocketContainer()
|
| H A D | Session.java | 173 <T> void addMessageHandler(Class<T> clazz, MessageHandler.Partial<T> handler) in addMessageHandler() argument
191 <T> void addMessageHandler(Class<T> clazz, MessageHandler.Whole<T> handler) in addMessageHandler() argument
|
| /unit/src/java/javax/websocket/server/ |
| H A D | ServerEndpointConfig.java | 181 Class<Configurator> clazz = in loadDefault() local
184 result = clazz.getConstructor().newInstance(); in loadDefault()
212 public <T extends Object> T getEndpointInstance(Class<T> clazz) in getEndpointInstance() argument
215 clazz); in getEndpointInstance()
|
| H A D | ServerContainer.java | 26 public abstract void addEndpoint(Class<?> clazz) throws DeploymentException; in addEndpoint() argument
|
| /unit/src/java/nginx/unit/ |
| H A D | Context.java | 3508 public <T extends EventListener> T createListener(Class<T> clazz)
3511 trace("createListener<C> " + clazz.getName());
3517 return clazz.getDeclaredConstructor().newInstance();
|