/usr/share/gocode/src/github.com/couchbase/moss/ping.go is in golang-github-couchbase-moss-dev 0.0~git20170914.0.07c86e8-4.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 | // Copyright (c) 2016 Couchbase, Inc.
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the
// License. You may obtain a copy of the License at
// http://www.apache.org/licenses/LICENSE-2.0
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an "AS
// IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
// express or implied. See the License for the specific language
// governing permissions and limitations under the License.
package moss
// A ping message is used to notify and wait for asynchronous tasks.
type ping struct {
kind string // The kind of ping.
// When non-nil, the pongCh will be closed when task is done.
pongCh chan struct{}
}
// replyToPings() is a helper function to respond to ping requests.
func replyToPings(pings []ping) {
for _, ping := range pings {
if ping.pongCh != nil {
close(ping.pongCh)
ping.pongCh = nil
}
}
}
// receivePings() collects any available ping requests, but will not
// block if there are no incoming ping requests.
func receivePings(pingCh chan ping, pings []ping,
kindMatch string, kindSeen bool) ([]ping, bool) {
for {
select {
case pingVal := <-pingCh:
pings = append(pings, pingVal)
if pingVal.kind == kindMatch {
kindSeen = true
}
default:
return pings, kindSeen
}
}
}
|