var buf bytes.Buffer
		for pb.Next() {
			runOnce(&buf)
		}
	})
}

func writeTestsToFS(tests []WriteTest) fs.FS {
	fsys := fstest.MapFS{}
	for _, wt := range tests {
		fsys[wt.Name] = &fstest.MapFile{
			Data: wt.Data,
			Mode: wt.Mode,
		}
	}
	return fsys
}

func TestWriterAddFS(t *testing.T) {
	buf := new(bytes.Buffer)
	w := NewWriter(buf)
	tests := []WriteTest{
		{

		}
	}
}

func TestWriterAddFS(t *testing.T) {
	fsys := fstest.MapFS{
		"file.go":              {Data: []byte("hello")},
		"subfolder/another.go": {Data: []byte("world")},
	}
	var buf bytes.Buffer
	tw := NewWriter(&buf)
	if err := tw.AddFS(fsys); err != nil {
		t.Fatal(err)
	}

	// Test that we can get the files back from the archive

// It walks the directory tree starting at the root of the filesystem
// adding each file to the zip using deflate while maintaining the directory structure.
func (w *Writer) AddFS(fsys fs.FS) error {
	return fs.WalkDir(fsys, ".", func(name string, d fs.DirEntry, err error) error {
		if err != nil {
			return err
		}
		if d.IsDir() {
			return nil
		}
		info, err := d.Info()
		if err != nil {

// It walks the directory tree starting at the root of the filesystem
// adding each file to the tar archive while maintaining the directory structure.
func (tw *Writer) AddFS(fsys fs.FS) error {
	return fs.WalkDir(fsys, ".", func(name string, d fs.DirEntry, err error) error {
		if err != nil {
			return err
		}
		if d.IsDir() {
			return nil
		}
		info, err := d.Info()
		if err != nil {

func (sys *BucketMetadataSys) Count() int {
	sys.RLock()
	defer sys.RUnlock()

	return len(sys.metadataMap)
}

// Remove bucket metadata from memory.
func (sys *BucketMetadataSys) Remove(buckets ...string) {
	sys.Lock()
	for _, bucket := range buckets {
		delete(sys.metadataMap, bucket)
		globalBucketMonitor.DeleteBucket(bucket)
	}
	sys.Unlock()
}

pkg syscall (freebsd-arm64), const SYS___SYSCTL = 202
pkg syscall (freebsd-arm64), const SYS___SYSCTL ideal-int
pkg syscall (freebsd-arm64), const SYS__UMTX_OP = 454
pkg syscall (freebsd-arm64), const SYS__UMTX_OP ideal-int
pkg syscall (freebsd-arm64), const SYS_ABORT2 = 463
pkg syscall (freebsd-arm64), const SYS_ABORT2 ideal-int
pkg syscall (freebsd-arm64), const SYS_ACCEPT = 30

pkg syscall (darwin-arm64), const SYS_CSOPS_AUDITTOKEN ideal-int
pkg syscall (darwin-arm64), const SYS_DELETE = 226
pkg syscall (darwin-arm64), const SYS_DELETE ideal-int
pkg syscall (darwin-arm64), const SYS_DUP = 41
pkg syscall (darwin-arm64), const SYS_DUP ideal-int
pkg syscall (darwin-arm64), const SYS_DUP2 = 90
pkg syscall (darwin-arm64), const SYS_DUP2 ideal-int

pkg syscall (darwin-386), const SYS_ATPGETREQ ideal-int
pkg syscall (darwin-386), const SYS_ATPGETRSP ideal-int
pkg syscall (darwin-386), const SYS_ATPSNDREQ ideal-int
pkg syscall (darwin-386), const SYS_ATPSNDRSP ideal-int
pkg syscall (darwin-386), const SYS_ATPUTMSG ideal-int
pkg syscall (darwin-386), const SYS_ATSOCKET ideal-int
pkg syscall (darwin-386), const SYS_AUDIT ideal-int

		lg = log.Info{Entry: e, NodeName: sys.nodeName}
	case string:
		lg = log.Info{ConsoleMsg: e, NodeName: sys.nodeName}
	}
	atomic.AddInt64(&sys.totalMessages, 1)

	sys.pubsub.Publish(lg)
	sys.Lock()
	// add log to ring buffer
	sys.logBuf.Value = lg
	sys.logBuf = sys.logBuf.Next()
	sys.Unlock()
	err := sys.console.Send(entry)
	if err != nil {
		atomic.AddInt64(&sys.failedMessages, 1)
	}
	return err

		if err != nil {
			sys.addNodeErr(&reply[index], sys.peerClients[index], err)
		}
	}
	return reply
}

// GetNetInfo - Network information
func (sys *NotificationSys) GetNetInfo(ctx context.Context) []madmin.NetInfo {
	reply := make([]madmin.NetInfo, len(sys.peerClients))

	g := errgroup.WithNErrs(len(sys.peerClients))
	for index, client := range sys.peerClients {
		if client == nil {