Searched defs:connection (Results 26 - 50 of 67) sorted by relevance

123

/openjdk7/hotspot/src/share/tools/IdealGraphVisualizer/HierarchicalLayout/src/com/sun/hotspot/igv/hierarchicallayout/
H A DClusterOutgoingConnection.java40 private Link connection; field in class:ClusterOutgoingConnection
46 this.connection = c;
/openjdk7/corba/src/share/classes/com/sun/corba/se/impl/encoding/
H A DCachedCodeBase.java37 * Provides the reading side with a per connection cache of
73 public CachedCodeBase(CorbaConnection connection) { argument
74 conn = connection;
155 // Ensures that we've used the connection's IOR to create
162 // The delegate was null, so see if the connection's
173 conn.dprint("CodeBase unavailable on connection: " + conn);
185 // Do we have a reference initialized by another connection?
H A DCDROutputObject.java72 private CorbaConnection connection; field in class:CDROutputObject
137 CorbaConnection connection, Message header,
150 this.connection = connection ;
171 public void writeTo(CorbaConnection connection) argument
185 dprint(".writeTo: " + connection);
192 connection.write(bbwi.byteBuffer);
207 if (connection != null) {
208 return connection;
228 * negotiated code sets from the connection
135 CDROutputObject(ORB orb, CorbaMessageMediator mediator, GIOPVersion giopVersion, CorbaConnection connection, Message header, byte streamFormatVersion) argument
[all...]
/openjdk7/corba/src/share/classes/com/sun/corba/se/impl/legacy/connection/
H A DEndPointInfoImpl.java26 package com.sun.corba.se.impl.legacy.connection;
28 import com.sun.corba.se.spi.legacy.connection.LegacyServerSocketEndPointInfo;
H A DLegacyServerSocketManagerImpl.java26 package com.sun.corba.se.impl.legacy.connection;
48 import com.sun.corba.se.spi.legacy.connection.LegacyServerSocketEndPointInfo;
49 import com.sun.corba.se.spi.legacy.connection.LegacyServerSocketManager;
54 import com.sun.corba.se.impl.legacy.connection.SocketFactoryAcceptorImpl;
55 import com.sun.corba.se.impl.legacy.connection.USLPort;
/openjdk7/corba/src/share/classes/com/sun/corba/se/impl/transport/
H A DReaderThreadImpl.java45 private Connection connection; field in class:ReaderThreadImpl
51 Connection connection, Selector selector)
54 this.connection = connection;
66 return connection;
72 dprint(".close: " + connection);
88 dprint(".doWork: Start ReaderThread: " + connection);
95 + connection);
98 if (connection.read()) {
105 + connection);
50 ReaderThreadImpl(ORB orb, Connection connection, Selector selector) argument
[all...]
H A DCorbaContactInfoBase.java106 // Note: not all derived classes will use a connection cache.
121 Connection connection,
134 connection,
138 ((CorbaConnection)connection).getNextRequestId(),
146 // Called when connection handling a read event.
150 CorbaConnection connection = (CorbaConnection) conn;
153 if (connection.shouldReadGiopHeaderOnly()) {
155 ".createMessageMediator: waiting for message header on connection: "
156 + connection);
159 ".createMessageMediator: waiting for message on connection
119 createMessageMediator(Broker broker, ContactInfo contactInfo, Connection connection, String methodName, boolean isOneWay) argument
[all...]
H A DCorbaResponseWaitingRoomImpl.java72 private CorbaConnection connection; field in class:CorbaResponseWaitingRoomImpl
76 public CorbaResponseWaitingRoomImpl(ORB orb, CorbaConnection connection) argument
81 this.connection = connection;
H A DSharedCDRContactInfoImpl.java106 Connection connection,
110 if (connection != null) {
112 throw new RuntimeException("connection is not null");
104 createMessageMediator(Broker broker, ContactInfo contactInfo, Connection connection, String methodName, boolean isOneWay) argument
H A DSocketOrChannelAcceptorImpl.java74 import com.sun.corba.se.spi.legacy.connection.LegacyServerSocketEndPointInfo;
246 CorbaConnection connection =
249 dprint(".accept: new: " + connection);
252 // NOTE: The connection MUST be put in the cache BEFORE being
254 // are read on the connection it will attempt a time stamp
256 getConnectionCache().put(this, connection);
258 if (connection.shouldRegisterServerReadEvent()) {
260 selector.registerForEvent(connection.getEventHandler());
501 Connection connection)
506 return contactInfo.createMessageMediator(broker, connection);
500 createMessageMediator(Broker broker, Connection connection) argument
510 finishCreatingMessageMediator(Broker broker, Connection connection, MessageMediator messageMediator) argument
[all...]
/openjdk7/corba/src/share/classes/com/sun/corba/se/pept/transport/
H A DContactInfo.java169 Connection connection,
184 Connection connection);
197 Connection connection,
167 createMessageMediator(Broker broker, ContactInfo contactInfo, Connection connection, String methodName, boolean isOneWay) argument
183 createMessageMediator(Broker broker, Connection connection) argument
196 finishCreatingMessageMediator(Broker broker, Connection connection, MessageMediator messageMediator) argument
/openjdk7/jdk/src/share/classes/javax/management/
H A DJMX.java149 * boolean) newMBeanProxy(connection, objectName, interfaceClass,
152 * @param connection the MBean server to forward to.
154 * {@code connection} to forward to.
164 public static <T> T newMBeanProxy(MBeanServerConnection connection, argument
167 return newMBeanProxy(connection, objectName, interfaceClass, false);
189 * @param connection the MBean server to forward to.
191 * {@code connection} to forward to.
196 * via {@code connection}.
204 public static <T> T newMBeanProxy(MBeanServerConnection connection, argument
208 return createProxy(connection, objectNam
302 newMXBeanProxy(MBeanServerConnection connection, ObjectName objectName, Class<T> interfaceClass) argument
342 newMXBeanProxy(MBeanServerConnection connection, ObjectName objectName, Class<T> interfaceClass, boolean notificationEmitter) argument
386 createProxy(MBeanServerConnection connection, ObjectName objectName, Class<T> interfaceClass, boolean notificationEmitter, boolean isMXBean) argument
[all...]
H A DMBeanServerInvocationHandler.java102 * to {@code new MBeanServerInvocationHandler(connection,
105 * @param connection the MBean server connection through which all
111 public MBeanServerInvocationHandler(MBeanServerConnection connection, argument
114 this(connection, objectName, false);
126 * @param connection the MBean server connection through which all
138 public MBeanServerInvocationHandler(MBeanServerConnection connection, argument
141 if (connection == null) {
142 throw new IllegalArgumentException("Null connection");
230 newProxyInstance(MBeanServerConnection connection, ObjectName objectName, Class<T> interfaceClass, boolean notificationBroadcaster) argument
481 private final MBeanServerConnection connection; field in class:MBeanServerInvocationHandler
[all...]
/openjdk7/hotspot/src/share/tools/IdealGraphVisualizer/NetworkConnection/src/com/sun/hotspot/igv/connection/
H A DServer.java25 package com.sun.hotspot.igv.connection;
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/api/server/
H A DAbstractServerAsyncTransport.java64 * @param connection that carries the web service request
69 protected Packet decodePacket(T connection, @NotNull Codec codec) throws IOException { argument
71 packet.acceptableMimeTypes = getAcceptableMimeTypes(connection);
72 packet.addSatellite(getPropertySet(connection));
73 packet.transportBackChannel = getTransportBackChannel(connection);
78 * Encodes the {@link Packet} to infoset and writes on the connection.
80 * @param connection that carries the web service request
85 protected abstract void encodePacket(T connection, @NotNull Packet packet, @NotNull Codec codec) throws IOException; argument
90 * @param connection that carries the web service request
93 protected abstract @Nullable String getAcceptableMimeTypes(T connection); argument
103 getTransportBackChannel(T connection) argument
112 getPropertySet(T connection) argument
120 getWebServiceContextDelegate(T connection) argument
130 handle(final T connection) argument
[all...]
/openjdk7/jdk/src/share/demo/jfc/TableExample/
H A DJDBCAdapter.java62 Connection connection; field in class:JDBCAdapter
73 System.out.println("Opening db connection");
75 connection = DriverManager.getConnection(url, user, passwd);
76 statement = connection.createStatement();
87 if (connection == null || statement == null) {
98 // Then we can close the connection.
122 System.out.println("Closing db connection");
125 connection.close();
/openjdk7/jdk/src/share/classes/sun/net/www/protocol/gopher/
H A DGopherClient.java86 sun.net.www.URLConnection connection; field in class:GopherClient
88 GopherClient(sun.net.www.URLConnection connection) { argument
89 this.connection = connection;
168 connection.setProperties(msgh);
/openjdk7/jdk/src/share/classes/java/lang/management/
H A DManagementFactory.java551 * @param connection the <tt>MBeanServerConnection</tt> to forward to.
553 * <tt>connection</tt> to forward to. <tt>mxbeanName</tt> must be
562 * <li>the named MXBean in the <tt>connection</tt> is
574 newPlatformMXBeanProxy(MBeanServerConnection connection, argument
597 if (!connection.isInstanceOf(objName, intfName)) {
604 boolean emitter = connection.isInstanceOf(objName, NOTIF_EMITTER);
607 return JMX.newMXBeanProxy(connection, objName, mxbeanInterface,
696 * getPlatformMXBeans(connection, mxbeanInterface)}.get(0);
699 * @param connection the {@code MBeanServerConnection} to forward to.
719 T getPlatformMXBean(MBeanServerConnection connection, argument
761 getPlatformMXBeans(MBeanServerConnection connection, Class<T> mxbeanInterface) argument
[all...]
/openjdk7/jdk/src/share/classes/com/sun/tools/jdi/
H A DAbstractLauncher.java137 return manager.createVirtualMachine(helper.connection(),
154 private Connection connection = null; field in class:AbstractLauncher.Helper
185 while ((connection == null) &&
211 Connection connection() { method in class:AbstractLauncher.Helper
212 return connection;
220 synchronized void notifyOfConnection(Connection connection) { argument
221 this.connection = connection;
252 "connection acceptor") {
255 Connection connection
[all...]
H A DTargetVM.java41 private Connection connection; field in class:TargetVM
53 TargetVM(VirtualMachineImpl vm, Connection connection) { argument
55 this.connection = connection;
118 byte b[] = connection.readPacket();
130 connection.close();
291 connection.writePacket(packet.toByteArray());
322 connection.close();
H A DVirtualMachineManagerImpl.java222 Connection connection,
225 if (!connection.isOpen()) {
226 throw new IllegalStateException("connection is not open");
231 vm = new VirtualMachineImpl(this, connection, process,
240 public VirtualMachine createVirtualMachine(Connection connection) throws IOException { argument
241 return createVirtualMachine(connection, null);
221 createVirtualMachine( Connection connection, Process process) argument
/openjdk7/hotspot/src/share/tools/IdealGraphVisualizer/View/src/com/sun/hotspot/igv/view/widgets/
H A DDiagramConnectionWidget.java59 private Connection connection; field in class:DiagramConnectionWidget
71 public DiagramConnectionWidget(Connection connection, Scene scene) { argument
73 this.connection = connection;
74 color = connection.getColor();
75 if (connection.getStyle() == Connection.ConnectionStyle.DASHED) {
77 } else if (connection.getStyle() == Connection.ConnectionStyle.BOLD) {
88 return connection;
92 List<Point> newControlPoints = connection.getControlPoints();
93 Connection c = connection;
[all...]
/openjdk7/jdk/src/share/native/com/sun/tools/jdi/
H A DSharedMemoryConnection.c239 SharedMemoryConnection *connection = ID_TO_CONNECTION(id); local
240 shmemBase_closeConnection(connection);
251 SharedMemoryConnection *connection = ID_TO_CONNECTION(id); local
255 rc = shmemBase_receiveByte(connection, &b);
271 SharedMemoryConnection *connection = ID_TO_CONNECTION(id); local
275 rc = shmemBase_receivePacket(connection, &packet);
296 SharedMemoryConnection *connection = ID_TO_CONNECTION(id); local
299 rc = shmemBase_sendByte(connection, b);
313 SharedMemoryConnection *connection = ID_TO_CONNECTION(id); local
322 rc = shmemBase_sendPacket(connection,
[all...]
H A DSharedMemoryTransport.c82 SharedMemoryConnection *connection = NULL; local
86 rc = shmemBase_accept(transport, (long)timeout, &connection);
96 return CONNECTION_TO_ID(connection);
107 SharedMemoryConnection *connection = NULL; local
113 return CONNECTION_TO_ID(connection);
116 return CONNECTION_TO_ID(connection);
119 rc = shmemBase_attach(addrChars, (long)timeout, &connection);
126 return CONNECTION_TO_ID(connection);
/openjdk7/jdk/src/share/classes/com/sun/tools/example/debug/tty/
H A DEnv.java49 private static VMConnection connection; field in class:Env
61 connection = new VMConnection(connectSpec, flags);
62 if (!connection.isLaunch() || openNow) {
63 connection.open();
67 static VMConnection connection() { method in class:Env
68 return connection;
72 return connection.vm();
80 if (connection != null) {
82 connection.disposeVM();

Completed in 138 milliseconds

123