/openjdk7/jdk/src/share/sample/nio/chatserver/ |
H A D | DataReader.java | 44 void beforeRead(Client client); argument 45 void onData(Client client, ByteBuffer buffer, int bytes); argument
|
H A D | ClientReader.java | 62 * read on the client. Handles closed channels and errors while reading. 63 * If the client is still connected a new round of actions are called. 65 public void run(final Client client) { argument 66 callback.beforeRead(client); 67 client.read(new CompletionHandler<Integer, ByteBuffer>() { 72 client.close(); 73 System.out.println("Closing connection to " + client); 74 chatServer.removeClient(client); 76 callback.onData(client, buffer, result); 78 client [all...] |
H A D | MessageReader.java | 62 * @param client the client to read messages from 65 public void beforeRead(Client client) { argument 67 String message = client.nextMessage(); 69 chatServer.writeMessageToClients(client, message); 70 message = client.nextMessage(); 76 * @param client the client to append messages to 81 public void onData(Client client, ByteBuffer buffer, int bytes) { argument 84 client [all...] |
H A D | NameReader.java | 48 * client. 61 * Writes the welcoming message to the client the first time this method 64 * @param client the client to receive the message 67 public void beforeRead(Client client) { argument 70 client.writeStringMessage("Name: "); 84 public void onData(Client client, ByteBuffer buffer, int bytes) { argument 89 onUserNameRead(client, name); 98 * @param client the client t 101 onUserNameRead(Client client, String name) argument 115 sendRemainingParts(Client client, String[] strings) argument [all...] |
H A D | ChatServer.java | 127 * Creates a new client and adds it to the list of connections. 133 Client client = new Client(channel, new ClientReader(this, new NameReader(this))); 139 connections.add(client); 140 client.run(); 148 * @param client the message source 151 public void writeMessageToClients(Client client, String message) { argument 154 if (clientConnection != client) { 155 clientConnection.writeMessageFrom(client, message); 161 public void removeClient(Client client) { argument 162 connections.remove(client); [all...] |
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/client/sei/ |
H A D | pacakge-info.java | 29 package com.sun.xml.internal.ws.client.sei;
|
H A D | MethodHandler.java | 26 package com.sun.xml.internal.ws.client.sei; 61 * If used on the client side, a {@link WebServiceException} signals an error
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/client/ |
H A D | ResponseContextReceiver.java | 26 package com.sun.xml.internal.ws.client;
|
H A D | BindingProviderProperties.java | 26 package com.sun.xml.internal.ws.client; 35 "com.sun.xml.internal.ws.client.http.HostnameVerificationProperty"; 37 "com.sun.xml.internal.ws.client.http.CookieJar"; 40 "com.sun.xml.internal.ws.client.http.RedirectRequestProperty"; 49 "com.sun.xml.internal.ws.client.handle";
|
H A D | ContentNegotiation.java | 26 package com.sun.xml.internal.ws.client; 32 * client transport will be performed to negotiate the encoding of XML infoset. 35 * A value of {@link #pessimistic} means the client transport will assume 38 * (The client transport initially and pessimistically assumes that a service 41 * A value of {@link #optimistic} means the client transport will assume 43 * (The client transport optimistically assumes that a service 56 public static final String PROPERTY = "com.sun.xml.internal.ws.client.ContentNegotiation";
|
/openjdk7/jdk/test/sun/security/ssl/com/sun/net/ssl/internal/ssl/ServerHandshaker/ |
H A D | GetPeerHost.java | 46 GetPeerHostClient client = new GetPeerHostClient(); 47 client.start();
|
/openjdk7/jdk/test/java/nio/channels/SocketChannel/ |
H A D | CloseRegisteredChannel.java | 43 SocketChannel client = SocketChannel.open (); 44 client.connect (new InetSocketAddress ("127.0.0.1", port)); 49 client.configureBlocking (false); 50 SelectionKey key = client.register ( 53 client.close(); 54 //System.out.println ("client.isOpen = " + client.isOpen());
|
/openjdk7/jdk/src/solaris/classes/sun/awt/X11/ |
H A D | XInputMethod.java | 92 do NOT call client code! 94 protected Container getParent(Component client) { argument 95 return client.getParent(); 99 * Returns peer of the given client component. If the given client component 100 * doesn't have peer, peer of the native container of the client is returned. 102 protected ComponentPeer getPeer(Component client) { argument 105 if (log.isLoggable(PlatformLogger.FINE)) log.fine("Client is " + client); 106 peer = (XComponentPeer)XToolkit.targetToPeer(client); 107 while (client ! [all...] |
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/messaging/saaj/client/p2p/ |
H A D | HttpSOAPConnectionFactory.java | 26 package com.sun.xml.internal.messaging.saaj.client.p2p;
|
/openjdk7/jdk/test/java/net/Socket/ |
H A D | RST.java | 33 Socket client; field in class:RST 37 client.setSoLinger(true, 0); // hard reset 38 client.close(); 46 client = new Socket("localhost", ss.getLocalPort());
|
H A D | UrgentDataTest.java | 40 Socket client, server; field in class:UrgentDataTest 46 System.out.println (" usage: java UrgentDataTest <runs client and server together>"); 48 System.out.println (" usage: java UrgentDataTest -client host port <runs client and connects to"+ 69 } else if (args[0].equals ("-client")) { 95 client = new Socket (clHost, clPort); 96 clis = client.getInputStream(); 97 clos = client.getOutputStream(); 98 client.setOOBInline (true); 99 if (client [all...] |
/openjdk7/jdk/test/java/net/DatagramSocket/ |
H A D | SendSize.java | 88 DatagramSocket client; field in class:SendSize.ClientThread 94 this.client = new DatagramSocket(); 99 System.err.println("started client thread: " + client); 105 client.send(sendPacket); 113 if (client != null) { client.close(); }
|
/openjdk7/jdk/test/javax/management/remote/mandatory/connection/ |
H A D | CloseServerTest.java | 77 JMXConnector client; 103 // with a client, but close the server first 104 System.out.println(">>> Open, start a server, create a client, close the server then the client."); 110 client = JMXConnectorFactory.newJMXConnector(addr, null); 111 client.connect(null); 116 client.close(); 121 // with a client, but close the client first 122 System.out.println(">>> Open, start a server, create a client, clos [all...] |
/openjdk7/jdk/test/sun/security/ssl/com/sun/net/ssl/internal/ssl/GenSSLConfigs/ |
H A D | main.java | 69 * client threads to use. 138 ClientThread client = new ClientThread (server.getServerPort(), sslContext); 141 setConfig (client, config, supported); 144 client.setBasicCipherSuites (cipher); 151 client.start (); 153 waitForClient (client); 154 if (client.passed ()) 157 clients.addElement (client); 161 ClientThread client; 163 client 178 waitForClient(Thread client) argument [all...] |
/openjdk7/jdk/test/sun/net/sdp/ |
H A D | Sanity.java | 57 SocketChannel client = SocketChannel.open(); 59 client.connect(new InetSocketAddress(addr, port)); 62 testConnection(Channels.newOutputStream(client), 68 client.close(); 72 client = SocketChannel.open(); 74 client.bind(new InetSocketAddress(addr, 0)) 78 client.close(); 92 AsynchronousSocketChannel client = AsynchronousSocketChannel.open(); 94 client.connect(new InetSocketAddress(addr, port)).get(); 97 testConnection(Channels.newOutputStream(client), [all...] |
/openjdk7/jdk/test/java/nio/channels/DatagramChannel/ |
H A D | Refused.java | 38 static DatagramChannel client; field in class:Refused 57 client = DatagramChannel.open(); 60 client.socket().bind((SocketAddress)null); 63 client.configureBlocking(false); 67 int port = client.socket().getLocalPort(); 78 client.close(); 98 client.close();
|
/openjdk7/jdk/src/share/classes/sun/net/www/protocol/mailto/ |
H A D | MailToURLConnection.java | 48 SmtpClient client; field in class:MailToURLConnection 86 client = new SmtpClient(connectTimeout); 87 client.setReadTimeout(readTimeout); 100 client.from(getFromAddress()); 101 client.to(to); 103 os = client.startMessage(); 111 String host = client.getMailHost() + ":" + 25;
|
/openjdk7/jdk/test/sun/net/www/ftptest/ |
H A D | FtpServer.java | 103 void addClient(Socket client) { argument 104 FtpCommandHandler h = new FtpCommandHandler(client, this); 125 Socket client; 129 client = listener.accept(); 130 addClient(client);
|
/openjdk7/jdk/src/share/classes/sun/awt/im/ |
H A D | InputMethodAdapter.java | 52 void setClientComponent(Component client) { argument 53 clientComponent = client; 88 * Notifies client Window location or status changes
|
/openjdk7/jdk/test/com/oracle/net/ |
H A D | Sanity.java | 66 SocketChannel client = Sdp.openSocketChannel(); 68 client.connect(new InetSocketAddress(addr, port)); 71 testConnection(Channels.newOutputStream(client), 77 client.close(); 81 client = Sdp.openSocketChannel(); 83 client.socket().bind(new InetSocketAddress(addr, 0)); 84 client.connect(new InetSocketAddress(addr, port)); 87 client.close();
|