Killed the stale random delays feature.
parent
b44d345076
commit
f0f62136a7
|
@ -15,20 +15,13 @@
|
||||||
package fuseutil
|
package fuseutil
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"flag"
|
|
||||||
"io"
|
"io"
|
||||||
"math/rand"
|
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
|
||||||
|
|
||||||
"github.com/jacobsa/fuse"
|
"github.com/jacobsa/fuse"
|
||||||
"github.com/jacobsa/fuse/fuseops"
|
"github.com/jacobsa/fuse/fuseops"
|
||||||
)
|
)
|
||||||
|
|
||||||
var fRandomDelays = flag.Bool(
|
|
||||||
"fuseutil.random_delays", false,
|
|
||||||
"If set, randomly delay each op received, to help expose concurrency issues.")
|
|
||||||
|
|
||||||
// An interface with a method for each op type in the fuseops package. This can
|
// An interface with a method for each op type in the fuseops package. This can
|
||||||
// be used in conjunction with NewFileSystemServer to avoid writing a "dispatch
|
// be used in conjunction with NewFileSystemServer to avoid writing a "dispatch
|
||||||
// loop" that switches on op types, instead receiving typed method calls
|
// loop" that switches on op types, instead receiving typed method calls
|
||||||
|
@ -115,13 +108,6 @@ func (s *fileSystemServer) ServeOps(c *fuse.Connection) {
|
||||||
func (s *fileSystemServer) handleOp(op fuseops.Op) {
|
func (s *fileSystemServer) handleOp(op fuseops.Op) {
|
||||||
defer s.opsInFlight.Done()
|
defer s.opsInFlight.Done()
|
||||||
|
|
||||||
// Delay if requested.
|
|
||||||
if *fRandomDelays {
|
|
||||||
const delayLimit = 100 * time.Microsecond
|
|
||||||
delay := time.Duration(rand.Int63n(int64(delayLimit)))
|
|
||||||
time.Sleep(delay)
|
|
||||||
}
|
|
||||||
|
|
||||||
// Dispatch to the appropriate method.
|
// Dispatch to the appropriate method.
|
||||||
var err error
|
var err error
|
||||||
switch typed := op.(type) {
|
switch typed := op.(type) {
|
||||||
|
|
Loading…
Reference in New Issue