mirror of
https://github.com/golang/go
synced 2024-11-21 21:14:47 -07:00
gofix -r mapdelete
R=golang-dev, r, adg, r, cw CC=golang-dev https://golang.org/cl/5266045
This commit is contained in:
parent
7242052bc7
commit
313c8224d5
@ -588,7 +588,7 @@ func (p *Package) loadDWARF(f *File, names []*Name) {
|
||||
n.Const = strconv.Itoa64(n.Type.EnumValues[k])
|
||||
// Remove injected enum to ensure the value will deep-compare
|
||||
// equally in future loads of the same constant.
|
||||
n.Type.EnumValues[k] = 0, false
|
||||
delete(n.Type.EnumValues, k)
|
||||
} else if n.Kind == "const" && i < len(enumVal) {
|
||||
n.Const = strconv.Itoa64(enumVal[i])
|
||||
}
|
||||
|
@ -65,7 +65,7 @@ func rewriteFile(pattern, replace ast.Expr, p *ast.File) *ast.File {
|
||||
return reflect.Value{}
|
||||
}
|
||||
for k := range m {
|
||||
m[k] = reflect.Value{}, false
|
||||
delete(m, k)
|
||||
}
|
||||
val = apply(f, val)
|
||||
if match(m, pat, val) {
|
||||
|
@ -579,6 +579,6 @@ Error:
|
||||
// If the parse fails, take the type out of the cache
|
||||
// so that the next call with this offset doesn't hit
|
||||
// the cache and return success.
|
||||
d.typeCache[off] = nil, false
|
||||
delete(d.typeCache, off)
|
||||
return nil, err
|
||||
}
|
||||
|
@ -154,7 +154,7 @@ func eliminate(t *testing.T, expected map[token.Pos]string, errors os.Error) {
|
||||
continue
|
||||
}
|
||||
// we have a match - eliminate this error
|
||||
expected[pos] = "", false
|
||||
delete(expected, pos)
|
||||
} else {
|
||||
// To keep in mind when analyzing failed test output:
|
||||
// If the same error position occurs multiple times in errors,
|
||||
|
@ -81,6 +81,7 @@ func init() {
|
||||
defFun("close")
|
||||
defFun("complex")
|
||||
defFun("copy")
|
||||
defFun("delete")
|
||||
defFun("imag")
|
||||
defFun("len")
|
||||
defFun("make")
|
||||
|
@ -1154,7 +1154,7 @@ func (dec *Decoder) getDecEnginePtr(remoteId typeId, ut *userTypeInfo) (enginePt
|
||||
decoderMap[remoteId] = enginePtr
|
||||
*enginePtr, err = dec.compileDec(remoteId, ut)
|
||||
if err != nil {
|
||||
decoderMap[remoteId] = nil, false
|
||||
delete(decoderMap, remoteId)
|
||||
}
|
||||
}
|
||||
return
|
||||
@ -1179,7 +1179,7 @@ func (dec *Decoder) getIgnoreEnginePtr(wireId typeId) (enginePtr **decEngine, er
|
||||
*enginePtr, err = dec.compileIgnoreSingle(wireId)
|
||||
}
|
||||
if err != nil {
|
||||
dec.ignorerCache[wireId] = nil, false
|
||||
delete(dec.ignorerCache, wireId)
|
||||
}
|
||||
}
|
||||
return
|
||||
|
@ -405,7 +405,7 @@ func newTypeObject(name string, ut *userTypeInfo, rt reflect.Type) (gobType, os.
|
||||
var type0, type1 gobType
|
||||
defer func() {
|
||||
if err != nil {
|
||||
types[rt] = nil, false
|
||||
delete(types, rt)
|
||||
}
|
||||
}()
|
||||
// Install the top-level type before the subtypes (e.g. struct before
|
||||
|
@ -194,7 +194,7 @@ func (c *child) serve() {
|
||||
case typeData:
|
||||
// If the filter role is implemented, read the data stream here.
|
||||
case typeAbortRequest:
|
||||
requests[rec.h.Id] = nil, false
|
||||
delete(requests, rec.h.Id)
|
||||
c.conn.writeEndRequest(rec.h.Id, 0, statusRequestComplete)
|
||||
if !req.keepConn {
|
||||
// connection will close upon return
|
||||
|
@ -165,7 +165,7 @@ func (sc *ServerConn) Write(req *Request, resp *Response) os.Error {
|
||||
// Retrieve the pipeline ID of this request/response pair
|
||||
sc.lk.Lock()
|
||||
id, ok := sc.pipereq[req]
|
||||
sc.pipereq[req] = 0, false
|
||||
delete(sc.pipereq, req)
|
||||
if !ok {
|
||||
sc.lk.Unlock()
|
||||
return ErrPipeline
|
||||
@ -353,7 +353,7 @@ func (cc *ClientConn) readUsing(req *Request, readRes func(*bufio.Reader, *Reque
|
||||
// Retrieve the pipeline ID of this request/response pair
|
||||
cc.lk.Lock()
|
||||
id, ok := cc.pipereq[req]
|
||||
cc.pipereq[req] = 0, false
|
||||
delete(cc.pipereq, req)
|
||||
if !ok {
|
||||
cc.lk.Unlock()
|
||||
return nil, ErrPipeline
|
||||
|
@ -366,7 +366,7 @@ func fixTransferEncoding(requestMethod string, header Header) ([]string, os.Erro
|
||||
return nil, nil
|
||||
}
|
||||
|
||||
header["Transfer-Encoding"] = nil, false
|
||||
delete(header, "Transfer-Encoding")
|
||||
|
||||
// Head responses have no bodies, so the transfer encoding
|
||||
// should be ignored.
|
||||
@ -399,7 +399,7 @@ func fixTransferEncoding(requestMethod string, header Header) ([]string, os.Erro
|
||||
// Chunked encoding trumps Content-Length. See RFC 2616
|
||||
// Section 4.4. Currently len(te) > 0 implies chunked
|
||||
// encoding.
|
||||
header["Content-Length"] = nil, false
|
||||
delete(header, "Content-Length")
|
||||
return te, nil
|
||||
}
|
||||
|
||||
|
@ -266,7 +266,7 @@ func (t *Transport) getIdleConn(cm *connectMethod) (pconn *persistConn) {
|
||||
}
|
||||
if len(pconns) == 1 {
|
||||
pconn = pconns[0]
|
||||
t.idleConn[key] = nil, false
|
||||
delete(t.idleConn, key)
|
||||
} else {
|
||||
// 2 or more cached connections; pop last
|
||||
// TODO: queue?
|
||||
|
@ -152,7 +152,7 @@ func (s *pollServer) LookupFD(fd int, mode int) *netFD {
|
||||
if !ok {
|
||||
return nil
|
||||
}
|
||||
s.pending[key] = nil, false
|
||||
delete(s.pending, key)
|
||||
return netfd
|
||||
}
|
||||
|
||||
@ -195,7 +195,7 @@ func (s *pollServer) CheckDeadlines() {
|
||||
}
|
||||
if t > 0 {
|
||||
if t <= now {
|
||||
s.pending[key] = nil, false
|
||||
delete(s.pending, key)
|
||||
if mode == 'r' {
|
||||
s.poll.DelFD(fd.sysfd, mode)
|
||||
fd.rdeadline = -1
|
||||
|
@ -105,7 +105,7 @@ func (p *pollster) StopWaiting(fd int, bits uint) {
|
||||
if e := syscall.EpollCtl(p.epfd, syscall.EPOLL_CTL_DEL, fd, nil); e != 0 {
|
||||
print("Epoll delete fd=", fd, ": ", os.Errno(e).String(), "\n")
|
||||
}
|
||||
p.events[fd] = 0, false
|
||||
delete(p.events, fd)
|
||||
}
|
||||
}
|
||||
|
||||
|
@ -39,5 +39,5 @@ func (h MIMEHeader) Get(key string) string {
|
||||
|
||||
// Del deletes the values associated with key.
|
||||
func (h MIMEHeader) Del(key string) {
|
||||
h[CanonicalMIMEHeaderKey(key)] = nil, false
|
||||
delete(h, CanonicalMIMEHeaderKey(key))
|
||||
}
|
||||
|
@ -108,7 +108,7 @@ func (s *sequencer) End(id uint) {
|
||||
}
|
||||
c, ok := s.wait[id]
|
||||
if ok {
|
||||
s.wait[id] = nil, false
|
||||
delete(s.wait, id)
|
||||
}
|
||||
s.mu.Unlock()
|
||||
if ok {
|
||||
|
@ -314,7 +314,7 @@ func (exp *Exporter) addClient(conn io.ReadWriter) *expClient {
|
||||
// delClient forgets the client existed
|
||||
func (exp *Exporter) delClient(client *expClient) {
|
||||
exp.mu.Lock()
|
||||
exp.clients[client] = false, false
|
||||
delete(exp.clients, client)
|
||||
exp.mu.Unlock()
|
||||
}
|
||||
|
||||
@ -388,7 +388,7 @@ func (exp *Exporter) Hangup(name string) os.Error {
|
||||
exp.mu.Lock()
|
||||
chDir, ok := exp.names[name]
|
||||
if ok {
|
||||
exp.names[name] = nil, false
|
||||
delete(exp.names, name)
|
||||
}
|
||||
// TODO drop all instances of channel from client sets
|
||||
exp.mu.Unlock()
|
||||
|
@ -256,8 +256,8 @@ func (imp *Importer) Hangup(name string) os.Error {
|
||||
if nc == nil {
|
||||
return os.NewError("netchan import: hangup: no such channel: " + name)
|
||||
}
|
||||
imp.names[name] = nil, false
|
||||
imp.chans[nc.id] = nil, false
|
||||
delete(imp.names, name)
|
||||
delete(imp.chans, nc.id)
|
||||
nc.close()
|
||||
return nil
|
||||
}
|
||||
|
@ -131,7 +131,7 @@ func (w *Watcher) RemoveWatch(path string) os.Error {
|
||||
if success == -1 {
|
||||
return os.NewSyscallError("inotify_rm_watch", errno)
|
||||
}
|
||||
w.watches[path] = nil, false
|
||||
delete(w.watches, path)
|
||||
return nil
|
||||
}
|
||||
|
||||
|
@ -876,7 +876,7 @@ L:
|
||||
fd = inf
|
||||
}
|
||||
|
||||
mark[t] = false, false
|
||||
delete(mark, t)
|
||||
return
|
||||
}
|
||||
|
||||
|
@ -104,7 +104,7 @@ func (client *Client) input() {
|
||||
seq := response.Seq
|
||||
client.mutex.Lock()
|
||||
c := client.pending[seq]
|
||||
client.pending[seq] = c, false
|
||||
delete(client.pending, seq)
|
||||
client.mutex.Unlock()
|
||||
|
||||
if response.Error == "" {
|
||||
|
@ -79,7 +79,7 @@ func (c *clientCodec) ReadResponseHeader(r *rpc.Response) os.Error {
|
||||
|
||||
c.mutex.Lock()
|
||||
r.ServiceMethod = c.pending[c.resp.Id]
|
||||
c.pending[c.resp.Id] = "", false
|
||||
delete(c.pending, c.resp.Id)
|
||||
c.mutex.Unlock()
|
||||
|
||||
r.Error = ""
|
||||
|
@ -107,7 +107,7 @@ func (c *serverCodec) WriteResponse(r *rpc.Response, x interface{}) os.Error {
|
||||
c.mutex.Unlock()
|
||||
return os.NewError("invalid sequence number in response")
|
||||
}
|
||||
c.pending[r.Seq] = nil, false
|
||||
delete(c.pending, r.Seq)
|
||||
c.mutex.Unlock()
|
||||
|
||||
if b == nil {
|
||||
|
@ -87,6 +87,6 @@ func (m *mmapper) Munmap(data []byte) (errno int) {
|
||||
if errno := m.munmap(uintptr(unsafe.Pointer(&b[0])), uintptr(len(b))); errno != 0 {
|
||||
return errno
|
||||
}
|
||||
m.active[p] = nil, false
|
||||
delete(m.active, p)
|
||||
return 0
|
||||
}
|
||||
|
@ -1152,7 +1152,7 @@ func foldExceptions(class []int) map[int]bool {
|
||||
|
||||
// Remove class itself.
|
||||
for _, r := range class {
|
||||
m[r] = false, false
|
||||
delete(m, r)
|
||||
}
|
||||
|
||||
// What's left is the exceptions.
|
||||
|
@ -206,7 +206,7 @@ func TestScripts(t *testing.T) {
|
||||
if !Is(Scripts[test.script], test.rune) {
|
||||
t.Errorf("IsScript(%U, %s) = false, want true", test.rune, test.script)
|
||||
}
|
||||
notTested[test.script] = false, false
|
||||
delete(notTested, test.script)
|
||||
}
|
||||
for _, test := range outTest {
|
||||
if Is(Scripts[test.script], test.rune) {
|
||||
@ -230,7 +230,7 @@ func TestCategories(t *testing.T) {
|
||||
if !Is(Categories[test.script], test.rune) {
|
||||
t.Errorf("IsCategory(%U, %s) = false, want true", test.rune, test.script)
|
||||
}
|
||||
notTested[test.script] = false, false
|
||||
delete(notTested, test.script)
|
||||
}
|
||||
for k := range notTested {
|
||||
t.Error("category not tested:", k)
|
||||
@ -249,7 +249,7 @@ func TestProperties(t *testing.T) {
|
||||
if !Is(Properties[test.script], test.rune) {
|
||||
t.Errorf("IsCategory(%U, %s) = false, want true", test.rune, test.script)
|
||||
}
|
||||
notTested[test.script] = false, false
|
||||
delete(notTested, test.script)
|
||||
}
|
||||
for k := range notTested {
|
||||
t.Error("property not tested:", k)
|
||||
|
@ -517,7 +517,7 @@ func (v Values) Add(key, value string) {
|
||||
|
||||
// Del deletes the values associated with key.
|
||||
func (v Values) Del(key string) {
|
||||
v[key] = nil, false
|
||||
delete(v, key)
|
||||
}
|
||||
|
||||
// ParseQuery parses the URL-encoded query string and returns
|
||||
|
@ -390,7 +390,11 @@ func (p *Parser) popElement(t *EndElement) bool {
|
||||
// translations that were associated with the element we just closed.
|
||||
for p.stk != nil && p.stk.kind != stkStart {
|
||||
s := p.pop()
|
||||
p.ns[s.name.Local] = s.name.Space, s.ok
|
||||
if s.ok {
|
||||
p.ns[s.name.Local] = s.name.Space
|
||||
} else {
|
||||
delete(p.ns, s.name.Local)
|
||||
}
|
||||
}
|
||||
|
||||
return true
|
||||
|
@ -150,7 +150,7 @@ func maptest() {
|
||||
m[2] = 3
|
||||
})
|
||||
shouldPanic(func() {
|
||||
m[2] = 0, false
|
||||
delete(m, 2)
|
||||
})
|
||||
}
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user