Searched refs:Bucket (Results 1 – 6 of 6) sorted by relevance
30 Complete(Bucket->Request.RequestContext, Bucket->Status, Bucket->Information); in BucketCompletionWorker()55 PTDI_BUCKET Bucket; in FlushReceiveQueue() local76 PTDI_BUCKET Bucket; in FlushSendQueue() local97 PTDI_BUCKET Bucket; in FlushShutdownQueue() local118 PTDI_BUCKET Bucket; in FlushConnectQueue() local138 PTDI_BUCKET Bucket; in FlushListenQueue() local234 PTDI_BUCKET Bucket; in TCPAcceptEventHandler() local297 PTDI_BUCKET Bucket; in TCPSendEventHandler() local354 Bucket->Information = (Bucket->Status == STATUS_SUCCESS) ? BytesSent : 0; in TCPSendEventHandler()383 PTDI_BUCKET Bucket; in TCPRecvEventHandler() local[all …]
42 PTDI_BUCKET Bucket; in DisconnectWorker() local55 Bucket->Information = 0; in DisconnectWorker()68 Bucket->Information = 0; in DisconnectWorker()313 PTDI_BUCKET Bucket; in TCPConnect() local398 if (!Bucket) in TCPConnect()436 PTDI_BUCKET Bucket; in TCPDisconnect() local537 PTDI_BUCKET Bucket; in TCPReceiveData() local552 if (!Bucket) in TCPReceiveData()589 PTDI_BUCKET Bucket; in TCPSendData() local613 if (!Bucket) in TCPSendData()[all …]
112 PTDI_BUCKET Bucket; in TCPAbortListenForSocket() local120 Bucket = CONTAINING_RECORD(ListEntry, TDI_BUCKET, Entry); in TCPAbortListenForSocket()122 if (Bucket->AssociatedEndpoint == Connection) in TCPAbortListenForSocket()124 DereferenceObject(Bucket->AssociatedEndpoint); in TCPAbortListenForSocket()125 RemoveEntryList( &Bucket->Entry ); in TCPAbortListenForSocket()146 PTDI_BUCKET Bucket; in TCPAccept() local152 if (Bucket) in TCPAccept()154 Bucket->AssociatedEndpoint = Connection; in TCPAccept()155 ReferenceObject(Bucket->AssociatedEndpoint); in TCPAccept()157 Bucket->Request.RequestNotifyObject = Complete; in TCPAccept()[all …]
215 VOID CompleteBucket(PCONNECTION_ENDPOINT Connection, PTDI_BUCKET Bucket, const BOOLEAN Synchronous);
2687 USHORT Bucket; in RxFinalizeConnection() local2694 for (Bucket = 0; Bucket < FcbTable->NumberOfBuckets; ++Bucket) in RxFinalizeConnection()2698 BucketList = &FcbTable->HashBuckets[Bucket]; in RxFinalizeConnection()2814 USHORT Bucket; in RxFinalizeFcbTable() local2822 for (Bucket = 0; Bucket < FcbTable->NumberOfBuckets; ++Bucket) in RxFinalizeFcbTable()3091 USHORT Bucket; in RxFinalizeNetRoot() local3095 for (Bucket = 0; Bucket < FcbTable->NumberOfBuckets; ++Bucket) in RxFinalizeNetRoot()3099 HashBucket = &FcbTable->HashBuckets[Bucket]; in RxFinalizeNetRoot()5821 USHORT Bucket; in RxOrphanSrvOpens() local5844 for (Bucket = 0; Bucket < FcbTable->NumberOfBuckets; ++Bucket) in RxOrphanSrvOpens()[all …]
2409 USHORT Bucket; in nfs41_DevFcbXXXControlFile() local2418 … for (Bucket = 0; Bucket < RxContext->RxDeviceObject->pRxNetNameTable->TableSize; ++Bucket) in nfs41_DevFcbXXXControlFile()2422 … for (Entry = RxContext->RxDeviceObject->pRxNetNameTable->HashBuckets[Bucket].Flink; in nfs41_DevFcbXXXControlFile()2423 … Entry != &RxContext->RxDeviceObject->pRxNetNameTable->HashBuckets[Bucket]; in nfs41_DevFcbXXXControlFile()