@@ -66,8 +66,10 @@ type LinuxSocketBind struct {
66
66
func NewLinuxSocketBind () Bind { return & LinuxSocketBind {sock4 : - 1 , sock6 : - 1 } }
67
67
func NewDefaultBind () Bind { return NewLinuxSocketBind () }
68
68
69
- var _ Endpoint = (* LinuxSocketEndpoint )(nil )
70
- var _ Bind = (* LinuxSocketBind )(nil )
69
+ var (
70
+ _ Endpoint = (* LinuxSocketEndpoint )(nil )
71
+ _ Bind = (* LinuxSocketBind )(nil )
72
+ )
71
73
72
74
func (* LinuxSocketBind ) ParseEndpoint (s string ) (Endpoint , error ) {
73
75
var end LinuxSocketEndpoint
@@ -171,7 +173,6 @@ func (bind *LinuxSocketBind) SetMark(value uint32) error {
171
173
unix .SO_MARK ,
172
174
int (value ),
173
175
)
174
-
175
176
if err != nil {
176
177
return err
177
178
}
@@ -184,7 +185,6 @@ func (bind *LinuxSocketBind) SetMark(value uint32) error {
184
185
unix .SO_MARK ,
185
186
int (value ),
186
187
)
187
-
188
188
if err != nil {
189
189
return err
190
190
}
@@ -327,15 +327,13 @@ func zoneToUint32(zone string) (uint32, error) {
327
327
}
328
328
329
329
func create4 (port uint16 ) (int , uint16 , error ) {
330
-
331
330
// create socket
332
331
333
332
fd , err := unix .Socket (
334
333
unix .AF_INET ,
335
334
unix .SOCK_DGRAM ,
336
335
0 ,
337
336
)
338
-
339
337
if err != nil {
340
338
return - 1 , 0 , err
341
339
}
@@ -371,15 +369,13 @@ func create4(port uint16) (int, uint16, error) {
371
369
}
372
370
373
371
func create6 (port uint16 ) (int , uint16 , error ) {
374
-
375
372
// create socket
376
373
377
374
fd , err := unix .Socket (
378
375
unix .AF_INET6 ,
379
376
unix .SOCK_DGRAM ,
380
377
0 ,
381
378
)
382
-
383
379
if err != nil {
384
380
return - 1 , 0 , err
385
381
}
@@ -410,7 +406,6 @@ func create6(port uint16) (int, uint16, error) {
410
406
}
411
407
412
408
return unix .Bind (fd , & addr )
413
-
414
409
}(); err != nil {
415
410
unix .Close (fd )
416
411
return - 1 , 0 , err
@@ -425,7 +420,6 @@ func create6(port uint16) (int, uint16, error) {
425
420
}
426
421
427
422
func send4 (sock int , end * LinuxSocketEndpoint , buff []byte ) error {
428
-
429
423
// construct message header
430
424
431
425
cmsg := struct {
@@ -465,7 +459,6 @@ func send4(sock int, end *LinuxSocketEndpoint, buff []byte) error {
465
459
}
466
460
467
461
func send6 (sock int , end * LinuxSocketEndpoint , buff []byte ) error {
468
-
469
462
// construct message header
470
463
471
464
cmsg := struct {
@@ -509,7 +502,6 @@ func send6(sock int, end *LinuxSocketEndpoint, buff []byte) error {
509
502
}
510
503
511
504
func receive4 (sock int , buff []byte , end * LinuxSocketEndpoint ) (int , error ) {
512
-
513
505
// construct message header
514
506
515
507
var cmsg struct {
@@ -518,7 +510,6 @@ func receive4(sock int, buff []byte, end *LinuxSocketEndpoint) (int, error) {
518
510
}
519
511
520
512
size , _ , _ , newDst , err := unix .Recvmsg (sock , buff , (* [unsafe .Sizeof (cmsg )]byte )(unsafe .Pointer (& cmsg ))[:], 0 )
521
-
522
513
if err != nil {
523
514
return 0 , err
524
515
}
@@ -541,7 +532,6 @@ func receive4(sock int, buff []byte, end *LinuxSocketEndpoint) (int, error) {
541
532
}
542
533
543
534
func receive6 (sock int , buff []byte , end * LinuxSocketEndpoint ) (int , error ) {
544
-
545
535
// construct message header
546
536
547
537
var cmsg struct {
@@ -550,7 +540,6 @@ func receive6(sock int, buff []byte, end *LinuxSocketEndpoint) (int, error) {
550
540
}
551
541
552
542
size , _ , _ , newDst , err := unix .Recvmsg (sock , buff , (* [unsafe .Sizeof (cmsg )]byte )(unsafe .Pointer (& cmsg ))[:], 0 )
553
-
554
543
if err != nil {
555
544
return 0 , err
556
545
}
0 commit comments