/dports/net-mgmt/thanos/thanos-0.11.0/vendor/go.mongodb.org/mongo-driver/x/network/wiremessage/ |
H A D | compressed.go | 16 MsgHeader Header member 31 if int(c.MsgHeader.MessageLength) != c.Len() { 35 if c.MsgHeader.OpCode != OpCompressed { 39 if c.OriginalOpCode != c.MsgHeader.OpCode { 51 err := c.MsgHeader.SetDefaults(c.Len(), OpCompressed) 53 b = c.MsgHeader.AppendHeader(b) 65 `OP_COMPRESSED{MsgHeader: %s, Uncompressed Size: %d, CompressorId: %d, Compressed message: %s}`, 66 c.MsgHeader, c.UncompressedSize, c.CompressorID, c.CompressedMessage, 79 c.MsgHeader, err = ReadHeader(b, 0) 84 if len(b) < int(c.MsgHeader.MessageLength) { [all …]
|
H A D | kill_cursors.go | 17 MsgHeader Header member 34 if int(kc.MsgHeader.MessageLength) != kc.Len() { 37 if kc.MsgHeader.OpCode != OpKillCursors { 50 err = kc.MsgHeader.SetDefaults(kc.Len(), OpKillCursors) 52 b = kc.MsgHeader.AppendHeader(b) 65 `OP_KILL_CURSORS{MsgHeader: %s, Zero: %d, Number of Cursor IDS: %d, Cursor IDs: %v}`, 66 kc.MsgHeader, kc.Zero, kc.NumberOfCursorIDs, kc.CursorIDs,
|
H A D | reply.go | 20 MsgHeader Header member 38 if int(r.MsgHeader.MessageLength) != r.Len() { 41 if r.MsgHeader.OpCode != OpReply { 57 err = r.MsgHeader.SetDefaults(r.Len(), OpReply) 59 b = r.MsgHeader.AppendHeader(b) 73 …`OP_REPLY{MsgHeader: %s, ResponseFlags: %s, CursorID: %d, StartingFrom: %d, NumberReturned: %d, Do… 74 r.MsgHeader, r.ResponseFlags, r.CursorID, r.StartingFrom, r.NumberReturned, r.Documents, 91 r.MsgHeader, err = ReadHeader(b, 0) 95 if r.MsgHeader.MessageLength < 36 { 98 if len(b) < int(r.MsgHeader.MessageLength) {
|
H A D | get_more.go | 18 MsgHeader Header member 33 if int(gm.MsgHeader.MessageLength) != gm.Len() { 36 if gm.MsgHeader.OpCode != OpGetMore { 55 err = gm.MsgHeader.SetDefaults(gm.Len(), OpGetMore) 57 b = gm.MsgHeader.AppendHeader(b) 68 `OP_GET_MORE{MsgHeader: %s, Zero: %d, FullCollectionName: %s, NumberToReturn: %d, CursorID: %d}`, 69 gm.MsgHeader, gm.Zero, gm.FullCollectionName, gm.NumberToReturn, gm.CursorID,
|
H A D | msg.go | 19 MsgHeader Header member 33 if int(m.MsgHeader.MessageLength) != m.Len() { 36 if m.MsgHeader.OpCode != OpMsg { 50 err = m.MsgHeader.SetDefaults(m.Len(), OpMsg) 52 b = m.MsgHeader.AppendHeader(b) 68 `OP_MSG{MsgHeader: %v, FlagBits: %d, Sections: %v, Checksum: %d}`, 69 m.MsgHeader, m.FlagBits, m.Sections, m.Checksum, 93 m.MsgHeader, err = ReadHeader(b, 0) 97 if len(b) < int(m.MsgHeader.MessageLength) { 107 sectionBytes := m.MsgHeader.MessageLength - 16 - 4 // number of bytes taken up by sections
|
H A D | query.go | 21 MsgHeader Header member 57 if int(q.MsgHeader.MessageLength) != q.Len() { 60 if q.MsgHeader.OpCode != OpQuery { 92 err = q.MsgHeader.SetDefaults(q.Len(), OpQuery) 94 b = q.MsgHeader.AppendHeader(b) 107 …`OP_QUERY{MsgHeader: %s, Flags: %s, FullCollectionname: %s, NumberToSkip: %d, NumberToReturn: %d, … 108 …q.MsgHeader, q.Flags, q.FullCollectionName, q.NumberToSkip, q.NumberToReturn, q.Query, q.ReturnFie… 121 q.MsgHeader, err = ReadHeader(b, 0) 125 if len(b) < int(q.MsgHeader.MessageLength) {
|
H A D | msg_test.go | 72 MsgHeader: Header{}, 86 MsgHeader: Header{}, 119 MsgHeader: msgHeader,
|
/dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/gotools/src/github.com/mongodb/mongo-tools/mongoreplay/ |
H A D | message.go | 21 type MsgHeader struct { struct 35 func ReadHeader(r io.Reader) (*MsgHeader, error) { 41 h := MsgHeader{} 47 func (m MsgHeader) ToWire() []byte { argument 58 func (m *MsgHeader) FromWire(b []byte) { argument 66 func (m *MsgHeader) WriteTo(w io.Writer) (int64, error) { argument 80 func (m *MsgHeader) LooksReal() bool { argument 97 func (m *MsgHeader) String() string { argument
|
/dports/databases/mongodb42-tools/mongo-tools-r4.2.17/mongoreplay/ |
H A D | message.go | 21 type MsgHeader struct { struct 35 func ReadHeader(r io.Reader) (*MsgHeader, error) { 41 h := MsgHeader{} 47 func (m MsgHeader) ToWire() []byte { argument 58 func (m *MsgHeader) FromWire(b []byte) { argument 66 func (m *MsgHeader) WriteTo(w io.Writer) (int64, error) { argument 80 func (m *MsgHeader) LooksReal() bool { argument 97 func (m *MsgHeader) String() string { argument
|
/dports/www/websh/websh-3.6.0b5/src/generic/ |
H A D | messages.c | 260 MsgHeader mh; in send_msg() 273 ret = Tcl_Write(f, (char *) &mh, sizeof(MsgHeader)); in send_msg() 281 if (ret != sizeof(MsgHeader)) { in send_msg() 285 sizeof(MsgHeader)); in send_msg() 306 sizeof(MsgHeader)); in send_msg() 331 MsgHeader mh; in receive_msg() 362 Tcl_Read(f, (char *) &mh.version, sizeof(MsgHeader) - sizeof(u_long)); in receive_msg() 369 if (ret != sizeof(MsgHeader) - sizeof(u_long)) { in receive_msg() 372 sizeof(MsgHeader) - sizeof(u_long)); in receive_msg()
|
H A D | messages.h | 40 typedef struct MsgHeader struct 47 MsgHeader; argument
|
/dports/security/snort/snort-2.9.18/src/file-process/ |
H A D | file_ss.c | 48 } MsgHeader; typedef 234 *data_ptr = (void *)(&file_io_buffer[0] + sizeof(MsgHeader)); in CreateFileSSUpdate() 246 if (Write(runtime_output_fd, file_io_buffer, sizeof(MsgHeader) + data_len) == -1) in SendFileSSUpdate() 335 MsgHeader *msg_header; in ReadFileSSMessagesFromFile() 352 msg_header = (MsgHeader *) msg; in ReadFileSSMessagesFromFile() 379 MsgHeader *msg_hdr; in WriteFileSSMsgHeader() 381 msg_hdr = (MsgHeader *) msg; in WriteFileSSMsgHeader()
|
/dports/security/snort/snort-2.9.18/src/dynamic-preprocessors/appid/ |
H A D | appId_ss.c | 50 } MsgHeader; typedef 177 MsgHeader *msg_header; in ReadAppIdSSMessagesFromFile() 195 msg_header = (MsgHeader *) msg; in ReadAppIdSSMessagesFromFile() 222 MsgHeader *msg_hdr; in WriteAppIdSSMsgHeader() 224 msg_hdr = (MsgHeader *) msg; in WriteAppIdSSMsgHeader() 254 *data_ptr = (void *)(&file_io_buffer[0] + sizeof(MsgHeader)); in CreateAppIdSSUpdate() 290 if (Write(runtime_output_fd, file_io_buffer, sizeof(MsgHeader) + data_len) == -1) in SendAppIdSSUpdate()
|
/dports/net-mgmt/thanos/thanos-0.11.0/vendor/go.mongodb.org/mongo-driver/x/network/connection/ |
H A D | connection.go | 278 requestID = converted.MsgHeader.RequestID 280 responseTo = converted.MsgHeader.ResponseTo 292 requestID = converted.MsgHeader.RequestID 294 responseTo = converted.MsgHeader.ResponseTo 313 MsgHeader: wiremessage.Header{ 347 RequestID: compressed.MsgHeader.RequestID, 348 ResponseTo: compressed.MsgHeader.ResponseTo, 399 startedEvent.RequestID = int64(converted.MsgHeader.RequestID) 424 startedEvent.RequestID = int64(converted.MsgHeader.RequestID) 525 requestID = int64(converted.MsgHeader.ResponseTo) [all …]
|
/dports/lang/gcc12-devel/gcc-12-20211205/gcc/testsuite/gdc.test/compilable/ |
H A D | ice10040.d | 4 struct MsgHeader {} struct 8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
|
/dports/lang/gcc10/gcc-10.3.0/gcc/testsuite/gdc.test/compilable/ |
H A D | ice10040.d | 4 struct MsgHeader {} struct 8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
|
/dports/lang/gcc11/gcc-11.2.0/gcc/testsuite/gdc.test/compilable/ |
H A D | ice10040.d | 4 struct MsgHeader {} struct 8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
|
/dports/lang/gcc9-aux/gcc-9.1.0/gcc/testsuite/gdc.test/compilable/ |
H A D | ice10040.d | 4 struct MsgHeader {} struct 8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
|
/dports/lang/gcc9-devel/gcc-9-20211007/gcc/testsuite/gdc.test/compilable/ |
H A D | ice10040.d | 4 struct MsgHeader {} struct 8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
|
/dports/lang/gcc11-devel/gcc-11-20211009/gcc/testsuite/gdc.test/compilable/ |
H A D | ice10040.d | 4 struct MsgHeader {} struct 8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
|
/dports/misc/cxx_atomics_pic/gcc-11.2.0/gcc/testsuite/gdc.test/compilable/ |
H A D | ice10040.d | 4 struct MsgHeader {} struct 8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
|
/dports/devel/avr-gcc/gcc-10.2.0/gcc/testsuite/gdc.test/compilable/ |
H A D | ice10040.d | 4 struct MsgHeader {} struct 8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
|
/dports/lang/gcc10-devel/gcc-10-20211008/gcc/testsuite/gdc.test/compilable/ |
H A D | ice10040.d | 4 struct MsgHeader {} struct 8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
|
/dports/lang/gcc9/gcc-9.4.0/gcc/testsuite/gdc.test/compilable/ |
H A D | ice10040.d | 4 struct MsgHeader {} struct 8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
|
/dports/security/snort/snort-2.9.18/src/dynamic-preprocessors/ssl_common/ |
H A D | ssl_ha.c | 69 } MsgHeader; typedef 580 MsgHeader *msg_hdr; in ConsumeSSLHAMessage() 595 msg_hdr = (MsgHeader *) msg; in ConsumeSSLHAMessage() 696 MsgHeader *msg_header; in ReadHAMessagesFromFile() 710 msg_header = (MsgHeader *) msg; in ReadHAMessagesFromFile() 771 MsgHeader *msg_hdr; in WriteSSLHAMessageHeader() 774 msg_hdr = (MsgHeader *) msg; in WriteSSLHAMessageHeader() 807 MsgHeader *msg_hdr; in UpdateSSLHAMessageHeaderLength() 809 msg_hdr = (MsgHeader *) msg; in UpdateSSLHAMessageHeaderLength() 817 msg_size = sizeof(MsgHeader); in CalculateSSLHAMessageSize()
|