Cross Reference: /src/usr.sbin/npf/npfd/npfd

Lines Matching refs:ctx
64 npfd_log_setfilter(npfd_log_t *ctx)
68 	if (ctx->filter == NULL)
71 	if (pcap_compile(ctx->pcap, &bprog, ctx->filter, 1, 0) == -1)
73 		    ctx->filter, pcap_geterr(ctx->pcap));
74 	if (pcap_setfilter(ctx->pcap, &bprog) == -1)
76 		    pcap_geterr(ctx->pcap));
81 npfd_log_gethdr(npfd_log_t *ctx, struct pcap_file_header*hdr)
83 	FILE *fp = fopen(ctx->path, "r");
100 		    hdr->sigfigs != (u_int)pcap_get_tstamp_precision(ctx->pcap))
115 npfd_log_getsnaplen(npfd_log_t *ctx)
118 	FILE *fp = npfd_log_gethdr(ctx, &hdr);
126 npfd_log_validate(npfd_log_t *ctx)
129 	FILE *fp = npfd_log_gethdr(ctx, &hdr);
153 			    ctx->path);
175 	    count, ctx->path, no);
179 		    ctx->path);
180 		if (truncate(ctx->path, (off_t)o) == -1) {
181 			syslog(LOG_ERR, "Cannot truncate `%s': %m", ctx->path);
185 		syslog(LOG_ERR, "Corrupt file `%s'", ctx->path);
193 	if (snprintf(tmp, sizeof(tmp), "%s.XXXXXX", ctx->path) > MAXPATHLEN)
195 		       ctx->path);
202 	if (rename(ctx->path, tmp) == -1) {
204 		    ctx->path, tmp);
216 	npfd_log_t *ctx;
218 	if ((ctx = calloc(1, sizeof(*ctx))) == NULL)
221 	snprintf(ctx->ifname, sizeof(ctx->ifname), "%s", ifname);
223 		snprintf(ctx->path, sizeof(ctx->path), NPFD_LOG_PATH "/%s.pcap",
224 		    ctx->ifname);
226 		snprintf(ctx->path, sizeof(ctx->path), "%s", filename);
229 		ctx->filter = strdup(filter);
230 		if (ctx->filter == NULL)
233 	ctx->snaplen = snaplen;
236 	npfd_log_pcap_reopen(ctx);
239 	npfd_log_file_reopen(ctx, false);
240 	return ctx;
245 npfd_log_pcap_reopen(npfd_log_t *ctx)
248 	int snaplen = ctx->snaplen;
251 	if (ctx->pcap != NULL)
252 		pcap_close(ctx->pcap);
256 	ctx->pcap = pcap_create(ctx->ifname, errbuf);
257 	if (ctx->pcap == NULL)
260 	if (pcap_setnonblock(ctx->pcap, 1, errbuf) == -1)
263 	int sl = npfd_log_getsnaplen(ctx);
265 		errx(EXIT_FAILURE, "corrupt log file `%s'", ctx->path);
269 		    sl, ctx->path);
273 	if (pcap_set_snaplen(ctx->pcap, snaplen) == -1)
275 		    pcap_geterr(ctx->pcap));
277 	if (pcap_set_timeout(ctx->pcap, 1000) == -1)
279 		    pcap_geterr(ctx->pcap));
281 	if ((rc = pcap_activate(ctx->pcap)) != 0) {
282 		const char *msg = pcap_geterr(ctx->pcap);
290 	npfd_log_setfilter(ctx);
295 npfd_log_file_reopen(npfd_log_t *ctx, bool die)
299 	if (ctx->dumper)
300 		pcap_dump_close(ctx->dumper);
304 	switch (npfd_log_validate(ctx)) {
310 		ctx->dumper = pcap_dump_open(ctx->pcap, ctx->path);
313 		ctx->dumper = pcap_dump_open_append(ctx->pcap, ctx->path);
318 	if (ctx->dumper == NULL) {
321 			    ctx->path, pcap_geterr(ctx->pcap));
323 		    ctx->path, pcap_geterr(ctx->pcap));
330 npfd_log_destroy(npfd_log_t *ctx)
332 	if (ctx->dumper)
333 		pcap_dump_close(ctx->dumper);
334 	if (ctx->pcap)
335 		pcap_close(ctx->pcap);
336 	free(ctx);
340 npfd_log_getsock(npfd_log_t *ctx)
342 	return pcap_get_selectable_fd(ctx->pcap);
346 npfd_log_flush(npfd_log_t *ctx)
348 	if (!ctx->dumper)
350 	if (pcap_dump_flush(ctx->dumper) == -1)
352 		    ctx->path);
357 npfd_log(npfd_log_t *ctx)
359 	pcap_dumper_t *dumper = ctx->dumper;
361 	return pcap_dispatch(ctx->pcap, PCAP_NPACKETS, pcap_dump,
366 npfd_log_stats(npfd_log_t *ctx)
368 	pcap_t *pcap = ctx->pcap;
376 	    ctx->ifname, ps.ps_recv, ps.ps_drop);
OpenGrok
