Merge pull request #1987 from slingamn/go_upgrade

upgrade go to 1.19

.github/workflows/build.yml

@@ -19,7 +19,7 @@ jobs:
       - name: "setup go"
         uses: "actions/setup-go@v2"
         with:
-          go-version: "1.18"
+          go-version: "1.19"
       - name: "install python3-pytest"
         run: "sudo apt install -y python3-pytest"
       - name: "make install"

Dockerfile

@@ -1,5 +1,5 @@
 ## build ergo binary
-FROM golang:1.18-alpine AS build-env
+FROM golang:1.19-alpine AS build-env
 
 RUN apk add -U --force-refresh --no-cache --purge --clean-protected -l -u make git
 

go.mod

@@ -1,6 +1,6 @@
 module github.com/ergochat/ergo
 
-go 1.18
+go 1.19
 
 require (
 	code.cloudfoundry.org/bytefmt v0.0.0-20200131002437-cf55d5288a48

irc/getters.go

@@ -16,7 +16,7 @@ import (
 )
 
 func (server *Server) Config() (config *Config) {
-	return server.config.Get()
+	return server.config.Load()
 }
 
 func (server *Server) ChannelRegistrationEnabled() bool {

irc/server.go

@@ -15,6 +15,7 @@ import (
 	"strconv"
 	"strings"
 	"sync"
+	"sync/atomic"
 	"syscall"
 	"time"
 
@@ -66,7 +67,7 @@ type Server struct {
 	channels          ChannelManager
 	channelRegistry   ChannelRegistry
 	clients           ClientManager
-	config            utils.ConfigStore[Config]
+	config            atomic.Pointer[Config]
 	configFilename    string
 	connectionLimiter connection_limits.Limiter
 	ctime             time.Time
@@ -707,7 +708,7 @@ func (server *Server) applyConfig(config *Config) (err error) {
 	config.Server.Cloaks.SetSecret(LoadCloakSecret(server.store))
 
 	// activate the new config
-	server.config.Set(config)
+	server.config.Store(config)
 
 	// load [dk]-lines, registered users and channels, etc.
 	if initial {

irc/smtp/smtp.go

@@ -4,9 +4,11 @@
 
 // Package smtp implements the Simple Mail Transfer Protocol as defined in RFC 5321.
 // It also implements the following extensions:
+//
 //	8BITMIME  RFC 1652
 //	AUTH      RFC 2554
 //	STARTTLS  RFC 3207
+//
 // Additional extensions may be handled by clients.
 //
 // The smtp package is frozen and is not accepting new features.

irc/socket.go

@@ -111,6 +111,7 @@ func (socket *Socket) Write(data []byte) (err error) {
 //  4. MUST respect the same ordering guarantees as Write (i.e., if a call to Write that sends
 //     message m1 happens-before a call to BlockingWrite that sends message m2,
 //     m1 must be sent on the wire before m2
+//
 // Callers MUST be writing to the client's socket from the client's own goroutine;
 // other callers must use the nonblocking Write call instead. Otherwise, a client
 // with a slow/unreliable connection risks stalling the progress of the system as a whole.

irc/utils/config.go

@@ -1,33 +0,0 @@
-// Copyright (c) 2022 Shivaram Lingamneni
-// released under the MIT license
-
-package utils
-
-import (
-	"sync/atomic"
-	"unsafe"
-)
-
-/*
-This can be used to implement the following pattern:
-
-1. Prepare a config object (this can be arbitrarily expensive)
-2. Take a pointer to the config object and use Set() to install it
-3. Use Get() to access the config from any goroutine
-4. To update the config, call Set() again with a new prepared config object
-5. As long as any individual config object is not modified (by any goroutine)
-   after it is installed with Set(), this is free of data races, and Get()
-   is extremely cheap (on amd64 it compiles down to plain MOV instructions).
-*/
-
-type ConfigStore[Config any] struct {
-	ptr unsafe.Pointer
-}
-
-func (c *ConfigStore[Config]) Get() *Config {
-	return (*Config)(atomic.LoadPointer(&c.ptr))
-}
-
-func (c *ConfigStore[Config]) Set(ptr *Config) {
-	atomic.StorePointer(&c.ptr, unsafe.Pointer(ptr))
-}

irc/utils/text.go

@@ -22,8 +22,11 @@ type MessagePair struct {
 // SplitMessage represents a message that's been split for sending.
 // Two possibilities:
 // (a) Standard message that can be relayed on a single 512-byte line
+//
 //	(MessagePair contains the message, Split == nil)
+//
 // (b) multiline message that was split on the client side
+//
 //	(Message == "", Split contains the split lines)
 type SplitMessage struct {
 	Message string