jdk8-mips64-public/jaxws: src/share/jaxws_classes/com/sun/xml/internal/ws/db/DatabindingImpl.java@9c07ef4934dd

     1 /*

     2  * Copyright (c) 1997, 2013, Oracle and/or its affiliates. All rights reserved.

     3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.

     4  *

     5  * This code is free software; you can redistribute it and/or modify it

     6  * under the terms of the GNU General Public License version 2 only, as

     7  * published by the Free Software Foundation.  Oracle designates this

     8  * particular file as subject to the "Classpath" exception as provided

     9  * by Oracle in the LICENSE file that accompanied this code.

    10  *

    11  * This code is distributed in the hope that it will be useful, but WITHOUT

    12  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or

    13  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License

    14  * version 2 for more details (a copy is included in the LICENSE file that

    15  * accompanied this code).

    16  *

    17  * You should have received a copy of the GNU General Public License version

    18  * 2 along with this work; if not, write to the Free Software Foundation,

    19  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.

    20  *

    21  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA

    22  * or visit www.oracle.com if you need additional information or have any

    23  * questions.

    24  */

    26 package com.sun.xml.internal.ws.db;

    28 import java.io.IOException;

    29 import java.io.InputStream;

    30 import java.io.OutputStream;

    31 import java.lang.reflect.Method;

    32 import java.util.HashMap;

    33 import java.util.Map;

    35 import javax.xml.ws.WebServiceFeature;

    37 import com.oracle.webservices.internal.api.databinding.JavaCallInfo;

    38 import com.oracle.webservices.internal.api.message.MessageContext;

    39 import com.sun.xml.internal.ws.api.databinding.EndpointCallBridge;

    40 import com.sun.xml.internal.ws.api.databinding.WSDLGenInfo;

    41 import com.sun.xml.internal.ws.api.databinding.Databinding;

    42 import com.sun.xml.internal.ws.api.databinding.DatabindingConfig;

    43 import com.sun.xml.internal.ws.api.databinding.ClientCallBridge;

    44 import com.sun.xml.internal.ws.api.message.Message;

    45 import com.sun.xml.internal.ws.api.message.MessageContextFactory;

    46 import com.sun.xml.internal.ws.api.message.Packet;

    47 import com.sun.xml.internal.ws.api.model.MEP;

    48 import com.sun.xml.internal.ws.api.model.SEIModel;

    49 import com.sun.xml.internal.ws.api.model.WSDLOperationMapping;

    50 import com.sun.xml.internal.ws.api.model.wsdl.WSDLPort;

    51 import com.sun.xml.internal.ws.api.pipe.Codec;

    52 import com.sun.xml.internal.ws.api.pipe.ContentType;

    53 import com.sun.xml.internal.ws.binding.BindingImpl;

    54 import com.sun.xml.internal.ws.client.sei.StubAsyncHandler;

    55 import com.sun.xml.internal.ws.client.sei.StubHandler;

    56 import com.sun.xml.internal.ws.model.AbstractSEIModelImpl;

    57 import com.sun.xml.internal.ws.model.JavaMethodImpl;

    58 import com.sun.xml.internal.ws.model.RuntimeModeler;

    59 import com.sun.xml.internal.ws.server.sei.TieHandler;

    60 import com.sun.xml.internal.ws.wsdl.ActionBasedOperationSignature;

    61 import com.sun.xml.internal.ws.wsdl.DispatchException;

    62 import com.sun.xml.internal.ws.wsdl.OperationDispatcher;

    64 /**

    65  * WsRuntimeImpl is the databinding processor built on SEIModel

    66  *

    67  * @author shih-chang.chen@oracle.com

    68  */

    69 public final class DatabindingImpl implements Databinding {

    71     AbstractSEIModelImpl seiModel;

    72     Map<Method, StubHandler> stubHandlers;

    73 //    QNameMap<TieHandler> wsdlOpMap = new QNameMap<TieHandler>();

    74     Map<JavaMethodImpl, TieHandler> wsdlOpMap = new HashMap<JavaMethodImpl, TieHandler>();

    75     Map<Method, TieHandler> tieHandlers = new HashMap<Method, TieHandler>();

    76     OperationDispatcher operationDispatcher;

    77     OperationDispatcher operationDispatcherNoWsdl;

    78     boolean clientConfig = false;

    79     Codec codec;

    80     MessageContextFactory packetFactory = null;

    82     public DatabindingImpl(DatabindingProviderImpl p, DatabindingConfig config) {

    83         RuntimeModeler modeler = new RuntimeModeler(config);

    84         modeler.setClassLoader(config.getClassLoader());

    85         seiModel = modeler.buildRuntimeModel();

    86         WSDLPort wsdlport = config.getWsdlPort();

    87         packetFactory = new MessageContextFactory(seiModel.getWSBinding().getFeatures());

    88         clientConfig = isClientConfig(config);

    89         if (clientConfig) {

    90             initStubHandlers();

    91         }

    92         seiModel.setDatabinding(this);

    93         if (wsdlport != null) {

    94             freeze(wsdlport);

    95         }

    96         if (operationDispatcher == null) {

    97             operationDispatcherNoWsdl = new OperationDispatcher(null, seiModel.getWSBinding(), seiModel);

    98         }

    99 //    if(!clientConfig) {

   100         for (JavaMethodImpl jm : seiModel.getJavaMethods()) {

   101             if (!jm.isAsync()) {

   102                 TieHandler th = new TieHandler(jm, seiModel.getWSBinding(), packetFactory);

   103                 wsdlOpMap.put(jm, th);

   104                 tieHandlers.put(th.getMethod(), th);

   105             }

   106         }

   107 //    }

   108     }

   110     //TODO isClientConfig

   111     private boolean isClientConfig(DatabindingConfig config) {

   112         if (config.getContractClass() == null) {

   113             return false;

   114         }

   115         if (!config.getContractClass().isInterface()) {

   116             return false;

   117         }

   118         return (config.getEndpointClass() == null || config.getEndpointClass().isInterface());

   119     }

   120     //TODO fix freeze

   122     public void freeze(WSDLPort port) {

   123         if (clientConfig) {

   124             return;

   125         }

   126         synchronized(this) {

   127             if (operationDispatcher == null) {

   128                 operationDispatcher = (port == null) ? null : new OperationDispatcher(port, seiModel.getWSBinding(), seiModel);

   129             }

   130         }

   131     }

   133     public SEIModel getModel() {

   134         return seiModel;

   135     }

   136 //Refactored from SEIStub

   138     private void initStubHandlers() {

   139         stubHandlers = new HashMap<Method, StubHandler>();

   140         Map<ActionBasedOperationSignature, JavaMethodImpl> syncs = new HashMap<ActionBasedOperationSignature, JavaMethodImpl>();

   141         // fill in methodHandlers.

   142         // first fill in sychronized versions

   143         for (JavaMethodImpl m : seiModel.getJavaMethods()) {

   144             if (!m.getMEP().isAsync) {

   145                 StubHandler handler = new StubHandler(m, packetFactory);

   146                 syncs.put(m.getOperationSignature(), m);

   147                 stubHandlers.put(m.getMethod(), handler);

   148             }

   149         }

   150         for (JavaMethodImpl jm : seiModel.getJavaMethods()) {

   151             JavaMethodImpl sync = syncs.get(jm.getOperationSignature());

   152             if (jm.getMEP() == MEP.ASYNC_CALLBACK || jm.getMEP() == MEP.ASYNC_POLL) {

   153                 Method m = jm.getMethod();

   154                 StubAsyncHandler handler = new StubAsyncHandler(jm, sync, packetFactory);

   155                 stubHandlers.put(m, handler);

   156             }

   157         }

   158     }

   160     JavaMethodImpl resolveJavaMethod(Packet req) throws DispatchException {

   161         WSDLOperationMapping m = req.getWSDLOperationMapping();

   162         if (m == null) {

   163             synchronized (this) {

   164                 m = (operationDispatcher != null)

   165                         ? operationDispatcher.getWSDLOperationMapping(req)

   166                         : operationDispatcherNoWsdl.getWSDLOperationMapping(req);

   167             }

   168         }

   169         return (JavaMethodImpl) m.getJavaMethod();

   170     }

   172     public JavaCallInfo deserializeRequest(Packet req) {

   173         com.sun.xml.internal.ws.api.databinding.JavaCallInfo call = new com.sun.xml.internal.ws.api.databinding.JavaCallInfo();

   174         try {

   175             JavaMethodImpl wsdlOp = resolveJavaMethod(req);

   176             TieHandler tie = wsdlOpMap.get(wsdlOp);

   177             call.setMethod(tie.getMethod());

   178             Object[] args = tie.readRequest(req.getMessage());

   179             call.setParameters(args);

   180         } catch (DispatchException e) {

   181             call.setException(e);

   182         }

   183         return call;

   184     }

   186     public JavaCallInfo deserializeResponse(Packet res, JavaCallInfo call) {

   187         StubHandler stubHandler = stubHandlers.get(call.getMethod());

   188         try {

   189             return stubHandler.readResponse(res, call);

   190         } catch (Throwable e) {

   191             call.setException(e);

   192             return call;

   193         }

   194     }

   196     public WebServiceFeature[] getFeatures() {

   197         // TODO Auto-generated method stub

   198         return null;

   199     }

   201     @Override

   202     public Packet serializeRequest(JavaCallInfo call) {

   203         StubHandler stubHandler = stubHandlers.get(call.getMethod());

   204         Packet p = stubHandler.createRequestPacket(call);

   205         p.setState(Packet.State.ClientRequest);

   206         return p;

   207     }

   209     @Override

   210     public Packet serializeResponse(JavaCallInfo call) {

   211         Method method = call.getMethod();

   212         Message message = null;

   213         if (method != null) {

   214             TieHandler th = tieHandlers.get(method);

   215             if (th != null) {

   216                 return th.serializeResponse(call);

   217             }

   218         }

   219         if (call.getException() instanceof DispatchException) {

   220             message = ((DispatchException) call.getException()).fault;

   221         }

   222         Packet p = (Packet) packetFactory.createContext(message);

   223         p.setState(Packet.State.ServerResponse);

   224         return p;

   225     }

   227     @Override

   228     public ClientCallBridge getClientBridge(Method method) {

   229         return stubHandlers.get(method);

   230     }

   232     @Override

   233     public void generateWSDL(WSDLGenInfo info) {

   234         com.sun.xml.internal.ws.wsdl.writer.WSDLGenerator wsdlGen = new com.sun.xml.internal.ws.wsdl.writer.WSDLGenerator(

   235                 seiModel,

   236                 info.getWsdlResolver(),

   237                 seiModel.getWSBinding(),

   238                 info.getContainer(), seiModel.getEndpointClass(),

   239                 info.isInlineSchemas(),

   240                 info.isSecureXmlProcessingDisabled(),

   241                 info.getExtensions());

   242         wsdlGen.doGeneration();

   243     }

   245     @Override

   246     public EndpointCallBridge getEndpointBridge(Packet req) throws DispatchException {

   247         JavaMethodImpl wsdlOp = resolveJavaMethod(req);

   248         return wsdlOpMap.get(wsdlOp);

   249     }

   251     Codec getCodec() {

   252         if (codec == null) {

   253             codec = ((BindingImpl) seiModel.getWSBinding()).createCodec();

   254         }

   255         return codec;

   256     }

   258     @Override

   259     public ContentType encode(Packet packet, OutputStream out) throws IOException {

   260         return getCodec().encode(packet, out);

   261     }

   263     @Override

   264     public void decode(InputStream in, String ct, Packet p) throws IOException {

   265         getCodec().decode(in, ct, p);

   266     }

   268     @Override

   269     public com.oracle.webservices.internal.api.databinding.JavaCallInfo createJavaCallInfo(Method method, Object[] args) {

   270         return new com.sun.xml.internal.ws.api.databinding.JavaCallInfo(method, args);

   271     }

   273     @Override

   274     public com.oracle.webservices.internal.api.databinding.JavaCallInfo deserializeResponse(

   275             MessageContext message, com.oracle.webservices.internal.api.databinding.JavaCallInfo call) {

   276         return deserializeResponse((Packet) message, (JavaCallInfo) call);

   277     }

   279     @Override

   280     public com.oracle.webservices.internal.api.databinding.JavaCallInfo deserializeRequest(MessageContext message) {

   281         return deserializeRequest((Packet) message);

   282     }

   284     @Override

   285     public MessageContextFactory getMessageContextFactory() {

   286         return packetFactory;

   287     }

   288 }

Mercurial > jdk8-mips64-public > jaxws / file revision

src/share/jaxws_classes/com/sun/xml/internal/ws/db/DatabindingImpl.java@9c07ef4934dd

src/share/jaxws_classes/com/sun/xml/internal/ws/db/DatabindingImpl.java