~ubuntu-branches/ubuntu/intrepid/asio/intrepid

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00131.html#441d03324a306a3f2e2c4c72485fdf4e">asio::placeholders::error</a>, ++endpoint_iterator));

}

void <a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00140.html#ggac57e38176c76b4323e69341f18ff8b3">write</a>(const chat_message& msg)

{

io_service_.post(boost::bind(&chat_client::do_write, this, msg));

}

void close()

{

io_service_.post(boost::bind(&chat_client::do_close, this));

}

private:

void handle_connect(const <a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00030.html">asio::error_code</a>& error,

tcp::resolver::iterator endpoint_iterator)

{

if (!error)

{

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00137.html#gb1d5925953621f0ba652f8b158eb4687">asio::async_read</a>(socket_,

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00134.html#g1ed66e401559cbfd19595392f653b47c">asio::buffer</a>(read_msg_.data(), chat_message::header_length),

boost::bind(&chat_client::handle_read_header, this,

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00131.html#441d03324a306a3f2e2c4c72485fdf4e">asio::placeholders::error</a>));

}

else if (endpoint_iterator != tcp::resolver::iterator())

{

socket_.close();

tcp::endpoint endpoint = *endpoint_iterator;

socket_.async_connect(endpoint,

boost::bind(&chat_client::handle_connect, this,

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00131.html#441d03324a306a3f2e2c4c72485fdf4e">asio::placeholders::error</a>, ++endpoint_iterator));

100

}

101

}

102

103

void handle_read_header(const <a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00030.html">asio::error_code</a>& error)

104

{

105

if (!error && read_msg_.decode_header())

106

{

107

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00137.html#gb1d5925953621f0ba652f8b158eb4687">asio::async_read</a>(socket_,

108

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00134.html#g1ed66e401559cbfd19595392f653b47c">asio::buffer</a>(read_msg_.body(), read_msg_.body_length()),

109

boost::bind(&chat_client::handle_read_body, this,

110

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00131.html#441d03324a306a3f2e2c4c72485fdf4e">asio::placeholders::error</a>));

111

}

112

else

113

{

114

do_close();

115

}

116

}

117

118

void handle_read_body(const <a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00030.html">asio::error_code</a>& error)

119

{

120

if (!error)

121

{

122

std::cout.write(read_msg_.body(), read_msg_.body_length());

123

std::cout << "\n";

124

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00137.html#gb1d5925953621f0ba652f8b158eb4687">asio::async_read</a>(socket_,

125

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00134.html#g1ed66e401559cbfd19595392f653b47c">asio::buffer</a>(read_msg_.data(), chat_message::header_length),

126

boost::bind(&chat_client::handle_read_header, this,

127

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00131.html#441d03324a306a3f2e2c4c72485fdf4e">asio::placeholders::error</a>));

128

}

129

else

130

{

131

do_close();

132

}

133

}

134

135

void do_write(chat_message msg)

136

{

137

bool write_in_progress = !write_msgs_.empty();

138

write_msgs_.push_back(msg);

139

if (!write_in_progress)

140

{

141

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00141.html#g1747d3ec27f952154952e23be9249fbc">asio::async_write</a>(socket_,

142

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00134.html#g1ed66e401559cbfd19595392f653b47c">asio::buffer</a>(write_msgs_.front().data(),

143

write_msgs_.front().length()),

144

boost::bind(&chat_client::handle_write, this,

145

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00131.html#441d03324a306a3f2e2c4c72485fdf4e">asio::placeholders::error</a>));

146

}

147

}

148

149

void handle_write(const <a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00030.html">asio::error_code</a>& error)

150

{

151

if (!error)

152

{

153

write_msgs_.pop_front();

154

if (!write_msgs_.empty())

155

{

156

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00141.html#g1747d3ec27f952154952e23be9249fbc">asio::async_write</a>(socket_,

157

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00134.html#g1ed66e401559cbfd19595392f653b47c">asio::buffer</a>(write_msgs_.front().data(),

158

write_msgs_.front().length()),

159

boost::bind(&chat_client::handle_write, this,

160

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00131.html#441d03324a306a3f2e2c4c72485fdf4e">asio::placeholders::error</a>));

161

}

162

}

163

else

164

{

165

do_close();

166

}

167

}

168

169

void do_close()

170

{

171

socket_.close();

172

}

173

174

private:

175

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00032.html">asio::io_service</a>& io_service_;

176

tcp::socket socket_;

177

chat_message read_msg_;

178

chat_message_queue write_msgs_;

179

};

180

181

int <a class="code" href="a00033.html#0ddf1224851353fc92bfbff6f499fa97">main</a>(int argc, char* argv[])

182

{

183

try

184

{

185

if (argc != 3)

186

{

187

std::cerr << "Usage: chat_client <host> <port>\n";

188

return 1;

189

}

190

191

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00032.html">asio::io_service</a> io_service;

192

193

tcp::resolver resolver(io_service);

194

tcp::resolver::query query(argv[1], argv[2]);

195

tcp::resolver::iterator iterator = resolver.resolve(query);

196

197

chat_client c(io_service, iterator);

198

199

<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00052.html">asio::thread</a> t(boost::bind(&<a class="codeRef" doxygen="asio.doxytags:../reference/" href="../reference/a00032.html#c84bed0d1dd061bc71010ba1228439da">asio::io_service::run</a>, &io_service));

200

201

char line[chat_message::max_body_length + 1];

202

while (std::cin.getline(line, chat_message::max_body_length + 1))

203

{

204

using namespace std; // For strlen and memcpy.

205

chat_message msg;

206

msg.body_length(strlen(line));

207

memcpy(msg.body(), line, msg.body_length());

208

msg.encode_header();

209

c.write(msg);

210

}

211

212

c.close();

213

t.join();

214

}

215

catch (std::exception& e)

216

{

217

std::cerr << "Exception: " << e.what() << "\n";

218

}

219

220

return 0;

221

}

222

</pre></div> <DIV CLASS="qindex">

223

224

<TR>

225

226

asio 0.3.8rc3

227

</TD>

228

229

<A CLASS="qindex" HREF="../index.html">Home</A> |

230

<A CLASS="qindex" HREF="../reference/index.html">Reference</A> |

231

<A CLASS="qindex" HREF="../tutorial/index.html">Tutorial</A> |

232

<A CLASS="qindex" HREF="../examples/index.html">Examples</A> |

233

<A CLASS="qindex" HREF="../design/index.html">Design</A>

234

</TD>

235

</TR>

236

</TABLE>

237

</DIV>

238

</BODY>

239

</HTML>

Older »