virtual/nbd/nbd.c

173 	status_t err = EINVAL;
179 		return err;
181 		return err;
184 	err = mutex_lock(&dev->ben);
185 	if (err)
186 		return err;
195 	err = ENOMEM;
200 	err = r->sem = create_sem(0, "nbd request sem");
201 	if (err < 0)
225 	dprintf(DP " %s: error 0x%08" B_PRIx32 "\n", __FUNCTION__, err);
226 	return err;
280 	status_t err;
286 		err = krecv(dev->sock, &reply, sizeof(reply), 0);
287 		if (err == -1 && errno < 0)
288 			err = errno;
289 		if (err < 0)
290 			goto err;
292 		if (err < (status_t)sizeof(reply))
293 			err = EINVAL;
294 		if (err < 0)
295 			goto err;
297 		err = EINVAL;
299 			goto err;
303 		err = mutex_lock(&dev->ben);
304 		if (err)
305 			goto err;
308 		err = nbd_dequeue_request(dev, B_BENDIAN_TO_HOST_INT64(reply.handle), &req);
313 		if (!err && !req) {
315 			err = ENOENT;
318 		if (err == B_OK) {
321 				err = 0;
324 					err = krecv(dev->sock, req->buffer, req->len, 0);
325 				if (err < 0)
326 					goto err;
328 				req->len = err;
336 			err = mutex_lock(&dev->ben);
337 			if (err)
338 				goto err;
355 err:
356 	dprintf(DP "%s: %s: error 0x%08" B_PRIx32 "\n", __FUNCTION__, reason, err);
357 	return err;
364 	status_t err;
368 	err = dev->sock = ksocket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
369 	if (err == -1 && errno < 0)
370 		err = errno;
371 	if (err < 0)
375 	err = kconnect(dev->sock, (struct sockaddr *)&dev->server, sizeof(dev->server));
376 	//err = ENOSYS;
377 	if (err == -1 && errno < 0)
378 		err = errno;
380 	if (err)
382 	if (err)
386 	err = krecv(dev->sock, &initpkt, sizeof(initpkt), 0);
387 	if (err == -1 && errno < 0)
388 		err = errno;
389 	if (err < (status_t)sizeof(initpkt))
391 	err = EINVAL;//EPROTO;
402 	err = dev->postoffice = spawn_kernel_thread(nbd_postoffice, "nbd postoffice", B_REAL_TIME_PRIORITY, dev);
403 	if (err < B_OK)
418 	dprintf(DP "<%s: error 0x%08" B_PRIx32 "\n", __FUNCTION__, err);
419 	return err;
437 	status_t err;
440 	err = ksend(dev->sock, &req->req, sizeof(req->req), 0);
441 	if (err < 0)
442 		return err;
445 		err = ksend(dev->sock, req->buffer, req->len, 0);
446 	if (err < 0)
447 		return err;
449 		req->len = err;
451 	err = nbd_queue_request(dev, req);
452 	return err;
463 	status_t err;
474 	err = ENOMEM;
480 	err = mutex_lock(&dev->ben);
481 	if (err)
485 		err = nbd_connect(dev);
486 	if (err)
512 	dprintf(DP " %s: error 0x%08" B_PRIx32 "\n", __FUNCTION__, err);
513 	return err;
519 	status_t err;
525 	err = mutex_lock(&dev->ben);
526 	if (err)
527 		return err;
548 	status_t err;
551 	err = mutex_lock(&dev->ben);
552 	if (err)
553 		return err;
556 		err = nbd_teardown(dev);
562 	return err;
627 	status_t err, semerr;
636 	err = nbd_alloc_request(dev, &req, NBD_CMD_READ, position, *numbytes, NULL);
637 	if (err)
641 	err = mutex_lock(&dev->ben);
642 	if (err)
645 	err = nbd_post_request(dev, req);
650 	if (err)
657 	err = mutex_lock(&dev->ben);
658 	if(err)
673 		err = B_OK;
675 			err = EIO;
677 		return err;
690 	return err;
697 	status_t err, semerr;
705 	err = B_NOT_ALLOWED;
709 	err = nbd_alloc_request(dev, &req, NBD_CMD_WRITE, position, *numbytes, data);
710 	if (err)
714 	err = mutex_lock(&dev->ben);
715 	if (err)
719 	err = nbd_post_request(dev, req);
724 	if (err)
731 	err = mutex_lock(&dev->ben);
732 	if(err)
746 		err = B_OK;
748 			err = EIO;
750 		return err;
763 	return err;
802 	status_t err;
815 	err = ksocket_init();
816 	if (err < B_OK)
817 		return err;