Home
last modified time | relevance | path

Searched refs:nBytes (Results 1 – 5 of 5) sorted by relevance

/thrift-3.4.0/lib/netstd/Thrift/Transport/Client/
DTNamedPipeTransport.cs98 var nBytes = Math.Min(15 * 4096, length); // 16 would exceed the limit in WriteAsync()
99 while (nBytes > 0) in WriteAsync()
102 await PipeStream.WriteAsync(buffer, offset, nBytes, cancellationToken); in WriteAsync()
104 await PipeStream.WriteAsync(buffer.AsMemory(offset, nBytes), cancellationToken); in WriteAsync()
106 offset += nBytes; in WriteAsync()
107 length -= nBytes; in WriteAsync()
108 nBytes = Math.Min(nBytes, length); in WriteAsync()
/thrift-3.4.0/lib/netstd/Thrift/Transport/Server/
DTNamedPipeServerTransport.cs423 var nBytes = Math.Min(15 * 4096, length); // 16 would exceed the limit in WriteAsync()
424 while (nBytes > 0) in WriteAsync()
427 await PipeStream.WriteAsync(buffer.AsMemory(offset, nBytes), cancellationToken); in WriteAsync()
429 await PipeStream.WriteAsync(buffer, offset, nBytes, cancellationToken); in WriteAsync()
431 offset += nBytes; in WriteAsync()
432 length -= nBytes; in WriteAsync()
433 nBytes = Math.Min(nBytes, length); in WriteAsync()
/thrift-3.4.0/lib/delphi/src/
DThrift.Transport.Pipes.pas386 var cbWritten, nBytes : DWORD;
395 nBytes := Min( 15*4096, count); // 16 would exceed the limit
398 while nBytes > 0 do begin
399 if not WriteFile( FPipe, pData^, nBytes, cbWritten, nil)
404 nBytes := Min( nBytes, count);
410 var cbWritten, dwWait, dwError, nBytes : DWORD;
420 nBytes := Min( 15*4096, count); // 16 would exceed the limit
423 while nBytes > 0 do begin
425 if not WriteFile( FPipe, pData^, nBytes, cbWritten, overlapped.OverlappedPtr)
447 ASSERT( DWORD(nBytes) = cbWritten);
[all …]
DThrift.Transport.pas1655 nBytes : Integer;
1670 wfd := WaitForData( msecs, pTmp, count, wsaError, nBytes);
1690 ASSERT( nBytes <= count);
1691 nBytes := FTcpClient.ReceiveBuf( pTmp^, nBytes);
1692 Inc( pTmp, nBytes);
1693 Dec( count, nBytes);
1694 Inc( result, nBytes);
1748 var nBytes : Integer;
1757 nBytes := FTcpClient.Read( pTmp^, count);
1758 if nBytes = 0 then Exit;
[all …]
/thrift-3.4.0/lib/cpp/src/thrift/server/
DTNonblockingServer.cpp1392 long nBytes = recv(fd, cast_sockopt(&connection), kSize, 0); in createNotificationPipe() local
1393 if (nBytes == kSize) { in createNotificationPipe()
1400 } else if (nBytes > 0) { in createNotificationPipe()
1402 GlobalOutput.printf("notifyHandler: Bad read of %d bytes, wanted %d", nBytes, kSize); in createNotificationPipe()
1405 } else if (nBytes == 0) { in createNotificationPipe()