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 */
25
26package com.sun.xml.internal.ws.api.pipe.helper;
27
28import com.sun.istack.internal.NotNull;
29import com.sun.xml.internal.ws.api.message.Packet;
30import com.sun.xml.internal.ws.api.pipe.Fiber;
31import com.sun.xml.internal.ws.api.pipe.NextAction;
32import com.sun.xml.internal.ws.api.pipe.Pipe;
33import com.sun.xml.internal.ws.api.pipe.PipeCloner;
34import com.sun.xml.internal.ws.api.pipe.Tube;
35import com.sun.xml.internal.ws.api.pipe.TubeCloner;
36
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 */
46public class PipeAdapter extends AbstractTubeImpl {
47    private final Pipe next;
48
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    }
56
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;
63
64                public TubeAdapter(Tube t) {
65                    this.t = t;
66                }
67
68                private TubeAdapter(TubeAdapter that, PipeCloner cloner) {
69                    super(that, cloner);
70                    this.t = cloner.copy(that.t);
71                }
72
73                public Packet process(Packet request) {
74                    return Fiber.current().runSync(t,request);
75                }
76
77                public Pipe copy(PipeCloner cloner) {
78                    return new TubeAdapter(this,cloner);
79                }
80            }
81
82            return new TubeAdapter(p);
83        }
84    }
85
86
87    private PipeAdapter(Pipe next) {
88        this.next = next;
89    }
90
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    }
98
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    }
106
107    public @NotNull NextAction processResponse(@NotNull Packet p) {
108        throw new IllegalStateException();
109    }
110
111    @NotNull
112    public NextAction processException(@NotNull Throwable t) {
113        throw new IllegalStateException();
114    }
115
116    public void preDestroy() {
117        next.preDestroy();
118    }
119
120    public PipeAdapter copy(TubeCloner cloner) {
121        return new PipeAdapter(this,cloner);
122    }
123
124    public String toString() {
125        return super.toString()+"["+next.toString()+"]";
126    }
127}
128