bin/pax/ar_io.c

1241

if (pipe(fds) < 0)

bin/sh/eval.c

581

if (pipe(pip) < 0) {

bin/sh/eval.c

683

if (pipe(pip) < 0)

bin/sh/eval.c

985

if (pipe(pip) < 0)

bin/sh/redir.c

262

if (pipe(pip) < 0)

cddl/usr.sbin/zfsd/zfsd.cc

161

if (pipe(s_signalPipeFD) != 0)

crypto/heimdal/appl/ftp/ftpd/popen.c

124

if (pipe(pdes) < 0)

crypto/heimdal/appl/rcp/rcp.c

722

pipe(reserved);

crypto/heimdal/appl/rcp/rcp.c

725

if (pipe(pin) < 0) {

crypto/heimdal/appl/rcp/rcp.c

729

if (pipe(pout) < 0) {

crypto/heimdal/appl/test/gssapi_client.c

233

if (pipe (pipefd) < 0)

crypto/heimdal/appl/test/gssapi_server.c

263

if (pipe (pipefd) < 0)

crypto/heimdal/lib/roken/simple_exec.c

153

pipe(in_fd);

crypto/heimdal/lib/roken/simple_exec.c

155

pipe(out_fd);

crypto/heimdal/lib/roken/simple_exec.c

157

pipe(err_fd);

crypto/krb5/src/ccapi/server/win/WorkItem.cpp

50

WorkItem::WorkItem(k5_ipc_stream buf, WIN_PIPE* pipe, const long type, const long sst)

crypto/krb5/src/ccapi/server/win/WorkItem.cpp

51

: _buf(buf), _rpcmsg(type), _pipe(pipe), _sst(sst) { }

crypto/krb5/src/ccapi/server/win/WorkItem.cpp

77

WIN_PIPE* temp = pipe();

crypto/krb5/src/ccapi/server/win/WorkQueue.cpp

54

const ccs_pipe_t pipe,

crypto/krb5/src/ccapi/server/win/WorkQueue.cpp

57

return worklist.add(new WorkItem(stream, pipe, rpcmsg, serverStartTime) );

crypto/krb5/src/ccapi/server/win/WorkQueue.cpp

61

ccs_pipe_t* pipe,

crypto/krb5/src/ccapi/server/win/WorkQueue.cpp

68

*pipe = item->take_pipe();

crypto/krb5/src/ccapi/server/win/WorkQueue.h

42

const ccs_pipe_t pipe,

crypto/krb5/src/ccapi/server/win/WorkQueue.h

47

ccs_pipe_t* pipe,

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

243

ccs_pipe_t pipe = NULL;

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

246

if (worklist_remove(&rpcmsg, &pipe, &buf, &serverStartTime)) {

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

247

uuid = ccs_win_pipe_getUuid(pipe);

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

262

status = ccs_server_add_client(pipe);

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

264

if (!status) {status = send_connection_reply(pipe);}

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

270

status = ccs_server_remove_client(pipe);

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

276

ccs_pipe_copy(&pipe2, pipe);

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

278

err = ccs_server_handle_request (pipe, pipe2, buf);

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

284

err = ccs_os_server_send_reply(pipe, stream);

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

547

ccs_pipe_t pipe = ccs_win_pipe_new((char*)pAsync->UserInfo, NULL);

crypto/krb5/src/ccapi/server/win/ccs_os_server.cpp

553

pipe,

crypto/krb5/src/ccapi/server/win/ccs_request_proc.c

47

WIN_PIPE* pipe = NULL;

crypto/krb5/src/ccapi/server/win/ccs_request_proc.c

59

pipe = ccs_win_pipe_new(pszUUID, *p);

crypto/krb5/src/ccapi/server/win/ccs_request_proc.c

60

worklist_add(rpcmsg, pipe, stream, serverStartTime);

crypto/krb5/src/ccapi/server/win/ccs_request_proc.c

72

WIN_PIPE* pipe = ccs_win_pipe_new(pszUUID, *p);

crypto/krb5/src/ccapi/server/win/ccs_request_proc.c

75

pipe,

crypto/krb5/src/ccapi/server/win/workitem.h

19

WIN_PIPE* pipe,

crypto/krb5/src/ccapi/server/win/workitem.h

29

WIN_PIPE* pipe() const {return _pipe;}

crypto/krb5/src/lib/krad/t_daemon.h

63

if (pipe(fds) != 0)

crypto/krb5/src/util/ss/pager.c

35

if (pipe(filedes) != 0)

crypto/krb5/src/util/verto/ev.c

2404

while (pipe (fds))

crypto/openssh/misc.c

2818

if (pipe(p) == -1) {

crypto/openssh/monitor.c

1924

if (pipe(pair) == -1)

crypto/openssh/openbsd-compat/bsd-pselect.c

74

if (pipe(notify_pipe) == -1) {

crypto/openssh/readpass.c

64

if (pipe(p) == -1) {

crypto/openssh/scp.c

300

if (pipe(pin) == -1 || pipe(pout) == -1)

crypto/openssh/session.c

409

if (pipe(pin) == -1) {

crypto/openssh/session.c

413

if (pipe(pout) == -1) {

crypto/openssh/session.c

419

if (pipe(perr) == -1) {

crypto/openssh/sftp.c

2369

if ((pipe(pin) == -1) || (pipe(pout) == -1))

crypto/openssh/sshconnect.c

208

if (pipe(pin) == -1 || pipe(pout) == -1)

crypto/openssh/sshconnect2.c

2034

if (pipe(to) == -1) {

crypto/openssh/sshconnect2.c

2038

if (pipe(from) == -1) {

crypto/openssl/apps/speed.c

4949

if (pipe(fd) == -1) {

crypto/openssl/engines/e_afalg.c

633

pipe(actx->zc_pipe);

crypto/openssl/engines/e_dasync.c

560

if (pipe(pipefds) != 0) {

crypto/openssl/test/drbgtest.c

338

if (!TEST_int_ge(pipe(fd), 0))

include/unistd.h

363

int pipe(int *);

lib/libc/sys/pipe.c

34

__weak_reference(__sys_pipe, pipe);

lib/libc/tests/gen/fmtmsg_test.c

167

if (pipe(pip) == -1)

lib/libc/tests/stdio/gets_s_test.c

64

pipe(fd);

lib/libc/tests/stdlib/libc_exit_test.c

61

ATF_REQUIRE(pipe(p) == 0);

lib/libc/tests/stdtime/detect_tz_changes_test.c

230

if (pipe(opd) != 0 || pipe(epd) != 0 || pipe(spd) != 0)

lib/libdpv/dialog_util.c

308

if (pipe(stdin_pipe) < 0)

lib/libdpv/util.c

80

if (pipe(stdin_pipe) < 0)

lib/libnv/tests/nvlist_send_recv_test.c

76

if (pipe(pfd) == -1)

lib/libpam/modules/pam_exec/pam_exec.c

248

if (pipe(chin) != 0) {

lib/libpam/modules/pam_exec/pam_exec.c

282

if (pipe(chout) != 0) {

lib/libpam/modules/pam_exec/pam_exec.c

297

if (pipe(cherr) != 0) {

lib/libpam/modules/pam_ssh/pam_ssh.c

281

if (pipe(agent_pipe) == -1)

lib/libpmc/libpmc.c

365

__K8MASK(add-pipe-excluding-junk-ops, 0),

lib/libpmc/libpmc.c

366

__K8MASK(multiply-pipe-excluding-junk-ops, 1),

lib/libpmc/libpmc.c

367

__K8MASK(store-pipe-excluding-junk-ops, 2),

lib/libpmc/libpmc.c

368

__K8MASK(add-pipe-junk-ops, 3),

lib/libpmc/libpmc.c

369

__K8MASK(multiply-pipe-junk-ops, 4),

lib/libpmc/libpmc.c

370

__K8MASK(store-pipe-junk-ops, 5),

lib/libprocstat/libprocstat.c

128

struct pipestat *pipe, char *errbuf);

lib/libprocstat/libprocstat.c

130

struct pipestat *pipe, char *errbuf);

lib/libprocstat/libprocstat.c

971

struct pipe pi;

lib/libprocstat/libprocstat.c

981

if (!kvm_read_all(kd, (unsigned long)pipep, &pi, sizeof(struct pipe))) {

lib/libprocstat/libprocstat.h

228

struct pipestat *pipe, char *errbuf);

lib/libutil/tests/pidfile_test.c

135

if (pipe(fd) != 0)

libexec/fingerd/fingerd.c

178

if (pipe(p) < 0)

libexec/flua/lfbsd/lfbsd.c

103

if (pipe(stdin_pipe) < 0) {

libexec/flua/lfbsd/lfbsd.c

109

if (capture_stdout && pipe(stdout_pipe) < 0) {

libexec/flua/modules/lposix.c

371

error = pipe(fd);

libexec/flua/modules/lposix.c

588

REG_SIMPLE(pipe),

sbin/dhclient/dhclient.c

507

if (pipe(pipe_fd) == -1)

sbin/ipfw/main.c

609

if (pipe(pipedes) == -1)

sbin/ipfw/tables.c

1517

v->pipe = val;

sbin/ipfw/tables.c

1586

v->pipe = strtol(n, &e, 10);

sbin/ipfw/tables.c

1842

l = snprintf(buf, sz, "%u,", v->pipe);

sbin/mdmfs/mdmfs.c

769

if (pipe(&pfd[0]) == -1)

sbin/pfctl/tests/pfctl_test.c

111

ATF_REQUIRE_ERRNO(0, pipe(pipefds) == 0);

sbin/swapon/swapon.c

668

if (pipe(&pfd[0]) == -1) {

share/doc/psd/20.ipctut/pipe.c

45

if (pipe(sockets) < 0) {

sys/arm/nvidia/drm2/tegra_dc.c

953

event->pipe = sc->tegra_crtc.nvidia_head;

sys/arm/nvidia/drm2/tegra_dc.c

955

drm_vblank_get(drm, event->pipe);

sys/arm/nvidia/drm2/tegra_host1x.c

282

host1x_drm_enable_vblank(struct drm_device *drm_dev, int pipe)

sys/arm/nvidia/drm2/tegra_host1x.c

287

if (pipe == tegra_dc_get_pipe(crtc)) {

sys/arm/nvidia/drm2/tegra_host1x.c

296

host1x_drm_disable_vblank(struct drm_device *drm_dev, int pipe)

sys/arm/nvidia/drm2/tegra_host1x.c

301

if (pipe == tegra_dc_get_pipe(crtc)) {

sys/compat/freebsd32/freebsd32_sysent.c

112

{ compat10(0,pipe), .sy_auevent = AUE_PIPE, .sy_flags = SYF_CAPENABLED, .sy_thrcnt = SY_THR_STATIC }, /* 42 = freebsd10 pipe */

sys/compat/linux/linux_file.c

1366

struct pipe *fpipe;

sys/dev/drm2/drmP.h

962

int pipe;

sys/dev/drm2/drm_fops.c

308

drm_vblank_put(dev, v->pipe);

sys/dev/drm2/drm_irq.c

1001

drm_vblank_put(dev, e->pipe);

sys/dev/drm2/drm_irq.c

1107

static int drm_queue_vblank_event(struct drm_device *dev, int pipe,

sys/dev/drm2/drm_irq.c

1122

e->pipe = pipe;

sys/dev/drm2/drm_irq.c

1139

seq = drm_vblank_count_and_time(dev, pipe, &now);

sys/dev/drm2/drm_irq.c

1148

vblwait->request.sequence, seq, pipe);

sys/dev/drm2/drm_irq.c

1150

CTR4(KTR_DRM, "vblank_event_queued %d %d rt %x %d", curproc->p_pid, pipe,

sys/dev/drm2/drm_irq.c

1155

drm_vblank_put(dev, pipe);

sys/dev/drm2/drm_irq.c

1172

drm_vblank_put(dev, pipe);

sys/dev/drm2/drm_irq.c

1313

if (e->pipe != crtc)

sys/dev/drm2/drm_irq.c

1322

drm_vblank_put(dev, e->pipe);

sys/dev/drm2/drm_irq.c

811

e->base.pid, e->pipe, e->event.sequence);

sys/dev/drm2/drm_irq.c

995

if (e->pipe != crtc)

sys/dev/hyperv/vmbus/vmbus_chan.c

1888

offer->chm_udata.pipe.user_def[0];

sys/dev/hyperv/vmbus/vmbus_reg.h

406

} pipe;

sys/dev/netmap/netmap_kern.h

531

struct netmap_kring *pipe; /* if this is a pipe ring,

sys/dev/netmap/netmap_pipe.c

186

struct netmap_kring *rxkring = txkring->pipe;

sys/dev/netmap/netmap_pipe.c

243

struct netmap_kring *txkring = rxkring->pipe;

sys/dev/netmap/netmap_pipe.c

342

k1->pipe = k2;

sys/dev/netmap/netmap_pipe.c

343

k2->pipe = k1;

sys/dev/netmap/netmap_pipe.c

402

kring->pipe->nr_kflags |= NKR_NEEDRING;

sys/dev/netmap/netmap_pipe.c

423

(kring->pipe->nr_kflags & NKR_FAKERING)) {

sys/dev/netmap/netmap_pipe.c

434

memcpy(kring->pipe->ring->slot,

sys/dev/netmap/netmap_pipe.c

439

*(uint64_t *)(uintptr_t)&kring->pipe->ring->offset_mask =

sys/dev/netmap/netmap_pipe.c

441

*(uint64_t *)(uintptr_t)&kring->pipe->ring->buf_align =

sys/dev/usb/controller/avr32dci.c

1078

struct usb_endpoint *pipe, uint8_t *did_stall)

sys/dev/usb/controller/avr32dci.c

1085

DPRINTFN(5, "pipe=%p\n", pipe);

sys/dev/usb/controller/avr32dci.c

1089

ep_no = (pipe->edesc->bEndpointAddress & UE_ADDR);

sys/dev/usb/controller/avr32dci.c

1160

avr32dci_clear_stall(struct usb_device *udev, struct usb_endpoint *pipe)

sys/dev/usb/controller/avr32dci.c

1165

DPRINTFN(5, "pipe=%p\n", pipe);

sys/dev/usb/controller/avr32dci.c

1178

ed = pipe->edesc;

sys/dev/usb/controller/avr32dci.c

1999

struct usb_endpoint *pipe)

sys/dev/usb/controller/avr32dci.c

2004

pipe, udev->address,

sys/dev/usb/controller/avr32dci.c

2015

pipe->methods = &avr32dci_device_isoc_fs_methods;

sys/dev/usb/controller/avr32dci.c

2017

pipe->methods = &avr32dci_device_non_isoc_methods;

sys/fs/fifofs/fifo_vnops.c

132

struct pipe *fpipe;

sys/fs/fifofs/fifo_vnops.c

265

struct pipe *cpipe;

sys/fs/fifofs/fifo_vnops.c

63

struct pipe *fi_pipe;

sys/kern/init_sysent.c

111

{ compat10(0,pipe), .sy_auevent = AUE_PIPE, .sy_flags = SYF_CAPENABLED, .sy_thrcnt = SY_THR_STATIC }, /* 42 = freebsd10 pipe */

sys/kern/sys_pipe.c

1019

pipe_clone_write_buffer(struct pipe *wpipe)

sys/kern/sys_pipe.c

1061

pipe_direct_write(struct pipe *wpipe, struct uio *uio)

sys/kern/sys_pipe.c

1147

struct pipe *wpipe, *rpipe;

sys/kern/sys_pipe.c

138

#define PIPE_PEER(pipe) \

sys/kern/sys_pipe.c

139

(((pipe)->pipe_type & PIPE_TYPE_NAMED) ? (pipe) : ((pipe)->pipe_peer))

sys/kern/sys_pipe.c

1412

struct pipe *cpipe;

sys/kern/sys_pipe.c

1430

struct pipe *mpipe = fp->f_data;

sys/kern/sys_pipe.c

1501

struct pipe *rpipe;

sys/kern/sys_pipe.c

1502

struct pipe *wpipe;

sys/kern/sys_pipe.c

1578

struct pipe *pipe;

sys/kern/sys_pipe.c

1583

pipe = fp->f_data;

sys/kern/sys_pipe.c

1586

PIPE_LOCK(pipe);

sys/kern/sys_pipe.c

1587

error = mac_pipe_check_stat(active_cred, pipe->pipe_pair);

sys/kern/sys_pipe.c

1588

PIPE_UNLOCK(pipe);

sys/kern/sys_pipe.c

1596

if (pipe->pipe_type & PIPE_TYPE_NAMED) {

sys/kern/sys_pipe.c

1603

if (pipe->pipe_pages.cnt != 0)

sys/kern/sys_pipe.c

1604

ub->st_size = pipe->pipe_pages.cnt;

sys/kern/sys_pipe.c

1606

ub->st_size = pipe->pipe_buffer.cnt;

sys/kern/sys_pipe.c

1608

ub->st_atim = pipe->pipe_atime;

sys/kern/sys_pipe.c

1609

ub->st_mtim = pipe->pipe_mtime;

sys/kern/sys_pipe.c

1610

ub->st_ctim = pipe->pipe_ctime;

sys/kern/sys_pipe.c

1614

ub->st_ino = pipe->pipe_ino;

sys/kern/sys_pipe.c

1637

struct pipe *cpipe;

sys/kern/sys_pipe.c

1652

struct pipe *cpipe;

sys/kern/sys_pipe.c

1666

struct pipe *pi;

sys/kern/sys_pipe.c

1682

pipe_free_kmem(struct pipe *cpipe)

sys/kern/sys_pipe.c

1709

pipeclose(struct pipe *cpipe)

sys/kern/sys_pipe.c

1714

struct pipe *ppipe;

sys/kern/sys_pipe.c

1790

struct pipe *cpipe;

sys/kern/sys_pipe.c

1838

struct pipe *cpipe = kn->kn_hook;

sys/kern/sys_pipe.c

1850

struct pipe *rpipe = kn->kn_hook;

sys/kern/sys_pipe.c

1871

struct pipe *wpipe = kn->kn_hook;

sys/kern/sys_pipe.c

1917

struct pipe *pipe = kn->kn_hook;

sys/kern/sys_pipe.c

1920

kin->knt_pipe.knt_pipe_ino = pipe->pipe_ino;

sys/kern/sys_pipe.c

237

static void pipeclose(struct pipe *cpipe);

sys/kern/sys_pipe.c

238

static void pipe_free_kmem(struct pipe *cpipe);

sys/kern/sys_pipe.c

239

static int pipe_create(struct pipe *pipe, bool backing);

sys/kern/sys_pipe.c

240

static void pipe_destroy(struct pipe *pipe);

sys/kern/sys_pipe.c

242

static __inline int pipelock(struct pipe *cpipe, bool catch);

sys/kern/sys_pipe.c

243

static __inline void pipeunlock(struct pipe *cpipe);

sys/kern/sys_pipe.c

246

static int pipe_build_write_buffer(struct pipe *wpipe, struct uio *uio);

sys/kern/sys_pipe.c

247

static void pipe_destroy_write_buffer(struct pipe *wpipe);

sys/kern/sys_pipe.c

248

static int pipe_direct_write(struct pipe *wpipe, struct uio *uio);

sys/kern/sys_pipe.c

249

static void pipe_clone_write_buffer(struct pipe *wpipe);

sys/kern/sys_pipe.c

251

static int pipespace(struct pipe *cpipe, int size);

sys/kern/sys_pipe.c

252

static int pipespace_new(struct pipe *cpipe, int size);

sys/kern/sys_pipe.c

304

struct pipe *rpipe, *wpipe;

sys/kern/sys_pipe.c

377

struct pipe *rpipe, *wpipe;

sys/kern/sys_pipe.c

426

pipe_named_ctor(struct pipe **ppipe, struct thread *td)

sys/kern/sys_pipe.c

440

pipe_dtor(struct pipe *dpipe)

sys/kern/sys_pipe.c

442

struct pipe *peer;

sys/kern/sys_pipe.c

476

struct pipe *rpipe, *wpipe;

sys/kern/sys_pipe.c

566

pipespace_new(struct pipe *cpipe, int size)

sys/kern/sys_pipe.c

656

pipespace(struct pipe *cpipe, int size)

sys/kern/sys_pipe.c

668

pipelock(struct pipe *cpipe, bool catch)

sys/kern/sys_pipe.c

696

pipeunlock(struct pipe *cpipe)

sys/kern/sys_pipe.c

711

pipeselwakeup(struct pipe *cpipe)

sys/kern/sys_pipe.c

730

pipe_create(struct pipe *pipe, bool large_backing)

sys/kern/sys_pipe.c

734

error = pipespace_new(pipe, !large_backing || amountpipekva >

sys/kern/sys_pipe.c

737

pipe->pipe_ino = alloc_unr64(&pipeino_unr);

sys/kern/sys_pipe.c

742

pipe_destroy(struct pipe *pipe)

sys/kern/sys_pipe.c

744

pipe_free_kmem(pipe);

sys/kern/sys_pipe.c

756

struct pipe *rpipe;

sys/kern/sys_pipe.c

952

pipe_build_write_buffer(struct pipe *wpipe, struct uio *uio)

sys/kern/sys_pipe.c

999

pipe_destroy_write_buffer(struct pipe *wpipe)

sys/netgraph/ng_pipe.c

247

NETGRAPH_INIT(pipe, &ng_pipe_typestruct);

sys/netinet/cc/cc.c

394

int pipe;

sys/netinet/cc/cc.c

405

pipe = tcp_compute_pipe(ccv->tp);

sys/netinet/cc/cc.c

406

if (pipe < CCV(ccv, snd_ssthresh))

sys/netinet/cc/cc.c

411

CCV(ccv, snd_cwnd) = max(pipe, mss) + mss;

sys/netinet/cc/cc.c

471

uint32_t cwin, mss, pipe;

sys/netinet/cc/cc.c

498

pipe = tcp_compute_pipe(ccv->tp);

sys/netinet/cc/cc.c

500

min(CCV(ccv, snd_wnd), pipe) / 2 / mss) * mss;

sys/netinet/cc/cc_cubic.c

421

uint32_t mss, pipe, ssthresh;

sys/netinet/cc/cc_cubic.c

481

pipe = tcp_compute_pipe(ccv->tp);

sys/netinet/cc/cc_cubic.c

483

(((uint64_t)min(CCV(ccv, snd_wnd), pipe) *

sys/netinet/cc/cc_cubic.c

534

int pipe;

sys/netinet/cc/cc_cubic.c

538

pipe = 0;

sys/netinet/cc/cc_cubic.c

546

pipe = tcp_compute_pipe(ccv->tp);

sys/netinet/cc/cc_cubic.c

547

if (pipe < CCV(ccv, snd_ssthresh))

sys/netinet/cc/cc_cubic.c

552

CCV(ccv, snd_cwnd) = max(pipe, mss) + mss;

sys/netinet/cc/cc_cubic.c

624

uint32_t cwnd, pipe;

sys/netinet/cc/cc_cubic.c

645

pipe = tcp_compute_pipe(ccv->tp);

sys/netinet/cc/cc_cubic.c

646

return ((pipe * CUBIC_BETA) >> CUBIC_SHIFT);

sys/netinet/cc/cc_dctcp.c

244

uint32_t cwin, mss, pipe;

sys/netinet/cc/cc_dctcp.c

297

pipe = tcp_compute_pipe(ccv->tp);

sys/netinet/cc/cc_dctcp.c

299

min(CCV(ccv, snd_wnd), pipe) / 2 / mss) * mss;

sys/netinet/cc/cc_htcp.c

285

uint32_t mss, pipe;

sys/netinet/cc/cc_htcp.c

328

pipe = tcp_compute_pipe(ccv->tp);

sys/netinet/cc/cc_htcp.c

330

min(CCV(ccv, snd_wnd), pipe) / 2 / mss) * mss;

sys/netinet/cc/cc_htcp.c

366

int pipe;

sys/netinet/cc/cc_htcp.c

370

pipe = 0;

sys/netinet/cc/cc_htcp.c

379

pipe = tcp_compute_pipe(ccv->tp);

sys/netinet/cc/cc_htcp.c

380

if (pipe < CCV(ccv, snd_ssthresh))

sys/netinet/cc/cc_htcp.c

385

CCV(ccv, snd_cwnd) = max(pipe, mss) + mss;

sys/netinet/cc/cc_newreno.c

369

uint32_t beta, beta_ecn, cwin, factor, mss, pipe;

sys/netinet/cc/cc_newreno.c

431

pipe = tcp_compute_pipe(ccv->tp);

sys/netinet/cc/cc_newreno.c

433

((uint64_t)min(CCV(ccv, snd_wnd), pipe) *

sys/netinet/ip_fw.h

1006

uint16_t pipe; /* O_PIPE/O_QUEUE */

sys/netinet/tcp_input.c

3997

int snd_cnt = 0, limit = 0, del_data = 0, pipe = 0;

sys/netinet/tcp_input.c

4015

pipe = tcp_compute_pipe(tp);

sys/netinet/tcp_input.c

4021

pipe = imax(0, tp->snd_max - tp->snd_una -

sys/netinet/tcp_input.c

4028

if (pipe >= tp->snd_ssthresh) {

sys/netinet/tcp_input.c

4054

snd_cnt = imin((tp->snd_ssthresh - pipe), limit);

sys/netinet/tcp_input.c

4064

tp->snd_cwnd = pipe - del_data + (snd_cnt * maxseg);

sys/netinet/tcp_input.c

4070

tp->snd_cwnd = pipe - del_data + (snd_cnt * maxseg);

sys/netinet/tcp_input.c

4119

int pipe;

sys/netinet/tcp_input.c

4122

pipe = (*tp->t_fb->tfb_compute_pipe)(tp);

sys/netinet/tcp_input.c

4124

pipe = tp->snd_max - tp->snd_una +

sys/netinet/tcp_input.c

4129

return (imax(pipe, 0));

sys/netinet/tcp_stacks/rack.c

10625

uint32_t pipe, snd_una;

sys/netinet/tcp_stacks/rack.c

10645

pipe = do_rack_compute_pipe(tp, rack, snd_una);

sys/netinet/tcp_stacks/rack.c

10646

if (pipe > tp->snd_ssthresh) {

sys/netinet/tcp_stacks/rack.c

10674

if (tp->snd_ssthresh > pipe) {

sys/netinet/tcp_stacks/rack.c

10675

rack->r_ctl.rc_prr_sndcnt = min((tp->snd_ssthresh - pipe), limit);

sys/netpfil/ipfw/ip_fw2.c

1319

tvalue = TARG_VAL(ch, tablearg, pipe);

sys/netpfil/ipfw/ip_fw2.c

3048

args->rule.info = TARG(cmd->arg1, pipe);

sys/netpfil/ipfw/ip_fw_log.c

196

TARG(cmd->arg1, pipe));

sys/netpfil/ipfw/ip_fw_log.c

200

TARG(cmd->arg1, pipe));

sys/netpfil/ipfw/ip_fw_log.c

512

*targ_value = TARG(cmd->arg1, pipe);

sys/netpfil/ipfw/ip_fw_private.h

338

uint16_t pipe; /* O_PIPE/O_QUEUE */

sys/netpfil/ipfw/ip_fw_table_value.c

112

_MCPY(pipe, IPFW_VTYPE_PIPE);

sys/netpfil/ipfw/ip_fw_table_value.c

529

v.pipe = iv->pipe;

sys/netpfil/ipfw/ip_fw_table_value.c

556

iv.pipe = v->pipe;

sys/security/mac/mac_pipe.c

111

MAC_POLICY_EXTERNALIZE(pipe, label, elements, outbuf, outbuflen);

sys/security/mac/mac_pipe.c

121

MAC_POLICY_INTERNALIZE(pipe, label, string);

sys/security/mac/mac_syscalls.c

505

struct pipe *pipe;

sys/security/mac/mac_syscalls.c

543

pipe = fp->f_data;

sys/security/mac/mac_syscalls.c

545

PIPE_LOCK(pipe);

sys/security/mac/mac_syscalls.c

546

mac_pipe_copy_label(pipe->pipe_pair->pp_label, intlabel);

sys/security/mac/mac_syscalls.c

547

PIPE_UNLOCK(pipe);

sys/security/mac/mac_syscalls.c

659

struct pipe *pipe;

sys/security/mac/mac_syscalls.c

712

pipe = fp->f_data;

sys/security/mac/mac_syscalls.c

713

PIPE_LOCK(pipe);

sys/security/mac/mac_syscalls.c

715

pipe->pipe_pair, intlabel);

sys/security/mac/mac_syscalls.c

716

PIPE_UNLOCK(pipe);

sys/sys/pipe.h

112

struct pipe *pipe_peer; /* link with other direction */

sys/sys/pipe.h

135

struct pipe pp_rpipe;

sys/sys/pipe.h

136

struct pipe pp_wpipe;

sys/sys/pipe.h

142

#define PIPE_MTX(pipe) (&(pipe)->pipe_pair->pp_mtx)

sys/sys/pipe.h

143

#define PIPE_LOCK(pipe) mtx_lock(PIPE_MTX(pipe))

sys/sys/pipe.h

144

#define PIPE_UNLOCK(pipe) mtx_unlock(PIPE_MTX(pipe))

sys/sys/pipe.h

145

#define PIPE_LOCK_ASSERT(pipe, type) mtx_assert(PIPE_MTX(pipe), (type))

sys/sys/pipe.h

148

void pipe_dtor(struct pipe *dpipe);

sys/sys/pipe.h

149

int pipe_named_ctor(struct pipe **ppipe, struct thread *td);

sys/sys/pipe.h

150

void pipeselwakeup(struct pipe *cpipe);

tests/sys/aio/aio_test.c

732

ATF_REQUIRE_MSG(pipe(pipes) != -1,

tests/sys/audit/inter-process.c

1506

ATF_REQUIRE_EQ(0, pipe(filedesc));

tests/sys/audit/inter-process.c

1532

ATF_REQUIRE_EQ(-1, pipe(NULL));

tests/sys/capsicum/capability-fd.cc

1228

EXPECT_OK(pipe(fds));

tests/sys/capsicum/capmode.cc

377

int rc = pipe(fd2);

tests/sys/capsicum/capmode.cc

533

EXPECT_OK(pipe(pipefds));

tests/sys/capsicum/capmode.cc

597

EXPECT_OK(pipe(thread_pipe));

tests/sys/capsicum/capmode.cc

599

EXPECT_OK(pipe(proc_pipe));

tests/sys/capsicum/procdesc.cc

101

EXPECT_OK(pipe(pipefds));

tests/sys/capsicum/procdesc.cc

235

EXPECT_EQ(0, pipe(pipefds));

tests/sys/capsicum/procdesc.cc

243

EXPECT_EQ(0, pipe(thread_pipefds));

tests/sys/capsicum/procdesc.cc

300

EXPECT_OK(pipe(pipes));

tests/sys/capsicum/procdesc.cc

377

EXPECT_EQ(0, pipe(pipefds));

tests/sys/capsicum/procdesc.cc

658

EXPECT_EQ(0, pipe(pipefds));

tests/sys/capsicum/procdesc.cc

712

EXPECT_OK(pipe(pipefds));

tests/sys/capsicum/procdesc.cc

842

EXPECT_OK(pipe(pipefds));

tests/sys/capsicum/procdesc.cc

884

EXPECT_OK(pipe(pipefds));

tests/sys/capsicum/socket.cc

160

EXPECT_EQ(0, pipe(pipefds));

tests/sys/capsicum/socket.cc

24

EXPECT_EQ(0, pipe(pipefds));

tests/sys/file/flock_helper.c

1063

if (pipe(pfd) < 0)

tests/sys/file/flock_helper.c

1345

if (pipe(pfd) < 0)

tests/sys/file/flock_helper.c

1452

if (pipe(pfd) < 0)

tests/sys/file/flock_helper.c

191

if (pipe(pfd) < 0)

tests/sys/file/flock_helper.c

262

if (pipe(pfd) < 0)

tests/sys/file/flock_helper.c

331

if (pipe(pfd) < 0)

tests/sys/file/flock_helper.c

606

if (pipe(pfd) < 0)

tests/sys/file/flock_helper.c

678

if (pipe(pfd) < 0)

tests/sys/file/flock_helper.c

755

if (pipe(pfd) < 0)

tests/sys/file/flock_helper.c

826

if (pipe(pfd) < 0)

tests/sys/file/flock_helper.c

980

if (pipe(pfd) < 0)

tests/sys/file/ftruncate_test.c

152

if (pipe(fds) < 0)

tests/sys/file/path_test.c

853

ATF_REQUIRE_MSG(pipe(fd) == 0, FMT_ERR("pipe"));

tests/sys/kern/pdeathsig.c

163

rc = pipe(pipe_ca);

tests/sys/kern/pdeathsig.c

165

rc = pipe(pipe_cb);

tests/sys/kern/pdeathsig.c

234

rc = pipe(pipe_ca);

tests/sys/kern/pdeathsig.c

236

rc = pipe(pipe_db);

tests/sys/kern/pdeathsig.c

238

rc = pipe(pipe_cd);

tests/sys/kern/pipe/big_pipe_test.c

51

if (pipe(fd) < 0)

tests/sys/kern/pipe/pipe_fstat_bug_test.c

59

error = pipe(desc);

tests/sys/kern/pipe/pipe_fstat_bug_test.c

63

error = pipe(ipc_coord);

tests/sys/kern/pipe/pipe_ino_test.c

47

if (pipe(pipefd) == -1)

tests/sys/kern/pipe/pipe_overcommit1_test.c

46

(void)pipe(&pipes[i]);

tests/sys/kern/pipe/pipe_overcommit2_test.c

65

returnval = pipe(&pipes[i]);

tests/sys/kern/pipe/pipe_overcommit2_test.c

75

returnval = pipe(&pipes[i]);

tests/sys/kern/pipe/pipe_reverse2_test.c

43

if (pipe(pip) == -1)

tests/sys/kern/pipe/pipe_reverse_test.c

57

error = pipe(desc);

tests/sys/kern/pipe/pipe_reverse_test.c

61

error = pipe(ipc_coord);

tests/sys/kern/pipe/pipe_wraparound_test.c

55

error = pipe(desc);

tests/sys/kern/pipe/pipe_wraparound_test.c

59

error = pipe(ipc_coord);

tests/sys/kern/prace.c

90

if (pipe(pd) != 0)

tests/sys/kern/ptrace_test.c

1020

REQUIRE_EQ(pipe(cpipe), 0);

tests/sys/kern/ptrace_test.c

1040

REQUIRE_EQ(pipe(dpipe), 0);

tests/sys/kern/ptrace_test.c

230

REQUIRE_EQ(pipe(cpipe), 0);

tests/sys/kern/ptrace_test.c

277

REQUIRE_EQ(pipe(cpipe), 0);

tests/sys/kern/ptrace_test.c

292

REQUIRE_EQ(pipe(dpipe), 0);

tests/sys/kern/ptrace_test.c

373

REQUIRE_EQ(pipe(cpipe), 0);

tests/sys/kern/ptrace_test.c

388

REQUIRE_EQ(pipe(dpipe), 0);

tests/sys/kern/ptrace_test.c

4534

ATF_REQUIRE(pipe(dpipe) == 0);

tests/sys/kern/ptrace_test.c

485

REQUIRE_EQ(pipe(cpipe1), 0);

tests/sys/kern/ptrace_test.c

486

REQUIRE_EQ(pipe(cpipe2), 0);

tests/sys/kern/ptrace_test.c

487

REQUIRE_EQ(pipe(gcpipe), 0);

tests/sys/kern/ptrace_test.c

827

REQUIRE_EQ(pipe(cpipe), 0);

tests/sys/kern/ptrace_test.c

895

REQUIRE_EQ(pipe(cpipe), 0);

tests/sys/kern/ptrace_test.c

958

REQUIRE_EQ(pipe(cpipe), 0);

tests/sys/kern/reaper.c

172

r = pipe(pip);

tests/sys/kern/reaper.c

322

r = pipe(pip);

tests/sys/kern/reaper.c

397

r = pipe(pipa);

tests/sys/kern/reaper.c

399

r = pipe(pipb);

tests/sys/kern/reaper.c

57

r = pipe(pip);

tests/sys/kern/reaper.c

595

r = pipe(pip);

tests/sys/kern/reaper.c

654

r = pipe(pip);

tests/sys/kqueue/libkqueue/proc.c

88

if (pipe(pipe_fd)) {

tests/sys/posixshm/posixshm_test.c

1858

ATF_REQUIRE(pipe(pfd) == 0);

tests/sys/ses/nondestructive.c

250

FILE *pipe;

tests/sys/ses/nondestructive.c

266

pipe = popen(cmd, "r");

tests/sys/ses/nondestructive.c

267

ATF_REQUIRE(pipe != NULL);

tests/sys/ses/nondestructive.c

268

while(NULL != fgets(line, sizeof(line), pipe)) {

tests/sys/ses/nondestructive.c

300

r = pclose(pipe);

tests/sys/ses/nondestructive.c

345

FILE *pipe;

tests/sys/ses/nondestructive.c

357

pipe = popen(cmd, "r");

tests/sys/ses/nondestructive.c

358

ATF_REQUIRE(pipe != NULL);

tests/sys/ses/nondestructive.c

359

r = fscanf(pipe, "0x%x", &status);

tests/sys/ses/nondestructive.c

360

pr = pclose(pipe);

tests/sys/ses/nondestructive.c

404

FILE *pipe;

tests/sys/ses/nondestructive.c

412

pipe = popen(cmd, "r");

tests/sys/ses/nondestructive.c

413

ATF_REQUIRE(pipe != NULL);

tests/sys/ses/nondestructive.c

415

while(NULL != fgets(line, sizeof(line), pipe)) {

tests/sys/ses/nondestructive.c

418

if (1 == fscanf(pipe, f, sg_encid))

tests/sys/ses/nondestructive.c

421

sg_ses_r = pclose(pipe);

tests/sys/ses/nondestructive.c

456

FILE *pipe;

tests/sys/ses/nondestructive.c

467

pipe = popen(cmd, "r");

tests/sys/ses/nondestructive.c

468

ATF_REQUIRE(pipe != NULL);

tests/sys/ses/nondestructive.c

469

ATF_REQUIRE(NULL != fgets(line, sizeof(line), pipe));

tests/sys/ses/nondestructive.c

47

FILE *pipe;

tests/sys/ses/nondestructive.c

470

pclose(pipe);

tests/sys/ses/nondestructive.c

503

FILE *pipe;

tests/sys/ses/nondestructive.c

511

pipe = popen(cmd, "r");

tests/sys/ses/nondestructive.c

512

ATF_REQUIRE(pipe != NULL);

tests/sys/ses/nondestructive.c

513

r = fscanf(pipe,

tests/sys/ses/nondestructive.c

516

pclose(pipe);

tests/sys/ses/nondestructive.c

548

FILE *pipe;

tests/sys/ses/nondestructive.c

555

pipe = popen(cmd, "r");

tests/sys/ses/nondestructive.c

556

ATF_REQUIRE(pipe != NULL);

tests/sys/ses/nondestructive.c

558

while(NULL != fgets(line, sizeof(line), pipe)) {

tests/sys/ses/nondestructive.c

561

if (1 == fscanf(pipe, " number of possible elements: %u",

tests/sys/ses/nondestructive.c

567

sg_ses_r = pclose(pipe);

tests/sys/ses/nondestructive.c

598

FILE *pipe;

tests/sys/ses/nondestructive.c

611

pipe = popen(cmd, "r");

tests/sys/ses/nondestructive.c

612

ATF_REQUIRE(pipe != NULL);

tests/sys/ses/nondestructive.c

613

sg_ses_count = fread(sg_ses_buf, 1, 65535, pipe);

tests/sys/ses/nondestructive.c

614

r = pclose(pipe);

tests/sys/ses/nondestructive.c

64

pipe = popen(cmd, "r");

tests/sys/ses/nondestructive.c

65

ATF_REQUIRE(pipe != NULL);

tests/sys/ses/nondestructive.c

66

while(NULL != fgets(line, sizeof(line), pipe)) {

tests/sys/ses/nondestructive.c

98

r = pclose(pipe);

tools/regression/poll/pipepoll.c

299

if (pipe(fd) != 0)

tools/regression/poll/pipeselect.c

296

if (pipe(fd) != 0)

tools/regression/posixsem/posixsem.c

78

if (pipe(pfd) < 0) {

tools/regression/security/cap_test/cap_test_capmode.c

176

if (pipe(fd2) == 0) {

tools/regression/sockets/unix_cmsg/uc_common.c

505

if (pipe(uc_cfg.sync_fd[SYNC_SERVER]) < 0 ||

tools/regression/sockets/unix_cmsg/uc_common.c

506

pipe(uc_cfg.sync_fd[SYNC_CLIENT]) < 0) {

tools/regression/sockets/zerosend/zerosend.c

203

if (pipe(fdp) < 0)

tools/tools/indent_wrapper/indent_wrapper.c

270

if (pipe(pdes) < 0)

tools/tools/indent_wrapper/indent_wrapper.c

273

if (pipe(pdes + 2) < 0) {

tools/tools/netrate/juggle/juggle.c

157

if (pipe(fds) < 0)

tools/tools/syscall_timing/syscall_timing.c

431

if (pipe(fd) < 0)

tools/tools/syscall_timing/syscall_timing.c

437

if (pipe(fd) == -1)

tools/tools/syscall_timing/syscall_timing.c

484

if (pipe(fd) < 0)

tools/tools/syscall_timing/syscall_timing.c

550

if (pipe(fd) < 0)

usr.bin/calendar/io.c

692

if (pipe(pdes) < 0)

usr.bin/m4/gnum4.c

649

if (pipe(p) == -1)

usr.bin/mail/fio.c

365

if (pipe(pivec) < 0) {

usr.bin/mail/popen.c

104

if (pipe(p) < 0)

usr.bin/mail/popen.c

152

if (fp_head->pipe)

usr.bin/mail/popen.c

159

register_file(FILE *fp, int pipe, pid_t pid)

usr.bin/mail/popen.c

166

fpp->pipe = pipe;

usr.bin/mail/popen.c

44

int pipe;

usr.bin/mail/tests/mailx_signal_test.c

45

if (pipe(ipd) != 0 || pipe(opd) != 0 || pipe(epd) != 0 ||

usr.bin/mail/tests/mailx_signal_test.c

46

pipe(spd) != 0 || fcntl(spd[1], F_SETFD, FD_CLOEXEC) != 0)

usr.bin/rpcgen/rpc_main.c

388

(void) pipe(pd);

usr.bin/sdiff/sdiff.c

379

if (pipe(fd))

usr.bin/su/su.c

428

if (pipe(fds) == -1) {

usr.bin/tip/tip/cmds.c

215

if (pipe(pdes)) {

usr.bin/tip/tip/cmds.c

925

if (pipe(pivec) < 0) {

usr.bin/tip/tip/tip.c

219

pipe(fildes); pipe(repdes);

usr.sbin/apmd/apmd.c

676

if (pipe(signal_fd) < 0)

usr.sbin/autofs/popen.c

86

error = pipe(outfds);

usr.sbin/bhyve/mevent.c

518

ret = pipe(mevent_pipefd);

usr.sbin/bsdinstall/runconsoles/common.h

44

error = pipe(fds);

usr.sbin/cron/cron/do_command.c

239

if (pipe(stdin_pipe) != 0 || pipe(stdout_pipe) != 0) {

usr.sbin/cron/cron/popen.c

78

if (pipe(pdes) < 0)

usr.sbin/daemon/daemon.c

422

if (pipe(pipe_fd)) {

usr.sbin/lpr/lpd/printjob.c

1555

pipe(p);

usr.sbin/lpr/lpd/printjob.c

1794

pipe(p);

usr.sbin/lpr/lpd/printjob.c

668

pipe(p);

usr.sbin/pmcstat/pmcstat.c

1108

if (pipe(pipefd) < 0)

usr.sbin/pmcstudy/pmcstudy.c

80

if (pipe(pdesin) < 0)

usr.sbin/pmcstudy/pmcstudy.c

83

if (pipe(pdesout) < 0) {

usr.sbin/ppp/bundle.c

1736

if (pipe(fds) == -1) {

usr.sbin/ppp/bundle.c

1750

if (pipe(fds) == -1) {

usr.sbin/ppp/chap.c

268

if (pipe(in) == -1) {

usr.sbin/ppp/chap.c

273

if (pipe(out) == -1) {

usr.sbin/ppp/chat.c

729

if (pipe(fids) < 0) {

usr.sbin/ppp/exec.c

277

if (pipe(pidpipe) == -1) {

usr.sbin/ppp/main.c

440

if (sw.mode == PHYS_BACKGROUND && pipe(bgpipe)) {

usr.sbin/rpc.ypupdated/update.c

147

if (pipe(pdto) < 0) {

usr.sbin/rpc.ypupdated/update.c

150

if (pipe(pdfrom) < 0) {

usr.sbin/rpcbind/rpcbind.c

235

error = pipe(fds);

usr.sbin/rtsold/cap_script.c

62

if (pipe(fd) != 0)

usr.sbin/syslogd/syslogd.c

3371

if (pipe(pipefd) == -1) {

usr.sbin/syslogd/syslogd.c

3719

if (pipe(pfd) == -1)

usr.sbin/uefisign/uefisign.c

403

error = pipe(pipefds);

usr.sbin/ypbind/ypbind.c

667

if (pipe(ypdb->dom_pipe_fds) < 0) {