Lines Matching full:pd

239 	struct pcap_dag *pd = p->priv;
241 if(dag_stop_stream(p->fd, pd->dag_stream) < 0)
244 if(dag_detach_stream(p->fd, pd->dag_stream) < 0)
247 if(pd->dag_ref != NULL) {
248 dag_config_dispose(pd->dag_ref);
251 * dag_close(p->fd), as dag_config_dispose(pd->dag_ref)
257 pd->dag_ref = NULL;
339 struct pcap_dag *pd = p->priv;
341 unsigned int nonblocking = pd->dag_flags & DAGF_NONBLOCK;
346 while (pd->dag_mem_top - pd->dag_mem_bottom < dag_record_size) {
372 if ( NULL == (pd->dag_mem_top = dag_advance_stream(p->fd, pd->dag_stream, &(pd->dag_mem_bottom))) ) {
376 if (nonblocking && (pd->dag_mem_top - pd->dag_mem_bottom < dag_record_size))
383 pd->dag_timeout &&
384 (pd->dag_mem_top - pd->dag_mem_bottom < dag_record_size))
398 while (pd->dag_mem_top - pd->dag_mem_bottom >= dag_record_size) {
404 dag_record_t *header = (dag_record_t *)(pd->dag_mem_bottom);
429 pd->dag_mem_bottom += rlen;
444 if ( (pd->drop_attr == kNullAttributeUuid) && (header->lctr) ) {
445 pd->stat.ps_drop += ntohs(header->lctr);
559 packet_len -= (pd->dag_fcs_bits >> 3);
578 packet_len -= (pd->dag_fcs_bits >> 3);
597 packet_len -= (pd->dag_fcs_bits >> 3);
704 pd->stat.ps_recv++;
743 struct pcap_dag *pd = p->priv;
769 if (dag_parse_name(device, newDev, strlen(device) + 16, &pd->dag_stream) < 0) {
783 if (pd->dag_stream%2) {
790 if((pd->dag_ref = dag_config_init((char *)device)) == NULL) {
814 if((p->fd = dag_config_get_card_fd(pd->dag_ref)) < 0) {
825 if (dag_attach_stream64(p->fd, pd->dag_stream, 0, 0) < 0) {
833 pd->drop_attr = kNullAttributeUuid;
834 pd->dag_root = dag_config_get_root_component(pd->dag_ref);
835 if ( dag_component_get_subcomponent(pd->dag_root, kComponentStreamFeatures, 0) )
837 pd->drop_attr = dag_config_get_indexed_attribute_uuid(pd->dag_ref, kUint32AttributeStreamDropCount, pd->dag_stream/2);
843 if (dag_get_stream_poll64(p->fd, pd->dag_stream,
855 pd->required_select_timeout = poll;
856 p->required_select_timeout = &pd->required_select_timeout;
888 if (dag_set_stream_poll64(p->fd, pd->dag_stream,
912 if(dag_start_stream(p->fd, pd->dag_stream) < 0) {
924 pd->dag_mem_bottom = 0;
925 pd->dag_mem_top = 0;
934 pd->dag_fcs_bits = 0;
942 pd->dag_fcs_bits = 32;
947 pd->dag_fcs_bits = n;
962 p->linktype_ext = LT_FCS_DATALINK_EXT(pd->dag_fcs_bits/16);
965 pd->dag_fcs_bits = 0;
969 pd->dag_timeout = p->opt.timeout;
1004 pd->stat.ps_drop = 0;
1005 pd->stat.ps_recv = 0;
1006 pd->stat.ps_ifdrop = 0;
1010 if (dag_stop_stream(p->fd, pd->dag_stream) < 0) {
1015 if (dag_detach_stream(p->fd, pd->dag_stream) < 0)
1019 dag_config_dispose(pd->dag_ref);
1022 * as dag_config_dispose(pd->dag_ref) does this.
1027 pd->dag_ref = NULL;
1114 struct pcap_dag *pd = p->priv;
1125 if(pd->drop_attr != kNullAttributeUuid) {
1129 if ((dag_error = dag_config_get_uint32_attribute_ex(pd->dag_ref, pd->drop_attr, &stream_drop)) == kDagErrNone) {
1130 pd->stat.ps_drop = stream_drop;
1138 *ps = pd->stat;
1223 struct pcap_dag *pd = p->priv;
1232 * "pd->dag_flags".
1237 if (dag_get_stream_poll64(p->fd, pd->dag_stream,
1253 if (dag_set_stream_poll64(p->fd, pd->dag_stream,
1261 pd->dag_flags |= DAGF_NONBLOCK;
1263 pd->dag_flags &= ~DAGF_NONBLOCK;
1271 struct pcap_dag *pd = p->priv;
1287 if (dag_get_stream_erf_types(p->fd, pd->dag_stream, types, 255) < 0) {