| /freebsd/lib/libiscsiutil/ |
| H A D | pdu.c | 44 pdu_ahs_length(const struct pdu *pdu) in pdu_ahs_length() argument
47 return (pdu->pdu_bhs->bhs_total_ahs_len * 4); in pdu_ahs_length()
51 pdu_data_segment_length(const struct pdu *pdu) in pdu_data_segment_length() argument
55 len += pdu->pdu_bhs->bhs_data_segment_len[0]; in pdu_data_segment_length()
57 len += pdu->pdu_bhs->bhs_data_segment_len[1]; in pdu_data_segment_length()
59 len += pdu->pdu_bhs->bhs_data_segment_len[2]; in pdu_data_segment_length()
65 pdu_set_data_segment_length(struct pdu *pdu, uint32_t len) in pdu_set_data_segment_length() argument
68 pdu->pdu_bhs->bhs_data_segment_len[2] = len; in pdu_set_data_segment_length()
69 pdu->pdu_bhs->bhs_data_segment_len[1] = len >> 8; in pdu_set_data_segment_length()
70 pdu->pdu_bhs->bhs_data_segment_len[0] = len >> 16; in pdu_set_data_segment_length()
[all …]
|
| H A D | libiscsiutil.h | 61 struct pdu { struct
70 void (*pdu_receive_proxy)(struct pdu *);
71 void (*pdu_send_proxy)(struct pdu *);
127 keys_load_pdu(struct keys *keys, const struct pdu *pdu) in keys_load_pdu() argument
129 keys_load(keys, pdu->pdu_data, pdu->pdu_data_len); in keys_load_pdu()
133 keys_save_pdu(struct keys *keys, struct pdu *pdu) in keys_save_pdu() argument
135 keys_save(keys, &pdu->pdu_data, &pdu->pdu_data_len); in keys_save_pdu()
138 struct pdu *pdu_new(struct connection *ic);
139 struct pdu *pdu_new_response(struct pdu *request);
140 int pdu_ahs_length(const struct pdu *pdu);
[all …]
|
| H A D | text.c | 41 static struct pdu *
44 struct pdu *request; in text_new_request()
62 static struct pdu *
65 struct pdu *request; in text_receive_request()
95 static struct pdu *
96 text_new_response(struct pdu *request, uint32_t ttt, bool final) in text_new_response()
98 struct pdu *response; in text_new_response()
124 static struct pdu *
127 struct pdu *response; in text_receive_response()
172 struct pdu *request; in text_send_request()
[all …]
|
| /freebsd/contrib/bsnmp/lib/ |
| H A D | snmp.c | 199 snmp_parse_pdus_hdr(struct asn_buf *b, struct snmp_pdu *pdu, asn_len_t *lenp) in snmp_parse_pdus_hdr() argument
201 if (pdu->type == SNMP_PDU_TRAP) { in snmp_parse_pdus_hdr()
202 if (asn_get_objid(b, &pdu->enterprise) != ASN_ERR_OK) { in snmp_parse_pdus_hdr()
206 if (asn_get_ipaddress(b, pdu->agent_addr) != ASN_ERR_OK) { in snmp_parse_pdus_hdr()
210 if (asn_get_integer(b, &pdu->generic_trap) != ASN_ERR_OK) { in snmp_parse_pdus_hdr()
214 if (asn_get_integer(b, &pdu->specific_trap) != ASN_ERR_OK) { in snmp_parse_pdus_hdr()
218 if (asn_get_timeticks(b, &pdu->time_stamp) != ASN_ERR_OK) { in snmp_parse_pdus_hdr()
223 if (asn_get_integer(b, &pdu->request_id) != ASN_ERR_OK) { in snmp_parse_pdus_hdr()
227 if (asn_get_integer(b, &pdu->error_status) != ASN_ERR_OK) { in snmp_parse_pdus_hdr()
231 if (asn_get_integer(b, &pdu->error_index) != ASN_ERR_OK) { in snmp_parse_pdus_hdr()
[all …]
|
| H A D | snmpagent.c | 169 snmp_pdu_create_response(const struct snmp_pdu *pdu, struct snmp_pdu *resp) in snmp_pdu_create_response() argument
172 strcpy(resp->community, pdu->community); in snmp_pdu_create_response()
173 resp->version = pdu->version; in snmp_pdu_create_response()
174 if (pdu->flags & SNMP_MSG_AUTODISCOVER) in snmp_pdu_create_response()
178 resp->request_id = pdu->request_id; in snmp_pdu_create_response()
179 resp->version = pdu->version; in snmp_pdu_create_response()
184 memcpy(&resp->engine, &pdu->engine, sizeof(pdu->engine)); in snmp_pdu_create_response()
185 memcpy(&resp->user, &pdu->user, sizeof(pdu->user)); in snmp_pdu_create_response()
187 resp->identifier = pdu->identifier; in snmp_pdu_create_response()
188 resp->security_model = pdu->security_model; in snmp_pdu_create_response()
[all …]
|
| H A D | snmpcrypto.c | 89 snmp_pdu_calc_digest(const struct snmp_pdu *pdu, uint8_t *digest) in snmp_pdu_calc_digest() argument
101 err = snmp_digest_init(&pdu->user, ctx, &dtype, &keylen); in snmp_pdu_calc_digest()
109 memset(pdu->digest_ptr, 0, sizeof(pdu->msg_digest)); in snmp_pdu_calc_digest()
110 memcpy(extkey, pdu->user.auth_key, keylen); in snmp_pdu_calc_digest()
119 EVP_DigestUpdate(ctx, pdu->outer_ptr, pdu->outer_len) != 1 || in snmp_pdu_calc_digest()
145 snmp_pdu_cipher_init(const struct snmp_pdu *pdu, int32_t len, in snmp_pdu_cipher_init() argument
151 if (pdu->user.priv_proto == SNMP_PRIV_DES) { in snmp_pdu_cipher_init()
155 memcpy(piv, pdu->msg_salt, sizeof(pdu->msg_salt)); in snmp_pdu_cipher_init()
157 piv[i] = piv[i] ^ pdu->user.priv_key[8 + i]; in snmp_pdu_cipher_init()
158 } else if (pdu->user.priv_proto == SNMP_PRIV_AES) { in snmp_pdu_cipher_init()
[all …]
|
| H A D | snmpclient.c | 79 struct snmp_pdu *pdu; member
124 struct snmp_pdu pdu; member
446 table_init_pdu(const struct snmp_table *descr, struct snmp_pdu *pdu) in table_init_pdu() argument
449 snmp_pdu_create(pdu, SNMP_PDU_GETNEXT); in table_init_pdu()
451 snmp_pdu_create(pdu, SNMP_PDU_GETBULK); in table_init_pdu()
452 pdu->error_index = 10; in table_init_pdu()
455 pdu->bindings[pdu->nbindings].syntax = SNMP_SYNTAX_NULL; in table_init_pdu()
456 pdu->bindings[pdu->nbindings].var = descr->last_change; in table_init_pdu()
457 pdu->nbindings++; in table_init_pdu()
458 if (pdu->version != SNMP_V1) in table_init_pdu()
[all …]
|
| /freebsd/lib/libsdp/ |
| H A D | service.c | 53 sdp_pdu_t pdu; in sdp_register_service() local
63 if (sizeof(pdu)+sizeof(uuid)+sizeof(*bdaddr)+datalen > SDP_LOCAL_MTU) { in sdp_register_service()
68 pdu.pid = SDP_PDU_SERVICE_REGISTER_REQUEST; in sdp_register_service()
69 pdu.tid = htons(++ss->tid); in sdp_register_service()
70 pdu.len = htons(sizeof(uuid) + sizeof(*bdaddr) + datalen); in sdp_register_service()
74 iov[0].iov_base = (void *) &pdu; in sdp_register_service()
75 iov[0].iov_len = sizeof(pdu); in sdp_register_service()
98 if (len != sizeof(pdu) + sizeof(uint16_t) + sizeof(uint32_t)) { in sdp_register_service()
118 sdp_pdu_t pdu; in sdp_unregister_service() local
127 if (sizeof(pdu) + sizeof(handle) > SDP_LOCAL_MTU) { in sdp_unregister_service()
[all …]
|
| H A D | search.c | 54 sdp_pdu_t pdu; in sdp_search() member
159 xpdu.pdu.pid = SDP_PDU_SERVICE_SEARCH_ATTRIBUTE_REQUEST; in sdp_search()
160 xpdu.pdu.tid = htons(ss->tid); in sdp_search()
161 xpdu.pdu.len = htons(req_cs - ss->req); in sdp_search()
165 iov[0].iov_len = sizeof(xpdu.pdu); in sdp_search()
197 xpdu.pdu.tid = ntohs(xpdu.pdu.tid); in sdp_search()
198 xpdu.pdu.len = ntohs(xpdu.pdu.len); in sdp_search()
201 if (xpdu.pdu.pid == SDP_PDU_ERROR_RESPONSE || in sdp_search()
202 xpdu.pdu.tid != ss->tid || in sdp_search()
203 xpdu.pdu.len > len || in sdp_search()
[all …]
|
| /freebsd/contrib/bsnmp/snmpd/ |
| H A D | trap.c | 423 snmp_create_v1_trap(struct snmp_pdu *pdu, char *com, in snmp_create_v1_trap() argument
426 memset(pdu, 0, sizeof(*pdu)); in snmp_create_v1_trap()
427 strlcpy(pdu->community, com, sizeof(pdu->community)); in snmp_create_v1_trap()
429 pdu->version = SNMP_V1; in snmp_create_v1_trap()
430 pdu->type = SNMP_PDU_TRAP; in snmp_create_v1_trap()
431 pdu->enterprise = systemg.object_id; in snmp_create_v1_trap()
432 memcpy(pdu->agent_addr, snmpd.trap1addr, 4); in snmp_create_v1_trap()
433 pdu->generic_trap = trap_oid->subs[trap_oid->len - 1] - 1; in snmp_create_v1_trap()
434 pdu->specific_trap = 0; in snmp_create_v1_trap()
435 pdu->time_stamp = get_ticks() - start_tick; in snmp_create_v1_trap()
[all …]
|
| H A D | main.c | 282 snmp_output(struct snmp_pdu *pdu, u_char *sndbuf, size_t *sndlen, in snmp_output() argument
291 if ((code = snmp_pdu_encode(pdu, &resp_b)) != SNMP_CODE_OK) { in snmp_output()
297 snmp_pdu_dump(pdu); in snmp_output()
306 snmp_pdu_auth_user(struct snmp_pdu *pdu) in snmp_pdu_auth_user() argument
311 if (pdu->engine.engine_len == 0 && strlen(pdu->user.sec_name) == 0) { in snmp_pdu_auth_user()
312 pdu->engine.engine_len = snmpd_engine.engine_len; in snmp_pdu_auth_user()
313 memcpy(pdu->engine.engine_id, snmpd_engine.engine_id, in snmp_pdu_auth_user()
316 pdu->engine.engine_boots = snmpd_engine.engine_boots; in snmp_pdu_auth_user()
317 pdu->engine.engine_time = snmpd_engine.engine_time; in snmp_pdu_auth_user()
318 pdu->flags |= SNMP_MSG_AUTODISCOVER; in snmp_pdu_auth_user()
[all …]
|
| /freebsd/lib/libnvmf/ |
| H A D | nvmf_tcp.c | 151 nvmf_tcp_write_pdu(struct nvmf_tcp_qpair *qp, const void *pdu, size_t len) in nvmf_tcp_write_pdu() argument
156 cp = pdu; in nvmf_tcp_write_pdu()
225 nvmf_tcp_validate_pdu(struct nvmf_tcp_qpair *qp, struct nvmf_tcp_rxpdu *pdu, in nvmf_tcp_validate_pdu() argument
236 ch = pdu->hdr; in nvmf_tcp_validate_pdu()
281 pdu->data_len = data_len; in nvmf_tcp_validate_pdu()
309 nvmf_tcp_read_pdu(struct nvmf_tcp_qpair *qp, struct nvmf_tcp_rxpdu *pdu) in nvmf_tcp_read_pdu() argument
315 memset(pdu, 0, sizeof(*pdu)); in nvmf_tcp_read_pdu()
327 pdu->hdr = &ch; in nvmf_tcp_read_pdu()
328 error = nvmf_tcp_validate_pdu(qp, pdu, sizeof(ch)); in nvmf_tcp_read_pdu()
329 pdu->hdr = NULL; in nvmf_tcp_read_pdu()
[all …]
|
| /freebsd/sys/dev/virtio/scmi/ |
| H A D | virtio_scmi.c | 266 struct vtscmi_pdu *pdu; in vtscmi_alloc_queues() local
277 q->pdus = mallocarray(q->vq_sz, sizeof(*pdu), M_DEVBUF, in vtscmi_alloc_queues()
281 for (i = 0, pdu = q->pdus; i < q->vq_sz; i++, pdu++) { in vtscmi_alloc_queues()
282 pdu->chan = idx; in vtscmi_alloc_queues()
284 sglist_init(&pdu->sg, in vtscmi_alloc_queues()
285 idx == VIRTIO_SCMI_CHAN_A2P ? 2 : 1, pdu->segs); in vtscmi_alloc_queues()
286 SLIST_INSERT_HEAD(&q->p_head, pdu, next); in vtscmi_alloc_queues()
329 struct vtscmi_pdu *pdu; in vtscmi_vq_intr() local
333 pdu = virtqueue_dequeue(q->vq, &rx_len); in vtscmi_vq_intr()
335 if (!pdu) in vtscmi_vq_intr()
[all …]
|
| /freebsd/sys/dev/nvmf/ |
| H A D | nvmf_tcp.c | 306 nvmf_tcp_validate_pdu(struct nvmf_tcp_qpair *qp, struct nvmf_tcp_rxpdu *pdu) in nvmf_tcp_validate_pdu() argument
309 struct mbuf *m = pdu->m; in nvmf_tcp_validate_pdu()
317 ch = pdu->hdr; in nvmf_tcp_validate_pdu()
346 pdu->data_digest_mismatch = false; in nvmf_tcp_validate_pdu()
353 pdu->data_digest_mismatch = true; in nvmf_tcp_validate_pdu()
357 pdu->data_len = data_len; in nvmf_tcp_validate_pdu()
362 nvmf_tcp_free_pdu(struct nvmf_tcp_rxpdu *pdu) in nvmf_tcp_free_pdu() argument
364 m_freem(pdu->m); in nvmf_tcp_free_pdu()
365 pdu->m = NULL; in nvmf_tcp_free_pdu()
366 pdu->hdr = NULL; in nvmf_tcp_free_pdu()
[all …]
|
| /freebsd/contrib/tcpdump/ |
| H A D | print-rpki-rtr.c | 255 const rpki_rtr_pdu_ipv4_prefix *pdu; in rpki_rtr_pdu_print() local
259 pdu = (const rpki_rtr_pdu_ipv4_prefix *)tptr; in rpki_rtr_pdu_print()
262 GET_IPADDR_STRING(pdu->prefix), in rpki_rtr_pdu_print()
263 GET_U_1(pdu->prefix_length), GET_U_1(pdu->max_length), in rpki_rtr_pdu_print()
264 GET_BE_U_4(pdu->as), GET_U_1(pdu->flags)); in rpki_rtr_pdu_print()
270 const rpki_rtr_pdu_ipv6_prefix *pdu; in rpki_rtr_pdu_print() local
274 pdu = (const rpki_rtr_pdu_ipv6_prefix *)tptr; in rpki_rtr_pdu_print()
277 GET_IP6ADDR_STRING(pdu->prefix), in rpki_rtr_pdu_print()
278 GET_U_1(pdu->prefix_length), GET_U_1(pdu->max_length), in rpki_rtr_pdu_print()
279 GET_BE_U_4(pdu->as), GET_U_1(pdu->flags)); in rpki_rtr_pdu_print()
[all …]
|
| /freebsd/sys/dev/cxgbe/nvmf/ |
| H A D | nvmf_che.c | 914 nvmf_che_validate_pdu(struct nvmf_che_qpair *qp, struct nvmf_che_rxpdu *pdu) in nvmf_che_validate_pdu() argument
917 struct mbuf *m = pdu->m; in nvmf_che_validate_pdu()
924 ch = pdu->hdr; in nvmf_che_validate_pdu()
986 pdu->m, pdu->hdr->hlen); in nvmf_che_validate_pdu()
1031 pdu->data_digest_mismatch = false; in nvmf_che_validate_pdu()
1035 pdu->data_digest_mismatch = true; in nvmf_che_validate_pdu()
1041 pdu->data_len = data_len; in nvmf_che_validate_pdu()
1047 nvmf_che_free_pdu(struct nvmf_che_rxpdu *pdu) in nvmf_che_free_pdu() argument
1049 m_freem(pdu->m); in nvmf_che_free_pdu()
1050 pdu->m = NULL; in nvmf_che_free_pdu()
[all …]
|
| /freebsd/usr.sbin/bsnmpd/tools/bsnmptools/ |
| H A D | bsnmpget.c | 322 snmptool_add_vbind(struct snmp_pdu *pdu, struct snmp_object *obj) in snmptool_add_vbind() argument
327 asn_append_oid(&(pdu->bindings[pdu->nbindings].var), &(obj->val.var)); in snmptool_add_vbind()
328 pdu->nbindings++; in snmptool_add_vbind()
330 return (pdu->nbindings); in snmptool_add_vbind()
337 snmpget_verify_vbind(struct snmp_toolinfo *snmptoolctx, struct snmp_pdu *pdu, in snmpget_verify_vbind() argument
340 if (pdu->version == SNMP_V1 && obj->val.syntax == in snmpget_verify_vbind()
346 if (ISSET_NUMERIC(snmptoolctx) || pdu->type == SNMP_PDU_GETNEXT || in snmpget_verify_vbind()
347 pdu->type == SNMP_PDU_GETBULK) in snmpget_verify_vbind()
350 if (pdu->type == SNMP_PDU_GET && obj->val.syntax == SNMP_SYNTAX_NULL) { in snmpget_verify_vbind()
365 snmpget_fix_getbulk(struct snmp_pdu *pdu, uint32_t max_rep, uint32_t non_rep) in snmpget_fix_getbulk() argument
[all …]
|
| /freebsd/usr.sbin/ctld/ |
| H A D | login.cc | 50 static void login_send_error(struct pdu *request,
106 login_set_nsg(struct pdu *response, int nsg) in login_set_nsg()
122 login_csg(const struct pdu *request) in login_csg()
132 login_set_csg(struct pdu *response, int csg) in login_set_csg()
146 static struct pdu *
149 struct pdu *request; in login_receive()
206 static struct pdu *
207 login_new_response(struct pdu *request) in login_new_response()
209 struct pdu *response; in login_new_response()
232 login_send_error(struct pdu *request, char error_class, char detail) in login_send_error()
[all …]
|
| H A D | iscsi.cc | 121 static void pdu_receive_proxy(struct pdu *pdu);
122 static void pdu_send_proxy(struct pdu *pdu);
377 pdu_receive_proxy(struct pdu *pdu) in pdu_receive_proxy() argument
383 conn = pdu->pdu_connection; in pdu_receive_proxy()
385 kernel_receive(pdu); in pdu_receive_proxy()
387 len = pdu_ahs_length(pdu); in pdu_receive_proxy()
391 len = pdu_data_segment_length(pdu); in pdu_receive_proxy()
393 pdu->pdu_data_len = len; in pdu_receive_proxy()
397 pdu_send_proxy(struct pdu *pdu) in pdu_send_proxy() argument
402 pdu_set_data_segment_length(pdu, pdu->pdu_data_len); in pdu_send_proxy()
[all …]
|
| H A D | iscsi.hh | 47 void login_negotiate_key(struct pdu *request, const char *name,
50 bool login_portal_redirect(struct pdu *request);
51 bool login_target_redirect(struct pdu *request);
52 void login_negotiate(struct pdu *request);
|
| /freebsd/usr.sbin/iscsid/ |
| H A D | iscsid.c | 61 static void pdu_receive_proxy(struct pdu *pdu);
62 static void pdu_send_proxy(struct pdu *pdu);
89 pdu_receive_proxy(struct pdu *pdu) in pdu_receive_proxy() argument
96 conn = (struct iscsid_connection *)pdu->pdu_connection; in pdu_receive_proxy()
99 pdu->pdu_data = malloc(conn->conn.conn_max_recv_data_segment_length); in pdu_receive_proxy()
100 if (pdu->pdu_data == NULL) in pdu_receive_proxy()
105 idr.idr_bhs = pdu->pdu_bhs; in pdu_receive_proxy()
107 idr.idr_data_segment = pdu->pdu_data; in pdu_receive_proxy()
113 len = pdu_ahs_length(pdu); in pdu_receive_proxy()
117 len = pdu_data_segment_length(pdu); in pdu_receive_proxy()
[all …]
|
| H A D | login.c | 45 login_nsg(const struct pdu *response) in login_nsg()
55 login_set_nsg(struct pdu *request, int nsg) in login_set_nsg()
70 login_set_csg(struct pdu *request, int csg) in login_set_csg()
188 login_handle_redirection(struct iscsid_connection *conn, struct pdu *response) in login_handle_redirection()
214 static struct pdu *
217 struct pdu *response; in login_receive()
270 static struct pdu *
273 struct pdu *request; in login_new_request()
480 struct pdu *request, *response; in login_negotiate()
601 struct pdu *request; in login_send_chap_a()
[all …]
|
| /freebsd/usr.sbin/bluetooth/sdpd/ |
| H A D | server.c | 408 sdp_pdu_p pdu = (sdp_pdu_p) srv->req; in server_process_request() local
435 if (len >= sizeof(*pdu) && in server_process_request()
436 sizeof(*pdu) + (pdu->len = ntohs(pdu->len)) == len) { in server_process_request()
437 switch (pdu->pid) { in server_process_request()
470 switch (pdu->pid) { in server_process_request()
504 pdu->pid, ntohs(pdu->tid), error); in server_process_request()
510 pdu->pid, ntohs(pdu->tid), pdu->len, len, error); in server_process_request()
517 pdu->pid, ntohs(pdu->tid), error); in server_process_request()
540 sdp_pdu_t pdu; in server_send_error_response() member
545 rsp.pdu.pid = SDP_PDU_ERROR_RESPONSE; in server_send_error_response()
[all …]
|
| H A D | srr.c | 117 sdp_pdu_t pdu; in server_send_service_register_response()
122 pdu.pid = SDP_PDU_ERROR_RESPONSE; in server_send_service_register_response()
123 pdu.tid = ((sdp_pdu_p)(srv->req))->tid; in server_send_service_register_response()
124 pdu.len = htons(srv->fdidx[fd].rsp_size); in server_send_service_register_response()
126 iov[0].iov_base = &pdu; in server_send_service_register_response()
127 iov[0].iov_len = sizeof(pdu); in server_send_service_register_response()
116 sdp_pdu_t pdu; server_send_service_register_response() local
|
| H A D | sar.c | 255 sdp_pdu_t pdu; in server_send_service_attribute_response()
286 pdu.pid = SDP_PDU_SERVICE_ATTRIBUTE_RESPONSE; in server_send_service_attribute_response()
288 pdu.pid = SDP_PDU_SERVICE_SEARCH_ATTRIBUTE_RESPONSE; in server_send_service_attribute_response()
290 pdu.tid = ((sdp_pdu_p)(srv->req))->tid; in server_send_service_attribute_response()
291 pdu.len = htons(sizeof(bcount) + bcount + 1 + cs[0]); in server_send_service_attribute_response()
295 iov[0].iov_base = &pdu; in server_send_service_attribute_response()
296 iov[0].iov_len = sizeof(pdu); in server_send_service_attribute_response()
254 sdp_pdu_t pdu; server_send_service_attribute_response() local
|