| /dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/ppapi/proxy/ |
| H A D | udp_socket_filter.cc | 70 queues_[resource] = std::make_unique<RecvQueue>(instance, private_api, in AddUDPResource()
133 UDPSocketFilter::RecvQueue::RecvQueue( in RecvQueue() function in ppapi::proxy::UDPSocketFilter::RecvQueue
146 UDPSocketFilter::RecvQueue::~RecvQueue() { in ~RecvQueue()
151 void UDPSocketFilter::RecvQueue::DataReceivedOnIOThread( in DataReceivedOnIOThread()
204 int32_t UDPSocketFilter::RecvQueue::RequestData( in RequestData()
242 PP_NetAddress_Private UDPSocketFilter::RecvQueue::GetLastAddrPrivate() const { in GetLastAddrPrivate()
|
| H A D | udp_socket_filter.h | 76 class RecvQueue {
78 explicit RecvQueue(PP_Instance instance,
81 ~RecvQueue();
134 std::unordered_map<PP_Resource, std::unique_ptr<RecvQueue>> queues_;
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/ppapi/proxy/ |
| H A D | udp_socket_filter.cc | 71 queues_[resource] = std::make_unique<RecvQueue>(instance, private_api, in AddUDPResource()
134 UDPSocketFilter::RecvQueue::RecvQueue( in RecvQueue() function in ppapi::proxy::UDPSocketFilter::RecvQueue
147 UDPSocketFilter::RecvQueue::~RecvQueue() { in ~RecvQueue()
152 void UDPSocketFilter::RecvQueue::DataReceivedOnIOThread( in DataReceivedOnIOThread()
205 int32_t UDPSocketFilter::RecvQueue::RequestData( in RequestData()
243 PP_NetAddress_Private UDPSocketFilter::RecvQueue::GetLastAddrPrivate() const { in GetLastAddrPrivate()
|
| H A D | udp_socket_filter.h | 76 class RecvQueue {
78 explicit RecvQueue(PP_Instance instance,
81 ~RecvQueue();
134 std::unordered_map<PP_Resource, std::unique_ptr<RecvQueue>> queues_;
|
| /dports/math/dune-uggrid/dune-uggrid-bc2d1229420367563410ce9e519f5ff82b45266f/dune/uggrid/parallel/ddd/basic/ |
| H A D | lowcomm.cc | 354 msg->next = lcContext.RecvQueue; in LC_NewRecvMsg()
355 lcContext.RecvQueue = msg; in LC_NewRecvMsg()
492 for(md=lcContext.RecvQueue; md != nullptr; md=md->next) in LC_PollRecv()
560 for(md=lcContext.RecvQueue; md != nullptr; md=next) in LC_FreeRecvQueue()
571 lcContext.RecvQueue = nullptr; in LC_FreeRecvQueue()
695 for(sumSize=0, md=lcContext.RecvQueue; md != nullptr; md=md->next) in LC_PrepareRecv()
714 for(md=lcContext.RecvQueue; md != nullptr; md=md->next) in LC_PrepareRecv()
1351 LC_PrintMsgList(context.lowCommContext().RecvQueue); in LC_PrintRecvMsgs()
|
| /dports/security/softether-devel/v4.36-9754/src/Cedar/ |
| H A D | Interop_SSTP.c | 296 BLOCK *b = GetNext(s->RecvQueue); in SstpProcessInterrupt()
953 s->RecvQueue = NewQueueFast(); in NewSstpServer()
978 BLOCK *b = GetNext(s->RecvQueue); in FreeSstpServer()
1000 ReleaseQueue(s->RecvQueue); in FreeSstpServer()
1092 InsertQueue(sstp->RecvQueue, b); in ProcessSstpHttps()
|
| H A D | IPsec_L2TP.c | 997 t->RecvQueue = NewList(CmpL2TPQueueForRecv); in NewL2TPTunnel()
1141 for (i = 0;i < LIST_NUM(t->RecvQueue);i++) in FreeL2TPTunnel()
1143 L2TP_QUEUE *q = LIST_DATA(t->RecvQueue, i); in FreeL2TPTunnel()
1148 ReleaseList(t->RecvQueue); in FreeL2TPTunnel()
1866 if (LIST_NUM(t->RecvQueue) < L2TP_WINDOW_SIZE) in ProcL2TPPacketRecv()
1871 if (Search(t->RecvQueue, &tt) == NULL) in ProcL2TPPacketRecv()
1877 Insert(t->RecvQueue, q); in ProcL2TPPacketRecv()
1883 if (LIST_NUM(t->RecvQueue) == 0) in ProcL2TPPacketRecv()
1888 q = LIST_DATA(t->RecvQueue, 0); in ProcL2TPPacketRecv()
1902 Delete(t->RecvQueue, q); in ProcL2TPPacketRecv()
|
| H A D | Interop_SSTP.h | 198 QUEUE *RecvQueue; // Receive queue member
|
| H A D | IPsec_L2TP.h | 291 LIST *RecvQueue; // Reception queue member
|
| H A D | Virtual.c | 1100 LockQueue(t->RecvQueue); in NnPoll()
1104 PKT *pkt = GetNext(t->RecvQueue); in NnPoll()
1116 UnlockQueue(t->RecvQueue); in NnPoll()
1855 LockQueue(t->RecvQueue); in NnMainLoop()
1958 InsertQueue(t->RecvQueue, pkt); in NnMainLoop()
1970 UnlockQueue(t->RecvQueue); in NnMainLoop()
2999 LockQueue(t->RecvQueue); in NnClearQueue()
3003 PKT *p = GetNext(t->RecvQueue); in NnClearQueue()
3013 UnlockQueue(t->RecvQueue); in NnClearQueue()
3225 t->RecvQueue = NewQueue(); in NewNativeNat()
[all …]
|
| H A D | Virtual.h | 177 QUEUE *RecvQueue; // Reception queue member
|
| /dports/security/softether/v4.38-9760/src/Cedar/ |
| H A D | Interop_SSTP.c | 296 BLOCK *b = GetNext(s->RecvQueue); in SstpProcessInterrupt()
953 s->RecvQueue = NewQueueFast(); in NewSstpServer()
978 BLOCK *b = GetNext(s->RecvQueue); in FreeSstpServer()
1000 ReleaseQueue(s->RecvQueue); in FreeSstpServer()
1092 InsertQueue(sstp->RecvQueue, b); in ProcessSstpHttps()
|
| H A D | IPsec_L2TP.c | 997 t->RecvQueue = NewList(CmpL2TPQueueForRecv); in NewL2TPTunnel()
1141 for (i = 0;i < LIST_NUM(t->RecvQueue);i++) in FreeL2TPTunnel()
1143 L2TP_QUEUE *q = LIST_DATA(t->RecvQueue, i); in FreeL2TPTunnel()
1148 ReleaseList(t->RecvQueue); in FreeL2TPTunnel()
1866 if (LIST_NUM(t->RecvQueue) < L2TP_WINDOW_SIZE) in ProcL2TPPacketRecv()
1871 if (Search(t->RecvQueue, &tt) == NULL) in ProcL2TPPacketRecv()
1877 Insert(t->RecvQueue, q); in ProcL2TPPacketRecv()
1883 if (LIST_NUM(t->RecvQueue) == 0) in ProcL2TPPacketRecv()
1888 q = LIST_DATA(t->RecvQueue, 0); in ProcL2TPPacketRecv()
1902 Delete(t->RecvQueue, q); in ProcL2TPPacketRecv()
|
| H A D | Interop_SSTP.h | 198 QUEUE *RecvQueue; // Receive queue member
|
| H A D | IPsec_L2TP.h | 291 LIST *RecvQueue; // Reception queue member
|
| H A D | Virtual.c | 1100 LockQueue(t->RecvQueue); in NnPoll()
1104 PKT *pkt = GetNext(t->RecvQueue); in NnPoll()
1116 UnlockQueue(t->RecvQueue); in NnPoll()
1855 LockQueue(t->RecvQueue); in NnMainLoop()
1958 InsertQueue(t->RecvQueue, pkt); in NnMainLoop()
1970 UnlockQueue(t->RecvQueue); in NnMainLoop()
2999 LockQueue(t->RecvQueue); in NnClearQueue()
3003 PKT *p = GetNext(t->RecvQueue); in NnClearQueue()
3013 UnlockQueue(t->RecvQueue); in NnClearQueue()
3225 t->RecvQueue = NewQueue(); in NewNativeNat()
[all …]
|
| H A D | Virtual.h | 177 QUEUE *RecvQueue; // Reception queue member
|
| /dports/security/softether5/SoftEtherVPN-5.02.5180/src/Cedar/ |
| H A D | Proto_SSTP.c | 146 InsertQueue(server->RecvQueue, b); in SstpProcessData()
376 BLOCK *b = GetNext(s->RecvQueue); in SstpProcessInterrupt()
1029 s->RecvQueue = NewQueueFast(); in NewSstpServer()
1052 BLOCK *b = GetNext(s->RecvQueue); in FreeSstpServer()
1074 ReleaseQueue(s->RecvQueue); in FreeSstpServer()
|
| H A D | Proto_L2TP.c | 913 t->RecvQueue = NewList(CmpL2TPQueueForRecv); in NewL2TPTunnel()
1057 for (i = 0;i < LIST_NUM(t->RecvQueue);i++) in FreeL2TPTunnel()
1059 L2TP_QUEUE *q = LIST_DATA(t->RecvQueue, i); in FreeL2TPTunnel()
1064 ReleaseList(t->RecvQueue); in FreeL2TPTunnel()
1782 if (LIST_NUM(t->RecvQueue) < L2TP_WINDOW_SIZE) in ProcL2TPPacketRecv()
1787 if (Search(t->RecvQueue, &tt) == NULL) in ProcL2TPPacketRecv()
1793 Insert(t->RecvQueue, q); in ProcL2TPPacketRecv()
1799 if (LIST_NUM(t->RecvQueue) == 0) in ProcL2TPPacketRecv()
1804 q = LIST_DATA(t->RecvQueue, 0); in ProcL2TPPacketRecv()
1818 Delete(t->RecvQueue, q); in ProcL2TPPacketRecv()
|
| H A D | Proto_SSTP.h | 104 QUEUE *RecvQueue; // Receive queue member
|
| H A D | Proto_L2TP.h | 197 LIST *RecvQueue; // Reception queue member
|
| H A D | Virtual.c | 1018 LockQueue(t->RecvQueue); in NnPoll()
1022 PKT *pkt = GetNext(t->RecvQueue); in NnPoll()
1034 UnlockQueue(t->RecvQueue); in NnPoll()
1773 LockQueue(t->RecvQueue); in NnMainLoop()
1876 InsertQueue(t->RecvQueue, pkt); in NnMainLoop()
1888 UnlockQueue(t->RecvQueue); in NnMainLoop()
2913 LockQueue(t->RecvQueue); in NnClearQueue()
2917 PKT *p = GetNext(t->RecvQueue); in NnClearQueue()
2927 UnlockQueue(t->RecvQueue); in NnClearQueue()
3139 t->RecvQueue = NewQueue(); in NewNativeNat()
[all …]
|
| H A D | Virtual.h | 83 QUEUE *RecvQueue; // Reception queue member
|
| /dports/comms/hylafax/hylafax-6.0.7/hfaxd/ |
| H A D | Makefile.in | 53 RecvQueue.c++ \
|
| /dports/math/dune-uggrid/dune-uggrid-bc2d1229420367563410ce9e519f5ff82b45266f/dune/uggrid/parallel/ddd/ |
| H A D | dddcontext.hh | 21 MSG_DESC *RecvQueue = nullptr; member
|