import "android.googlesource.com/platform/tools/gpu/rpc"
Package rpc implements a remote procedure call system.
RPC uses the binary package for serialization and the multiplexer package to merge in-flight requests onto a single stream.
var ErrInvalidHeader = NewError("Invalid RPC header")
ErrInvalidHeader is returned when either client or server detects an incorrectly formed rpc header.
func Serve(logger log.Logger, r io.Reader, w io.Writer, mtu int, handler Handler)
Server implements the receiving side of a client server rpc pair. It listens on the reader for calls, and dispatches them to the supplied handler. Any result returned from the handler is then sent back down the writer.
type Client struct {
}
Client implements the sending side of a client-server rpc pair.
func NewClient(r io.Reader, w io.Writer, mtu int) Client
NewClient creates a new rpc client object that sends messages down the writer, and waits for responses on the reader. The client supports multiple in-flight rpc calls. The chunk size used for multiplexing the calls for fairness is specified by mtu.
func (b Client) Send(call binary.Object) (interface{}, error)
Send encodes an rpc call and sends it to the server. It blocks until a reply is received or an error indicating there will be no reply occurs. This method is safe for concurrent use.
type Error struct {
binary.Generate
}
Error is an implementation of error that can be sent over the wire.
func NewError(msg string, args ...interface{}) *Error
NewError is used to create new rpc error objects with the specified human readable message.
func (*Error) Class() binary.Class
func (e *Error) Error() string
type Handler func(interface{}) binary.Object
Handler is the signature for a function that handles incoming rpc calls.