Home
last modified time | relevance | path

Searched refs:pktReader (Results 1 – 24 of 24) sorted by relevance

/dports/net-im/dendrite/dendrite-0.5.1/vendor/github.com/pressly/goose/vendor/github.com/ziutek/mymysql/native/
H A Dpacket.go10 type pktReader struct { struct
19 func (my *Conn) newPktReader() *pktReader {
20 return &pktReader{rd: my.rd, seq: &my.seq}
23 func (pr *pktReader) readHeader() { argument
50 func (pr *pktReader) readFull(buf []byte) { argument
73 func (pr *pktReader) readByte() byte { argument
111 func (pr *pktReader) skipAll() { argument
128 func (pr *pktReader) skipN(n int) { argument
150 func (pr *pktReader) unreadByte() { argument
157 func (pr *pktReader) eof() bool { argument
[all …]
H A Dcodecs.go15 func (pr *pktReader) readU16() uint16 {
24 func (pr *pktReader) readU24() uint32 {
34 func (pr *pktReader) readU32() uint32 {
46 func (pr *pktReader) readU64() (rv uint64) {
120 func (pr *pktReader) readLCB() uint64 {
172 func (pr *pktReader) readBin() []byte {
180 func (pr *pktReader) skipBin() {
227 func (pr *pktReader) readNTB() (buf []byte) {
256 func (pr *pktReader) readDuration() time.Duration {
338 func (pr *pktReader) readTime() time.Time {
[all …]
H A Dresult.go138 func (my *Conn) getOkPacket(pr *pktReader) (res *Result) { argument
163 func (my *Conn) getErrorPacket(pr *pktReader) { argument
182 func (my *Conn) getEofPacket(pr *pktReader) (warn_count int, status uint16) { argument
206 func (my *Conn) getResSetHeadPacket(pr *pktReader) (res *Result) { argument
227 func (my *Conn) getFieldPacket(pr *pktReader) (field *mysql.Field) { argument
266 func (my *Conn) getTextRowPacket(pr *pktReader, res *Result, row mysql.Row) { argument
283 func (my *Conn) getBinRowPacket(pr *pktReader, res *Result, row mysql.Row) { argument
309 func readValue(pr *pktReader, typ byte, unsigned bool) interface{} { argument
361 func readValueNarrow(pr *pktReader, typ byte, unsigned bool) interface{} { argument
H A Dprepared.go138 func (my *Conn) getPrepareOkPacket(pr *pktReader) (stmt *Stmt) { argument
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/cloudflare/cfssl/cfssl-2001f384ec4f/vendor/github.com/ziutek/mymysql/native/
H A Dpacket.go10 type pktReader struct { struct
19 func (my *Conn) newPktReader() *pktReader {
20 return &pktReader{rd: my.rd, seq: &my.seq}
23 func (pr *pktReader) readHeader() { argument
50 func (pr *pktReader) readFull(buf []byte) { argument
73 func (pr *pktReader) readByte() byte { argument
111 func (pr *pktReader) skipAll() { argument
128 func (pr *pktReader) skipN(n int) { argument
150 func (pr *pktReader) unreadByte() { argument
157 func (pr *pktReader) eof() bool { argument
[all …]
H A Dcodecs.go15 func (pr *pktReader) readU16() uint16 {
24 func (pr *pktReader) readU24() uint32 {
34 func (pr *pktReader) readU32() uint32 {
46 func (pr *pktReader) readU64() (rv uint64) {
120 func (pr *pktReader) readLCB() uint64 {
172 func (pr *pktReader) readBin() []byte {
180 func (pr *pktReader) skipBin() {
227 func (pr *pktReader) readNTB() (buf []byte) {
256 func (pr *pktReader) readDuration() time.Duration {
338 func (pr *pktReader) readTime() time.Time {
[all …]
H A Dresult.go138 func (my *Conn) getOkPacket(pr *pktReader) (res *Result) { argument
163 func (my *Conn) getErrorPacket(pr *pktReader) { argument
182 func (my *Conn) getEofPacket(pr *pktReader) (warn_count int, status uint16) { argument
206 func (my *Conn) getResSetHeadPacket(pr *pktReader) (res *Result) { argument
227 func (my *Conn) getFieldPacket(pr *pktReader) (field *mysql.Field) { argument
266 func (my *Conn) getTextRowPacket(pr *pktReader, res *Result, row mysql.Row) { argument
283 func (my *Conn) getBinRowPacket(pr *pktReader, res *Result, row mysql.Row) { argument
309 func readValue(pr *pktReader, typ byte, unsigned bool) interface{} { argument
361 func readValueNarrow(pr *pktReader, typ byte, unsigned bool) interface{} { argument
H A Dprepared.go138 func (my *Conn) getPrepareOkPacket(pr *pktReader) (stmt *Stmt) { argument
/dports/net/ooni-probe-cli/probe-cli-3.10.1/vendor/github.com/ziutek/mymysql/native/
H A Dpacket.go10 type pktReader struct { struct
19 func (my *Conn) newPktReader() *pktReader {
20 return &pktReader{rd: my.rd, seq: &my.seq}
23 func (pr *pktReader) readHeader() { argument
50 func (pr *pktReader) readFull(buf []byte) { argument
73 func (pr *pktReader) readByte() byte { argument
111 func (pr *pktReader) skipAll() { argument
128 func (pr *pktReader) skipN(n int) { argument
150 func (pr *pktReader) unreadByte() { argument
157 func (pr *pktReader) eof() bool { argument
[all …]
H A Dcodecs.go15 func (pr *pktReader) readU16() uint16 {
24 func (pr *pktReader) readU24() uint32 {
34 func (pr *pktReader) readU32() uint32 {
46 func (pr *pktReader) readU64() (rv uint64) {
120 func (pr *pktReader) readLCB() uint64 {
172 func (pr *pktReader) readBin() []byte {
180 func (pr *pktReader) skipBin() {
227 func (pr *pktReader) readNTB() (buf []byte) {
256 func (pr *pktReader) readDuration() time.Duration {
338 func (pr *pktReader) readTime() time.Time {
[all …]
H A Dresult.go138 func (my *Conn) getOkPacket(pr *pktReader) (res *Result) { argument
163 func (my *Conn) getErrorPacket(pr *pktReader) { argument
182 func (my *Conn) getEofPacket(pr *pktReader) (warn_count int, status uint16) { argument
206 func (my *Conn) getResSetHeadPacket(pr *pktReader) (res *Result) { argument
227 func (my *Conn) getFieldPacket(pr *pktReader) (field *mysql.Field) { argument
266 func (my *Conn) getTextRowPacket(pr *pktReader, res *Result, row mysql.Row) { argument
283 func (my *Conn) getBinRowPacket(pr *pktReader, res *Result, row mysql.Row) { argument
309 func readValue(pr *pktReader, typ byte, unsigned bool) interface{} { argument
361 func readValueNarrow(pr *pktReader, typ byte, unsigned bool) interface{} { argument
H A Dprepared.go138 func (my *Conn) getPrepareOkPacket(pr *pktReader) (stmt *Stmt) { argument
/dports/multimedia/navidrome/navidrome-0.40.0/vendor/github.com/pressly/goose/vendor/github.com/ziutek/mymysql/native/
H A Dpacket.go10 type pktReader struct { struct
19 func (my *Conn) newPktReader() *pktReader {
20 return &pktReader{rd: my.rd, seq: &my.seq}
23 func (pr *pktReader) readHeader() { argument
50 func (pr *pktReader) readFull(buf []byte) { argument
73 func (pr *pktReader) readByte() byte { argument
111 func (pr *pktReader) skipAll() { argument
128 func (pr *pktReader) skipN(n int) { argument
150 func (pr *pktReader) unreadByte() { argument
157 func (pr *pktReader) eof() bool { argument
[all …]
H A Dcodecs.go15 func (pr *pktReader) readU16() uint16 {
24 func (pr *pktReader) readU24() uint32 {
34 func (pr *pktReader) readU32() uint32 {
46 func (pr *pktReader) readU64() (rv uint64) {
120 func (pr *pktReader) readLCB() uint64 {
172 func (pr *pktReader) readBin() []byte {
180 func (pr *pktReader) skipBin() {
227 func (pr *pktReader) readNTB() (buf []byte) {
256 func (pr *pktReader) readDuration() time.Duration {
338 func (pr *pktReader) readTime() time.Time {
[all …]
H A Dresult.go138 func (my *Conn) getOkPacket(pr *pktReader) (res *Result) { argument
163 func (my *Conn) getErrorPacket(pr *pktReader) { argument
182 func (my *Conn) getEofPacket(pr *pktReader) (warn_count int, status uint16) { argument
206 func (my *Conn) getResSetHeadPacket(pr *pktReader) (res *Result) { argument
227 func (my *Conn) getFieldPacket(pr *pktReader) (field *mysql.Field) { argument
266 func (my *Conn) getTextRowPacket(pr *pktReader, res *Result, row mysql.Row) { argument
283 func (my *Conn) getBinRowPacket(pr *pktReader, res *Result, row mysql.Row) { argument
309 func readValue(pr *pktReader, typ byte, unsigned bool) interface{} { argument
361 func readValueNarrow(pr *pktReader, typ byte, unsigned bool) interface{} { argument
H A Dprepared.go138 func (my *Conn) getPrepareOkPacket(pr *pktReader) (stmt *Stmt) { argument
/dports/multimedia/navidrome/navidrome-0.40.0/vendor/github.com/ziutek/mymysql/native/
H A Dpacket.go10 type pktReader struct { struct
19 func (my *Conn) newPktReader() *pktReader {
20 return &pktReader{rd: my.rd, seq: &my.seq}
23 func (pr *pktReader) readHeader() { argument
50 func (pr *pktReader) readFull(buf []byte) { argument
73 func (pr *pktReader) readByte() byte { argument
111 func (pr *pktReader) skipAll() { argument
128 func (pr *pktReader) skipN(n int) { argument
150 func (pr *pktReader) unreadByte() { argument
157 func (pr *pktReader) eof() bool { argument
[all …]
H A Dcodecs.go15 func (pr *pktReader) readU16() uint16 {
24 func (pr *pktReader) readU24() uint32 {
34 func (pr *pktReader) readU32() uint32 {
46 func (pr *pktReader) readU64() (rv uint64) {
120 func (pr *pktReader) readLCB() uint64 {
172 func (pr *pktReader) readBin() []byte {
180 func (pr *pktReader) skipBin() {
227 func (pr *pktReader) readNTB() (buf []byte) {
256 func (pr *pktReader) readDuration() time.Duration {
338 func (pr *pktReader) readTime() time.Time {
[all …]
H A Dresult.go138 func (my *Conn) getOkPacket(pr *pktReader) (res *Result) { argument
163 func (my *Conn) getErrorPacket(pr *pktReader) { argument
182 func (my *Conn) getEofPacket(pr *pktReader) (warn_count int, status uint16) { argument
206 func (my *Conn) getResSetHeadPacket(pr *pktReader) (res *Result) { argument
227 func (my *Conn) getFieldPacket(pr *pktReader) (field *mysql.Field) { argument
266 func (my *Conn) getTextRowPacket(pr *pktReader, res *Result, row mysql.Row) { argument
283 func (my *Conn) getBinRowPacket(pr *pktReader, res *Result, row mysql.Row) { argument
309 func readValue(pr *pktReader, typ byte, unsigned bool) interface{} { argument
361 func readValueNarrow(pr *pktReader, typ byte, unsigned bool) interface{} { argument
H A Dprepared.go138 func (my *Conn) getPrepareOkPacket(pr *pktReader) (stmt *Stmt) { argument
/dports/multimedia/navidrome/navidrome-0.40.0/vendor/github.com/djherbis/fscache/
H A Dstream.go17 type pktReader struct { struct
32 func (t *pktReader) ReadAt(p []byte, off int64) (n int, err error) { argument
37 func (t *pktReader) Read(p []byte) (int, error) { argument
49 func (t *pktReader) Close() error { argument
71 return &pktReader{dec: json.NewDecoder(r)}
/dports/net/syncthing/syncthing-1.18.1/syncthing/vendor/github.com/AudriusButkevicius/pfilter/
H A Dfilter.go142 pktReader := d.readFrom
144 pktReader = d.readMsgUdp
146 go d.loop(pktReader)
194 func (d *PacketFilter) loop(pktReader func() packet) {
196 pkt := pktReader()
/dports/security/vault/vault-1.8.2/vendor/github.com/apple/foundationdb/fdbrpc/
H A DFlowTransport.actor.cpp705 BinaryReader pktReader(unprocessed_begin, connectPacketSize, AssumeVersion(protocolVersion)); in connectionReader()
707 serializer(pktReader, pkt); in connectionReader()
/dports/lang/mono/mono-5.10.1.57/mcs/class/referencesource/System.Web/Configuration/
H A DBrowserCapabilitiesCodeGenerator.cs864 using (StreamReader pktReader = new StreamReader(pktStream)) { in LoadPublicKeyTokenFromFile()
865 return pktReader.ReadLine(); in LoadPublicKeyTokenFromFile()