astisystemv

Documentation

Index

• Constants
• func NewKey(projectID int, path string) (int, error)
• type Semaphore
  • func CreateSemaphore(key, flags int) (*Semaphore, error)
  • func OpenSemaphore(key int) (*Semaphore, error)
  • func (s *Semaphore) Close() error
  • func (s *Semaphore) Key() int
  • func (s *Semaphore) Lock() error
  • func (s *Semaphore) Unlock() error
• type SemaphoredSharedMemoryReadOptions
• type SemaphoredSharedMemoryReader
  • func NewSemaphoredSharedMemoryReader() *SemaphoredSharedMemoryReader
  • func (r *SemaphoredSharedMemoryReader) Close()
  • func (r *SemaphoredSharedMemoryReader) ReadBytes(o *SemaphoredSharedMemoryReadOptions) (b []byte, err error)
• type SemaphoredSharedMemoryWriter
  • func NewSemaphoredSharedMemoryWriter() *SemaphoredSharedMemoryWriter
  • func (w *SemaphoredSharedMemoryWriter) Close()
  • func (w *SemaphoredSharedMemoryWriter) Write(src unsafe.Pointer, size int) (ro *SemaphoredSharedMemoryReadOptions, err error)
  • func (w *SemaphoredSharedMemoryWriter) WriteBytes(b []byte) (*SemaphoredSharedMemoryReadOptions, error)
• type SharedMemory
  • func CreateSharedMemory(key, size, flags int) (*SharedMemory, error)
  • func OpenSharedMemory(key int) (*SharedMemory, error)
  • func (shm *SharedMemory) Addr() unsafe.Pointer
  • func (shm *SharedMemory) Close() error
  • func (shm *SharedMemory) Key() int
  • func (shm *SharedMemory) ReadBytes(size int) ([]byte, error)
  • func (shm *SharedMemory) Write(src unsafe.Pointer, size int) error
  • func (shm *SharedMemory) WriteBytes(b []byte) error

Constants

const (
	IpcCreate    = C.IPC_CREAT
	IpcExclusive = C.IPC_EXCL
)

Functions

func NewKey

func NewKey(projectID int, path string) (int, error)

Types

type Semaphore

type Semaphore struct {
	// contains filtered or unexported fields
}

func CreateSemaphore

func CreateSemaphore(key, flags int) (*Semaphore, error)

func OpenSemaphore

func OpenSemaphore(key int) (*Semaphore, error)

func (*Semaphore) Close

func (s *Semaphore) Close() error

func (*Semaphore) Key

func (s *Semaphore) Key() int

func (*Semaphore) Lock

func (s *Semaphore) Lock() error

func (*Semaphore) Unlock

func (s *Semaphore) Unlock() error

type SemaphoredSharedMemoryReadOptions

type SemaphoredSharedMemoryReadOptions struct {
	SemaphoreKey    int
	SharedMemoryAt  int64
	SharedMemoryKey int
	Size            int
}

type SemaphoredSharedMemoryReader

type SemaphoredSharedMemoryReader struct {
	// contains filtered or unexported fields
}

func NewSemaphoredSharedMemoryReader

func NewSemaphoredSharedMemoryReader() *SemaphoredSharedMemoryReader

func (*SemaphoredSharedMemoryReader) Close

func (r *SemaphoredSharedMemoryReader) Close()

func (*SemaphoredSharedMemoryReader) ReadBytes

func (r *SemaphoredSharedMemoryReader) ReadBytes(o *SemaphoredSharedMemoryReadOptions) (b []byte, err error)

type SemaphoredSharedMemoryWriter

type SemaphoredSharedMemoryWriter struct {
	// contains filtered or unexported fields
}

func NewSemaphoredSharedMemoryWriter

func NewSemaphoredSharedMemoryWriter() *SemaphoredSharedMemoryWriter

func (*SemaphoredSharedMemoryWriter) Close

func (w *SemaphoredSharedMemoryWriter) Close()

func (*SemaphoredSharedMemoryWriter) Write

func (w *SemaphoredSharedMemoryWriter) Write(src unsafe.Pointer, size int) (ro *SemaphoredSharedMemoryReadOptions, err error)

func (*SemaphoredSharedMemoryWriter) WriteBytes

func (w *SemaphoredSharedMemoryWriter) WriteBytes(b []byte) (*SemaphoredSharedMemoryReadOptions, error)

type SharedMemory

type SharedMemory struct {
	// contains filtered or unexported fields
}

func CreateSharedMemory

func CreateSharedMemory(key, size, flags int) (*SharedMemory, error)

func OpenSharedMemory

func OpenSharedMemory(key int) (*SharedMemory, error)

func (*SharedMemory) Addr

func (shm *SharedMemory) Addr() unsafe.Pointer

func (*SharedMemory) Close

func (shm *SharedMemory) Close() error

func (*SharedMemory) Key

func (shm *SharedMemory) Key() int

func (*SharedMemory) ReadBytes

func (shm *SharedMemory) ReadBytes(size int) ([]byte, error)

func (*SharedMemory) Write

func (shm *SharedMemory) Write(src unsafe.Pointer, size int) error

func (*SharedMemory) WriteBytes

func (shm *SharedMemory) WriteBytes(b []byte) error