Function CallTest

pkg/sentry/fsimpl/fuse/dev_test.go:164–188

CallTest makes a request to the server and blocks the invoking goroutine until a server responds with a response. Doesn't block a kernel.Task. Analogous to Connection.Call but used for testing.

(conn *connection, t *kernel.Task, r *Request, i uint32)

// goroutine until a server responds with a response. Doesn't block
// a kernel.Task. Analogous to Connection.Call but used for testing.
func CallTest(conn *connection, t *kernel.Task, r *Request, i uint32) (*Response, error) {
	conn.mu.Lock()

	// Wait until we're certain that a new request can be processed.
	for conn.numActiveRequests == conn.maxActiveRequests {
		conn.mu.Unlock()
		<-conn.fullQueueCh
		conn.mu.Lock()
	}

	fut, err := conn.callFutureLocked(r) // No task given.
	conn.mu.Unlock()

	if err != nil {
		return nil, err
	}

	// Resolve the response.
	//
	// Block without a task.
	<-fut.ch

	// A response is ready. Resolve and return it.
	return fut.getResponse(), nil
}

// ReadTest is analogous to vfs.FileDescription.Read and reads from the FUSE
// device. However, it does so by - not blocking the task that is calling - and