return RPC_PORT_ERROR_NONE;
else if (ret == PORT_STATUS_ERROR_IO_ERROR)
return RPC_PORT_ERROR_IO_ERROR;
- }
-
- if (delayed_message_size_ > QUEUE_SIZE_MAX) {
- _E("cache fail : delayed_message_size (%d), count(%zu)",
- delayed_message_size_, queue_.size());
- return RPC_PORT_ERROR_IO_ERROR;
- }
-
- ret = PushDelayedMessage(
- std::make_shared<DelayMessage>(static_cast<const char*>(buf),
- sent_bytes, size));
-
- if (CanWrite()) {
+ } else if (CanWrite()) {
while (!queue_.empty()) {
int port_status = PopDelayedMessage();
if (port_status != PORT_STATUS_ERROR_NONE) {
}
}
- return ret;
+ if (delayed_message_size_ > QUEUE_SIZE_MAX) {
+ _E("cache fail : delayed_message_size (%d), count(%zu)",
+ delayed_message_size_, queue_.size());
+ return RPC_PORT_ERROR_IO_ERROR;
+ }
+
+ return PushDelayedMessage(
+ std::make_shared<DelayMessage>(
+ static_cast<const char*>(buf), sent_bytes, size));
}
int Port::Write(const void* buf, unsigned int size, int* sent_bytes) {
return G_SOURCE_REMOVE;
}
+ _W("Writing is now possible. fd: %d, id: %s",
+ port->GetFd(), port->GetId().c_str());
std::lock_guard<std::recursive_mutex> lock(port->rw_mutex_);
if (port->source_id_ == 0) {
_E("GSource is destroyed");