Lines Matching defs:in

9  * by Oracle in the LICENSE file that accompanied this code.
11 * This code is distributed in the hope that it will be useful, but WITHOUT
14 * version 2 for more details (a copy is included in the LICENSE file that
114 private int readSocksReply(InputStream in, byte[] data) throws IOException {
115 return readSocksReply(in, data, 0L);
118 private int readSocksReply(InputStream in, byte[] data, long deadlineMillis) throws IOException {
124 count = ((SocketInputStream)in).read(data, received, len - received, remainingMillis(deadlineMillis));
138 private boolean authenticate(byte method, InputStream in,
140 return authenticate(method, in, out, 0L);
143 private boolean authenticate(byte method, InputStream in,
150 * User/Password authentication. Try, in that order :
193 int i = readSocksReply(in, data, deadlineMillis);
198 in.close();
207 * implementation. I'll leave this in for future completion.
232 // i = readSocksReply(in, data, deadlineMillis);
234 // in.close();
238 // i = readSocksReply(in, data, deadlineMillis);
243 // i = readSocksReply(in, data, deadlineMillis);
246 // in.close();
254 // in.close();
261 private void connectV4(InputStream in, OutputStream out,
281 int n = readSocksReply(in, data, deadlineMillis);
306 in.close();
319 * @param timeout the timeout value in milliseconds
352 // specified proxy in which case it does bypass the ProxySelector
442 InputStream in = cmdIn;
449 connectV4(in, out, epoint, deadlineMillis);
460 int i = readSocksReply(in, data, deadlineMillis);
468 connectV4(in, out, epoint, deadlineMillis);
473 if (!authenticate(data[1], in, out, deadlineMillis)) {
503 i = readSocksReply(in, data, deadlineMillis);
515 i = readSocksReply(in, addr, deadlineMillis);
519 i = readSocksReply(in, data, deadlineMillis);
526 i = readSocksReply(in, host, deadlineMillis);
530 i = readSocksReply(in, data, deadlineMillis);
537 i = readSocksReply(in, addr, deadlineMillis);
541 i = readSocksReply(in, data, deadlineMillis);
576 in.close();
583 private void bindV4(InputStream in, OutputStream out,
617 int n = readSocksReply(in, data);
642 in.close();
669 // specified proxy in which case it does bypass the ProxySelector
770 InputStream in = cmdIn;
772 bindV4(in, out, saddr.getAddress(), saddr.getPort());
781 int i = readSocksReply(in, data);
785 bindV4(in, out, saddr.getAddress(), saddr.getPort());
790 if (!authenticate(data[1], in, out)) {
827 i = readSocksReply(in, data);
837 i = readSocksReply(in, addr);
841 i = readSocksReply(in, data);
852 i = readSocksReply(in, host);
856 i = readSocksReply(in, data);
866 i = readSocksReply(in, addr);
870 i = readSocksReply(in, data);
906 in.close();
912 cmdIn = in;
930 InputStream in = cmdIn;
933 in.read();
934 int i = in.read();
935 in.read();
943 i = in.read();
947 readSocksReply(in, addr);
948 nport = in.read() << 8;
949 nport += in.read();
954 int len = in.read();
956 readSocksReply(in, addr);
957 nport = in.read() << 8;
958 nport += in.read();
963 readSocksReply(in, addr);
964 nport = in.read() << 8;
965 nport += in.read();
1014 psi.setInputStream((SocketInputStream) in);