SFUNetworkStream は、TCP クライアントとしてのネットワーク入出力を実現します。 ストリーム バッファとして内部で SFUNetworkBuffer を使用しています。

ここでは、HTTP を通じて Web サーバーにアクセスする例を取り上げます。

class TestStream {
    SFUNetworkStreamPtr netstream;
    Void NotifyFunc(enum SFUNetworkBuffer::NOTIFICATION);
    static Void _NotifyFunc(enum SFUNetworkBuffer::NOTIFICATION notify, VoidPtr p)
    {((TestStream*)p)->NotifyFunc(notify);}
      
    Void Start();
};

Void TestStream::Start() {
    SFUIPEndpoint endpoint("216.239.39.99:80");
    netstream = new SFUNetworkStream(endpoint, _NotifyFunc, this, 500);
    if (netstream->Exception() != NO_ERROR) {
      return
    }
}
      
Void TestStream::NotifyFunc(enum SFUNetworkBuffer::NOTIFICATION notify)
{
    switch (notify) {
        case SFUNetworkBuffer::NOTIFY_ERROR:
            TRACE("NetworkStream Notify ERROR");
            break;

        case SFUNetworkBuffer::NOTIFY_CONNECT:
            TRACE("NetworkStream Notify CONNECT");
            (*netstream) << "GET /index.html HTTP/1.0" << endl << endl;
            netstream->Flush();
            break;

        case SFUNetworkBuffer::NOTIFY_READ:
            TRACE("NetworkStream Notify READ");
            {
                UInt08 buf[1000];
                UInt08* p = buf;
                UInt08* line = buf;

                TRACE("available %d", netstream->Available());
                while (! netstream->IsEOB() && netstream->Exception() == 0) {
                    (*netstream) >> *(p++);
                }
                *p = '\0';
                TRACE("DATA>>> %s", buf);

                if (! netstream->IsEOS()) {
                    netstream->Fetch(100);
                }
            }
            break;

        case SFUNetworkBuffer::NOTIFY_WRITE:
            TRACE("NetworkStream Notify WRITE");
            netstream->Fetch(100);
            break;
    }
}      

まず TestStream::Start() では、接続先の IP エンドポイントを作成しています。 IP エンドポイントは IP アドレスとポート番号のペアです。 IP エンドポイントは次のように INAddr と INPort から作成することもできます。

INAddr addr;
INET_ATON("216.239.39.99", &addr);
INPort port = HTONS(80);
SFUIPEndpoint endpoint(addr, port);

SFUNetworkStream のコンストラクタでは、 TCP 接続先の IP エンドポイントと、通知を受け取るコールバック関数、 ユーザー定義データ、送信バッファの初期サイズを指定します。 コールバック関数はグローバル関数かクラスの静的メンバ関数でなくてはなりません。

ここではユーザー定義データとして this を渡し、 通知関数として TestStream::_NotifyFunc を指定しています。 TestStream::_NotifyFunc では引数に渡された TestStream オブジェクトの 関数を呼び出すことで通常のメンバ関数に処理を委譲しています。

SFUNetworkStream のコンストラクタではサーバーに対して接続を試みますが、 接続時にエラーが発生すると、 Exception() 関数が NO_ERROR = 0 以外の値を返します。 SFUNetworkStream のコンストラクタが成功すると、 すぐに接続が開始し、接続が完了するとコールバックに通知されます。 接続完了の通知ではコールバックに SFUNetworkBuffer::NOTIFICATION が渡されますので、そのタイミングで追加の処理を行うことができます。

この例では、接続完了後にサーバーに対して HTTP リクエストを送信しています。 データを送信するには、ストリームのインサータを使って ストリーム バッファにデータを蓄積した上で、 Flush() 関数を呼び出します。 実際のデータ送信は Flush() 関数呼び出し時に行われます。

Flush() を呼び出すと、ストリーム バッファに蓄積されたデータが サーバーに送信され、送信が完了すると再びコールバック関数が呼び出されます。 このときの通知コードは SFUNetworkBuffer::NOTIFY_WRITE です。 ここでは Web サーバーに HTTP リクエストを送信した後、 Web サーバーからの応答を受け取るために、Fetch() 関数を呼び出しています。

Fetch() 関数の引数には最大のバッファサイズを指定します。 Fetch() を呼び出すと通知コールバックに SFUNetworkBuffer::NOTIFY_READ が渡されます。 コールバックでは受信バッファのデータを受け取るために エクストラクタで 1 バイトずつ読み取っています。 バッファの終端に達すると IsEOB() が TRUE になります。 また、ストリームの終端まで読み取ると IsEOS() が TRUE になりますので、 ストリームの終端 (HTTP 応答の終端) に達していない場合は、 再び Fetch() 関数を呼び出すことで、 受信処理を繰り返します。

接続、送信、受信の処理中に通信エラーがあると、 コールバック関数に SFUNetworkBuffer::NOTIFY_ERROR が渡されます。 また、ストリームの作成時、書き込み時、読み取り時に何らかのエラーが 発生しますと SFUNetworkStream::Exception() が NO_ERROR = 0 以外の値を返します。