import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
/**
 * Creates a new pipeline for the given port name.
 */
private Tube createPipeline(WSPortInfo portInfo, WSBinding binding) {
    //Check all required WSDL extensions are understood
    checkAllWSDLExtensionsUnderstood(portInfo, binding);
    SEIModel seiModel = null;
    Class sei = null;
    if (portInfo instanceof SEIPortInfo) {
            SEIPortInfo sp = (SEIPortInfo) portInfo;
        seiModel = sp.model;
        sei = sp.sei;
    }
    BindingID bindingId = portInfo.getBindingId();

    TubelineAssembler assembler = TubelineAssemblerFactory.create(
            Thread.currentThread().getContextClassLoader(), bindingId, owner.getContainer());
    if (assembler == null) {
        throw new WebServiceException("Unable to process bindingID=" + bindingId); // TODO: i18n
    }
    return assembler.createClient(
            new ClientTubeAssemblerContext(
                    portInfo.getEndpointAddress(),
                    portInfo.getPort(),
                    this, binding, owner.getContainer(), ((BindingImpl) binding).createCodec(), seiModel, sei));
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
/**
 * On Server-side, HandlerChains cannot be changed after it is deployed.
 * During assembling the Pipelines, we can decide if we really need a
 * SOAPHandlerPipe and LogicalHandlerPipe for a particular Endpoint.
 */
public Tube createServer(ServerTubeAssemblerContext context) {
    Tube head = context.getTerminalTube();
    head = context.createValidationTube(head);
    head = context.createHandlerTube(head);
    head = context.createMonitoringTube(head);
    head = context.createServerMUTube(head);
    head = context.createWsaTube(head);
    if (dump) {
        // for debugging inject a dump pipe. this is left in the production code,
        // as it would be very handy for a trouble-shooting at the production site.
        head = context.createDumpTube("server", System.out, head);
    }
    head = context.createSecurityTube(head);
    return head;
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
public static Tube adapt(Pipe p) {
    if (p instanceof Tube) {
        return (Tube) p;
    } else {
        return new PipeAdapter(p);
    }
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
public WsaTube(WSDLPort wsdlPort, WSBinding binding, Tube next) {
    super(next);
    this.wsdlPort = wsdlPort;
    this.binding = binding;
    addKnownHeadersToBinding(binding);
    addressingVersion = binding.getAddressingVersion();
    soapVersion = binding.getSOAPVersion();
    helper = getTubeHelper();
    addressingRequired = AddressingVersion.isRequired(binding);
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
@Deprecated
public static Dispatch<Source> createSourceDispatch(QName port, Mode mode, WSServiceDelegate owner, Tube pipe, BindingImpl binding, WSEndpointReference epr) {
    if(isXMLHttp(binding))
        return new RESTSourceDispatch(port,mode,owner,pipe,binding,epr);
    else
        return new SOAPSourceDispatch(port,mode,owner,pipe,binding,epr);
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
/**
 * Creates a new instance of SOAPHandlerTube
 */
public ServerSOAPHandlerTube(WSBinding binding, WSDLPort port, Tube next) {
    super(next, port, binding);
    if (binding.getSOAPVersion() != null) {
        // SOAPHandlerTube should n't be used for bindings other than SOAP.
        // TODO: throw Exception
    }
    setUpHandlersOnce();
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
public ServerSchemaValidationTube(WSEndpoint endpoint, WSBinding binding,
        SEIModel seiModel, WSDLPort wsdlPort, Tube next) {
    super(binding, next);
    this.seiModel = seiModel;
    this.wsdlPort = wsdlPort;

    if (endpoint.getServiceDefinition() != null) {
        MetadataResolverImpl mdresolver = new MetadataResolverImpl(endpoint.getServiceDefinition());
        Source[] sources = getSchemaSources(endpoint.getServiceDefinition(), mdresolver);
        for(Source source : sources) {
            LOGGER.fine("Constructing service validation schema from = "+source.getSystemId());
            //printDOM((DOMSource)source);
        }
        if (sources.length != 0) {
            noValidation = false;
            sf.setResourceResolver(mdresolver);
            try {
                schema = sf.newSchema(sources);
            } catch(SAXException e) {
                throw new WebServiceException(e);
            }
            validator = schema.newValidator();
            return;
        }
    }
    noValidation = true;
    schema = null;
    validator = null;
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
/**
 * Creates a new instance of SOAPHandlerTube
 */
public ClientSOAPHandlerTube(WSBinding binding, WSDLPort port, Tube next) {
    super(next, port, binding);
    if (binding.getSOAPVersion() != null) {
        // SOAPHandlerTube should n't be used for bindings other than SOAP.
        // TODO: throw Exception
    }
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
public Tube createTube(ClientTubelineAssemblyContext context) throws WebServiceException {
    MessageDumpingFeature messageDumpingFeature = context.getBinding().getFeature(MessageDumpingFeature.class);
    if (messageDumpingFeature != null) {
        return new MessageDumpingTube(context.getTubelineHead(), messageDumpingFeature);
    }

    return context.getTubelineHead();
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
public LoggingDumpTube(Level loggingLevel, Position position, Tube tubelineHead) {
    super(tubelineHead);

    this.position = position;
    this.loggingLevel = loggingLevel;

    this.tubeId = ID_GENERATOR.incrementAndGet();
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
public Tube createTube(ServerTubelineAssemblyContext context) throws WebServiceException {
    MessageDumpingFeature messageDumpingFeature = context.getEndpoint().getBinding().getFeature(MessageDumpingFeature.class);
    if (messageDumpingFeature != null) {
        return new MessageDumpingTube(context.getTubelineHead(), messageDumpingFeature);
    }

    return context.getTubelineHead();
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
@Deprecated
public SEIStub(WSServiceDelegate owner, BindingImpl binding, SOAPSEIModel seiModel, Tube master, WSEndpointReference epr) {
    super(owner, master, binding, seiModel.getPort(), seiModel.getPort().getAddress(), epr);
    this.seiModel = seiModel;
    this.soapVersion = binding.getSOAPVersion();
    databinding = seiModel.getDatabinding();
    initMethodHandlers();
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
@Override
public <T> T getImplementation(Class<T> type) {
    for (Tube tube : tubes) {
        if (type.isInstance(tube)) {
            return type.cast(tube);
        }
    }
    return null;
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
@Override
public Tube decorateClientTail(
        Tube tube,
        ClientTubelineAssemblyContext context) {
    for (TubelineAssemblyDecorator decorator : decorators) {
        tube = decorator.decorateClientTail(tube, context);
    }
    return tube;
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
@Override
public Tube decorateServerTail(
        Tube tube, ServerTubelineAssemblyContext context) {
    for (TubelineAssemblyDecorator decorator : decorators) {
        tube = decorator.decorateServerTail(tube, context);
    }
    return tube;
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
@Override
public Tube decorateClient(Tube tube, ClientTubelineAssemblyContext context) {
    for (TubelineAssemblyDecorator decorator : decorators) {
        tube = decorator.decorateClient(tube, context);
    }
    return tube;
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
public ClientSchemaValidationTube(WSBinding binding, WSDLPort port, Tube next) {
    super(binding, next);
    this.port = port;
    if (port != null) {
        String primaryWsdl = port.getOwner().getParent().getLocation().getSystemId();
        MetadataResolverImpl mdresolver = new MetadataResolverImpl();
        Map<String, SDDocument> docs = MetadataUtil.getMetadataClosure(primaryWsdl, mdresolver, true);
        mdresolver = new MetadataResolverImpl(docs.values());
        Source[] sources = getSchemaSources(docs.values(), mdresolver);
        for(Source source : sources) {
            LOGGER.fine("Constructing client validation schema from = "+source.getSystemId());
            //printDOM((DOMSource)source);
        }
        if (sources.length != 0) {
            noValidation = false;
            sf.setResourceResolver(mdresolver);
            try {
                schema = sf.newSchema(sources);
            } catch(SAXException e) {
                throw new WebServiceException(e);
            }
            validator = schema.newValidator();
            return;
        }
    }
    noValidation = true;
    schema = null;
    validator = null;
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
@Override
protected Tube create() {
    return TubeCloner.clone(master);
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
public ClientMUTube(WSBinding binding, Tube next) {
    super(binding, next);
}
 

import com.sun.xml.internal.ws.api.pipe.Tube; //导入依赖的package包/类
/**
* Send a response to a non-anonymous address. Also closes the transport back channel
* of {@link Packet} if it's not closed already.
*
* @param packet
*      The response from our server, which will be delivered to the destination.
* @return The response packet that should be used to complete the tubeline response processing
*/
   public Packet process(Packet packet) {
   Fiber.CompletionCallback fiberCallback = null;
   Fiber currentFiber = Fiber.getCurrentIfSet();
   if (currentFiber != null) {
       // Link completion of the current fiber to the new fiber that will
       // deliver the async response. This allows access to the response
       // packet that may be generated by sending a new message for the
       // current async response.

           final Fiber.CompletionCallback currentFiberCallback =
               currentFiber.getCompletionCallback();

                   if (currentFiberCallback != null) {
                     fiberCallback = new Fiber.CompletionCallback() {
                     public void onCompletion(@NotNull Packet response) {
                       currentFiberCallback.onCompletion(response);
                     }

                     public void onCompletion(@NotNull Throwable error) {
                       currentFiberCallback.onCompletion(error);
                     }
                   };
                   currentFiber.setCompletionCallback(null);
           }
   }

   // we need to assemble a pipeline to talk to this endpoint.
           WSEndpoint<?> endpoint = packet.endpoint;
           WSBinding binding = endpoint.getBinding();
   Tube transport = TransportTubeFactory.create(Thread.currentThread().getContextClassLoader(),
       new ClientTubeAssemblerContext(
                   packet.endpointAddress, endpoint.getPort(), (WSService) null,
                   binding, endpoint.getContainer(),
                   ((BindingImpl) binding).createCodec(), null, null));
   Fiber fiber = endpoint.getEngine().createFiber();
   fiber.start(transport, packet, fiberCallback);

   // then we'll proceed the rest like one-way.
   Packet copy = packet.copy(false);
   copy.endpointAddress = null;

   return copy;
   }