/dports/emulators/ppsspp-qt5/ppsspp-1.12.3/Core/HLE/ |
H A D | sceKernelMsgPipe.cpp | 441 while (!m->sendWaitingThreads.empty() && receiveSize != 0) in __KernelReceiveMsgPipe() 446 u32 bytesToReceive = std::min(thread->freeSize, receiveSize); in __KernelReceiveMsgPipe() 450 receiveSize -= bytesToReceive; in __KernelReceiveMsgPipe() 464 if (receiveSize != 0 && (waitMode != SCE_KERNEL_MPW_ASAP || curReceiveAddr == receiveBufAddr)) in __KernelReceiveMsgPipe() 484 if (receiveSize > (u32) m->nmp.bufSize) in __KernelReceiveMsgPipe() 492 u32 bytesToReceive = std::min(receiveSize, m->GetUsedSize()); in __KernelReceiveMsgPipe() 499 receiveSize -= bytesToReceive; in __KernelReceiveMsgPipe() 507 if (receiveSize != 0 && (waitMode != SCE_KERNEL_MPW_ASAP || curReceiveAddr == receiveBufAddr)) in __KernelReceiveMsgPipe() 869 if (receiveSize & 0x80000000) in __KernelValidateReceiveMsgPipe() 871 ERROR_LOG(SCEKERNEL, "__KernelReceiveMsgPipe(%d): illegal size %d", uid, receiveSize); in __KernelValidateReceiveMsgPipe() [all …]
|
H A D | sceKernelMsgPipe.h | 27 int sceKernelReceiveMsgPipe(SceUID uid, u32 receiveBufAddr, u32 receiveSize, u32 waitMode, u32 resu… 28 int sceKernelReceiveMsgPipeCB(SceUID uid, u32 receiveBufAddr, u32 receiveSize, u32 waitMode, u32 re… 29 int sceKernelTryReceiveMsgPipe(SceUID uid, u32 receiveBufAddr, u32 receiveSize, u32 waitMode, u32 r…
|
/dports/emulators/ppsspp/ppsspp-1.12.3/Core/HLE/ |
H A D | sceKernelMsgPipe.cpp | 441 while (!m->sendWaitingThreads.empty() && receiveSize != 0) in __KernelReceiveMsgPipe() 446 u32 bytesToReceive = std::min(thread->freeSize, receiveSize); in __KernelReceiveMsgPipe() 450 receiveSize -= bytesToReceive; in __KernelReceiveMsgPipe() 464 if (receiveSize != 0 && (waitMode != SCE_KERNEL_MPW_ASAP || curReceiveAddr == receiveBufAddr)) in __KernelReceiveMsgPipe() 484 if (receiveSize > (u32) m->nmp.bufSize) in __KernelReceiveMsgPipe() 492 u32 bytesToReceive = std::min(receiveSize, m->GetUsedSize()); in __KernelReceiveMsgPipe() 499 receiveSize -= bytesToReceive; in __KernelReceiveMsgPipe() 507 if (receiveSize != 0 && (waitMode != SCE_KERNEL_MPW_ASAP || curReceiveAddr == receiveBufAddr)) in __KernelReceiveMsgPipe() 869 if (receiveSize & 0x80000000) in __KernelValidateReceiveMsgPipe() 871 ERROR_LOG(SCEKERNEL, "__KernelReceiveMsgPipe(%d): illegal size %d", uid, receiveSize); in __KernelValidateReceiveMsgPipe() [all …]
|
H A D | sceKernelMsgPipe.h | 27 int sceKernelReceiveMsgPipe(SceUID uid, u32 receiveBufAddr, u32 receiveSize, u32 waitMode, u32 resu… 28 int sceKernelReceiveMsgPipeCB(SceUID uid, u32 receiveBufAddr, u32 receiveSize, u32 waitMode, u32 re… 29 int sceKernelTryReceiveMsgPipe(SceUID uid, u32 receiveBufAddr, u32 receiveSize, u32 waitMode, u32 r…
|
/dports/emulators/libretro-ppsspp/ppsspp-1.12.3/Core/HLE/ |
H A D | sceKernelMsgPipe.cpp | 441 while (!m->sendWaitingThreads.empty() && receiveSize != 0) in __KernelReceiveMsgPipe() 446 u32 bytesToReceive = std::min(thread->freeSize, receiveSize); in __KernelReceiveMsgPipe() 450 receiveSize -= bytesToReceive; in __KernelReceiveMsgPipe() 464 if (receiveSize != 0 && (waitMode != SCE_KERNEL_MPW_ASAP || curReceiveAddr == receiveBufAddr)) in __KernelReceiveMsgPipe() 484 if (receiveSize > (u32) m->nmp.bufSize) in __KernelReceiveMsgPipe() 492 u32 bytesToReceive = std::min(receiveSize, m->GetUsedSize()); in __KernelReceiveMsgPipe() 499 receiveSize -= bytesToReceive; in __KernelReceiveMsgPipe() 507 if (receiveSize != 0 && (waitMode != SCE_KERNEL_MPW_ASAP || curReceiveAddr == receiveBufAddr)) in __KernelReceiveMsgPipe() 869 if (receiveSize & 0x80000000) in __KernelValidateReceiveMsgPipe() 871 ERROR_LOG(SCEKERNEL, "__KernelReceiveMsgPipe(%d): illegal size %d", uid, receiveSize); in __KernelValidateReceiveMsgPipe() [all …]
|
H A D | sceKernelMsgPipe.h | 27 int sceKernelReceiveMsgPipe(SceUID uid, u32 receiveBufAddr, u32 receiveSize, u32 waitMode, u32 resu… 28 int sceKernelReceiveMsgPipeCB(SceUID uid, u32 receiveBufAddr, u32 receiveSize, u32 waitMode, u32 re… 29 int sceKernelTryReceiveMsgPipe(SceUID uid, u32 receiveBufAddr, u32 receiveSize, u32 waitMode, u32 r…
|
/dports/security/vault/vault-1.8.2/vendor/github.com/aerospike/aerospike-client-go/ |
H A D | single_command.go | 51 receiveSize := int(sz&0xFFFFFFFFFFFF) - int(headerLength) 54 if receiveSize > 0 { 55 if err := cmd.sizeBufferSz(receiveSize, false); err != nil { 58 if _, err := conn.Read(cmd.dataBuffer, receiveSize); err != nil {
|
H A D | admin_command.go | 431 receiveSize := (size & 0xFFFFFFFFFFFF) 433 if receiveSize > 0 { 434 if receiveSize > int64(len(acmd.dataBuffer)) { 435 acmd.dataBuffer = make([]byte, receiveSize) 456 for acmd.dataOffset < receiveSize { 568 receiveSize := int(size & 0xFFFFFFFFFFFF) 570 if receiveSize > 0 { 571 if receiveSize > len(acmd.dataBuffer) { 572 acmd.dataBuffer = make([]byte, receiveSize) 577 status, list, err = acmd.parseRolesFull(receiveSize) [all …]
|
H A D | multi_command.go | 131 receiveSize := int(proto & 0xFFFFFFFFFFFF) 132 if receiveSize <= 0 { 143 receiveSize = int(Buffer.BytesToInt64(cmd.dataBuffer, 0)) - 8 161 if receiveSize > 0 { 162 cmd.bc.reset(receiveSize) 164 status, err = ifc.parseRecordResults(ifc, receiveSize) 232 func (cmd *baseMultiCommand) parseRecordResults(ifc command, receiveSize int) (bool, error) { 236 for cmd.dataOffset < receiveSize {
|
H A D | login_command.go | 105 receiveSize := int((sz & 0xFFFFFFFFFFFF) - int64(_HEADER_REMAINING)) 108 if receiveSize <= 0 || receiveSize > len(lcmd.dataBuffer) || fieldCount <= 0 { 112 if len(lcmd.dataBuffer) < receiveSize { 113 lcmd.dataBuffer = make([]byte, receiveSize) 116 _, err := conn.Read(lcmd.dataBuffer, receiveSize)
|
H A D | query_aggregate_command.go | 53 func (cmd *queryAggregateCommand) parseRecordResults(ifc command, receiveSize int) (bool, error) { 57 for cmd.dataOffset < receiveSize { 67 if cmd.dataOffset < receiveSize { 68 if err := cmd.readBytes(receiveSize - cmd.dataOffset); err != nil {
|
H A D | read_command.go | 133 receiveSize := int((sz & 0xFFFFFFFFFFFF) - int64(headerLength)) 136 if receiveSize > 0 { 137 if err = cmd.sizeBufferSz(receiveSize, false); err != nil { 140 _, err = conn.Read(cmd.dataBuffer, receiveSize)
|
H A D | server_command.go | 35 func (cmd *serverCommand) parseRecordResults(ifc command, receiveSize int) (bool, error) { 41 for cmd.dataOffset < receiveSize {
|
/dports/devel/libpololu-avr/libpololu-avr-151002/src/OrangutanSerial/ |
H A D | OrangutanSerial.cpp | 243 …{mode:SERIAL_AUTOMATIC, sentBytes:0, receivedBytes:0, sendSize:0, receiveSize:0, receiveRingOn:0, … 245 …{mode:SERIAL_AUTOMATIC, sentBytes:0, receivedBytes:0, sendSize:0, receiveSize:0, receiveRingOn:0, … 246 …{mode:SERIAL_CHECK, sentBytes:0, receivedBytes:0, sendSize:0, receiveSize:0, receiveRingOn:0, … 471 …if(ports[port].receiveBuffer && ports[port].receivedBytes < ports[port].receiveSize && *ucsra(port… in serial_rx_check() 486 …COMM].receiveBuffer && ports[USB_COMM].receivedBytes < ports[USB_COMM].receiveSize && BYTES_RECEIV… in serial_rx_check() 494 if(ports[USB_COMM].receivedBytes == ports[USB_COMM].receiveSize && ports[USB_COMM].receiveRingOn) in serial_rx_check() 513 if(ports[port].receiveBuffer && ports[port].receivedBytes < ports[port].receiveSize) in serial_rx_handle_byte() 518 if(ports[port].receivedBytes == ports[port].receiveSize && ports[port].receiveRingOn) in serial_rx_handle_byte() 534 ports[port].receiveSize = size; in receive_inline()
|
H A D | OrangutanSerial.h | 73 unsigned char receiveSize; member 151 static inline char receiveBufferFull() { return getReceivedBytes() == ports[0].receiveSize; } in receiveBufferFull() 171 …receiveBufferFull(unsigned char port) { return getReceivedBytes(port) == ports[port].receiveSize; } in receiveBufferFull()
|
/dports/games/moonlight-embedded/moonlight-embedded-2.4.11/third_party/moonlight-common-c/src/ |
H A D | VideoStream.c | 74 int bufferSize, receiveSize; in ReceiveThreadProc() local 79 receiveSize = StreamConfig.packetSize + MAX_RTP_HEADER_SIZE; in ReceiveThreadProc() 80 bufferSize = receiveSize + sizeof(RTPFEC_QUEUE_ENTRY); in ReceiveThreadProc() 104 err = recvUdpSocket(rtpSocket, buffer, receiveSize, useSelect); in ReceiveThreadProc() 125 … queueStatus = RtpfAddPacket(&rtpQueue, packet, err, (PRTPFEC_QUEUE_ENTRY)&buffer[receiveSize]); in ReceiveThreadProc()
|
H A D | RtpFecQueue.c | 121 int receiveSize = StreamConfig.packetSize + MAX_RTP_HEADER_SIZE; in reconstructFrame() local 122 int packetBufferSize = receiveSize + sizeof(RTPFEC_QUEUE_ENTRY); in reconstructFrame() 131 if (entry->length < receiveSize) { in reconstructFrame() 132 memset(&packets[index][entry->length], 0, receiveSize - entry->length); in reconstructFrame() 149 ret = reed_solomon_reconstruct(rs, packets, marks, totalPackets, receiveSize); in reconstructFrame() 160 PRTPFEC_QUEUE_ENTRY queueEntry = (PRTPFEC_QUEUE_ENTRY)&packets[i][receiveSize]; in reconstructFrame()
|
/dports/math/vtk9/VTK-9.1.0/Filters/ParallelMPI/ |
H A D | vtkDistributedPointCloudFilter.cxx | 489 std::vector<vtkIdType> receiveSize(np); in GetPointsInsideBounds() local 494 com->Gather(messagesSize.data() + i, receiveSize.data(), 1, i); in GetPointsInsideBounds() 504 if (receiveSize[partner] > 0) in GetPointsInsideBounds() 507 com->NoBlockReceive(dataToReceive[partner]->WritePointer(0, receiveSize[partner]), in GetPointsInsideBounds() 508 receiveSize[partner], partner, 0, receiveRequests[partner]); in GetPointsInsideBounds() 517 if (receiveSize[rank] > 0) in GetPointsInsideBounds() 545 if ((partner == rank || receiveRequests[partner].Test() == 1) && receiveSize[partner] > 0) in GetPointsInsideBounds() 593 receiveSize[partner] = 0; in GetPointsInsideBounds()
|
/dports/math/vtk8/VTK-8.2.0/Filters/ParallelMPI/ |
H A D | vtkDistributedPointCloudFilter.cxx | 486 std::vector<vtkIdType> receiveSize(np); in GetPointsInsideBounds() local 491 com->Gather(messagesSize.data() + i, receiveSize.data(), 1, i); in GetPointsInsideBounds() 501 if (receiveSize[partner] > 0) in GetPointsInsideBounds() 504 com->NoBlockReceive(dataToReceive[partner]->WritePointer(0, receiveSize[partner]), in GetPointsInsideBounds() 505 receiveSize[partner], partner, 0, receiveRequests[partner]); in GetPointsInsideBounds() 514 if (receiveSize[rank] > 0) in GetPointsInsideBounds() 542 if ((partner == rank || receiveRequests[partner].Test() == 1) && receiveSize[partner] > 0) in GetPointsInsideBounds() 590 receiveSize[partner] = 0; in GetPointsInsideBounds()
|
/dports/databases/mysql55-client/mysql-5.5.62/storage/ndb/src/common/transporter/ |
H A D | TCP_Transporter.cpp | 86 sendSize = receiveSize = 0; in TCP_Transporter() 395 receiveSize += nBytesRead; in doReceive() 398 reportReceiveLen(get_callback_obj(), remoteNodeId, receiveCount, receiveSize); in doReceive() 400 receiveSize = 0; in doReceive()
|
/dports/lang/mono/mono-5.10.1.57/external/corefx/src/System.Net.Sockets/src/System/Net/Sockets/ |
H A D | Socket.Unix.cs | 59 int receiveSize = -1, receiveTimeout = -1, sendSize = -1, sendTimeout = -1; in ReplaceHandle() 66 …if (_handle.IsTrackedOption(TrackedSocketOptions.ReceiveBufferSize)) receiveSize = ReceiveBufferSi… in ReplaceHandle() 90 … (_handle.IsTrackedOption(TrackedSocketOptions.ReceiveBufferSize)) ReceiveBufferSize = receiveSize; in ReplaceHandle()
|
/dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/ndb/src/common/transporter/ |
H A D | TCP_Transporter.cpp | 113 sendSize = receiveSize = 0; in TCP_Transporter() 424 receiveSize += nBytesRead; in doReceive() 428 receiveCount, receiveSize); in doReceive() 430 receiveSize = 0; in doReceive()
|
/dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/ndb/src/common/transporter/ |
H A D | TCP_Transporter.cpp | 113 sendSize = receiveSize = 0; in TCP_Transporter() 424 receiveSize += nBytesRead; in doReceive() 428 receiveCount, receiveSize); in doReceive() 430 receiveSize = 0; in doReceive()
|
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/ndb/src/common/transporter/ |
H A D | TCP_Transporter.cpp | 113 sendSize = receiveSize = 0; in TCP_Transporter() 424 receiveSize += nBytesRead; in doReceive() 428 receiveCount, receiveSize); in doReceive() 430 receiveSize = 0; in doReceive()
|
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/ndb/src/common/transporter/ |
H A D | TCP_Transporter.cpp | 107 receiveCount(0), receiveSize(0), in TCP_Transporter() 440 receiveSize += nBytesRead; in doReceive() 445 receiveCount, receiveSize); in doReceive() 447 receiveSize = 0; in doReceive()
|