ed14061578
* Work on raft backend * Add logstore locally * Add encryptor and unsealable interfaces * Add clustering support to raft * Remove client and handler * Bootstrap raft on init * Cleanup raft logic a bit * More raft work * Work on TLS config * More work on bootstrapping * Fix build * More work on bootstrapping * More bootstrapping work * fix build * Remove consul dep * Fix build * merged oss/master into raft-storage * Work on bootstrapping * Get bootstrapping to work * Clean up FMS and node-id * Update local node ID logic * Cleanup node-id change * Work on snapshotting * Raft: Add remove peer API (#906) * Add remove peer API * Add some comments * Fix existing snapshotting (#909) * Raft get peers API (#912) * Read raft configuration * address review feedback * Use the Leadership Transfer API to step-down the active node (#918) * Raft join and unseal using Shamir keys (#917) * Raft join using shamir * Store AEAD instead of master key * Split the raft join process to answer the challenge after a successful unseal * get the follower to standby state * Make unseal work * minor changes * Some input checks * reuse the shamir seal access instead of new default seal access * refactor joinRaftSendAnswer function * Synchronously send answer in auto-unseal case * Address review feedback * Raft snapshots (#910) * Fix existing snapshotting * implement the noop snapshotting * Add comments and switch log libraries * add some snapshot tests * add snapshot test file * add TODO * More work on raft snapshotting * progress on the ConfigStore strategy * Don't use two buckets * Update the snapshot store logic to hide the file logic * Add more backend tests * Cleanup code a bit * [WIP] Raft recovery (#938) * Add recovery functionality * remove fmt.Printfs * Fix a few fsm bugs * Add max size value for raft backend (#942) * Add max size value for raft backend * Include physical.ErrValueTooLarge in the message * Raft snapshot Take/Restore API (#926) * Inital work on raft snapshot APIs * Always redirect snapshot install/download requests * More work on the snapshot APIs * Cleanup code a bit * On restore handle special cases * Use the seal to encrypt the sha sum file * Add sealer mechanism and fix some bugs * Call restore while state lock is held * Send restore cb trigger through raft log * Make error messages nicer * Add test helpers * Add snapshot test * Add shamir unseal test * Add more raft snapshot API tests * Fix locking * Change working to initalize * Add underlying raw object to test cluster core * Move leaderUUID to core * Add raft TLS rotation logic (#950) * Add TLS rotation logic * Cleanup logic a bit * Add/Remove from follower state on add/remove peer * add comments * Update more comments * Update request_forwarding_service.proto * Make sure we populate all nodes in the followerstate obj * Update times * Apply review feedback * Add more raft config setting (#947) * Add performance config setting * Add more config options and fix tests * Test Raft Recovery (#944) * Test raft recovery * Leave out a node during recovery * remove unused struct * Update physical/raft/snapshot_test.go * Update physical/raft/snapshot_test.go * fix vendoring * Switch to new raft interface * Remove unused files * Switch a gogo -> proto instance * Remove unneeded vault dep in go.sum * Update helper/testhelpers/testhelpers.go Co-Authored-By: Calvin Leung Huang <cleung2010@gmail.com> * Update vault/cluster/cluster.go * track active key within the keyring itself (#6915) * track active key within the keyring itself * lookup and store using the active key ID * update docstring * minor refactor * Small text fixes (#6912) * Update physical/raft/raft.go Co-Authored-By: Calvin Leung Huang <cleung2010@gmail.com> * review feedback * Move raft logical system into separate file * Update help text a bit * Enforce cluster addr is set and use it for raft bootstrapping * Fix tests * fix http test panic * Pull in latest raft-snapshot library * Add comment
164 lines
3.7 KiB
Go
164 lines
3.7 KiB
Go
// Copyright 2016 The Go Authors. All rights reserved.
|
|
// Use of this source code is governed by a BSD-style
|
|
// license that can be found in the LICENSE file.
|
|
|
|
package unix
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"strconv"
|
|
"syscall"
|
|
"unsafe"
|
|
)
|
|
|
|
// Pledge implements the pledge syscall.
|
|
//
|
|
// The pledge syscall does not accept execpromises on OpenBSD releases
|
|
// before 6.3.
|
|
//
|
|
// execpromises must be empty when Pledge is called on OpenBSD
|
|
// releases predating 6.3, otherwise an error will be returned.
|
|
//
|
|
// For more information see pledge(2).
|
|
func Pledge(promises, execpromises string) error {
|
|
maj, min, err := majmin()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
err = pledgeAvailable(maj, min, execpromises)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
pptr, err := syscall.BytePtrFromString(promises)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
// This variable will hold either a nil unsafe.Pointer or
|
|
// an unsafe.Pointer to a string (execpromises).
|
|
var expr unsafe.Pointer
|
|
|
|
// If we're running on OpenBSD > 6.2, pass execpromises to the syscall.
|
|
if maj > 6 || (maj == 6 && min > 2) {
|
|
exptr, err := syscall.BytePtrFromString(execpromises)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
expr = unsafe.Pointer(exptr)
|
|
}
|
|
|
|
_, _, e := syscall.Syscall(SYS_PLEDGE, uintptr(unsafe.Pointer(pptr)), uintptr(expr), 0)
|
|
if e != 0 {
|
|
return e
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// PledgePromises implements the pledge syscall.
|
|
//
|
|
// This changes the promises and leaves the execpromises untouched.
|
|
//
|
|
// For more information see pledge(2).
|
|
func PledgePromises(promises string) error {
|
|
maj, min, err := majmin()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
err = pledgeAvailable(maj, min, "")
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
// This variable holds the execpromises and is always nil.
|
|
var expr unsafe.Pointer
|
|
|
|
pptr, err := syscall.BytePtrFromString(promises)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
_, _, e := syscall.Syscall(SYS_PLEDGE, uintptr(unsafe.Pointer(pptr)), uintptr(expr), 0)
|
|
if e != 0 {
|
|
return e
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// PledgeExecpromises implements the pledge syscall.
|
|
//
|
|
// This changes the execpromises and leaves the promises untouched.
|
|
//
|
|
// For more information see pledge(2).
|
|
func PledgeExecpromises(execpromises string) error {
|
|
maj, min, err := majmin()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
err = pledgeAvailable(maj, min, execpromises)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
// This variable holds the promises and is always nil.
|
|
var pptr unsafe.Pointer
|
|
|
|
exptr, err := syscall.BytePtrFromString(execpromises)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
_, _, e := syscall.Syscall(SYS_PLEDGE, uintptr(pptr), uintptr(unsafe.Pointer(exptr)), 0)
|
|
if e != 0 {
|
|
return e
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// majmin returns major and minor version number for an OpenBSD system.
|
|
func majmin() (major int, minor int, err error) {
|
|
var v Utsname
|
|
err = Uname(&v)
|
|
if err != nil {
|
|
return
|
|
}
|
|
|
|
major, err = strconv.Atoi(string(v.Release[0]))
|
|
if err != nil {
|
|
err = errors.New("cannot parse major version number returned by uname")
|
|
return
|
|
}
|
|
|
|
minor, err = strconv.Atoi(string(v.Release[2]))
|
|
if err != nil {
|
|
err = errors.New("cannot parse minor version number returned by uname")
|
|
return
|
|
}
|
|
|
|
return
|
|
}
|
|
|
|
// pledgeAvailable checks for availability of the pledge(2) syscall
|
|
// based on the running OpenBSD version.
|
|
func pledgeAvailable(maj, min int, execpromises string) error {
|
|
// If OpenBSD <= 5.9, pledge is not available.
|
|
if (maj == 5 && min != 9) || maj < 5 {
|
|
return fmt.Errorf("pledge syscall is not available on OpenBSD %d.%d", maj, min)
|
|
}
|
|
|
|
// If OpenBSD <= 6.2 and execpromises is not empty,
|
|
// return an error - execpromises is not available before 6.3
|
|
if (maj < 6 || (maj == 6 && min <= 2)) && execpromises != "" {
|
|
return fmt.Errorf("cannot use execpromises on OpenBSD %d.%d", maj, min)
|
|
}
|
|
|
|
return nil
|
|
}
|