OpenGrok
Home
Sort by relevance
Sort by last modified time
Full Search
Definition
Symbol
File Path
History
|
|
Help
Searched
refs:outbound
(Results
1 - 4
of
4
) sorted by null
/external/jmonkeyengine/engine/src/networking/com/jme3/network/kernel/tcp/
NioEndpoint.java
47
* track of the
outbound
data queue for the channel.
59
private ConcurrentLinkedQueue<ByteBuffer>
outbound
= new ConcurrentLinkedQueue<ByteBuffer>();
field in class:NioEndpoint
137
outbound
.add(buffer);
149
return
outbound
.peek();
158
return
outbound
.poll();
163
return !
outbound
.isEmpty();
/external/jmonkeyengine/engine/src/networking/com/jme3/network/base/
ConnectorAdapter.java
70
private BlockingQueue<ByteBuffer>
outbound
;
field in class:ConnectorAdapter
89
// The backlog makes sure that the
outbound
channel blocks once
95
outbound
= new ArrayBlockingQueue<ByteBuffer>(OUTBOUND_BACKLOG);
99
// if a TCP
outbound
queue fills to capacity and a client sends
102
// all get full and no
outbound
messages move and we forever block
106
// First, currently the server-side
outbound
queues are all unbounded and
107
// so won't ever block the handling of messages if the
outbound
channel is full.
139
outbound
.put( data );
208
ByteBuffer data =
outbound
.take();
/external/chromium/chrome/common/extensions/docs/examples/extensions/irc/servlet/src/org/chromium/
IRCProxyWebSocket.java
38
Outbound
outbound_;
45
public void onConnect(
Outbound
outbound
) {
46
outbound_=
outbound
;
/external/libpcap/
scanner.l
262
outbound
return
OUTBOUND
;
Completed in 159 milliseconds