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