← Back to branch summary

~ubuntu-branches/ubuntu/saucy/zeromq3/saucy

« back to all changes in this revision

Viewing changes to src/req.cpp

  • Committer: Package Import Robot
  • Author(s): Alessandro Ghedini
  • Date: 2012-10-16 19:49:30 UTC
  • mfrom: (1.1.2)
  • Revision ID: package-import@ubuntu.com-20121016194930-98r0bi746eoaa4iv
Tags: 3.2.1~rc2+dfsg-1
http://bugs.debian.org/690704
* New upstream RC release (Closes: #690704)
* Bump Standards-Version to 3.9.4 (no changes needed)

Show diffs side-by-side

added added

removed removed

Lines of Context:
src/req.cpp
150
150
    state = options.recv_identity ? identity : bottom;
151
151
}
152
152
 
153
 
int zmq::req_session_t::write (msg_t *msg_)
 
153
int zmq::req_session_t::push_msg (msg_t *msg_)
154
154
{
155
155
    switch (state) {
156
156
    case bottom:
157
157
        if (msg_->flags () == msg_t::more && msg_->size () == 0) {
158
158
            state = body;
159
 
            return dealer_session_t::write (msg_);
 
159
            return dealer_session_t::push_msg (msg_);
160
160
        }
161
161
        break;
162
162
    case body:
163
163
        if (msg_->flags () == msg_t::more)
164
 
            return dealer_session_t::write (msg_);
 
164
            return dealer_session_t::push_msg (msg_);
165
165
        if (msg_->flags () == 0) {
166
166
            state = bottom;
167
 
            return dealer_session_t::write (msg_);
 
167
            return dealer_session_t::push_msg (msg_);
168
168
        }
169
169
        break;
170
170
    case identity:
171
171
        if (msg_->flags () == 0) {
172
172
            state = bottom;
173
 
            return dealer_session_t::write (msg_);
 
173
            return dealer_session_t::push_msg (msg_);
174
174
        }
175
175
        break;
176
176
    }