/third_party/protobuf/benchmarks/go/ |
H A D | go_benchmark_test.go | 11 "github.com/golang/protobuf/proto" 19 newMessage func() proto.Message 21 unmarshaled []proto.Message 27 func generateNewMessageFunction(dataset benchmarkWrapper.BenchmarkDataset) func() proto.Message { 30 return func() proto.Message { return new(googleMessage1Proto3.GoogleMessage1) } 32 return func() proto.Message { return new(googleMessage1Proto2.GoogleMessage1) } 34 return func() proto.Message { return new(googleMessage2.GoogleMessage2) } 36 return func() proto.Message { return new(googleMessage3.GoogleMessage3) } 38 return func() proto.Message { return new(googleMessage4.GoogleMessage4) } 55 if err := proto [all...] |
/kernel/linux/linux-5.10/tools/testing/selftests/net/ |
H A D | reuseport_addr_any.c | 34 static void build_rcv_fd(int family, int proto, int *rcv_fds, int count, in build_rcv_fd() argument 75 rcv_fds[i] = socket(family, proto, 0); in build_rcv_fd() 87 if (proto == SOCK_STREAM && listen(rcv_fds[i], 10)) in build_rcv_fd() 89 else if (proto == SOCK_DCCP) { in build_rcv_fd() 101 static int connect_and_send(int family, int proto) in connect_and_send() argument 147 fd = socket(family, proto, 0); in connect_and_send() 151 if (proto == SOCK_DCCP && in connect_and_send() 168 static int receive_once(int epfd, int proto) in receive_once() argument 178 if (proto == SOCK_STREAM || proto in receive_once() 194 test(int *rcv_fds, int count, int family, int proto, int fd) test() argument 221 run_one_test(int fam_send, int fam_rcv, int proto, const char *addr_str) run_one_test() argument 244 test_proto(int proto, const char *proto_str) test_proto() argument [all...] |
/kernel/linux/linux-6.6/tools/testing/selftests/net/ |
H A D | reuseport_addr_any.c | 34 static void build_rcv_fd(int family, int proto, int *rcv_fds, int count, in build_rcv_fd() argument 75 rcv_fds[i] = socket(family, proto, 0); in build_rcv_fd() 87 if (proto == SOCK_STREAM && listen(rcv_fds[i], 10)) in build_rcv_fd() 89 else if (proto == SOCK_DCCP) { in build_rcv_fd() 101 static int connect_and_send(int family, int proto) in connect_and_send() argument 147 fd = socket(family, proto, 0); in connect_and_send() 151 if (proto == SOCK_DCCP && in connect_and_send() 168 static int receive_once(int epfd, int proto) in receive_once() argument 178 if (proto == SOCK_STREAM || proto in receive_once() 194 test(int *rcv_fds, int count, int family, int proto, int fd) test() argument 221 run_one_test(int fam_send, int fam_rcv, int proto, const char *addr_str) run_one_test() argument 244 test_proto(int proto, const char *proto_str) test_proto() argument [all...] |
/kernel/linux/linux-5.10/drivers/block/paride/ |
H A D | paride.c | 47 pi->proto->write_regr(pi, cont, regr, val); in pi_write_regr() 54 return pi->proto->read_regr(pi, cont, regr); in pi_read_regr() 61 pi->proto->write_block(pi, buf, count); in pi_write_block() 68 pi->proto->read_block(pi, buf, count); in pi_read_block() 139 pi->proto->connect(pi); in pi_connect() 146 pi->proto->disconnect(pi); in pi_disconnect() 163 if (pi->proto->release_proto) in pi_release() 164 pi->proto->release_proto(pi); in pi_release() 165 module_put(pi->proto->owner); in pi_release() 175 pi->proto in default_test_proto() 374 struct pi_protocol *proto = protocols[p]; pi_init() local [all...] |
/kernel/linux/linux-5.10/net/ipv4/ |
H A D | gre_demux.c | 31 int gre_add_protocol(const struct gre_protocol *proto, u8 version) in gre_add_protocol() argument 36 return (cmpxchg((const struct gre_protocol **)&gre_proto[version], NULL, proto) == NULL) ? in gre_add_protocol() 41 int gre_del_protocol(const struct gre_protocol *proto, u8 version) in gre_del_protocol() argument 48 ret = (cmpxchg((const struct gre_protocol **)&gre_proto[version], proto, NULL) == proto) ? in gre_del_protocol() 63 bool *csum_err, __be16 proto, int nhs) in gre_parse_header() 83 tpi->proto = greh->protocol; in gre_parse_header() 114 if (greh->flags == 0 && tpi->proto == htons(ETH_P_WCCP)) { in gre_parse_header() 121 tpi->proto = proto; in gre_parse_header() 62 gre_parse_header(struct sk_buff *skb, struct tnl_ptk_info *tpi, bool *csum_err, __be16 proto, int nhs) gre_parse_header() argument 148 const struct gre_protocol *proto; gre_rcv() local 176 const struct gre_protocol *proto; gre_err() local [all...] |
/kernel/linux/linux-6.6/net/ipv4/ |
H A D | gre_demux.c | 31 int gre_add_protocol(const struct gre_protocol *proto, u8 version) in gre_add_protocol() argument 36 return (cmpxchg((const struct gre_protocol **)&gre_proto[version], NULL, proto) == NULL) ? in gre_add_protocol() 41 int gre_del_protocol(const struct gre_protocol *proto, u8 version) in gre_del_protocol() argument 48 ret = (cmpxchg((const struct gre_protocol **)&gre_proto[version], proto, NULL) == proto) ? in gre_del_protocol() 63 bool *csum_err, __be16 proto, int nhs) in gre_parse_header() 83 tpi->proto = greh->protocol; in gre_parse_header() 114 if (greh->flags == 0 && tpi->proto == htons(ETH_P_WCCP)) { in gre_parse_header() 121 tpi->proto = proto; in gre_parse_header() 62 gre_parse_header(struct sk_buff *skb, struct tnl_ptk_info *tpi, bool *csum_err, __be16 proto, int nhs) gre_parse_header() argument 148 const struct gre_protocol *proto; gre_rcv() local 176 const struct gre_protocol *proto; gre_err() local [all...] |
/third_party/node/lib/internal/ |
H A D | buffer.js | 965 function addBufferPrototypeMethods(proto) { 966 proto.readBigUInt64LE = readBigUInt64LE; 967 proto.readBigUInt64BE = readBigUInt64BE; 968 proto.readBigUint64LE = readBigUInt64LE; 969 proto.readBigUint64BE = readBigUInt64BE; 970 proto.readBigInt64LE = readBigInt64LE; 971 proto.readBigInt64BE = readBigInt64BE; 972 proto.writeBigUInt64LE = writeBigUInt64LE; 973 proto.writeBigUInt64BE = writeBigUInt64BE; 974 proto [all...] |
/kernel/linux/linux-6.6/net/netfilter/ |
H A D | nf_conntrack_proto_tcp.c | 271 seq_printf(s, "%s ", tcp_conntrack_names[ct->proto.tcp.state]); in tcp_print_conntrack() 515 struct ip_ct_tcp *state = &ct->proto.tcp; in tcp_in_window() 753 if (ct->proto.tcp.last_dir != dir && in nf_tcp_handle_invalid() 754 (ct->proto.tcp.last_index == TCP_FIN_SET || in nf_tcp_handle_invalid() 755 ct->proto.tcp.last_index == TCP_RST_SET)) { in nf_tcp_handle_invalid() 769 index, dir, ct->proto.tcp.last_index, timeout); in nf_tcp_handle_invalid() 774 ct->proto.tcp.last_index = index; in nf_tcp_handle_invalid() 775 ct->proto.tcp.last_dir = dir; in nf_tcp_handle_invalid() 856 memset(&ct->proto.tcp, 0, sizeof(ct->proto in tcp_new() [all...] |
H A D | nf_conntrack_proto_sctp.c | 141 seq_printf(s, "%s ", sctp_conntrack_names[ct->proto.sctp.state]); in sctp_print_conntrack() 253 memset(&ct->proto.sctp, 0, sizeof(ct->proto.sctp)); in sctp_new() 281 ct->proto.sctp.vtag[IP_CT_DIR_REPLY] = ih->init_tag; in sctp_new() 285 ct->proto.sctp.vtag[IP_CT_DIR_ORIGINAL] = sh->vtag; in sctp_new() 291 ct->proto.sctp.vtag[IP_CT_DIR_REPLY] = sh->vtag; in sctp_new() 294 ct->proto.sctp.state = SCTP_CONNTRACK_NONE; in sctp_new() 378 sh->vtag != ct->proto.sctp.vtag[dir]) { in nf_conntrack_sctp_packet() 381 sh->vtag, ct->proto.sctp.vtag[dir], dir); in nf_conntrack_sctp_packet() 398 sh->vtag != ct->proto in nf_conntrack_sctp_packet() [all...] |
/third_party/skia/third_party/externals/angle2/src/tests/test_utils/runner/ |
H A D | HistogramWriter.cpp | 31 namespace proto = catapult::tracing::tracing::proto; 37 std::string GetUnitAndDirection(proto::UnitAndDirection unit) in GetUnitAndDirection() 39 ASSERT(unit.improvement_direction() == proto::SMALLER_IS_BETTER); in GetUnitAndDirection() 40 ASSERT(unit.unit() == proto::MS_BEST_FIT_FORMAT); in GetUnitAndDirection() 57 proto::UnitAndDirection unitAndDirection; in addSample() 58 unitAndDirection.set_improvement_direction(proto::SMALLER_IS_BETTER); in addSample() 59 unitAndDirection.set_unit(proto::MS_BEST_FIT_FORMAT); in addSample() 66 builder->SetSummaryOptions(proto::SummaryOptions()); in addSample() 69 proto in addSample() 84 std::unique_ptr<proto::Histogram> proto = histogram.second->toProto(); getAsJSON() local [all...] |
/kernel/linux/linux-5.10/net/nfc/ |
H A D | af_nfc.c | 18 static int nfc_sock_create(struct net *net, struct socket *sock, int proto, in nfc_sock_create() argument 26 if (proto < 0 || proto >= NFC_SOCKPROTO_MAX) in nfc_sock_create() 30 if (proto_tab[proto] && try_module_get(proto_tab[proto]->owner)) { in nfc_sock_create() 31 rc = proto_tab[proto]->create(net, sock, proto_tab[proto], kern); in nfc_sock_create() 32 module_put(proto_tab[proto]->owner); in nfc_sock_create() 52 rc = proto_register(nfc_proto->proto, 0); in nfc_proto_register() 64 proto_unregister(nfc_proto->proto); in nfc_proto_register() [all...] |
/kernel/linux/linux-6.6/net/nfc/ |
H A D | af_nfc.c | 18 static int nfc_sock_create(struct net *net, struct socket *sock, int proto, in nfc_sock_create() argument 26 if (proto < 0 || proto >= NFC_SOCKPROTO_MAX) in nfc_sock_create() 30 if (proto_tab[proto] && try_module_get(proto_tab[proto]->owner)) { in nfc_sock_create() 31 rc = proto_tab[proto]->create(net, sock, proto_tab[proto], kern); in nfc_sock_create() 32 module_put(proto_tab[proto]->owner); in nfc_sock_create() 52 rc = proto_register(nfc_proto->proto, 0); in nfc_proto_register() 64 proto_unregister(nfc_proto->proto); in nfc_proto_register() [all...] |
/third_party/selinux/libsepol/src/ |
H A D | nodes.c | 23 int proto; in node_from_record() local 35 proto = sepol_node_get_proto(data); in node_from_record() 37 switch (proto) { in node_from_record() 47 ERR(handle, "unsupported protocol %u", proto); in node_from_record() 85 ocontext_t * node, int proto, sepol_node_t ** record) in node_to_record() 96 sepol_node_set_proto(tmp_record, proto); in node_to_record() 98 switch (proto) { in node_to_record() 125 ERR(handle, "unsupported protocol %u", proto); in node_to_record() 177 int proto; in sepol_node_exists() local 179 sepol_node_key_unpack(key, &addr, &mask, &proto); in sepol_node_exists() 83 node_to_record(sepol_handle_t * handle, const policydb_t * policydb, ocontext_t * node, int proto, sepol_node_t ** record) node_to_record() argument 237 int proto; sepol_node_query() local 304 int proto; sepol_node_modify() local [all...] |
/kernel/linux/linux-5.10/net/netfilter/ |
H A D | nf_conntrack_proto_sctp.c | 141 seq_printf(s, "%s ", sctp_conntrack_names[ct->proto.sctp.state]); in sctp_print_conntrack() 269 memset(&ct->proto.sctp, 0, sizeof(ct->proto.sctp)); in sctp_new() 297 ct->proto.sctp.vtag[IP_CT_DIR_REPLY] = ih->init_tag; in sctp_new() 301 ct->proto.sctp.vtag[IP_CT_DIR_ORIGINAL] = sh->vtag; in sctp_new() 307 ct->proto.sctp.vtag[IP_CT_DIR_REPLY] = sh->vtag; in sctp_new() 310 ct->proto.sctp.state = SCTP_CONNTRACK_NONE; in sctp_new() 394 sh->vtag != ct->proto.sctp.vtag[dir]) { in nf_conntrack_sctp_packet() 412 sh->vtag != ct->proto.sctp.vtag[dir]) || in nf_conntrack_sctp_packet() 414 sh->vtag != ct->proto in nf_conntrack_sctp_packet() [all...] |
/device/soc/rockchip/common/sdk_linux/include/trace/hooks/ |
H A D | vendor_hooks.h | 20 #define DEFINE_HOOK_FN(_name, _reg, _unreg, proto, args) \
23 int __traceiter_##_name(void *__data, proto); \
34 int __traceiter_##_name(void *__data, proto) \
42 ((void (*)(void *, proto))(it_func))(__data, args); \
49 #define DECLARE_RESTRICTED_HOOK(name, proto, args, cond) DEFINE_HOOK_FN(name, NULL, NULL, PARAMS(proto), PARAMS(args))
78 #define I_DECLARE_RESTRICTED_HOOK(name, proto, args, cond, data_proto) \
82 static inline void trace_##name(proto) \
101 #define DECLARE_RESTRICTED_HOOK(name, proto, args, cond) \
102 I_DECLARE_RESTRICTED_HOOK(name, PARAMS(proto), PARAM [all...] |
/kernel/linux/linux-5.10/drivers/s390/net/ |
H A D | qeth_l3.h | 33 enum qeth_prot_versions proto; member 48 enum qeth_prot_versions proto) in qeth_l3_init_ipaddr() 52 addr->proto = proto; in qeth_l3_init_ipaddr() 60 if (a1->proto != a2->proto) in qeth_l3_addr_match_ip() 62 if (a1->proto == QETH_PROT_IPV6) in qeth_l3_addr_match_ip() 71 * so 'proto' and 'addr' match for sure. in qeth_l3_addr_match_all() 82 if (a1->proto == QETH_PROT_IPV6) in qeth_l3_addr_match_all() 89 if (addr->proto in qeth_l3_ipaddr_hash() 46 qeth_l3_init_ipaddr(struct qeth_ipaddr *addr, enum qeth_ip_types type, enum qeth_prot_versions proto) qeth_l3_init_ipaddr() argument 97 enum qeth_prot_versions proto; global() member [all...] |
/kernel/linux/linux-6.6/drivers/s390/net/ |
H A D | qeth_l3.h | 33 enum qeth_prot_versions proto; member 48 enum qeth_prot_versions proto) in qeth_l3_init_ipaddr() 52 addr->proto = proto; in qeth_l3_init_ipaddr() 60 if (a1->proto != a2->proto) in qeth_l3_addr_match_ip() 62 if (a1->proto == QETH_PROT_IPV6) in qeth_l3_addr_match_ip() 71 * so 'proto' and 'addr' match for sure. in qeth_l3_addr_match_all() 82 if (a1->proto == QETH_PROT_IPV6) in qeth_l3_addr_match_all() 89 if (addr->proto in qeth_l3_ipaddr_hash() 46 qeth_l3_init_ipaddr(struct qeth_ipaddr *addr, enum qeth_ip_types type, enum qeth_prot_versions proto) qeth_l3_init_ipaddr() argument 97 enum qeth_prot_versions proto; global() member [all...] |
/third_party/lwip/src/core/ |
H A D | stats.c | 64 stats_display_proto(struct stats_proto *proto, const char *name) in stats_display_proto() argument 67 LWIP_PLATFORM_DIAG(("xmit: %"STAT_COUNTER_F"\n\t", proto->xmit)); in stats_display_proto() 68 LWIP_PLATFORM_DIAG(("recv: %"STAT_COUNTER_F"\n\t", proto->recv)); in stats_display_proto() 69 LWIP_PLATFORM_DIAG(("fw: %"STAT_COUNTER_F"\n\t", proto->fw)); in stats_display_proto() 70 LWIP_PLATFORM_DIAG(("drop: %"STAT_COUNTER_F"\n\t", proto->drop)); in stats_display_proto() 71 LWIP_PLATFORM_DIAG(("chkerr: %"STAT_COUNTER_F"\n\t", proto->chkerr)); in stats_display_proto() 72 LWIP_PLATFORM_DIAG(("lenerr: %"STAT_COUNTER_F"\n\t", proto->lenerr)); in stats_display_proto() 73 LWIP_PLATFORM_DIAG(("memerr: %"STAT_COUNTER_F"\n\t", proto->memerr)); in stats_display_proto() 74 LWIP_PLATFORM_DIAG(("rterr: %"STAT_COUNTER_F"\n\t", proto->rterr)); in stats_display_proto() 75 LWIP_PLATFORM_DIAG(("proterr: %"STAT_COUNTER_F"\n\t", proto in stats_display_proto() [all...] |
/kernel/linux/linux-5.10/scripts/ |
H A D | bpf_helpers_doc.py | 28 @proto: function prototype of the helper function 32 def __init__(self, proto='', desc='', ret=''): 33 self.proto = proto 46 capture = proto_re.match(self.proto) 77 proto = self.parse_proto() 80 return Helper(proto=proto, desc=desc, ret=ret) 360 proto = helper.proto_break_down() 362 print('**%s %s%s(' % (proto['ret_typ [all...] |
/third_party/python/Lib/test/test_asyncio/ |
H A D | test_sslproto.py | 34 def ssl_protocol(self, *, waiter=None, proto=None): 36 if proto is None: # app protocol 37 proto = asyncio.Protocol() 38 ssl_proto = sslproto.SSLProtocol(self.loop, proto, sslcontext, waiter, 40 self.assertIs(ssl_proto._app_transport.get_protocol(), proto) 199 proto = Proto(1, usemv) variable in BaseStartTLS.test_buf_feed_data.Proto 200 protocols._feed_data_to_buffered_proto(proto, b'12345') 201 self.assertEqual(proto.data, b'12345') 203 proto = Proto(2, usemv) variable in BaseStartTLS.test_buf_feed_data.Proto 204 protocols._feed_data_to_buffered_proto(proto, 207 proto = Proto(2, usemv) global() variable in BaseStartTLS.test_buf_feed_data.Proto 211 proto = Proto(4, usemv) global() variable in BaseStartTLS.test_buf_feed_data.Proto 215 proto = Proto(100, usemv) global() variable in BaseStartTLS.test_buf_feed_data.Proto 219 proto = Proto(0, usemv) global() variable in BaseStartTLS.test_buf_feed_data.Proto [all...] |
/third_party/protobuf/java/compatibility_tests/v2.5.0/tests/src/main/java/com/google/protobuf/test/ |
H A D | LazyStringEndToEndTest.java | 95 UnittestProto.TestAllTypes proto = in testNoStringCachingIfOnlyBytesAccessed() 97 ByteString optional = proto.getOptionalStringBytes(); in testNoStringCachingIfOnlyBytesAccessed() 98 assertSame(optional, proto.getOptionalStringBytes()); in testNoStringCachingIfOnlyBytesAccessed() 99 assertSame(optional, proto.toBuilder().getOptionalStringBytes()); in testNoStringCachingIfOnlyBytesAccessed() 101 ByteString repeated0 = proto.getRepeatedStringBytes(0); in testNoStringCachingIfOnlyBytesAccessed() 102 ByteString repeated1 = proto.getRepeatedStringBytes(1); in testNoStringCachingIfOnlyBytesAccessed() 103 assertSame(repeated0, proto.getRepeatedStringBytes(0)); in testNoStringCachingIfOnlyBytesAccessed() 104 assertSame(repeated1, proto.getRepeatedStringBytes(1)); in testNoStringCachingIfOnlyBytesAccessed() 105 assertSame(repeated0, proto.toBuilder().getRepeatedStringBytes(0)); in testNoStringCachingIfOnlyBytesAccessed() 106 assertSame(repeated1, proto in testNoStringCachingIfOnlyBytesAccessed() [all...] |
/third_party/protobuf/js/ |
H A D | proto3_test.js | 33 // CommonJS-LoadFromFile: testbinary_pb proto.jspb.test 34 goog.require('proto.jspb.test.ForeignMessage'); 35 // CommonJS-LoadFromFile: proto3_test_pb proto.jspb.test 36 goog.require('proto.jspb.test.Proto3Enum'); 37 goog.require('proto.jspb.test.TestProto3'); 38 // CommonJS-LoadFromFile: google/protobuf/any_pb proto.google.protobuf 39 goog.require('proto.google.protobuf.Any'); 40 // CommonJS-LoadFromFile: google/protobuf/timestamp_pb proto.google.protobuf 41 goog.require('proto.google.protobuf.Timestamp'); 42 // CommonJS-LoadFromFile: google/protobuf/struct_pb proto [all...] |
/kernel/linux/linux-5.10/samples/bpf/ |
H A D | sockex2_kern.c | 29 static inline int proto_ports_offset(__u64 proto) in proto_ports_offset() argument 31 switch (proto) { in proto_ports_offset() 105 __u64 proto = load_half(skb, 12); in flow_dissector() local 108 if (proto == ETH_P_8021AD) { in flow_dissector() 109 proto = load_half(skb, nhoff + offsetof(struct vlan_hdr, in flow_dissector() 114 if (proto == ETH_P_8021Q) { in flow_dissector() 115 proto = load_half(skb, nhoff + offsetof(struct vlan_hdr, in flow_dissector() 120 if (likely(proto == ETH_P_IP)) in flow_dissector() 122 else if (proto == ETH_P_IPV6) in flow_dissector() 131 __be16 proto; in flow_dissector() member [all...] |
/kernel/linux/linux-6.6/include/trace/ |
H A D | trace_custom_events.h | 27 #define TRACE_CUSTOM_EVENT(name, proto, args, tstruct, assign, print) \ 29 PARAMS(proto), \ 34 DEFINE_CUSTOM_EVENT(name, name, PARAMS(proto), PARAMS(args)); 41 #define DECLARE_CUSTOM_EVENT_CLASS(name, proto, args, tstruct, assign, print) \ 51 #define DEFINE_CUSTOM_EVENT(template, name, proto, args) \ 62 #define DECLARE_CUSTOM_EVENT_CLASS(call, proto, args, tstruct, assign, print) \ 68 #define DEFINE_CUSTOM_EVENT(template, name, proto, args) 77 #define DECLARE_CUSTOM_EVENT_CLASS(call, proto, args, tstruct, assign, print) \ 108 #define DECLARE_CUSTOM_EVENT_CLASS(call, proto, args, tstruct, func, print) \ 120 #define DECLARE_CUSTOM_EVENT_CLASS(call, proto, arg [all...] |
/kernel/linux/linux-6.6/samples/bpf/ |
H A D | sockex2_kern.c | 29 static inline int proto_ports_offset(__u64 proto) in proto_ports_offset() argument 31 switch (proto) { in proto_ports_offset() 105 __u64 proto = load_half(skb, 12); in flow_dissector() local 108 if (proto == ETH_P_8021AD) { in flow_dissector() 109 proto = load_half(skb, nhoff + offsetof(struct vlan_hdr, in flow_dissector() 114 if (proto == ETH_P_8021Q) { in flow_dissector() 115 proto = load_half(skb, nhoff + offsetof(struct vlan_hdr, in flow_dissector() 120 if (likely(proto == ETH_P_IP)) in flow_dissector() 122 else if (proto == ETH_P_IPV6) in flow_dissector() 131 __be16 proto; in flow_dissector() member [all...] |