equal
deleted
inserted
replaced
27 |
27 |
28 import java.nio.channels.*; |
28 import java.nio.channels.*; |
29 import java.nio.channels.spi.AsynchronousChannelProvider; |
29 import java.nio.channels.spi.AsynchronousChannelProvider; |
30 import java.util.concurrent.ExecutorService; |
30 import java.util.concurrent.ExecutorService; |
31 import java.util.concurrent.ThreadFactory; |
31 import java.util.concurrent.ThreadFactory; |
32 import java.net.ProtocolFamily; |
|
33 import java.io.IOException; |
32 import java.io.IOException; |
34 |
33 |
35 public class LinuxAsynchronousChannelProvider |
34 public class LinuxAsynchronousChannelProvider |
36 extends AsynchronousChannelProvider |
35 extends AsynchronousChannelProvider |
37 { |
36 { |
86 public AsynchronousSocketChannel openAsynchronousSocketChannel(AsynchronousChannelGroup group) |
85 public AsynchronousSocketChannel openAsynchronousSocketChannel(AsynchronousChannelGroup group) |
87 throws IOException |
86 throws IOException |
88 { |
87 { |
89 return new UnixAsynchronousSocketChannelImpl(toPort(group)); |
88 return new UnixAsynchronousSocketChannelImpl(toPort(group)); |
90 } |
89 } |
91 |
|
92 @Override |
|
93 public AsynchronousDatagramChannel openAsynchronousDatagramChannel(ProtocolFamily family, |
|
94 AsynchronousChannelGroup group) |
|
95 throws IOException |
|
96 { |
|
97 return new SimpleAsynchronousDatagramChannelImpl(family, toPort(group)); |
|
98 } |
|
99 } |
90 } |