jp.go.aist.rtm.RTC.port

クラス SharedMemory

java.lang.Object

org.omg.PortableServer.Servant

OpenRTM.PortSharedMemoryPOA

jp.go.aist.rtm.RTC.port.SharedMemory

すべての実装されたインタフェース:

PortSharedMemoryOperations, org.omg.CORBA.portable.InvokeHandler

直系の既知のサブクラス:

InPortSHMProvider, OutPortSHMProvider

public class SharedMemory
extends PortSharedMemoryPOA

SharedMemory クラス

共有メモリ操作クラス CORBAによる通信により、mmapの初期化、終了などがリモートに操作できる

フィールドのサマリー

フィールド

修飾子とタイプ	フィールドと説明
protected boolean	m_endian

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
SharedMemory() コンストラクタ

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	close_memory()
void	close_memory(boolean unlink) マッピングした共有メモリをアンマップする
void	create_memory(long memory_size, java.lang.String shm_address) 共有メモリの初期化 {@.en Initializes a shared memory
PortStatus	get() データの送信を要求する {@.en Get data
void	open_memory(long memory_size, java.lang.String shm_address) 共有メモリのマッピングを行う
PortStatus	put() データの送信を知らせる {@.en Put data
void	read(CdrDataHolder data) データを読み込む
void	setEndian(boolean isLittleEndian) エンディアンを設定する
void	setInterface(PortSharedMemory sm) 通信先のCORBAインターフェースを登録する
long	string_to_MemorySize(java.lang.String size_str) 文字列で指定したデータサイズを数値に変換する
void	write(CdrDataHolder data) データを書き込む

クラスから継承されたメソッド OpenRTM.PortSharedMemoryPOA

_all_interfaces, _invoke, _this, _this

クラスから継承されたメソッド org.omg.PortableServer.Servant

_default_POA, _get_delegate, _get_interface_def, _is_a, _non_existent, _object_id, _orb, _poa, _set_delegate, _this_object, _this_object

クラスから継承されたメソッド java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

フィールドの詳細

m_endian

protected boolean m_endian

コンストラクタの詳細

SharedMemory

public SharedMemory()

コンストラクタ

メソッドの詳細

string_to_MemorySize

public long string_to_MemorySize(java.lang.String size_str)

文字列で指定したデータサイズを数値に変換する

1M -> 1048576 1k -> 1024 100 -> 100

パラメータ:

size_str - データサイズ(文字列)

戻り値:

データサイズ(数値) # int string_to_MemorySize(string size_str);

create_memory

public void create_memory(long memory_size,
                          java.lang.String shm_address)

共有メモリの初期化 # windowsではページングファイル上に領域を確保する # Linuxでは/dev/shm以下にファイルを作成する # 作成したファイルの内容を仮想アドレスにマッピングする

パラメータ:

memory_size - 共有メモリのサイズ

shm_address - 空間名 # void create_memory(int memory_size, string shm_address);

open_memory

public void open_memory(long memory_size,
                        java.lang.String shm_address)

共有メモリのマッピングを行う

パラメータ:

memory_size - 共有メモリのサイズ

shm_address - 空間名 # void open_memory(int memory_size, string shm_address);

close_memory

public void close_memory(boolean unlink)

マッピングした共有メモリをアンマップする

パラメータ:

unlink - Linuxで/dev/shm以下に作成したファイルを削除する場合にTrueにする # void close_memory(boolean unlink);

close_memory

public void close_memory()

write

public void write(CdrDataHolder data)

データを書き込む

先頭8byteにデータサイズを書き込み、その後ろにデータを書き込む 設定したデータサイズが共有メモリのサイズを上回った場合、 共有メモリの初期化を行う

パラメータ:

data - 書き込むデータ # void write(cdrMemoryStream& data);

read

public void read(CdrDataHolder data)

データを読み込む

パラメータ:

data - 読み込んだデータを受け取るためのオブジェクト # void read(::OpenRTM::CdrData_out data);

setInterface

public void setInterface(PortSharedMemory sm)

通信先のCORBAインターフェースを登録する

登録する事により共有メモリの初期化したときに、 通信先でもマッピングをやり直すことができる

パラメータ:

sm - SharedMemoryのオブジェクトリファレンス # void close(int memory_size, string shm_address);

setEndian

public void setEndian(boolean isLittleEndian)

エンディアンを設定する

パラメータ:

isLittleEndian - true: little, false: big PortStatus setEndian();

put

public PortStatus put()

データの送信を知らせる # PortStatus put();

get

public PortStatus get()

データの送信を要求する # # PortStatus get();