| /dports/net/nast/nast-0.2.0/ncurses/ |
| H A D | n_stream.c | 33 struct stream_thread struct
39 struct stream_thread st_thread_data[1]; argument
117 struct stream_thread *sdata; in read_packet()
118 sdata = (struct stream_thread *) threadid; in read_packet()
|
| /dports/net-im/kopete/kopete-21.12.3/protocols/jabber/libjingle/talk/session/tunnel/ |
| H A D | securetunnelsessionclient.cc | 131 Session* session, talk_base::Thread* stream_thread, in MakeTunnelSession() argument
133 return new SecureTunnelSession(this, session, stream_thread, role); in MakeTunnelSession()
311 talk_base::Thread* stream_thread, TunnelSessionRole role) in SecureTunnelSession() argument
312 : TunnelSession(client, session, stream_thread), in SecureTunnelSession()
|
| H A D | securetunnelsessionclient.h | 99 Session* session, talk_base::Thread* stream_thread,
126 talk_base::Thread* stream_thread,
|
| H A D | tunnelsessionclient.cc | 199 Session* session, talk_base::Thread* stream_thread, in MakeTunnelSession() argument
201 return new TunnelSession(this, session, stream_thread); in MakeTunnelSession()
306 talk_base::Thread* stream_thread) in TunnelSession() argument
311 channel_ = new PseudoTcpChannel(stream_thread, session_); in TunnelSession()
|
| H A D | tunnelsessionclient.h | 97 talk_base::Thread* stream_thread,
158 talk_base::Thread* stream_thread);
|
| H A D | pseudotcpchannel.h | 71 PseudoTcpChannel(talk_base::Thread* stream_thread,
|
| H A D | pseudotcpchannel.cc | 102 PseudoTcpChannel::PseudoTcpChannel(Thread* stream_thread, Session* session) in PseudoTcpChannel() argument
105 stream_thread_(stream_thread), in PseudoTcpChannel()
|
| /dports/security/suricata/suricata-6.0.4/src/ |
| H A D | flow-worker.c | 63 StreamTcpThread *stream_thread; member
312 StreamTcpThreadDeinit(tv, (void *)fw->stream_thread); in FlowWorkerThreadDeinit()
377 StreamTcp(tv, p, fw->stream_thread, &fw->pq); in FlowWorkerStreamTCPUpdate()
381 StreamTcpDetectLogFlush(tv, fw->stream_thread, p->flow, p, &fw->pq); in FlowWorkerStreamTCPUpdate()
547 AppLayerHandleUdp(tv, fw->stream_thread->ra_ctx->app_tctx, p, p->flow); in FlowWorker()
|
| /dports/audio/squeezelite/squeezelite-7b13fd9/ |
| H A D | stream.c | 149 static void *stream_thread() {
415 pthread_create(&thread, &attr, stream_thread, NULL);
419 …thread = CreateThread(NULL, STREAM_THREAD_STACK_SIZE, (LPTHREAD_START_ROUTINE)&stream_thread, NULL…
|
| /dports/games/corsix-th/CorsixTH-0.65.1/CorsixTH/Src/ |
| H A D | th_movie.cpp | 379 stream_thread{},
484 if (stream_thread.joinable()) { in unload()
485 stream_thread.join(); in unload()
634 stream_thread = std::thread(&movie_player::read_streams, this); in play()
|
| H A D | th_movie.h | 434 std::thread stream_thread; ///< The thread responsible for reading the variable
|
| /dports/multimedia/butt/butt-0.1.27/src/ |
| H A D | port_audio.cpp | 77 pthread_t stream_thread; variable
373 pthread_create(&stream_thread, NULL, snd_stream_thread, NULL); in snd_start_stream()
|
| /dports/databases/mydumper/mydumper-0.11.3-2/ |
| H A D | myloader.c | 473 GThread *stream_thread = g_thread_create((GThreadFunc)process_stream, &conf, TRUE, NULL); in main() local
474 g_thread_join(stream_thread); in main()
|
| H A D | mydumper.c | 1811 GThread *stream_thread = NULL; in start_dump() local
1814 stream_thread = g_thread_create((GThreadFunc)process_stream, stream_queue, TRUE, NULL); in start_dump()
2055 g_thread_join(stream_thread); in start_dump()
|
| /dports/www/varnish6/varnish-cache-varnish-6.6.2/bin/varnishtest/ |
| H A D | vtc_http2.c | 2561 stream_thread(void *priv) in stream_thread() function
2642 AZ(pthread_create(&s->tp, NULL, stream_thread, s)); in stream_start()
|