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

net: remove dreg of obsoleted network poller

Browse Source 
R=golang-dev, dave
CC=golang-dev
https://golang.org/cl/13396051
This commit is contained in:
Mikio Hara 2013-09-10 20:00:21 +09:00
parent 6cbc5387c3
commit 02faa939d3
2 changed files with 0 additions and 91 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

57
src/pkg/net/fd_posix_test.go
View File

@ -1,57 +0,0 @@
// Copyright 2012 The Go Authors. All rights reserved.
// Use of this source code is governed by a BSD-style
// license that can be found in the LICENSE file.
// +build darwin dragonfly freebsd linux netbsd openbsd windows
package net
import (
"testing"
"time"
)
var deadlineSetTimeTests = []struct {
input time.Time
expected int64
}{
{noDeadline, 0},
{time.Date(2009, 11, 10, 23, 00, 00, 00, time.UTC), 1257894000000000000}, // 2009-11-10 23:00:00 +0000 UTC
}
func TestDeadlineSetTime(t *testing.T) {
for _, tt := range deadlineSetTimeTests {
var d deadline
d.setTime(tt.input)
actual := d.value()
expected := int64(0)
if !tt.input.IsZero() {
expected = tt.input.UnixNano()
}
if actual != expected {
t.Errorf("set/value failed: expected %v, actual %v", expected, actual)
}
}
}
var deadlineExpiredTests = []struct {
deadline time.Time
expired bool
}{
// note, times are relative to the start of the test run, not
// the start of TestDeadlineExpired
{time.Now().Add(5 * time.Minute), false},
{time.Now().Add(-5 * time.Minute), true},
{noDeadline, false},
}
func TestDeadlineExpired(t *testing.T) {
for _, tt := range deadlineExpiredTests {
var d deadline
d.set(tt.deadline.UnixNano())
expired := d.expired()
if expired != tt.expired {
t.Errorf("expire failed: expected %v, actual %v", tt.expired, expired)
}
}
}

34
src/pkg/net/net.go
View File

@ -46,7 +46,6 @@ import (
"errors" "errors"
"io" "io"
"os" "os"
"sync"
"syscall" "syscall"
"time" "time"
) )
@ -401,39 +400,6 @@ func genericReadFrom(w io.Writer, r io.Reader) (n int64, err error) {
return io.Copy(writerOnly{w}, r) return io.Copy(writerOnly{w}, r)
} }
// deadline is an atomically-accessed number of nanoseconds since 1970
// or 0, if no deadline is set.
type deadline struct {
sync.Mutex
val int64
}
func (d *deadline) expired() bool {
t := d.value()
return t > 0 && time.Now().UnixNano() >= t
}
func (d *deadline) value() (v int64) {
d.Lock()
v = d.val
d.Unlock()
return
}
func (d *deadline) set(v int64) {
d.Lock()
d.val = v
d.Unlock()
}
func (d *deadline) setTime(t time.Time) {
if t.IsZero() {
d.set(0)
} else {
d.set(t.UnixNano())
}
}
// Limit the number of concurrent cgo-using goroutines, because // Limit the number of concurrent cgo-using goroutines, because
// each will block an entire operating system thread. The usual culprit // each will block an entire operating system thread. The usual culprit
// is resolving many DNS names in separate goroutines but the DNS // is resolving many DNS names in separate goroutines but the DNS