+ GSequenceIter *i;
+ BlueSkyDirent start = {NULL, NULL, argp->cookie, 0};
+
+ /* Perform a prefetch pass on inodes: for all the inodes we think we will
+ * return information about, try to load each one but don't wait. This
+ * should let multiple inodes be fetched in parallel, instead of
+ * sequentially in the loop that follows. */
+ i = g_sequence_search(dir->dirents, &start, bluesky_dirent_compare, NULL);
+ while (count < MAX_READDIR_DIRENTS
+ && !g_sequence_iter_is_end(i)
+ && dircount <= argp->dircount
+ && dircount + attrcount <= argp->maxcount)
+ {
+ BlueSkyDirent *d = g_sequence_get(i);
+ BlueSkyInode *inode = bluesky_get_inode(fs, d->inum);
+ if (inode != NULL)
+ bluesky_inode_unref(inode);
+ dircount += 24 + ((strlen(d->name) + 3) & ~3);
+ attrcount += 88 + 8 + 8;
+ i = g_sequence_iter_next(i);
+ }
+
+ i = g_sequence_search(dir->dirents, &start, bluesky_dirent_compare, NULL);
+ count = 0;
+ dircount = 88 + 16;
+ attrcount = 0;
+ while (count < MAX_READDIR_DIRENTS && !g_sequence_iter_is_end(i)) {
+ BlueSkyDirent *d = g_sequence_get(i);
+ BlueSkyInode *inode = bluesky_get_inode(fs, d->inum);
+ g_mutex_lock(inode->lock);
+ if (inode != NULL) {
+ dircount += 24 + ((strlen(d->name) + 3) & ~3);
+ attrcount += 88 + 8 + 8;
+ if (dircount > argp->dircount
+ || dircount + attrcount > argp->maxcount)
+ {
+ g_mutex_unlock(inode->lock);
+ bluesky_inode_unref(inode);
+ break;
+ }
+ dirents[count].fileid = d->inum;
+ dirents[count].name = d->name;
+ dirents[count].cookie = d->cookie;
+ dirents[count].nextentry = NULL;
+ dirents[count].name_attributes.present = TRUE;
+ encode_fattr3(&dirents[count].name_attributes.post_op_attr_u.attributes, inode);
+ fh_bytes[count] = GUINT64_TO_BE(d->inum);
+ dirents[count].name_handle.present = TRUE;
+ dirents[count].name_handle.post_op_fh3_u.handle.data.data_len = 8;
+ dirents[count].name_handle.post_op_fh3_u.handle.data.data_val
+ = (char *)&fh_bytes[count];
+ if (count > 0)
+ dirents[count - 1].nextentry = &dirents[count];
+ count++;
+ g_mutex_unlock(inode->lock);
+ bluesky_inode_unref(inode);
+ }
+ i = g_sequence_iter_next(i);
+ }
+
+ if (count > 0)
+ result.readdirplus3res_u.resok.reply.entries = &dirents[0];
+ else
+ result.readdirplus3res_u.resok.reply.entries = NULL;
+ result.readdirplus3res_u.resok.reply.eof = g_sequence_iter_is_end(i);
+
+ g_mutex_unlock(dir->lock);
+ async_rpc_send_reply(req, &result);