| /openjdk7/corba/src/share/classes/com/sun/corba/se/pept/transport/ |
| H A D | InboundConnectionCache.java | 34 public Connection get(Acceptor acceptor); // REVISIT argument
36 public void put(Acceptor acceptor, Connection connection); argument
|
| H A D | TransportManager.java | 47 public InboundConnectionCache getInboundConnectionCache(Acceptor acceptor); argument
53 public void registerAcceptor(Acceptor acceptor); argument
57 public void unregisterAcceptor(Acceptor acceptor); argument
|
| /openjdk7/jdk/src/share/classes/org/ietf/jgss/ |
| H A D | ChannelBinding.java | 41 * The acceptor must provide an identical binding in order to validate
53 * Conceptually, the GSS-API concatenates the initiator and acceptor
58 * interface. The same bindings are set by the context acceptor for its
83 private InetAddress acceptor; field in class:ChannelBinding
95 * acceptor. <code>null</code> value can be supplied to indicate that
105 acceptor = acceptAddr;
135 * Get the acceptor's address for this channel binding.
137 * @return the acceptor's address. null is returned if the address has
141 return acceptor;
167 * the same values for the initiator and acceptor addresse
[all...] |
| /openjdk7/corba/src/share/classes/com/sun/corba/se/impl/transport/ |
| H A D | CorbaInboundConnectionCacheImpl.java | 57 public CorbaInboundConnectionCacheImpl(ORB orb, Acceptor acceptor) argument
59 super(orb, acceptor.getConnectionCacheType(),
60 ((CorbaAcceptor)acceptor).getMonitoringName());
69 public Connection get(Acceptor acceptor) argument
74 public void put(Acceptor acceptor, Connection connection) argument
77 dprint(".put: " + acceptor + " " + connection);
|
| H A D | DefaultSocketFactoryImpl.java | 91 public void setAcceptedSocketOptions(Acceptor acceptor, argument
|
| H A D | ListenerThreadImpl.java | 46 private Acceptor acceptor; field in class:ListenerThreadImpl
51 public ListenerThreadImpl(ORB orb, Acceptor acceptor, Selector selector) argument
54 this.acceptor = acceptor;
66 return acceptor;
72 dprint(".close: " + acceptor);
89 dprint(".doWork: Start ListenerThread: " + acceptor);
94 dprint(".doWork: BEFORE ACCEPT CYCLE: " + acceptor);
97 acceptor.accept();
100 dprint(".doWork: AFTER ACCEPT CYCLE: " + acceptor);
[all...] |
| H A D | CorbaTransportManagerImpl.java | 125 Acceptor acceptor)
127 synchronized (acceptor) {
128 if (acceptor.getConnectionCache() == null) {
133 acceptor.getConnectionCacheType());
139 acceptor);
141 acceptor.getConnectionCacheType(),
145 acceptor.setConnectionCache(connectionCache);
147 return acceptor.getConnectionCache();
161 public synchronized void registerAcceptor(Acceptor acceptor) argument
164 dprint(".registerAcceptor->: " + acceptor);
124 getInboundConnectionCache( Acceptor acceptor) argument
177 unregisterAcceptor(Acceptor acceptor) argument
[all...] |
| H A D | SocketOrChannelConnectionImpl.java | 119 protected Acceptor acceptor; field in class:SocketOrChannelConnectionImpl
244 Acceptor acceptor,
264 this.acceptor = acceptor;
274 Acceptor acceptor,
277 this(orb, acceptor, socket,
334 } else if (acceptor != null) {
335 messageMediator = acceptor.createMessageMediator(orb, this);
400 } else if (acceptor != null) {
402 acceptor
243 SocketOrChannelConnectionImpl(ORB orb, Acceptor acceptor, Socket socket, boolean useSelectThreadToWait, boolean useWorkerThread) argument
273 SocketOrChannelConnectionImpl(ORB orb, Acceptor acceptor, Socket socket) argument
[all...] |
| /openjdk7/corba/src/share/classes/com/sun/corba/se/spi/transport/ |
| H A D | ORBSocketFactory.java | 52 public void setAcceptedSocketOptions(Acceptor acceptor, argument
|
| /openjdk7/jdk/src/share/classes/sun/rmi/transport/tcp/ |
| H A D | TCPChannel.java | 75 /** connection acceptor (should be in TCPTransport) */
76 private ConnectionAcceptor acceptor; field in class:TCPChannel
403 if (acceptor == null) {
404 acceptor = new ConnectionAcceptor(tr);
405 acceptor.startNewAcceptor();
407 acceptor.accept(conn);
|
| /openjdk7/jdk/test/java/nio/channels/ |
| H A D | AsyncCloseAndInterrupt.java | 63 static ServerSocketChannel acceptor; field in class:AsyncCloseAndInterrupt
66 acceptor = ServerSocketChannel.open();
67 acceptor.socket().bind(wildcardAddress);
73 SocketChannel sc = acceptor.accept();
165 SocketAddress sa = acceptor.socket().getLocalSocketAddress();
|
| /openjdk7/corba/src/share/classes/com/sun/corba/se/impl/orb/ |
| H A D | ParserTable.java | 561 public void setAcceptedSocketOptions(Acceptor acceptor, argument
1032 Acceptor acceptor = null ;
1035 acceptor = (Acceptor)AccessController.doPrivileged(
1052 return acceptor ;
|