| /glassfish-3.1.2/core/kernel/src/main/java/com/sun/enterprise/v3/services/impl/monitor/ |
| H A D | MonitorableSSLSelectorHandler.java | 87 final SocketChannel channel = (SocketChannel) super.acceptWithoutRegistration(key);
88 if (channel != null) {
89 final String address = ((InetSocketAddress) channel.socket().getRemoteSocketAddress()).toString();
92 monitoringId, channel.hashCode(), address);
95 return channel;
101 final SocketChannel channel = (SocketChannel) key.channel();
102 final String address = ((InetSocketAddress) channel.socket().getRemoteSocketAddress()).toString();
105 monitoringId, channel.hashCode(), address);
|
| H A D | MonitorableSelectorHandler.java | 99 final SocketChannel channel = (SocketChannel) super.acceptWithoutRegistration(key);
100 if (channel != null) {
101 final String address = ((InetSocketAddress) channel.socket().
105 connectionAcceptedEvent(monitoringId, channel.hashCode(),
109 return channel;
115 final SocketChannel channel = (SocketChannel) key.channel();
116 final String address = ((InetSocketAddress) channel.socket().getRemoteSocketAddress()).toString();
119 monitoringId, channel.hashCode(), address);
|
| H A D | MonitorableSelectionKeyHandler.java | 95 monitoringId, key.channel().hashCode());
|
| /glassfish-3.1.2/common/internal-api/src/main/java/org/glassfish/internal/grizzly/ |
| H A D | LazyServiceInitializer.java | 88 * channel itself. The service can setup connection, its characteristics,
93 * @param channel where the incoming request was accepted.
95 public void handleRequest(SelectableChannel channel); argument
|
| /glassfish-3.1.2/webservices/soap-tcp/src/main/java/org/glassfish/webservices/transport/tcp/ |
| H A D | Connector.java | 82 public void process(ByteBuffer buffer, SocketChannel channel) throws IOException { argument
87 processor.process(buffer, channel);
93 public void notifyConnectionClosed(SocketChannel channel) { argument
94 processor.notifyClosed(channel);
|
| H A D | WSTCPProtocolFilter.java | 95 final SocketChannel channel = (SocketChannel) ctx.getSelectionKey().channel();
96 connector.process(byteBuffer, channel);
118 connector.notifyConnectionClosed((SocketChannel) key.channel());
122 connector.notifyConnectionClosed((SocketChannel) key.channel());
|
| /glassfish-3.1.2/jbi/serviceengine/sun-javaee-engine/src/main/java/com/sun/enterprise/jbi/serviceengine/work/ |
| H A D | OneWork.java | 62 private DeliveryChannel channel = null; field in class:OneWork
70 * Initializes the work. Save a local copy of delivery channel
74 this.channel = JavaEEServiceEngineContext.getInstance().getDeliveryChannel();
143 * Retrieves the delivery channel object.
146 return this.channel;
|
| /glassfish-3.1.2/deployment/dol/src/main/java/com/sun/enterprise/deployment/util/ |
| H A D | AnnotationDetector.java | 156 ReadableByteChannel channel = null;
158 channel = Channels.newChannel(is);
159 if (channel!=null) {
160 result = classFile.containsAnnotation(channel, size);
164 if (channel != null) {
165 channel.close();
|
| /glassfish-3.1.2/core/kernel/src/main/java/com/sun/enterprise/v3/services/impl/ |
| H A D | ServiceInitializerHandler.java | 88 SelectableChannel channel = acceptWithoutRegistration(key);
115 if (channel != null) {
116 targetInitializer.handleRequest(channel);
|
| H A D | GrizzlyUtils.java | 77 return Utils.readWithTemporarySelector(key.channel(),
95 return SSLUtils.doSecureRead(key.channel(), sslEngine, byteBuffer,
|
| /glassfish-3.1.2/orb/orb-connector/src/main/java/org/glassfish/enterprise/iiop/api/ |
| H A D | ORBLazyServiceInitializer.java | 102 public void handleRequest(SelectableChannel channel) { argument
104 orbHelper.getSelectableChannelDelegate().handleRequest(channel);
|
| H A D | GlassFishORBHelper.java | 200 public void handleRequest(SelectableChannel channel); argument
|
| /glassfish-3.1.2/jbi/serviceengine/sun-javaee-engine/src/main/java/com/sun/enterprise/jbi/serviceengine/bridge/transport/ |
| H A D | JAXRPCClientTransport.java | 72 private DeliveryChannel channel; field in class:JAXRPCClientTransport
77 channel = JavaEEServiceEngineContext.getInstance().getDeliveryChannel();
|
| H A D | NMRClientConnection.java | 99 DeliveryChannel channel =
108 channel.createExchangeFactoryForService(service);
|
| /glassfish-3.1.2/web/web-ajp/src/main/java/org/apache/jk/common/ |
| H A D | ChannelNioSocket.java | 174 /** Set the port for the ajp13 channel.
384 log.finest("Accepted socket " + s +" channel " + sc.isBlocking());
560 /* If we disabled the channel return */
575 log.info("Error shutting down the channel " + port + " " +
1040 private SocketChannel channel; field in class:ChannelNioSocket.SocketInputStream
1045 SocketInputStream(SocketChannel channel) { argument
1046 this.channel = channel;
1098 int count = channel.read(buffer);
1196 SocketChannel channel; field in class:ChannelNioSocket.SocketOutputStream
1198 SocketOutputStream(SocketChannel channel) argument
[all...] |
| /glassfish-3.1.2/orb/orb-iiop/src/main/java/org/glassfish/enterprise/iiop/impl/ |
| H A D | PEORBConfigurator.java | 320 public void handleRequest(SelectableChannel channel) { argument
321 SocketChannel sch = (SocketChannel)channel ;
|
| /glassfish-3.1.2/jbi/serviceengine/sun-javaee-engine/src/main/java/com/sun/enterprise/jbi/serviceengine/util/soap/ |
| H A D | MessageExchangeHelper.java | 372 DeliveryChannel channel =
376 channel.createExchangeFactoryForService(serviceName);
|
| /glassfish-3.1.2/web/web-core/src/main/java/org/apache/catalina/connector/ |
| H A D | Request.java | 4281 ((Request)getAttachment()).clientClosedConnection = ((SocketChannel)selectionKey.channel()).
|