libpkg/common/dstream.c

100 int	ds_fd = -1;
163 		if (read(ds_fd, ds_header + ds_headsize, BLK_SIZE) < BLK_SIZE)
195 	if (ds_fd >= 0)
196 		(void) close(ds_fd);
197 	if ((ds_fd = open(device, O_RDONLY)) >= 0 &&
198 	    read(ds_fd, buf, BLK_SIZE) == BLK_SIZE &&
216 	} else if (ds_fd >= 0) {
217 		(void) close(ds_fd);
218 		ds_fd = -1;
269 	    ds_fd, ds_realfd, ds_volcnt, ds_volno, ds_totread, ds_volpart,
279 	    &ds_fd, &ds_realfd, &ds_volcnt, &ds_volno, &ds_totread,
287  * Return true if the file descriptor (ds_fd) is open on the package stream.
292 	return (ds_fd >= 0 ? B_TRUE : B_FALSE);
308 		if (ds_fd >= 0)
312 		if ((ds_fd = open(device, O_RDONLY)) < 0) {
334 		if (read(ds_fd, ds_header, BLK_SIZE) != BLK_SIZE) {
359 				while (read(ds_fd, ds_header, BLK_SIZE) > 0)
366 			if ((ds_fd = open(norewind, O_RDONLY)) < 0) {
382 			if (read(ds_fd, ds_header, BLK_SIZE) != BLK_SIZE) {
408 			if (read(ds_fd, ds_header + header_size, BLK_SIZE) !=
513 	if (n = esystem(cmd, ds_fd, -1)) {
640 	if ((ds_fd = open(device, O_RDONLY)) < 0)
668 		if (n = esystem(cmd, ds_fd, -1)) {
715 		if (n = esystem(cmd, ds_fd, -1)) {
743  * Description:	Dumps all data from the static 'ds_fd' file handle into
765 	while ((amtread = read(ds_fd, readbuf, BLK_SIZE)) != 0) {
845 	oflag = fcntl(ds_fd, F_GETFL, 0);
848 	if (fstat(ds_fd, &st_buf) == -1)
894 			if (fstat(ds_fd, &orig_st_buf) < 0) {
899 			(void) close(ds_fd);
900 			if ((ds_fd = open(device, nflag, 0666)) != -1) {
901 				if (ioctl(ds_fd, STREAMON) != -1) {
902 					(void) close(ds_fd);
905 					if ((ds_fd =
920 				read(ds_fd, buf, BLK_SIZE);
951 		fcntl(ds_fd, F_DUPFD, fd);
966 		ds_realfd = ds_fd;
967 		ds_fd = fileno(ds_pp);
999 					if ((n = write(ds_fd, ptr,
1023 		ds_fd = -1;
1024 	} else if (ds_fd >= 0) {
1025 		(void) close(ds_fd);
1026 		ds_fd = -1;