Method foo

src/client/SyntheticClient.cc:2867–3056

void SyntheticClient::foo()
{
  UserPerm perms = client->pick_my_perms();

  if (1) {
    // make 2 parallel dirs, link/unlink between them.
    char a[100], b[100];
    client->mkdir("/a", 0755, perms);
    client->mkdir("/b", 0755, perms);
    for (int i=0; i<10; i++) {
      snprintf(a, sizeof(a), "/a/%d", i);
      client->mknod(a, 0644, perms);
    }
    while (1) {
      for (int i=0; i<10; i++) {
	snprintf(a, sizeof(a), "/a/%d", i);
	snprintf(b, sizeof(b), "/b/%d", i);
	client->link(a, b, perms);
      }
      for (int i=0; i<10; i++) {
	snprintf(b, sizeof(b), "/b/%d", i);
	client->unlink(b, perms);
      }
    }
    return;
  }
  if (1) {
    // bug1.cpp
    const char *fn = "blah";
    char buffer[8192]; 
    client->unlink(fn, perms);
    int handle = client->open(fn, O_CREAT|O_RDWR, perms, S_IRWXU);
    ceph_assert(handle>=0);
    int r=client->write(handle,buffer,8192);
    ceph_assert(r>=0);
    r=client->close(handle);
    ceph_assert(r>=0);
         
    handle = client->open(fn, O_RDWR, perms); // open the same  file, it must have some data already
    ceph_assert(handle>=0);      
    r=client->read(handle,buffer,8192);
    ceph_assert(r==8192); //  THIS ASSERTION FAILS with disabled cache
    r=client->close(handle);
    ceph_assert(r>=0);

    return;
  }
  if (1) {
    dout(0) << "first" << dendl;
    int fd = client->open("tester", O_WRONLY|O_CREAT, perms);
    client->write(fd, "hi there", 0, 8);
    client->close(fd);
    dout(0) << "sleep" << dendl;
    sleep(10);
    dout(0) << "again" << dendl;
    fd = client->open("tester", O_WRONLY|O_CREAT, perms);
    client->write(fd, "hi there", 0, 8);
    client->close(fd);