Wed, 27 Apr 2016 01:27:09 +0800
Initial load
http://hg.openjdk.java.net/jdk8u/jdk8u/jaxws/
changeset: 657:d47a47f961ee
tag: jdk8u25-b17
1 /*
2 * Copyright (c) 1997, 2012, 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.api.pipe.helper;
28 import com.sun.istack.internal.NotNull;
29 import com.sun.xml.internal.ws.api.message.Packet;
30 import com.sun.xml.internal.ws.api.pipe.Fiber;
31 import com.sun.xml.internal.ws.api.pipe.NextAction;
32 import com.sun.xml.internal.ws.api.pipe.Pipe;
33 import com.sun.xml.internal.ws.api.pipe.PipeCloner;
34 import com.sun.xml.internal.ws.api.pipe.Tube;
35 import com.sun.xml.internal.ws.api.pipe.TubeCloner;
37 /**
38 * {@link Tube} that invokes {@link Pipe}.
39 *
40 * <p>
41 * This can be used to make a {@link Pipe} look like a {@link Tube}.
42 *
43 * @author Kohsuke Kawaguchi
44 * @author Jitendra Kotamraju
45 */
46 public class PipeAdapter extends AbstractTubeImpl {
47 private final Pipe next;
49 public static Tube adapt(Pipe p) {
50 if (p instanceof Tube) {
51 return (Tube) p;
52 } else {
53 return new PipeAdapter(p);
54 }
55 }
57 public static Pipe adapt(Tube p) {
58 if (p instanceof Pipe) {
59 return (Pipe) p;
60 } else {
61 class TubeAdapter extends AbstractPipeImpl {
62 private final Tube t;
64 public TubeAdapter(Tube t) {
65 this.t = t;
66 }
68 private TubeAdapter(TubeAdapter that, PipeCloner cloner) {
69 super(that, cloner);
70 this.t = cloner.copy(that.t);
71 }
73 public Packet process(Packet request) {
74 return Fiber.current().runSync(t,request);
75 }
77 public Pipe copy(PipeCloner cloner) {
78 return new TubeAdapter(this,cloner);
79 }
80 }
82 return new TubeAdapter(p);
83 }
84 }
87 private PipeAdapter(Pipe next) {
88 this.next = next;
89 }
91 /**
92 * Copy constructor
93 */
94 private PipeAdapter(PipeAdapter that, TubeCloner cloner) {
95 super(that,cloner);
96 this.next = ((PipeCloner)cloner).copy(that.next);
97 }
99 /**
100 * Uses the current fiber and runs the whole pipe to the completion
101 * (meaning everything from now on will run synchronously.)
102 */
103 public @NotNull NextAction processRequest(@NotNull Packet p) {
104 return doReturnWith(next.process(p));
105 }
107 public @NotNull NextAction processResponse(@NotNull Packet p) {
108 throw new IllegalStateException();
109 }
111 @NotNull
112 public NextAction processException(@NotNull Throwable t) {
113 throw new IllegalStateException();
114 }
116 public void preDestroy() {
117 next.preDestroy();
118 }
120 public PipeAdapter copy(TubeCloner cloner) {
121 return new PipeAdapter(this,cloner);
122 }
124 public String toString() {
125 return super.toString()+"["+next.toString()+"]";
126 }
127 }