Functions — github.com/MyCATApache/Mycat-IPC

CodeHub MCPcopy Create free account

hub / github.com/MyCATApache/Mycat-IPC / functions

Functions92 in github.com/MyCATApache/Mycat-IPC

⨍ Functions 92 ◇ Types & classes 13

↓ 9 callersMethodcompareAndSwapLong

(long pos, long expected, long value)

src/main/java/io/mycat/ipc/UnsafeMemory.java:326

↓ 8 callersMethodgetStartPos

src/main/java/io/mycat/ipc/SharedMMRing.java:26

↓ 6 callersMethodputByte

Writes a byte to the specified position. @param pos the position in the memory mapped file @param val the value to write

src/main/java/io/mycat/ipc/UnsafeMemory.java:191

↓ 6 callersMethodputByteVolatile

Writes a byte (volatile) to the specified position. @param pos the position in the memory mapped file @param val the value to w

src/main/java/io/mycat/ipc/UnsafeMemory.java:203

↓ 5 callersMethodgetBytes

Reads a buffer of data. @param pos the position in the memory mapped file @param data the input buffer @param offset

src/main/java/io/mycat/ipc/UnsafeMemory.java:302

↓ 4 callersMethodgetEndPos

src/main/java/io/mycat/ipc/UnsafeMemory.java:76

↓ 4 callersMethodgetLongVolatile

Reads a long (volatile) from the specified position. @param pos position in the memory mapped file @return the value read

src/main/java/io/mycat/ipc/UnsafeMemory.java:179

↓ 4 callersMethodgetStartPos

src/main/java/io/mycat/ipc/FastestFileStorage.java:55

↓ 4 callersMethodgetWriteIndexPos

src/main/java/io/mycat/ipc/SharedMMRing.java:30

↓ 4 callersMethodmapAndSetOffset

(final String loc, long fileSize, boolean createNewFile, long startPos, long mapSize)

src/main/java/io/mycat/ipc/UnsafeMemory.java:37

↓ 4 callersMethodroundTo4096

src/main/java/io/mycat/ipc/util/Util.java:10

↓ 3 callersMethodclose

src/main/java/io/mycat/ipc/FastestFileStorage.java:72

↓ 3 callersMethodgetAddr

src/main/java/io/mycat/ipc/QueueMeta.java:30

↓ 3 callersMethodgetByteVolatile

Reads a byte (volatile) from the specified position. @param pos the position in the memory mapped file @return the value read

src/main/java/io/mycat/ipc/UnsafeMemory.java:113

↓ 3 callersMethodgetNextDataAddr

src/main/java/io/mycat/ipc/SharedMMRing.java:70

↓ 3 callersMethodgetNextDataFlagIndexPos

src/main/java/io/mycat/ipc/SharedMMRing.java:34

↓ 3 callersMethodgetQueueCountInMM

src/main/java/io/mycat/ipc/SharedMMIPMemPool.java:103

↓ 3 callersMethodgetWriteIndexPos

src/main/java/io/mycat/ipc/FastestFileStorage.java:51

↓ 3 callersMethodunmap

src/main/java/io/mycat/ipc/UnsafeMemory.java:90

↓ 2 callersMethodcreateNewRing

(short groupId, int rawLength, byte storageType)

src/main/java/io/mycat/ipc/SharedMMIPMemPool.java:70

↓ 2 callersMethodgetFirstQueueAddr

src/main/java/io/mycat/ipc/SharedMMIPMemPool.java:66

↓ 2 callersMethodgetMethod

(Class<?> cls, String name, Class<?>... params)

src/main/java/io/mycat/ipc/UnsafeMemory.java:84

↓ 2 callersMethodgetMsgTotalSpace

src/main/java/io/mycat/ipc/SharedMMRing.java:66

↓ 2 callersMethodgetRelovePos

src/main/java/io/mycat/ipc/UnsafeMemory.java:67

↓ 2 callersMethodgetShortVolatile

Reads a short (volatile) from the specified position. @param pos the position in the memory mapped file @return the value read

src/main/java/io/mycat/ipc/UnsafeMemory.java:135

↓ 2 callersMethodgetStartPos

src/main/java/io/mycat/ipc/UnsafeMemory.java:72

↓ 2 callersMethodgetWriteStartAddr

