- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 150 for Pd (0.1 sec)
-
src/internal/poll/fd_poll_js.go
closing bool } func (pd *pollDesc) init(fd *FD) error { pd.fd = fd; return nil } func (pd *pollDesc) close() {} func (pd *pollDesc) evict() { pd.closing = true if pd.fd != nil { syscall.StopIO(pd.fd.Sysfd) } } func (pd *pollDesc) prepare(mode int, isFile bool) error { if pd.closing { return errClosing(isFile) } return nil }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 25 00:12:40 UTC 2023 - 2.3K bytes - Viewed (0) -
src/runtime/netpoll.go
} else if pd.rd != rd0 || combo != combo0 { pd.rseq++ // invalidate current timers if pd.rd > 0 { pd.rt.modify(pd.rd, 0, rtf, pd.makeArg(), pd.rseq) } else { pd.rt.stop() pd.rrun = false } } if !pd.wrun { if pd.wd > 0 && !combo { pd.wt.modify(pd.wd, 0, netpollWriteDeadline, pd.makeArg(), pd.wseq) pd.wrun = true } } else if pd.wd != wd0 || combo != combo0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 19:57:43 UTC 2024 - 20.7K bytes - Viewed (0) -
src/internal/poll/fd_poll_runtime.go
func (pd *pollDesc) evict() { if pd.runtimeCtx == 0 { return } runtime_pollUnblock(pd.runtimeCtx) } func (pd *pollDesc) prepare(mode int, isFile bool) error { if pd.runtimeCtx == 0 { return nil } res := runtime_pollReset(pd.runtimeCtx, mode) return convertErr(res, isFile) } func (pd *pollDesc) prepareRead(isFile bool) error { return pd.prepare('r', isFile) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:18:59 UTC 2024 - 4.2K bytes - Viewed (0) -
src/runtime/netpoll_solaris.go
return } old := pd.user events := (old & ^clear) | set if old == events { return } tp := taggedPointerPack(unsafe.Pointer(pd), pd.fdseq.Load()) if events != 0 && port_associate(portfd, _PORT_SOURCE_FD, pd.fd, events, uintptr(tp)) != 0 { print("runtime: port_associate failed (errno=", errno(), ")\n") throw("runtime: netpollupdate failed") } pd.user = events }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 11.2K bytes - Viewed (0) -
src/test/java/org/codelibs/core/beans/impl/BeanDescImplTest.java
final BeanDesc bd = BeanDescFactory.getBeanDesc(Hoge.class); PropertyDesc pd = bd.getPropertyDesc("baz"); assertThat(pd.isParameterized(), is(true)); assertThat(pd.getKeyClassOfMap(), is(sameClass(String.class))); assertThat(pd.getValueClassOfMap(), is(sameClass(Date.class))); ParameterizedClassDesc pcd = pd.getParameterizedClassDesc(); assertThat(pcd.getRawClass(), is(sameClass(Map.class)));
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 13.9K bytes - Viewed (0) -
src/runtime/netpoll_epoll.go
mode += 'w' } if mode != 0 { tp := *(*taggedPointer)(unsafe.Pointer(&ev.Data)) pd := (*pollDesc)(tp.pointer()) tag := tp.tag() if pd.fdseq.Load() == tag { pd.setEventErr(ev.Events == syscall.EPOLLERR, tag) delta += netpollready(&toRun, pd, mode) } } } return toRun, delta
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 4.6K bytes - Viewed (0) -
src/internal/poll/fd_unix.go
return 0, nil } if err := fd.pd.prepareRead(fd.isFile); err != nil { return 0, err } if fd.IsStream && len(p) > maxRW { p = p[:maxRW] } for { n, err := ignoringEINTRIO(syscall.Read, fd.Sysfd, p) if err != nil { n = 0 if err == syscall.EAGAIN && fd.pd.pollable() { if err = fd.pd.waitRead(fd.isFile); err == nil { continue } } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 31 04:09:44 UTC 2024 - 17.9K bytes - Viewed (0) -
src/cmd/covdata/merge.go
m.mm.visitMetaDataFile(mdf, mfr) } func (m *mstate) BeginPackage(pd *decodemeta.CoverageMetaDataDecoder, pkgIdx uint32) { dbgtrace(3, "VisitPackage(pk=%d path=%s)", pkgIdx, pd.PackagePath()) m.mm.visitPackage(pd, pkgIdx, *pcombineflag) } func (m *mstate) EndPackage(pd *decodemeta.CoverageMetaDataDecoder, pkgIdx uint32) { }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 23 11:36:37 UTC 2023 - 3.2K bytes - Viewed (0) -
src/runtime/netpoll_wasip1.go
pd.user = uint32(disarmed)<<16 | uint32(disarmed) unlock(&mtx) return 0 } const disarmed = 0xFFFF func netpollarm(pd *pollDesc, mode int) { lock(&mtx) var s subscription s.userdata = userdata(uintptr(unsafe.Pointer(pd))) fdReadwrite := s.u.subscriptionFdReadwrite() fdReadwrite.fd = int32(pd.fd) ridx := int(pd.user >> 16) widx := int(pd.user & 0xFFFF)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 6.1K bytes - Viewed (0) -
cmd/erasure-server-pool-decom.go
QueuedBuckets: pd.QueuedBuckets, DecommissionedBuckets: pd.DecommissionedBuckets, Bucket: pd.Bucket, Prefix: pd.Prefix, Object: pd.Object, ItemsDecommissioned: pd.ItemsDecommissioned, ItemsDecommissionFailed: pd.ItemsDecommissionFailed, BytesDone: pd.BytesDone, BytesFailed: pd.BytesFailed, } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 06 14:30:43 UTC 2024 - 41.5K bytes - Viewed (1)