Searched refs:ep (Results 1 - 25 of 51) sorted by relevance

123

/glassfish-3.1.2/web/web-ajp/src/main/java/org/apache/jk/core/
H A DJkChannel.java82 * @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 DChannelJni.java106 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 DWorkerDummy.java94 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 DChannelUn.java240 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 DChannelSocket.java344 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 DChannelNioSocket.java369 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 DJniHandler.java286 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 DHandlerRequest.java283 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 DHandlerDispatch.java122 public int invoke(Msg msg, MsgContext ep )
126 ep.setType( type );
140 return handler.invoke( msg, ep );
H A DShm14.java108 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 DJBIEndpointManager.java158 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 DEndpointRegistry.java145 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 DConfigPropertyHandler.java120 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 DIsAnonymousUserEnabledCommand.java77 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 DCheckConfigPropertyType.java102 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 DCheckConfigPropertyName.java81 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 DManagedConnectionFactoryProperties.java124 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 DAprImpl.java212 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 DConnectorConnectionPoolDeployer.java499 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 DJkCoyoteHandler.java216 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 DParamName.java70 EnvironmentProperty ep;
78 ep = (EnvironmentProperty)en.nextElement();
79 epName = ep.getName();
H A DParamValue.java70 EnvironmentProperty ep;
82 ep = (EnvironmentProperty)itr.next();
83 epValue = ep.getValue();
H A DServletParamValue.java73 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 DConnectorDDTransformUtils.java137 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 DServerPipeCreator.java71 public void init(WebServiceEndpoint ep){ argument
72 endpoint = ep;

Completed in 86 milliseconds

123