2012-12-22 17 views
6

私は自分のプロジェクトを通してboost asioを使用しています。 デバイスファイル(/dev/input/eventX)を読んでみたいです。ブーストASIOのドキュメントで それは通常のファイルIOが不可能であると述べているが、デバイスファイルやパイプは、私がオープンし、stream_descriptorにそれを割り当てられ経由でファイルディスクリプタをオープンしasio::posix::stream_descriptor.デバイスファイルでasioを使用する方法

を使用することによってサポートされています。私は今返さないasync_read()呼び出しを発行します。

入力イベントでboost asioを使用することはできますか? ioctl経由でasioで使用する前にファイルハンドルを設定する必要がありますか?

編集:サンプルコードを追加 - >サンプルコードを追加しました。

次のコードは/ dev/input/event12を開き、io_serviceオブジェクトのrunメソッドが呼び出されます。

#include <boost/asio.hpp> 
#include <string> 
#include <iostream> 
#include <boost/bind.hpp> 
#include <linux/input.h> 

namespace asio = boost::asio; 
#ifdef BOOST_ASIO_HAS_POSIX_STREAM_DESCRIPTOR 
typedef asio::posix::stream_descriptor stream_descriptor; 
#else // BOOST_ASIO_HAS_POSIX_STREAM_DESCRIPTOR 
typedef asio::windows::stream_handle stream_descriptor; 
#endif // BOOST_ASIO_HAS_POSIX_STREAM_DESCRIPTOR 

class FileReader 
{ 
    typedef boost::shared_ptr<asio::streambuf> StreambufPtr; 
    typedef boost::shared_ptr<FileReader> FileReaderPtr; 
    typedef boost::weak_ptr<FileReader> FileReaderWeakPtr; 
    public: 
    static FileReaderWeakPtr Create(asio::io_service& io_service, const std::string& path); 
    virtual ~FileReader(); 

    void HandleRead(FileReaderPtr me, StreambufPtr sb, 
        const boost::system::error_code &error); 
private: 
    FileReader(asio::io_service& io_service, const std::string& path); 
    stream_descriptor m_InputStream; 
}; 

FileReader::FileReaderWeakPtr FileReader::Create(asio::io_service& io_service, 
               const std::string& path){ 
    FileReaderPtr ptr(new FileReader(io_service, path)); 
    StreambufPtr sb(new boost::asio::streambuf()); 

    asio::async_read(ptr->m_InputStream, *sb, 
      boost::bind(&FileReader::HandleRead, ptr.get(), 
      ptr, sb, asio::placeholders::error)); 
    return ptr; 
} 

FileReader::FileReader(asio::io_service& io_service, const std::string& path) 
    :m_InputStream(io_service) 
{ 
    int dev = open(path.c_str(), O_RDONLY); 
    if (dev == -1) { 
     throw std::runtime_error("failed to open device " + path); 
    } 

    m_InputStream.assign(dev); 
} 

void FileReader::HandleRead(FileReaderPtr me, StreambufPtr sb, 
        const boost::system::error_code &error) { 
    if(!error) { 
     //Inform all of a sucessfull read 
     std::istream is(sb.get()); 
     size_t data_length = sb->size(); 
     asio::async_read(m_InputStream, *sb, 
      boost::bind(&FileReader::HandleRead, this, me, sb, asio::placeholders::error)); 
    } 
} 
+0

async_read()の呼び出しが返されない、またはコールバックが呼び出されないことを意味しますか?コードなしでは、診断するのは難しいです。 io_service :: run()を呼び出すことを忘れましたか?それが価値あるものについては、私はこれを正確に行い、それは間違いなく機能します。 – Sean

+0

@seanコールバックは決して呼ばれません。 –

答えて

3

問題は完全な条件なしでasync_readを使用していたことでした。したがって、コールバックは呼び出されませんでした。 async_read_someへの呼び出しを変更した後は、すべてが期待通りに機能します。

+2

_ async_read_some_への呼び出しを変更しても、誰にも役立つものではありません。あなたは、それぞれの変更でいくつかのコードを書く必要があります。 – Victor

関連する問題