qbit/go
1
0
Fork 0
mirror of https://github.com/golang/go synced 2024-11-25 20:07:56 -07:00
Code Releases Activity

time: isolate syscall reference in sys.go

Browse Source 
R=dsymonds
CC=golang-dev
https://golang.org/cl/4291052
This commit is contained in:
Russ Cox 2011-03-17 13:46:05 -04:00
parent bc35379763
commit 2ca46a789b
2 changed files with 13 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/pkg/time/sleep.go
View File

@ -5,9 +5,8 @@
package time package time
import ( import (
"syscall"
"sync"
"container/heap" "container/heap"
"sync"
) )
// The Timer type represents a single event. // The Timer type represents a single event.
@ -126,7 +125,7 @@ func sleeper(sleeperId int64) {
dt = maxSleepTime dt = maxSleepTime
} }
timerMutex.Unlock() timerMutex.Unlock()
syscall.Sleep(dt) sysSleep(dt)
timerMutex.Lock() timerMutex.Lock()
if currentSleeper != sleeperId { if currentSleeper != sleeperId {
// Another sleeper has been started, making this one redundant. // Another sleeper has been started, making this one redundant.

14
src/pkg/time/sys.go
View File

@ -44,11 +44,19 @@ func sleep(t, ns int64) (int64, os.Error) {
// TODO(cw): use monotonic-time once it's available // TODO(cw): use monotonic-time once it's available
end := t + ns end := t + ns
for t < end { for t < end {
errno := syscall.Sleep(end - t) err := sysSleep(end - t)
if errno != 0 && errno != syscall.EINTR { if err != nil {
return 0, os.NewSyscallError("sleep", errno) return 0, err
} }
t = Nanoseconds() t = Nanoseconds()
} }
return t, nil return t, nil
} }
func sysSleep(t int64) os.Error {
errno := syscall.Sleep(t)
if errno != 0 && errno != syscall.EINTR {
return os.NewSyscallError("sleep", errno)
}
return nil
}