src/main/java/io/mycat/ipc/FastestFileStorage.java:150

↓ 2 callersMethodgetWriteStartAddr

src/main/java/io/mycat/ipc/SharedMMRing.java:75

↓ 2 callersMethodpullData

src/main/java/io/mycat/ipc/SharedMMRing.java:206

↓ 2 callersMethodputData

if return false,means can't put ,ring is full @param rawMsg @return

src/main/java/io/mycat/ipc/SharedMMRing.java:177

↓ 2 callersMethodputLongVolatile

Writes a long (volatile) to the specified position. @param pos the position in the memory mapped file @param val the value to w

src/main/java/io/mycat/ipc/UnsafeMemory.java:275

↓ 2 callersMethodputShort

Writes an short to the specified position. @param pos the position in the memory mapped file @param val the value to write

src/main/java/io/mycat/ipc/UnsafeMemory.java:239

↓ 2 callersMethodputShortVolatile

Writes an short (volatile) to the specified position. @param pos the position in the memory mapped file @param val the value to

src/main/java/io/mycat/ipc/UnsafeMemory.java:251

↓ 2 callersMethodreadData

(long prevNextDataFlagPos, long curDataFlagPos)

src/main/java/io/mycat/ipc/SharedMMRing.java:195

↓ 2 callersMethodsetBytes

Writes a buffer of data. @param pos the position in the memory mapped file @param data the output buffer @param offset

src/main/java/io/mycat/ipc/UnsafeMemory.java:318

↓ 2 callersMethodtryReWindWrite

(byte[] rawMsg)

src/main/java/io/mycat/ipc/SharedMMRing.java:88

↓ 2 callersMethodwriteMsg

(UnsafeMemory mm, long pos, byte[] data)

src/main/java/io/mycat/ipc/FastestFileStorage.java:136

↓ 2 callersMethodwriteMsg

(long pos, byte[] data)

src/main/java/io/mycat/ipc/SharedMMRing.java:58

↓ 1 callersMethodgetAddrEnd

src/main/java/io/mycat/ipc/QueueMeta.java:20

↓ 1 callersMethodgetEndPos

src/main/java/io/mycat/ipc/SharedMMRing.java:38

↓ 1 callersMethodgetIntVolatile

Reads an int (volatile) from the specified position. @param pos position in the memory mapped file @return the value read

src/main/java/io/mycat/ipc/UnsafeMemory.java:157

↓ 1 callersMethodgetMetaData

src/main/java/io/mycat/ipc/SharedMMRing.java:84

↓ 1 callersMethodgetMsgTotalSpace

src/main/java/io/mycat/ipc/FastestFileStorage.java:155

↓ 1 callersMethodgetNextDataAddr

src/main/java/io/mycat/ipc/FastestFileStorage.java:145

↓ 1 callersMethodgetNextDataFlagIndexPos

src/main/java/io/mycat/ipc/FastestFileStorage.java:47

↓ 1 callersMethodgetRawLenth

src/main/java/io/mycat/ipc/QueueMeta.java:27

↓ 1 callersMethodgetRing

src/main/java/io/mycat/ipc/SharedMMIPMemPool.java:95

↓ 1 callersMethodgetShort

Reads a short from the specified position. @param pos the position in the memory mapped file @return the value read

src/main/java/io/mycat/ipc/UnsafeMemory.java:124

↓ 1 callersMethodgetSize

src/main/java/io/mycat/ipc/UnsafeMemory.java:80

↓ 1 callersMethodinit

src/main/java/io/mycat/ipc/FastestFileStorage.java:59

↓ 1 callersMethodinit

src/main/java/io/mycat/ipc/SharedMMIPMemPool.java:44

↓ 1 callersMethodputIntVolatile

Writes an int (volatile) to the specified position. @param pos the position in the memory mapped file @param val the value to w

src/main/java/io/mycat/ipc/UnsafeMemory.java:227

↓ 1 callersMethodtryWriteData

return 0 ,wirte ok , 1 ,try agagin ,-1 no space @param rawMsg @return

src/main/java/io/mycat/ipc/SharedMMRing.java:125

↓ 1 callersMethodwriteData

(byte[] rawMsg)

src/main/java/io/mycat/ipc/FastestFileStorage.java:83

