/openjdk7/jdk/test/java/nio/channels/SocketChannel/ |
H A D | SocketOptionTests.java | 39 static void checkOption(SocketChannel sc, SocketOption name, Object expectedValue) argument 42 Object value = sc.getOption(name); 48 SocketChannel sc = SocketChannel.open(); 51 Set<SocketOption<?>> options = sc.supportedOptions(); 60 int linger = sc.<Integer>getOption(SO_LINGER); 63 checkOption(sc, SO_KEEPALIVE, false); 64 checkOption(sc, TCP_NODELAY, false); 67 sc.setOption(SO_KEEPALIVE, true); 68 checkOption(sc, SO_KEEPALIVE, true); 69 sc [all...] |
H A D | OutOfBand.java | 179 static void test4(SocketChannel sc) throws IOException { argument 180 boolean blocking = sc.isBlocking(); 181 sc.configureBlocking(false); 183 sc.socket().sendUrgentData(0); 188 sc.configureBlocking(blocking);
|
H A D | ShortWrite.java | 54 final SocketChannel sc; field in class:ShortWrite.Reader 57 Reader(SocketChannel sc, int expectedSize) { argument 58 this.sc = sc; 64 int n = sc.read(buf);
|
H A D | ConnectState.java | 69 abstract String go(SocketChannel sc) throws Exception; argument 76 static void check(SocketChannel sc, int state) throws Exception { argument 79 check(!sc.isConnected(), "!isConnected"); 80 check(!sc.isConnectionPending(), "!isConnectionPending"); 81 check(sc.isOpen(), "isOpen"); 84 check(!sc.isConnected(), "!isConnected"); 85 check(sc.isConnectionPending(), "isConnectionPending"); 86 check(sc.isOpen(), "isOpen"); 89 check(sc.isConnected(), "isConnected"); 90 check(!sc [all...] |
/openjdk7/jdk/test/java/nio/channels/Selector/ |
H A D | Alias.java | 56 SocketChannel sc = SocketChannel.open(); 57 sc.configureBlocking(false); 58 boolean result = sc.connect(isa); 63 SelectionKey key = sc.register(selector, 80 read(sc); 85 static void read(SocketChannel sc) throws Exception { argument 89 n = sc.read(bb); 94 sc.close();
|
H A D | Connect.java | 56 SocketChannel sc = SocketChannel.open(); 57 sc.configureBlocking(false); 58 boolean connected = sc.connect(isa); 61 SelectionKey RKey = sc.register (RSelector, SelectionKey.OP_CONNECT); 77 readAndClose(sc); 81 static void readAndClose(SocketChannel sc) throws Exception { argument 85 n = sc.read(bb); 90 sc.close();
|
H A D | RegAfterPreClose.java | 70 Closer(Channel sc) { argument 71 this.channel = sc; 112 SocketChannel sc = ssc.accept(); 113 if (sc != null) { 115 sc.configureBlocking(false); 116 sc.register(sel, SelectionKey.OP_READ); 117 executor.execute(new Closer(sc));
|
H A D | ChangingInterests.java | 61 static void drain(SocketChannel sc) throws IOException { argument 64 while ((n = sc.read(buf)) > 0) { 140 final SocketChannel sc = SocketChannel.open(); 141 sc.connect(new InetSocketAddress(lh, ssc.socket().getLocalPort())); 144 sc.configureBlocking(false); 146 // ensure that channel "sc" is readable 150 SelectionKey key = sc.register(sel, 0); 169 drain(sc); 180 sc.close();
|
/openjdk7/jdk/src/share/classes/java/beans/beancontext/ |
H A D | BeanContextServiceAvailableEvent.java | 48 * @param sc A <code>Class</code> reference to the newly available service 50 public BeanContextServiceAvailableEvent(BeanContextServices bcs, Class sc) { argument 53 serviceClass = sc;
|
H A D | BeanContextServiceRevokedEvent.java | 46 * @param sc the service that is being revoked 49 public BeanContextServiceRevokedEvent(BeanContextServices bcs, Class sc, boolean invalidate) { argument 52 serviceClass = sc;
|
/openjdk7/jaxws/src/share/jaxws_classes/com/sun/xml/internal/ws/client/ |
H A D | SCAnnotations.java | 49 SCAnnotations(final Class<?> sc) { argument 52 WebServiceClient wsc =sc.getAnnotation(WebServiceClient.class); 66 for (Method method : sc.getDeclaredMethods()) {
|
/openjdk7/jdk/test/java/nio/channels/spi/SelectorProvider/inheritedChannel/ |
H A D | EchoService.java | 65 private static void doIt(SocketChannel sc, int closeAfter, int delay) throws IOException { argument 70 int n = sc.read(bb); 78 sc.write(bb); 86 sc.close(); 117 private SocketChannel sc; field in class:EchoService.Worker 119 Worker(SocketChannel sc) { argument 120 this.sc = sc; 128 doIt(sc, -1, -1); 168 SocketChannel sc; [all...] |
H A D | Util.java | 55 public static int getFD(SocketChannel sc) { argument 57 Object fdObj = get("sun.nio.ch.SocketChannelImpl", "fd", sc);
|
/openjdk7/langtools/test/tools/javac/AccessMethods/ |
H A D | ChainedAssignment.java | 42 static private int sc = 0; field in class:ChainedAssignment 69 System.out.println(sa + " " + sb + " " + sc); 70 sa = sb = sc; 74 System.out.println(sa + " " + sb + " " + sc); 79 System.out.println(sa + " " + sb + " " + sc);
|
/openjdk7/jdk/test/sun/security/ssl/javax/net/ssl/NewAPIs/SSLEngine/ |
H A D | SSLEngineService.java | 58 protected static void deliver(SSLEngine ssle, SocketChannel sc) argument 95 if (sc.write(localNetData) < 0) { 134 protected static void receive(SSLEngine ssle, SocketChannel sc) argument 147 if (ssle.isInboundDone() || sc.read(peerNetData) < 0) { 218 protected static void handshaking(SSLEngine ssle, SocketChannel sc) argument 240 if (sc.read(peerNetData) < 0) { 293 if (sc.write(localNetData) < 0) {
|
/openjdk7/jdk/src/share/classes/sun/reflect/generics/tree/ |
H A D | ClassSignature.java | 36 ClassTypeSignature sc, 39 superclass = sc; 44 ClassTypeSignature sc, 46 return new ClassSignature(ftps, sc, sis); 35 ClassSignature(FormalTypeParameter[] ftps, ClassTypeSignature sc, ClassTypeSignature[] sis) argument 43 make(FormalTypeParameter[] ftps, ClassTypeSignature sc, ClassTypeSignature[] sis) argument
|
/openjdk7/jdk/src/share/classes/com/sun/jndi/ldap/sasl/ |
H A D | SaslInputStream.java | 57 private SaslClient sc; field in class:SaslInputStream 60 SaslInputStream(SaslClient sc, InputStream in) throws SaslException { argument 63 this.sc = sc; 65 String str = (String) sc.getNegotiatedProperty(Sasl.MAX_BUFFER); 147 buf = sc.unwrap(saslBuffer, 0, len); 188 sc.dispose(); // Dispose of SaslClient's state
|
H A D | SaslOutputStream.java | 40 private SaslClient sc; field in class:SaslOutputStream 42 SaslOutputStream(SaslClient sc, OutputStream out) throws SaslException { argument 44 this.sc = sc; 50 String str = (String) sc.getNegotiatedProperty(Sasl.RAW_SEND_SIZE); 89 wrappedToken = sc.wrap(buffer, offset+i, count); 107 sc.dispose(); // Dispose of SaslClient's state
|
/openjdk7/jdk/src/windows/classes/sun/nio/ch/ |
H A D | SinkChannelImpl.java | 47 SocketChannel sc; field in class:SinkChannelImpl 50 return ((SocketChannelImpl)sc).getFD(); 54 return ((SocketChannelImpl)sc).getFDVal(); 57 SinkChannelImpl(SelectorProvider sp, SocketChannel sc) { argument 59 this.sc = sc; 68 sc.close(); 72 sc.configureBlocking(block); 115 return sc.write(src); 124 return sc [all...] |
H A D | SourceChannelImpl.java | 46 SocketChannel sc; field in class:SourceChannelImpl 49 return ((SocketChannelImpl) sc).getFD(); 53 return ((SocketChannelImpl) sc).getFDVal(); 56 SourceChannelImpl(SelectorProvider sp, SocketChannel sc) { argument 58 this.sc = sc; 67 sc.close(); 71 sc.configureBlocking(block); 114 return sc.read(dst); 136 return sc [all...] |
/openjdk7/jdk/test/com/sun/nio/sctp/SctpChannel/ |
H A D | SocketOptionTests.java | 50 <T> void checkOption(SctpChannel sc, SctpSocketOption<T> name, argument 52 T value = sc.getOption(name); 57 <T> void optionalSupport(SctpChannel sc, SctpSocketOption<T> name, argument 60 sc.setOption(name, value); 61 checkOption(sc, name, value); 76 SctpChannel sc = SctpChannel.open(); 79 Set<SctpSocketOption<?>> options = sc.supportedOptions(); 92 sc.setOption(SCTP_INIT_MAXSTREAMS, streams); 93 checkOption(sc, SCTP_INIT_MAXSTREAMS, streams); 94 streams = sc [all...] |
/openjdk7/jdk/test/java/nio/channels/FileChannel/ |
H A D | Transfer.java | 551 private SocketChannel sc; field in class:Transfer.EchoServer 553 public EchoServer(SocketChannel sc) { argument 554 this.sc = sc; 561 int n = sc.read(bb); 567 sc.write(bb); 575 sc.close();
|
/openjdk7/jdk/src/share/sample/nio/server/ |
H A D | ChannelIO.java | 58 protected SocketChannel sc; field in class:ChannelIO 68 protected ChannelIO(SocketChannel sc, boolean blocking) argument 70 this.sc = sc; 71 sc.configureBlocking(blocking); 74 static ChannelIO getInstance(SocketChannel sc, boolean blocking) argument 76 ChannelIO cio = new ChannelIO(sc, blocking); 83 return sc; 134 return sc.read(requestBB); 148 return sc [all...] |
/openjdk7/jdk/src/share/classes/javax/swing/text/rtf/ |
H A D | RTFAttributes.java | 349 String r, Number ds, int dr, float sc) 354 scale = sc; 348 NumericAttribute(int d, Object s, String r, Number ds, int dr, float sc) argument
|
/openjdk7/jdk/test/com/sun/nio/sctp/SctpServerChannel/ |
H A D | Accept.java | 145 SctpChannel sc = ssc.accept(); 146 check(sc == null, "non-blocking mode should return null"); 174 SctpChannel sc = null; 178 sc = ssc.accept(); 180 checkAcceptedChannel(sc); 224 try { if (sc != null) sc.close(); } 230 void checkAcceptedChannel(SctpChannel sc) { argument 233 check(sc.association() != null, 235 check(!(sc [all...] |