aboutsummaryrefslogtreecommitdiff
path: root/forged/internal/ipc/git2c/client.go
diff options
context:
space:
mode:
authorRunxi Yu <me@runxiyu.org>2025-08-17 13:52:55 +0800
committerRunxi Yu <me@runxiyu.org>2025-08-17 13:52:55 +0800
commitafcf2c711b907514a91e5c4d45d2da7f118bb2b8 (patch)
tree15debbe9e2086d310a85f1929f4c580186fabec1 /forged/internal/ipc/git2c/client.go
parentLinting (diff)
downloadforge-afcf2c711b907514a91e5c4d45d2da7f118bb2b8.tar.gz
forge-afcf2c711b907514a91e5c4d45d2da7f118bb2b8.tar.zst
forge-afcf2c711b907514a91e5c4d45d2da7f118bb2b8.zip
Lint ipc
Diffstat (limited to 'forged/internal/ipc/git2c/client.go')
-rw-r--r--forged/internal/ipc/git2c/client.go13
1 files changed, 9 insertions, 4 deletions
diff --git a/forged/internal/ipc/git2c/client.go b/forged/internal/ipc/git2c/client.go
index 9f1b55c..8b11035 100644
--- a/forged/internal/ipc/git2c/client.go
+++ b/forged/internal/ipc/git2c/client.go
@@ -4,6 +4,7 @@
package git2c
import (
+ "context"
"fmt"
"net"
@@ -19,8 +20,9 @@ type Client struct {
}
// NewClient establishes a connection to a git2d socket and returns a new Client.
-func NewClient(socketPath string) (*Client, error) {
- conn, err := net.Dial("unix", socketPath)
+func NewClient(ctx context.Context, socketPath string) (*Client, error) {
+ dialer := &net.Dialer{} //exhaustruct:ignore
+ conn, err := dialer.DialContext(ctx, "unix", socketPath)
if err != nil {
return nil, fmt.Errorf("git2d connection failed: %w", err)
}
@@ -37,9 +39,12 @@ func NewClient(socketPath string) (*Client, error) {
}
// Close terminates the underlying socket connection.
-func (c *Client) Close() error {
+func (c *Client) Close() (err error) {
if c.conn != nil {
- return c.conn.Close()
+ err = c.conn.Close()
+ if err != nil {
+ return fmt.Errorf("close underlying socket: %w", err)
+ }
}
return nil
}