Home
last modified time | relevance | path

Searched refs:SendPacketQueue (Results 1 – 13 of 13) sorted by relevance

/dports/net/zerotier/ZeroTierOne-1.8.3/windows/TapDriver6/
H A Dtxpath.c350 KeAcquireSpinLock(&Adapter->SendPacketQueue.QueueLock,&irql); in tapProcessSendPacketQueue()
352 while(Adapter->SendPacketQueue.Count > 0 ) in tapProcessSendPacketQueue()
371 &Adapter->SendPacketQueue in tapProcessSendPacketQueue()
390 KeReleaseSpinLock(&Adapter->SendPacketQueue.QueueLock,irql); in tapProcessSendPacketQueue()
402 KeAcquireSpinLock(&Adapter->SendPacketQueue.QueueLock,&irql); in tapFlushSendPacketQueue()
405 Adapter->SendPacketQueue.Count)); in tapFlushSendPacketQueue()
407 while(Adapter->SendPacketQueue.Count > 0 ) in tapFlushSendPacketQueue()
413 &Adapter->SendPacketQueue in tapFlushSendPacketQueue()
422 KeReleaseSpinLock(&Adapter->SendPacketQueue.QueueLock,irql); in tapFlushSendPacketQueue()
686 tapPacketQueueInsertTail(&Adapter->SendPacketQueue,tapPacket); in tapAdapterTransmit()
H A Ddevice.c686 (int)adapter->SendPacketQueue.Count, in TapDeviceControl()
687 (int)adapter->SendPacketQueue.MaxCount, in TapDeviceControl()
855 ASSERT(adapter->SendPacketQueue.Count == 0); in TapDeviceCleanup()
1161 ASSERT(Adapter->SendPacketQueue.Count == 0); in DestroyTapDevice()
H A Dadapter.h164 TAP_PACKET_QUEUE SendPacketQueue; member
H A Dadapter.c109 tapPacketQueueInitialize(&adapter->SendPacketQueue); in tapAdapterContextAllocate()
/dports/security/softether-devel/v4.36-9754/src/Cedar/
H A DLink.c173 k->SendPacketQueue = NewQueue(); in LinkPaInit()
216 LockQueue(k->SendPacketQueue); in LinkPaGetNextPacket()
218 BLOCK *block = GetNext(k->SendPacketQueue); in LinkPaGetNextPacket()
232 UnlockQueue(k->SendPacketQueue); in LinkPaGetNextPacket()
365 LockQueue(k->SendPacketQueue); in LinkPaFree()
368 while (block = GetNext(k->SendPacketQueue)) in LinkPaFree()
373 UnlockQueue(k->SendPacketQueue); in LinkPaFree()
375 ReleaseQueue(k->SendPacketQueue); in LinkPaFree()
H A DLink.h123 QUEUE *SendPacketQueue; // Transmission packet queue member
H A DConnection.c1539 LockQueue(k->SendPacketQueue); in ConnectionSend()
1548 if (k->SendPacketQueue->num_item >= MAX_STORED_QUEUE_NUM) in ConnectionSend()
1556 InsertQueue(k->SendPacketQueue, block); in ConnectionSend()
1560 UnlockQueue(k->SendPacketQueue); in ConnectionSend()
/dports/security/softether/v4.38-9760/src/Cedar/
H A DLink.c173 k->SendPacketQueue = NewQueue(); in LinkPaInit()
216 LockQueue(k->SendPacketQueue); in LinkPaGetNextPacket()
218 BLOCK *block = GetNext(k->SendPacketQueue); in LinkPaGetNextPacket()
232 UnlockQueue(k->SendPacketQueue); in LinkPaGetNextPacket()
365 LockQueue(k->SendPacketQueue); in LinkPaFree()
368 while (block = GetNext(k->SendPacketQueue)) in LinkPaFree()
373 UnlockQueue(k->SendPacketQueue); in LinkPaFree()
375 ReleaseQueue(k->SendPacketQueue); in LinkPaFree()
H A DLink.h123 QUEUE *SendPacketQueue; // Transmission packet queue member
H A DConnection.c1539 LockQueue(k->SendPacketQueue); in ConnectionSend()
1548 if (k->SendPacketQueue->num_item >= MAX_STORED_QUEUE_NUM) in ConnectionSend()
1556 InsertQueue(k->SendPacketQueue, block); in ConnectionSend()
1560 UnlockQueue(k->SendPacketQueue); in ConnectionSend()
/dports/security/softether5/SoftEtherVPN-5.02.5180/src/Cedar/
H A DLink.c90 k->SendPacketQueue = NewQueue(); in LinkPaInit()
133 LockQueue(k->SendPacketQueue); in LinkPaGetNextPacket()
135 BLOCK *block = GetNext(k->SendPacketQueue); in LinkPaGetNextPacket()
149 UnlockQueue(k->SendPacketQueue); in LinkPaGetNextPacket()
282 LockQueue(k->SendPacketQueue); in LinkPaFree()
285 while (block = GetNext(k->SendPacketQueue)) in LinkPaFree()
290 UnlockQueue(k->SendPacketQueue); in LinkPaFree()
292 ReleaseQueue(k->SendPacketQueue); in LinkPaFree()
H A DLink.h30 QUEUE *SendPacketQueue; // Transmission packet queue member
H A DConnection.c1494 LockQueue(k->SendPacketQueue); in ConnectionSend()
1503 if (k->SendPacketQueue->num_item >= MAX_STORED_QUEUE_NUM) in ConnectionSend()
1511 InsertQueue(k->SendPacketQueue, block); in ConnectionSend()
1515 UnlockQueue(k->SendPacketQueue); in ConnectionSend()