/glassfish-3.1.2/web/web-ajp/src/main/java/org/apache/jk/core/ |
H A D | JkChannel.java | 82 * @param ep The connection point for this request. 84 public int send(Msg msg, MsgContext ep) throws IOException; argument 89 * @param ep The connection point for this request. 91 public int receive(Msg msg, MsgContext ep) throws IOException; argument 96 public int flush(Msg msg, MsgContext ep) throws IOException; argument 101 public int invoke(Msg msg, MsgContext ep) throws IOException; argument 106 public boolean isSameAddress(MsgContext ep); argument 111 public void registerRequest(Request req, MsgContext ep, int count); argument
|
/glassfish-3.1.2/web/web-ajp/src/main/java/org/apache/jk/common/ |
H A D | ChannelJni.java | 106 public int receive( Msg msg, MsgContext ep ) 109 Msg sentResponse=(Msg)ep.getNote( receivedNote ); 110 ep.setNote( receivedNote, null ); 137 public int send( Msg msg, MsgContext ep ) 140 ep.setNote( receivedNote, null ); 143 int rc=super.nativeDispatch( msg, ep, JK_HANDLE_JNI_DISPATCH, 0); 148 ep.setNote( receivedNote, msg ); 153 public int flush(Msg msg, MsgContext ep) throws IOException { argument 154 ep.setNote( receivedNote, null ); 158 public boolean isSameAddress(MsgContext ep) { argument 162 registerRequest(Request req, MsgContext ep, int count) argument [all...] |
H A D | WorkerDummy.java | 94 public int invoke( Msg in, MsgContext ep ) 97 MsgAjp msg=(MsgAjp)ep.getNote( headersMsgNote ); 100 ep.setNote( headersMsgNote, msg ); 110 ep.setType( JkHandler.HANDLE_SEND_PACKET ); 111 ep.getSource().invoke( msg, ep ); 120 ep.getSource().invoke(msg, ep); 126 ep.getSource().invoke(msg, ep ); [all...] |
H A D | ChannelUn.java | 240 public void registerRequest(Request req, MsgContext ep, int count) { argument 249 ep.setNote(JMXRequestNote, roname); 262 public int open(MsgContext ep) throws IOException { argument 263 // Will associate a jk_endpoint with ep and call open() on it. 266 return super.nativeDispatch( ep.getMsg(0), ep, CH_OPEN, 1 ); 269 public void close(MsgContext ep) throws IOException { argument 270 super.nativeDispatch( ep.getMsg(0), ep, CH_CLOSE, 1 ); 273 public int send( Msg msg, MsgContext ep) argument 297 flush( Msg msg, MsgContext ep) argument 339 processConnection(MsgContext ep) argument 424 MsgContext ep; field in class:AprConnection 426 AprConnection(ChannelUn wajp, MsgContext ep) argument [all...] |
H A D | ChannelSocket.java | 344 public void accept( MsgContext ep ) throws IOException { 356 ep.setNote( socketNote, s ); 374 ep.setNote( isNote, is ); 375 ep.setNote( osNote, os ); 376 ep.setControl( tp ); 499 public void registerRequest(Request req, MsgContext ep, int count) { argument 507 ep.setNote(JMXRequestNote, roname); 516 public void open(MsgContext ep) throws IOException { argument 520 public void close(MsgContext ep) throws IOException { argument 521 Socket s=(Socket)ep 570 send( Msg msg, MsgContext ep) argument 584 flush( Msg msg, MsgContext ep) argument 661 read( MsgContext ep, byte[] b, int offset, int len) argument 727 processConnection(MsgContext ep) argument 825 isSameAddress(MsgContext ep) argument 926 MsgContext ep; field in class:ChannelSocket.SocketConnection 928 SocketConnection(ChannelSocket wajp, MsgContext ep) argument [all...] |
H A D | ChannelNioSocket.java | 369 public void accept( MsgContext ep ) throws IOException { 382 ep.setNote( socketNote, s ); 397 ep.setNote( isNote, is ); 398 ep.setNote( osNote, os ); 399 ep.setControl( tp ); 527 public void registerRequest(Request req, MsgContext ep, int count) { argument 535 ep.setNote(JMXRequestNote, roname); 544 public void open(MsgContext ep) throws IOException { argument 548 public void close(MsgContext ep) throws IOException { argument 549 Socket s=(Socket)ep 581 send( Msg msg, MsgContext ep) argument 595 flush( Msg msg, MsgContext ep) argument 670 read( MsgContext ep, byte[] b, int offset, int len) argument 770 isSameAddress(MsgContext ep) argument 854 MsgContext ep; field in class:ChannelNioSocket.SocketConnection 858 SocketConnection(MsgContext ep) argument 882 processConnection(MsgContext ep) argument 962 unregister(MsgContext ep) argument 982 register(MsgContext ep) argument [all...] |
H A D | JniHandler.java | 286 log.finest("create ep " + epP ); 293 protected void recycleNative(MsgContext ep) { argument 294 apr.jkRecycle(ep.getJniEnv(), ep.getJniContext()); 300 protected int nativeDispatch( Msg msg, MsgContext ep, int code, int raw ) argument 314 long xEnv=ep.getJniEnv(); 315 long nativeContext=ep.getJniContext(); 317 setNativeEndpoint( ep ); 318 xEnv=ep.getJniEnv(); 319 nativeContext=ep [all...] |
H A D | HandlerRequest.java | 283 public int invoke(Msg msg, MsgContext ep ) 290 Object control=ep.getControl(); 291 MessageBytes tmpMB=(MessageBytes)ep.getNote( tmpBufNote ); 294 ep.setNote( tmpBufNote, tmpMB); 306 decodeRequest( msg, ep, tmpMB ); 310 ((Request)ep.getRequest()).unparsedURI()); 316 Response res=ep.getRequest().getResponse(); 319 ep.getRequest().setResponse(res); 328 String epSecret=(String)ep.getNote( secretNote ); 337 int err= next.invoke( msg, ep ); 402 checkRequest(MsgContext ep) argument 418 decodeRequest( Msg msg, MsgContext ep, MessageBytes tmpMB ) argument 480 decodeAttributes( MsgContext ep, Msg msg, Request req, MessageBytes tmpMB) argument 594 decodeHeaders( MsgContext ep, Msg msg, Request req, MessageBytes tmpMB ) argument [all...] |
H A D | HandlerDispatch.java | 122 public int invoke(Msg msg, MsgContext ep ) 126 ep.setType( type ); 140 return handler.invoke( msg, ep );
|
H A D | Shm14.java | 108 public int invoke(Msg msg, MsgContext ep ) 112 log.finest("ChannelShm14.invoke: " + ep );
|
/glassfish-3.1.2/jbi/serviceengine/sun-javaee-engine/src/main/java/com/sun/enterprise/jbi/serviceengine/core/ |
H A D | JBIEndpointManager.java | 158 for (DescriptorEndpointInfo ep : registryManager.getAllConsumerEP(su_Name)) 159 ep.setStarted(true); 161 for (DescriptorEndpointInfo ep : registryManager.getAllProviderEP(su_Name)) { 162 if(registryManager.getSEEndpoint(ep)==null) { 164 WebServiceEndpoint ws_endpoint = registryManager.getWSEndpoint(ep, su_Name); 172 if (endpoint.getServiceName().equals(ep.getServiceName()) && 173 endpointName.equals(ep.getEndpointName())) { 182 ep.getServiceName().getLocalPart(), 184 createEndpoint(ws_endpoint, ep); 187 if (ep 225 createEndpoint(WebServiceEndpoint endpoint, DescriptorEndpointInfo ep) argument 376 getSEEndpoint(DescriptorEndpointInfo ep) argument 382 getWSEndpoint(DescriptorEndpointInfo ep, String appName) argument [all...] |
H A D | EndpointRegistry.java | 145 DescriptorEndpointInfo ep = 147 return ep !=null && ep.isStarted(); 151 DescriptorEndpointInfo ep = 153 return ep !=null && ep.isStarted();
|
/glassfish-3.1.2/connectors/connectors-runtime/src/main/java/com/sun/enterprise/connectors/deployment/annotation/handlers/ |
H A D | ConfigPropertyHandler.java | 120 ConnectorConfigProperty ep = getConfigProperty(defaultValue, firstDesc, ignore, 123 handleConfigPropertyAnnotation(element, desc, ep, m.getDeclaringClass()); 142 ConnectorConfigProperty ep = getConfigProperty(defaultValue,firstDesc, ignore, 145 handleConfigPropertyAnnotation(element, desc, ep, f.getDeclaringClass()); 212 ConnectorConfigProperty ep = new ConnectorConfigProperty(); 215 ep.setDescription(description); 219 ep.setValue(defaultValue); 221 ep.setType(type.getName()); 223 ep.setName(propertyName); 225 if (!ep 237 handleConfigPropertyAnnotation(AnnotationInfo element, ConnectorDescriptor desc, ConnectorConfigProperty ep, Class declaringClass) argument 276 processAdministeredObject(AnnotationInfo element, ConnectorDescriptor desc, ConnectorConfigProperty ep, Class declaringClass) argument 317 handleAdministeredObject(AnnotationInfo element, ConnectorDescriptor desc, ConnectorConfigProperty ep, Class adminObjectClass, Class adminObjectIntf) argument 337 processActivation(AnnotationInfo element, ConnectorDescriptor desc, ConnectorConfigProperty ep, Class declaringClass) argument 390 processConnectionDefinition(AnnotationInfo element, ConnectorDescriptor desc, ConnectorConfigProperty ep, Class declaringClass) argument 431 processConnector(ConnectorDescriptor desc, ConnectorConfigProperty ep, Class declaringClass) argument 589 isConfigDefined(Set configProperties, ConnectorConfigProperty ep) argument [all...] |
/glassfish-3.1.2/admin/rest/src/main/java/org/glassfish/admin/rest/cli/ |
H A D | IsAnonymousUserEnabledCommand.java | 77 Properties ep = new Properties(); 78 ep.put("anonymousUserEnabled", userName != null); 79 report.setExtraProperties(ep); 84 ep.put("anonymousUserName", userName);
|
/glassfish-3.1.2/verifier/verifier-impl/src/main/java/com/sun/enterprise/tools/verifier/tests/connector/ |
H A D | CheckConfigPropertyType.java | 102 EnvironmentProperty ep = (EnvironmentProperty) iterator.next(); 103 String type = ep.getType(); 111 new Object[] {ep.getName()})); 125 new Object[] {ep.getType(), ep.getName()})); 143 new Object[] {ep.getType(), ep.getName()}));
|
H A D | CheckConfigPropertyName.java | 81 EnvironmentProperty ep = (EnvironmentProperty) iterator.next(); 82 if (hs.add(ep.getName())==false) { 90 new Object[] {ep.getName()}));
|
/glassfish-3.1.2/verifier/verifier-impl/src/main/java/com/sun/enterprise/tools/verifier/tests/connector/managed/ |
H A D | ManagedConnectionFactoryProperties.java | 124 EnvironmentProperty ep = (EnvironmentProperty) propIterator.next(); 127 String propertyName = Character.toUpperCase(ep.getName().charAt(0)) + ep.getName().substring(1); 129 Class[] parmTypes = new Class[] { ep.getValueType() }; 138 new Object[] { m, ep.getName()})); 148 new Object[] { "public void "+ setMethodName+"("+ep.getValueType().getName()+")", 150 ep.getName()})); 161 new Object[] { m, ep.getName()})); 171 new Object[] { "public " + ep.getValueType().getName() + " " + getMethodName, 173 ep [all...] |
/glassfish-3.1.2/web/web-ajp/src/main/java/org/apache/jk/apr/ |
H A D | AprImpl.java | 212 MsgContext ep=jkH.createMsgContext(); 214 ep.setSource( jkH ); 216 ep.setJniContext( cContext ); 217 return ep; 228 MsgContext ep=(MsgContext)ctx; 229 ep.setJniEnv( jContext ); 230 ep.setType( 0 );
|
/glassfish-3.1.2/connectors/connectors-runtime/src/main/java/com/sun/enterprise/resource/deployer/ |
H A D | ConnectorConnectionPoolDeployer.java | 499 ConnectorConfigProperty ep = new ConnectorConfigProperty( 501 if (defaultMCFProps.contains(ep)) { 502 mergedSet.remove(ep); 504 mergedSet.add(ep); 527 for (Property ep : elemProps) { 528 if (ep != null) { 529 if ("MATCHCONNECTIONS".equals(ep.getName().toUpperCase())) { 533 ccp.setMatchConnections(toBoolean(ep.getValue(), true)); 534 } else if ("LAZYCONNECTIONASSOCIATION".equals(ep.getName().toUpperCase())) { 535 ConnectionPoolObjectsUtils.setLazyEnlistAndLazyAssocProperties(ep [all...] |
/glassfish-3.1.2/web/web-ajp/src/main/java/org/apache/jk/server/ |
H A D | JkCoyoteHandler.java | 216 public int invoke( Msg msg, MsgContext ep ) 218 if( ep.isLogTimeEnabled() ) 219 ep.setLong( MsgContext.TIMER_PRE_REQUEST, System.currentTimeMillis()); 221 Request req=ep.getRequest(); 227 res.setNote( epNote, ep ); 228 ep.setStatus( MsgContext.JK_STATUS_HEAD ); 236 if(ep.getStatus() != MsgContext.JK_STATUS_CLOSED) { 243 ep.recycle(); 244 if( ep.getStatus() == MsgContext.JK_STATUS_ERROR ) { 247 ep [all...] |
/glassfish-3.1.2/verifier/verifier-impl/src/main/java/com/sun/enterprise/tools/verifier/tests/web/ |
H A D | ParamName.java | 70 EnvironmentProperty ep; 78 ep = (EnvironmentProperty)en.nextElement(); 79 epName = ep.getName();
|
H A D | ParamValue.java | 70 EnvironmentProperty ep; 82 ep = (EnvironmentProperty)itr.next(); 83 epValue = ep.getValue();
|
H A D | ServletParamValue.java | 73 EnvironmentProperty ep = null; 88 ep = (EnvironmentProperty)en.nextElement(); 89 epValue = ep.getValue();
|
/glassfish-3.1.2/connectors/connectors-runtime/src/main/java/com/sun/enterprise/connectors/util/ |
H A D | ConnectorDDTransformUtils.java | 137 ConnectorConfigProperty ep = new ConnectorConfigProperty ( 139 if (defaultMCFProps.contains(ep)) { 145 //and if they are equal, set ep's type to envProp's type 151 if (envProp.equals(ep)) { 153 ep.setType(envProp.getType()); 161 + ep.getName() + " envPropValue : " + ep.getValue()); 163 mergedSet.remove(ep); 165 mergedSet.add(ep);
|
/glassfish-3.1.2/webservices/jsr109-impl/src/main/java/org/glassfish/webservices/ |
H A D | ServerPipeCreator.java | 71 public void init(WebServiceEndpoint ep){ argument 72 endpoint = ep;
|