| /dports/www/srt/srt-1.4.4/srtcore/ |
| H A D | crypto.cpp | 742 EncryptionStatus CCryptoControl::encrypt(CPacket& w_packet SRT_ATR_UNUSED) in encrypt()
749 … = HaiCrypt_Tx_Data(m_hSndCrypto, ((uint8_t*)w_packet.getHeader()), ((uint8_t*)w_packet.m_pcData),… in encrypt()
758 w_packet.setLength(rc); in encrypt()
767 EncryptionStatus CCryptoControl::decrypt(CPacket& w_packet SRT_ATR_UNUSED) in decrypt()
770 if (w_packet.getMsgCryptoFlags() == EK_NOENC) in decrypt()
784 << w_packet.getLength() << " dropped"); in decrypt()
817 << " - dropping size=" << w_packet.getLength()); in decrypt()
821 …= HaiCrypt_Rx_Data(m_hRcvCrypto, ((uint8_t *)w_packet.getHeader()), ((uint8_t *)w_packet.m_pcData)… in decrypt()
830 w_packet.setLength(rc); /* In case clr txt size is different from cipher txt */ in decrypt()
833 w_packet.setMsgCryptoFlags(EK_NOENC); in decrypt()
|
| H A D | channel.cpp | 629 EReadStatus srt::CChannel::recvfrom(sockaddr_any& w_addr, CPacket& w_packet) const in recvfrom()
649 w_packet.setLength(-1); in recvfrom()
659 mh.msg_iov = (w_packet.m_PacketVector); in recvfrom()
730 DWORD size = (DWORD)(CPacket::HDR_SIZE + w_packet.getLength()); in recvfrom()
734 ((LPWSABUF)w_packet.m_PacketVector), in recvfrom()
812 w_packet.setLength(recv_size - CPacket::HDR_SIZE); in recvfrom()
819 uint32_t* p = w_packet.m_nHeader; in recvfrom()
827 if (w_packet.isControl()) in recvfrom()
829 for (size_t j = 0, n = w_packet.getLength() / sizeof(uint32_t); j < n; ++j) in recvfrom()
830 *((uint32_t*)w_packet.m_pcData + j) = ntohl(*((uint32_t*)w_packet.m_pcData + j)); in recvfrom()
[all …]
|
| H A D | packetfilter.cpp | 211 bool srt::PacketFilter::packControlPacket(int32_t seq, int kflg, CPacket& w_packet) in packControlPacket() argument
219 uint32_t* hdr = w_packet.getHeader(); in packControlPacket()
223 w_packet.m_pcData = m_sndctlpkt.buffer; in packControlPacket()
224 w_packet.setLength(m_sndctlpkt.length); in packControlPacket()
232 w_packet.m_iMsgNo = SRT_MSGNO_CONTROL | MSGNO_PACKET_BOUNDARY::wrap(PB_SOLO); in packControlPacket()
235 w_packet.setMsgCryptoFlags(EncryptionKeySpec(kflg)); in packControlPacket()
|
| H A D | packetfilter.h | 191 void feedSource(CPacket& w_packet);
193 bool packControlPacket(int32_t seq, int kflg, CPacket& w_packet);
212 …e void PacketFilter::feedSource(CPacket& w_packet) { SRT_ASSERT(m_filter); return m_filter->feedSo… in feedSource() argument
|
| H A D | crypto.h | 261 EncryptionStatus encrypt(srt::CPacket& w_packet);
268 EncryptionStatus decrypt(srt::CPacket& w_packet);
|
| H A D | queue.cpp | 666 int srt::CSndQueue::sendto(const sockaddr_any& w_addr, CPacket& w_packet) in sendto() argument
669 m_pChannel->sendto(w_addr, w_packet); in sendto()
670 return (int)w_packet.getLength(); in sendto()
1648 int srt::CRcvQueue::recvfrom(int32_t id, CPacket& w_packet) in recvfrom() argument
1664 w_packet.setLength(-1); in recvfrom()
1672 if (w_packet.getLength() < newpkt->getLength()) in recvfrom()
1674 w_packet.setLength(-1); in recvfrom()
1686 memcpy((w_packet.m_nHeader), newpkt->m_nHeader, CPacket::HDR_SIZE); in recvfrom()
1687 memcpy((w_packet.m_pcData), newpkt->m_pcData, newpkt->getLength()); in recvfrom()
1688 w_packet.setLength(newpkt->getLength()); in recvfrom()
[all …]
|
| H A D | buffer.cpp | 414 int CSndBuffer::readData(srt::CPacket& w_packet, steady_clock::time_point& w_srctime, int kflgs) in readData() argument
421 w_packet.m_pcData = m_pCurrBlock->m_pcData; in readData()
423 w_packet.setLength(readlen); in readData()
424 w_packet.m_iSeqNo = m_pCurrBlock->m_iSeqNo; in readData()
460 w_packet.m_iMsgNo = m_pCurrBlock->m_iMsgNoBitset; in readData()
515 int CSndBuffer::readData(const int offset, srt::CPacket& w_packet, steady_clock::time_point& w_srct… in readData() argument
517 int32_t& msgno_bitset = w_packet.m_iMsgNo; in readData()
584 w_packet.m_pcData = p->m_pcData; in readData()
586 w_packet.setLength(readlen); in readData()
594 w_packet.m_iMsgNo = p->m_iMsgNoBitset; in readData()
[all …]
|
| H A D | core.cpp | 8887 w_packet.m_iSeqNo, in packLostData()
8919 seqpair[0] = w_packet.m_iSeqNo; in packLostData()
8957 w_packet.m_iMsgNo |= PACKET_SND_REXMIT; in packLostData()
9005 payload = (int) w_packet.getLength(); in packData()
9055 … << " DIFF: " << packetspan << " STAMP:" << BufferStamp(w_packet.m_pcData, w_packet.getLength())); in packData()
9087 << " STAMP:" << BufferStamp(w_packet.m_pcData, w_packet.getLength())); in packData()
9142 setPacketTS(w_packet, origintime); in packData()
9158 w_packet.m_iID = m_PeerID; in packData()
9165 if (m_pCryptoControl->encrypt((w_packet))) in packData()
9180 m_PacketFilter.feedSource((w_packet)); in packData()
[all …]
|
| H A D | buffer.h | 148 int readData(srt::CPacket& w_packet, time_point& w_origintime, int kflgs);
157 int readData(const int offset, srt::CPacket& w_packet, time_point& w_origintime, int& w_msglen);
|
| /dports/games/xray_re-tools/xray_re-tools-52721d2/sources/xray_re/ |
| H A D | xr_level_spawn.cxx | 45 w.w_packet(packet); in save()
|
| H A D | xr_game_spawn.cxx | 108 w.w_packet(packet); in save_spawns()
116 w.w_packet(packet); in save_spawns()
|
| H A D | xr_scene_spawns.cxx | 122 w.w_packet(packet); in save()
|
| H A D | xr_writer.cxx | 89 void xr_writer::w_packet(const xr_packet& packet) in w_packet() function in xr_writer
|
| H A D | xr_writer.h | 69 void w_packet(const xr_packet& packet);
|