]> ruderich.org/simon Gitweb - safcm/safcm.git/blob - gob.go
rpc: remove empty line
[safcm/safcm.git] / gob.go
1 // RPC primitives for safcm: basic connection implementation
2
3 // Copyright (C) 2021  Simon Ruderich
4 //
5 // This program is free software: you can redistribute it and/or modify
6 // it under the terms of the GNU General Public License as published by
7 // the Free Software Foundation, either version 3 of the License, or
8 // (at your option) any later version.
9 //
10 // This program is distributed in the hope that it will be useful,
11 // but WITHOUT ANY WARRANTY; without even the implied warranty of
12 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
13 // GNU General Public License for more details.
14 //
15 // You should have received a copy of the GNU General Public License
16 // along with this program.  If not, see <http://www.gnu.org/licenses/>.
17
18 package safcm
19
20 import (
21         "encoding/gob"
22         "io"
23 )
24
25 type GobConn struct {
26         enc *gob.Encoder
27         dec *gob.Decoder
28 }
29
30 func NewGobConn(r io.Reader, w io.Writer) *GobConn {
31         return &GobConn{
32                 enc: gob.NewEncoder(w),
33                 dec: gob.NewDecoder(r),
34         }
35 }
36
37 func (c *GobConn) Send(x Msg) error {
38         // & lets Encode send the interface itself and not a concrete type
39         // which is necessary to Decode as an interface
40         return c.enc.Encode(&x)
41 }
42
43 func (c *GobConn) Recv() (Msg, error) {
44         var x Msg
45         err := c.dec.Decode(&x)
46         if err != nil {
47                 return nil, err
48         }
49         return x, nil
50 }