Lines Matching defs:request
121 // prepare request
122 remote_disk_header request;
123 request.command = REMOTE_DISK_HELLO_REQUEST;
139 // send request
141 error = _SendRequest(&request, sizeof(request), REMOTE_DISK_HELLO_REPLY,
192 // prepare request
193 remote_disk_header request;
194 request.offset = htonll(pos);
196 request.size = htons(toRead);
197 request.command = REMOTE_DISK_READ_REQUEST;
199 // send request
200 error = _SendRequest(&request, sizeof(request), REMOTE_DISK_READ_REPLY);
247 // prepare request
248 remote_disk_header* request = (remote_disk_header*)fPacket;
249 request->offset = htonll(pos);
251 request->size = htons(toWrite);
252 request->command = REMOTE_DISK_WRITE_REQUEST;
256 status_t error = user_memcpy(request->data, buffer, toWrite);
260 memcpy(request->data, buffer, toWrite);
262 // send request
263 size_t requestSize = request->data + toWrite - (uint8_t*)request;
266 error = _SendRequest(request, requestSize, REMOTE_DISK_WRITE_REPLY,
382 RemoteDisk::_SendRequest(remote_disk_header* request, size_t size,
385 return _SendRequest(request, size, expectedReply, peerAddress, fPacket,
391 RemoteDisk::_SendRequest(remote_disk_header *request, size_t size,
395 request->request_id = fRequestID++;
396 request->port = fSocketAddress.sin_port;
398 // try sending the request kMaxRequestResendCount times at most
400 // send request
403 bytesSent = sendto(fSocket, request, size, 0,
440 if (reply->request_id == request->request_id