39 #include "nio.h"
40 #include "nio_util.h"
41 #include "net_util.h"
42
43 #include "sun_nio_ch_ServerSocketChannelImpl.h"
44
45
46 static jfieldID fd_fdID; /* java.io.FileDescriptor.fd */
47 static jclass isa_class; /* java.net.InetSocketAddress */
48 static jmethodID isa_ctorID; /* InetSocketAddress(InetAddress, int) */
49
50
51 /**************************************************************
52 * static method to store field IDs in initializers
53 */
54
55 JNIEXPORT void JNICALL
56 Java_sun_nio_ch_ServerSocketChannelImpl_initIDs(JNIEnv *env, jclass cls)
57 {
58 cls = (*env)->FindClass(env, "java/io/FileDescriptor");
59 fd_fdID = (*env)->GetFieldID(env, cls, "fd", "I");
60
61 cls = (*env)->FindClass(env, "java/net/InetSocketAddress");
62 isa_class = (*env)->NewGlobalRef(env, cls);
63 isa_ctorID = (*env)->GetMethodID(env, cls, "<init>",
64 "(Ljava/net/InetAddress;I)V");
65 }
66
67 JNIEXPORT void JNICALL
68 Java_sun_nio_ch_ServerSocketChannelImpl_listen(JNIEnv *env, jclass cl,
69 jobject fdo, jint backlog)
70 {
71 if (listen(fdval(env,fdo), backlog) == SOCKET_ERROR) {
72 NET_ThrowNew(env, WSAGetLastError(), "listen");
73 }
74 }
75
76 JNIEXPORT jint JNICALL
77 Java_sun_nio_ch_ServerSocketChannelImpl_accept0(JNIEnv *env, jobject this,
78 jobject ssfdo, jobject newfdo,
79 jobjectArray isaa)
80 {
81 jint ssfd = (*env)->GetIntField(env, ssfdo, fd_fdID);
82 jint newfd;
83 SOCKETADDRESS sa;
84 jobject remote_ia;
85 int remote_port;
86 jobject isa;
87 int addrlen = sizeof(sa);
88
89 memset((char *)&sa, 0, sizeof(sa));
90 newfd = (jint)accept(ssfd, (struct sockaddr *)&sa, &addrlen);
91 if (newfd == INVALID_SOCKET) {
92 int theErr = (jint)WSAGetLastError();
93 if (theErr == WSAEWOULDBLOCK) {
94 return IOS_UNAVAILABLE;
95 }
96 JNU_ThrowIOExceptionWithLastError(env, "Accept failed");
97 return IOS_THROWN;
98 }
99
100 (*env)->SetIntField(env, newfdo, fd_fdID, newfd);
101 remote_ia = NET_SockaddrToInetAddress(env, (struct sockaddr *)&sa, (int *)&remote_port);
102
103 isa = (*env)->NewObject(env, isa_class, isa_ctorID,
104 remote_ia, remote_port);
105 (*env)->SetObjectArrayElement(env, isaa, 0, isa);
106
107 return 1;
108 }
|
39 #include "nio.h"
40 #include "nio_util.h"
41 #include "net_util.h"
42
43 #include "sun_nio_ch_ServerSocketChannelImpl.h"
44
45
46 static jfieldID fd_fdID; /* java.io.FileDescriptor.fd */
47 static jclass isa_class; /* java.net.InetSocketAddress */
48 static jmethodID isa_ctorID; /* InetSocketAddress(InetAddress, int) */
49
50
51 /**************************************************************
52 * static method to store field IDs in initializers
53 */
54
55 JNIEXPORT void JNICALL
56 Java_sun_nio_ch_ServerSocketChannelImpl_initIDs(JNIEnv *env, jclass cls)
57 {
58 cls = (*env)->FindClass(env, "java/io/FileDescriptor");
59 CHECK_NULL(cls);
60 fd_fdID = (*env)->GetFieldID(env, cls, "fd", "I");
61 CHECK_NULL(fd_fdID);
62
63 cls = (*env)->FindClass(env, "java/net/InetSocketAddress");
64 CHECK_NULL(cls);
65 isa_class = (*env)->NewGlobalRef(env, cls);
66 if (isa_class == NULL) {
67 JNU_ThrowOutOfMemoryError(env, NULL);
68 return;
69 }
70 isa_ctorID = (*env)->GetMethodID(env, cls, "<init>",
71 "(Ljava/net/InetAddress;I)V");
72 CHECK_NULL(isa_ctorID);
73 }
74
75 JNIEXPORT void JNICALL
76 Java_sun_nio_ch_ServerSocketChannelImpl_listen(JNIEnv *env, jclass cl,
77 jobject fdo, jint backlog)
78 {
79 if (listen(fdval(env,fdo), backlog) == SOCKET_ERROR) {
80 NET_ThrowNew(env, WSAGetLastError(), "listen");
81 }
82 }
83
84 JNIEXPORT jint JNICALL
85 Java_sun_nio_ch_ServerSocketChannelImpl_accept0(JNIEnv *env, jobject this,
86 jobject ssfdo, jobject newfdo,
87 jobjectArray isaa)
88 {
89 jint ssfd = (*env)->GetIntField(env, ssfdo, fd_fdID);
90 jint newfd;
91 SOCKETADDRESS sa;
92 jobject remote_ia;
93 int remote_port;
94 jobject isa;
95 int addrlen = sizeof(sa);
96
97 memset((char *)&sa, 0, sizeof(sa));
98 newfd = (jint)accept(ssfd, (struct sockaddr *)&sa, &addrlen);
99 if (newfd == INVALID_SOCKET) {
100 int theErr = (jint)WSAGetLastError();
101 if (theErr == WSAEWOULDBLOCK) {
102 return IOS_UNAVAILABLE;
103 }
104 JNU_ThrowIOExceptionWithLastError(env, "Accept failed");
105 return IOS_THROWN;
106 }
107
108 (*env)->SetIntField(env, newfdo, fd_fdID, newfd);
109 remote_ia = NET_SockaddrToInetAddress(env, (struct sockaddr *)&sa, (int *)&remote_port);
110 CHECK_NULL_RETURN(remote_ia, IOS_THROWN);
111
112 isa = (*env)->NewObject(env, isa_class, isa_ctorID, remote_ia, remote_port);
113 CHECK_NULL_RETURN(isa, IOS_THROWN);
114 (*env)->SetObjectArrayElement(env, isaa, 0, isa);
115 return 1;
116 }
|