Home
last modified time | relevance | path

Searched refs:myGroupAndInvokeCount (Results 1 – 3 of 3) sorted by relevance

/libcore/ojluni/src/main/java/sun/nio/ch/
DInvoker.java71 private static final ThreadLocal<GroupAndInvokeCount> myGroupAndInvokeCount = field in Invoker
82 myGroupAndInvokeCount.set(new GroupAndInvokeCount(group)); in bindToGroup()
89 return myGroupAndInvokeCount.get(); in getGroupAndInvokeCount()
96 return myGroupAndInvokeCount.get() != null; in isBoundToAnyGroup()
104 static boolean mayInvokeDirect(GroupAndInvokeCount myGroupAndInvokeCount, in mayInvokeDirect() argument
107 if ((myGroupAndInvokeCount != null) && in mayInvokeDirect()
108 (myGroupAndInvokeCount.group() == group) && in mayInvokeDirect()
109 (myGroupAndInvokeCount.invokeCount() < maxHandlerInvokeCount)) in mayInvokeDirect()
153 static <V,A> void invokeDirect(GroupAndInvokeCount myGroupAndInvokeCount, in invokeDirect() argument
159 myGroupAndInvokeCount.incrementInvokeCount(); in invokeDirect()
[all …]
DEPollPort.java249 Invoker.GroupAndInvokeCount myGroupAndInvokeCount = in run() local
251 final boolean isPooledThread = (myGroupAndInvokeCount != null); in run()
258 myGroupAndInvokeCount.resetInvokeCount(); in run()
DUnixAsynchronousSocketChannelImpl.java507 Invoker.GroupAndInvokeCount myGroupAndInvokeCount = null; in implRead() local
514 myGroupAndInvokeCount = Invoker.getGroupAndInvokeCount(); in implRead()
515 invokeDirect = Invoker.mayInvokeDirect(myGroupAndInvokeCount, port); in implRead()
577 Invoker.invokeDirect(myGroupAndInvokeCount, handler, attachment, (V)result, exc); in implRead()
698 Invoker.GroupAndInvokeCount myGroupAndInvokeCount = in implWrite() local
700 boolean invokeDirect = Invoker.mayInvokeDirect(myGroupAndInvokeCount, port); in implWrite()
760 Invoker.invokeDirect(myGroupAndInvokeCount, handler, attachment, (V)result, exc); in implWrite()