netfs/shared/InsecureConnection.cpp

83 	// create the initial channel
84 	Channel* channel = new(std::nothrow) InsecureChannel(fd);
85 	if (!channel) {
90 	error = AddDownStreamChannel(channel);
92 		delete channel;
131 	// open the initial channel
132 	Channel* channel;
133 	error = _OpenClientChannel(serverAddr, port, &channel);
136 	error = AddUpStreamChannel(channel);
138 		delete channel;
147 	error = channel->Send(&request, sizeof(ConnectRequest));
152 	error = channel->Receive(&reply, sizeof(ConnectReply));
164 		PRINT("  creating channel %" B_PRId32 "\n", i);
165 		// open the channel
166 		error = _OpenClientChannel(serverAddr, port, &channel);
171 			error = AddUpStreamChannel(channel);
173 			error = AddDownStreamChannel(channel);
175 			delete channel;
187 	// get the down stream channel
188 	InsecureChannel* channel
190 	if (!channel)
194 	status_t error = channel->Receive(&request, sizeof(ConnectRequest));
200 		_SendErrorReply(channel, B_ERROR);
221 	if (channel->GetPeerAddress(&peerAddress) == B_OK
232 		_SendErrorReply(channel, error);
243 		_SendErrorReply(channel, error);
250 		_SendErrorReply(channel, error);
257 		_SendErrorReply(channel, error);
263 		_SendErrorReply(channel, error);
272 	error = channel->Send(&reply, sizeof(ConnectReply));
295 		PRINT("  accepting channel %" B_PRId32 "\n", i);
296 		// create a channel
297 		channel = new(std::nothrow) InsecureChannel(channelFD);
298 		if (!channel) {
304 			error = AddDownStreamChannel(channel);
306 			error = AddUpStreamChannel(channel);
308 			delete channel;
336 	// create the channel
337 	Channel* channel = new(std::nothrow) InsecureChannel(fd);
338 	if (!channel) {
342 	*_channel = channel;
348 InsecureConnection::_SendErrorReply(Channel* channel, status_t error)
352 	return channel->Send(&reply, sizeof(ConnectReply));