Home
last modified time | relevance | path

Searched refs:WRITE (Results 1 – 8 of 8) sorted by relevance

/thrift-3.4.0/lib/rb/ext/
Dmacros.h23 #define WRITE(obj, data, length) rb_funcall(obj, write_method_id, 1, rb_str_new(data, length))
Dbinary_protocol_accelerated.c41 WRITE(trans, (char*)&b, 1); in write_byte_direct()
50 WRITE(trans, data, 2); in write_i16_direct()
61 WRITE(trans, data, 4); in write_i32_direct()
77 WRITE(trans, data, 8); in write_i64_direct()
Dcompact_protocol.c98 WRITE(transport, (char*)&b, 1); in write_byte_direct()
305 WRITE(GET_TRANSPORT(self), buf, 8); in rb_thrift_compact_proto_write_double()
319 WRITE(transport, StringValuePtr(buf), RSTRING_LEN(buf)); in rb_thrift_compact_proto_write_binary()
/thrift-3.4.0/lib/d/src/thrift/async/
Dbase.d214 WRITE /// The transport became ready to be written to. enumerator
Dsocket.d146 asyncManager_.addOneshotListener(socket_, TAsyncEventType.WRITE, in open()
263 auto r = yieldOnBlock(socket_.send(buf), TAsyncEventType.WRITE); in writeSome()
310 case TAsyncEventType.WRITE: in yieldOnBlock()
Dlibevent.d457 case TAsyncEventType.WRITE: in libeventEventType()
/thrift-3.4.0/lib/cpp/src/thrift/transport/
DTFileTransport.cpp913 : bufferMode_(WRITE), writePoint_(0), readPoint_(0), size_(size) { in TFileTransportBuffer()
941 if (bufferMode_ == WRITE) { in getNext()
953 if (bufferMode_ == WRITE || writePoint_ > readPoint_) { in reset()
960 bufferMode_ = WRITE; in reset()
DTFileTransport.h137 enum mode { WRITE, READ }; enumerator