Skip to content

Commit 2c5c975

Browse files
committed
Better naming
1 parent 9a2f30a commit 2c5c975

2 files changed

Lines changed: 7 additions & 7 deletions

File tree

conn.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ type Conn struct {
8989

9090
reading chan struct{}
9191
handshakeRecv chan recvHandshakeState
92-
packetInject chan addrPkt
92+
inboundPacketInject chan addrPkt
9393
cancelHandshaker func()
9494
cancelHandshakeReader func()
9595

@@ -228,7 +228,7 @@ func createConn(
228228

229229
reading: make(chan struct{}, 1),
230230
handshakeRecv: make(chan recvHandshakeState),
231-
packetInject: make(chan addrPkt),
231+
inboundPacketInject: make(chan addrPkt),
232232
closed: closer.NewCloser(),
233233
cancelHandshaker: func() {},
234234
cancelHandshakeReader: func() {},
@@ -775,8 +775,8 @@ var poolReadBuffer = sync.Pool{ //nolint:gochecknoglobals
775775
},
776776
}
777777

778-
func (c *Conn) InjectPacket(p []byte, rAddr net.Addr) {
779-
c.packetInject <- addrPkt{rAddr, p}
778+
func (c *Conn) InjectInboundPacket(p []byte, rAddr net.Addr) {
779+
c.inboundPacketInject <- addrPkt{rAddr, p}
780780
}
781781

782782
func (c *Conn) nextPacket(ctx context.Context) ([]byte, net.Addr, error) {
@@ -814,7 +814,7 @@ func (c *Conn) nextPacket(ctx context.Context) ([]byte, net.Addr, error) {
814814
}
815815
}()
816816
select {
817-
case p := <-c.packetInject:
817+
case p := <-c.inboundPacketInject:
818818
return p.data, p.rAddr, nil
819819
case p := <-readCh:
820820
return p.data, p.rAddr, p.err

conn_test.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3499,7 +3499,7 @@ func TestOutboundInterceptor(t *testing.T) {
34993499
server, err := Server(dtlsnet.PacketConnFromConn(cb), cb.RemoteAddr(), &Config{
35003500
Certificates: []tls.Certificate{serverCert},
35013501
OutboundHandshakePacketInterceptor: func(packet []byte) bool {
3502-
client.InjectPacket(packet, ca.RemoteAddr())
3502+
client.InjectInboundPacket(packet, ca.RemoteAddr())
35033503

35043504
return true
35053505
},
@@ -3518,7 +3518,7 @@ func TestOutboundInterceptor(t *testing.T) {
35183518
client, err = Client(dtlsnet.PacketConnFromConn(ca), ca.RemoteAddr(), &Config{
35193519
Certificates: []tls.Certificate{clientCert},
35203520
OutboundHandshakePacketInterceptor: func(packet []byte) bool {
3521-
server.InjectPacket(packet, cb.RemoteAddr())
3521+
server.InjectInboundPacket(packet, cb.RemoteAddr())
35223522

35233523
return true
35243524
},

0 commit comments

Comments
 (0)