Searched refs:queue (Results 1 – 13 of 13) sorted by relevance
| /thrift-3.4.0/lib/rb/spec/ |
| D | nonblocking_server_spec.rb | 57 def initialize(transport, queue) argument
59 @queue = queue
91 def initialize(host, port, queue) argument
93 @queue = queue
107 queue = Queue.new
108 @transport = SpecServerSocket.new('localhost', @port, queue)
123 queue.pop
136 def setup_client(queue = nil) argument
137 …ort = SpecTransport.new(Thrift::FramedTransport.new(Thrift::Socket.new('localhost', @port)), queue)
146 queue = Queue.new
[all …]
|
| /thrift-3.4.0/lib/d/src/thrift/async/ |
| D | libevent.d | 283 auto queue = workQueues_[msg.transport]; in receiveControlMsg() local
284 if (queue.length > 0) { in receiveControlMsg()
285 workQueues_[msg.transport] = [queue[0]] ~ in receiveControlMsg()
286 removeEqual(queue[1 .. $], msg.work); in receiveControlMsg()
296 auto queue = msg.transport in workQueues_; in receiveControlMsg() local
297 if (queue is null || (*queue).empty) { in receiveControlMsg()
303 (*queue) ~= msg.work; in receiveControlMsg()
344 auto queue = workQueues_[transport]; in executeWork()
345 assert(queue.front == item); in executeWork()
346 queue.popFront(); in executeWork()
[all …]
|
| /thrift-3.4.0/lib/perl/lib/Thrift/ |
| D | ServerSocket.pm | 57 if (not defined $self->{queue}) {
58 $self->{queue} = 128;
120 Listen => $self->{queue},
|
| D | UnixServerSocket.pm | 71 Listen => $self->{queue})
|
| D | SSLServerSocket.pm | 57 my $opts = {Listen => $self->{queue},
|
| /thrift-3.4.0/lib/py/src/server/ |
| D | TNonblockingServer.py | 35 from six.moves import queue
48 def __init__(self, queue): argument
50 self.queue = queue
56 processor, iprot, oprot, otrans, callback = self.queue.get()
252 self.tasks = queue.Queue()
|
| D | TServer.py | 20 from six.moves import queue
167 self.clients = queue.Queue()
|
| /thrift-3.4.0/lib/java/src/main/java/org/apache/thrift/server/ |
| D | THsHaServer.java | 141 LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>(); in createInvokerPool() local
144 minWorkerThreads, maxWorkerThreads, stopTimeoutVal, stopTimeoutUnit, queue); in createInvokerPool()
|
| /thrift-3.4.0/lib/rb/lib/thrift/server/ |
| D | nonblocking_server.rb | 263 def initialize(processor, transport_factory, protocol_factory, logger, queue) argument
268 @queue = queue
|
| /thrift-3.4.0/lib/cpp/src/thrift/async/ |
| D | TEvhttpClientChannel.h | 80 typedef std::queue<Completion> CompletionQueue;
|
| /thrift-3.4.0/contrib/Rebus/ |
| D | README.md | 12 this example, since we are effectively implementing two queue listeners in
|
| /thrift-3.4.0/doc/specs/ |
| D | thrift.tex | 918 samples. Others may simply wish to react immediately to work-queue
|
| /thrift-3.4.0/ |
| D | CHANGES.md | 1001 ….org/jira/browse/THRIFT-3060) - Node.js client retry logic doesn't flush offline queue on reconnect
2316 …/THRIFT-615) - TThreadPoolServer doesn't call task_done after pulling tasks from it's clients queue
|
