Home
last modified time | relevance | path

Searched refs:MsgHeader (Results 1 – 25 of 79) sorted by relevance

1234

/dports/net-mgmt/thanos/thanos-0.11.0/vendor/go.mongodb.org/mongo-driver/x/network/wiremessage/
H A Dcompressed.go16 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 Dkill_cursors.go17 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 Dreply.go20 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 Dget_more.go18 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 Dmsg.go19 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 Dquery.go21 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 Dmsg_test.go72 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 Dmessage.go21 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 Dmessage.go21 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 Dmessages.c260 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 Dmessages.h40 typedef struct MsgHeader struct
47 MsgHeader; argument
/dports/security/snort/snort-2.9.18/src/file-process/
H A Dfile_ss.c48 } 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 DappId_ss.c50 } 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 Dconnection.go278 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 Dice10040.d4 struct MsgHeader {} struct
8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
/dports/lang/gcc10/gcc-10.3.0/gcc/testsuite/gdc.test/compilable/
H A Dice10040.d4 struct MsgHeader {} struct
8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
/dports/lang/gcc11/gcc-11.2.0/gcc/testsuite/gdc.test/compilable/
H A Dice10040.d4 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 Dice10040.d4 struct MsgHeader {} struct
8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
/dports/lang/gcc9-devel/gcc-9-20211007/gcc/testsuite/gdc.test/compilable/
H A Dice10040.d4 struct MsgHeader {} struct
8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
/dports/lang/gcc11-devel/gcc-11-20211009/gcc/testsuite/gdc.test/compilable/
H A Dice10040.d4 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 Dice10040.d4 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 Dice10040.d4 struct MsgHeader {} struct
8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
/dports/lang/gcc10-devel/gcc-10-20211008/gcc/testsuite/gdc.test/compilable/
H A Dice10040.d4 struct MsgHeader {} struct
8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
/dports/lang/gcc9/gcc-9.4.0/gcc/testsuite/gdc.test/compilable/
H A Dice10040.d4 struct MsgHeader {} struct
8 mixin(mixinMembers!(MsgHeader.init)); in MsgMixin()
/dports/security/snort/snort-2.9.18/src/dynamic-preprocessors/ssl_common/
H A Dssl_ha.c69 } 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()

1234