Home
last modified time | relevance | path

Searched refs:receiveSize (Results 1 – 25 of 73) sorted by relevance

123

/dports/emulators/ppsspp-qt5/ppsspp-1.12.3/Core/HLE/
H A DsceKernelMsgPipe.cpp441 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 DsceKernelMsgPipe.h27 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 DsceKernelMsgPipe.cpp441 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 DsceKernelMsgPipe.h27 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 DsceKernelMsgPipe.cpp441 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 DsceKernelMsgPipe.h27 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 Dsingle_command.go51 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 Dadmin_command.go431 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 Dmulti_command.go131 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 Dlogin_command.go105 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 Dquery_aggregate_command.go53 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 Dread_command.go133 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 Dserver_command.go35 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 DOrangutanSerial.cpp243 …{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 DOrangutanSerial.h73 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 DVideoStream.c74 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 DRtpFecQueue.c121 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 DvtkDistributedPointCloudFilter.cxx489 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 DvtkDistributedPointCloudFilter.cxx486 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 DTCP_Transporter.cpp86 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 DSocket.Unix.cs59 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 DTCP_Transporter.cpp113 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 DTCP_Transporter.cpp113 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 DTCP_Transporter.cpp113 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 DTCP_Transporter.cpp107 receiveCount(0), receiveSize(0), in TCP_Transporter()
440 receiveSize += nBytesRead; in doReceive()
445 receiveCount, receiveSize); in doReceive()
447 receiveSize = 0; in doReceive()

123