MethodFastestFileStorage

Constructs a new memory mapped file. @param loc the file name @param len the file length @throws Exception in case

src/main/java/io/mycat/ipc/FastestFileStorage.java:34

MethodNativeMemoryRegion

(UnsafeMemory mm, long addr, long size)

src/main/java/io/mycat/ipc/NativeMemoryRegion.java:7

MethodQueueMeta

(short groupId, int rawLenth, long addr,byte storageType)

src/main/java/io/mycat/ipc/QueueMeta.java:8

MethodRawMessage

src/main/java/io/mycat/ipc/RawMessage.java:11

MethodSharedMMIPMemPool

Constructs a new memory mapped file. @param loc the file name @param len the file length @throws Exception in case

src/main/java/io/mycat/ipc/SharedMMIPMemPool.java:33

MethodSharedMMRing

(QueueMeta metaData, long rawMemoryStartAddr)

src/main/java/io/mycat/ipc/SharedMMRing.java:42

MethodUnsafeMemory

(long addr, long startPos, long size)

src/main/java/io/mycat/ipc/UnsafeMemory.java:54

MethodcompareAndSwapInt

(long pos, int expected, int value)

src/main/java/io/mycat/ipc/UnsafeMemory.java:322

src/main/java/io/mycat/ipc/QueueMeta.java:45

src/main/java/io/mycat/ipc/NativeMemoryRegion.java:16

src/main/java/io/mycat/ipc/UnsafeMemory.java:60

MethodgetAndAddLong

(long pos, long delta)

src/main/java/io/mycat/ipc/UnsafeMemory.java:330

Reads a byte from the specified position. @param pos the position in the memory mapped file @return the value read

src/main/java/io/mycat/ipc/UnsafeMemory.java:102

MethodgetDataFlag

src/main/java/io/mycat/ipc/RawMessage.java:19

MethodgetEndAddr

src/main/java/io/mycat/ipc/UnsafeMemory.java:64

MethodgetGroupId

src/main/java/io/mycat/ipc/QueueMeta.java:24

Reads an int from the specified position. @param pos the position in the memory mapped file @return the value read

src/main/java/io/mycat/ipc/UnsafeMemory.java:146

MethodgetLastRing

src/main/java/io/mycat/ipc/SharedMMIPMemPool.java:99

src/main/java/io/mycat/ipc/SharedMMIPMemPool.java:40

Reads a long from the specified position. @param pos position in the memory mapped file @return the value read

src/main/java/io/mycat/ipc/UnsafeMemory.java:168

src/main/java/io/mycat/ipc/NativeMemoryRegion.java:13

src/main/java/io/mycat/ipc/SharedMMRing.java:80

MethodgetRawData

src/main/java/io/mycat/ipc/RawMessage.java:15

src/main/java/io/mycat/ipc/NativeMemoryRegion.java:19

MethodgetStorageType

src/main/java/io/mycat/ipc/QueueMeta.java:16

src/main/java/io/mycat/ipc/QueueMeta.java:34

MethodlazySetInt

(long pos, int val)

src/main/java/io/mycat/ipc/UnsafeMemory.java:285

MethodlazySetLong

(long pos, long val)

src/main/java/io/mycat/ipc/UnsafeMemory.java:280

(String[] args)

src/test/java/io/mycat/ipc/Reader.java:4

(String[] args)

src/test/java/io/mycat/ipc/Writer.java:4

(String[] args)

src/main/java/io/mycat/ipc/util/Util.java:13

Writes an int to the specified position. @param pos the position in the memory mapped file @param val the value to write

src/main/java/io/mycat/ipc/UnsafeMemory.java:215

Writes a long to the specified position. @param pos the position in the memory mapped file @param val the value to write

src/main/java/io/mycat/ipc/UnsafeMemory.java:263

MethodreaderFarBehindWriter

src/main/java/io/mycat/ipc/FastestFileStorage.java:77

MethodtestInitFromFile

src/test/java/io/mycat/ipc/TestSharedMMIPMemPool.java:8

MethodtestWriteAndRead

src/test/java/io/mycat/ipc/TestFastFileStorage.java:7

MethodtestbitOp

src/test/java/io/mycat/ipc/TestBase.java:7

src/main/java/io/mycat/ipc/QueueMeta.java:65