Searched refs:client (Results 1 - 25 of 221) sorted by relevance

123456789

/openjdk7/jdk/src/share/sample/nio/chatserver/
H A DDataReader.java44 void beforeRead(Client client); argument
45 void onData(Client client, ByteBuffer buffer, int bytes); argument
H A DClientReader.java62 * 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 DMessageReader.java62 * @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 DNameReader.java48 * 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 DChatServer.java127 * 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 Dpacakge-info.java29 package com.sun.xml.internal.ws.client.sei;
H A DMethodHandler.java26 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 DResponseContextReceiver.java26 package com.sun.xml.internal.ws.client;
H A DBindingProviderProperties.java26 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 DContentNegotiation.java26 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 DGetPeerHost.java46 GetPeerHostClient client = new GetPeerHostClient();
47 client.start();
/openjdk7/jdk/test/java/nio/channels/SocketChannel/
H A DCloseRegisteredChannel.java43 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 DXInputMethod.java92 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 DHttpSOAPConnectionFactory.java26 package com.sun.xml.internal.messaging.saaj.client.p2p;
/openjdk7/jdk/test/java/net/Socket/
H A DRST.java33 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 DUrgentDataTest.java40 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 DSendSize.java88 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 DCloseServerTest.java77 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 Dmain.java69 * 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 DSanity.java57 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 DRefused.java38 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 DMailToURLConnection.java48 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 DFtpServer.java103 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 DInputMethodAdapter.java52 void setClientComponent(Component client) { argument
53 clientComponent = client;
88 * Notifies client Window location or status changes
/openjdk7/jdk/test/com/oracle/net/
H A DSanity.java66 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();

Completed in 609 milliseconds

123456789