~ubuntu-branches/ubuntu/trusty/ceph/trusty-updates

« back to all changes in this revision

Viewing changes to src/client/Client.h

  • Committer: Package Import Robot
  • Author(s): James Page
  • Date: 2014-04-09 11:14:03 UTC
  • mfrom: (1.1.33)
  • Revision ID: package-import@ubuntu.com-20140409111403-jlql95pa8kg1nk9a
Tags: 0.79-0ubuntu1
* New upstream release (LP: #1278466):
  - d/p/modules.patch: Refreshed.
  - d/ceph.install: Install all jerasure modules.

Show diffs side-by-side

added added

removed removed

Lines of Context:
255
255
  void resend_unsafe_requests(MetaSession *s);
256
256
 
257
257
  // mds requests
258
 
  tid_t last_tid, last_flush_seq;
259
 
  map<tid_t, MetaRequest*> mds_requests;
 
258
  ceph_tid_t last_tid, last_flush_seq;
 
259
  map<ceph_tid_t, MetaRequest*> mds_requests;
260
260
  set<int>                 failed_mds;
261
261
 
262
262
  void dump_mds_requests(Formatter *f);
445
445
  void add_update_cap(Inode *in, MetaSession *session, uint64_t cap_id,
446
446
                      unsigned issued, unsigned seq, unsigned mseq, inodeno_t realm,
447
447
                      int flags);
448
 
  void remove_cap(Cap *cap);
 
448
  void remove_cap(Cap *cap, bool queue_release);
449
449
  void remove_all_caps(Inode *in);
450
450
  void remove_session_caps(MetaSession *session);
451
451
  void mark_caps_dirty(Inode *in, int caps);
547
547
  void _closedir(dir_result_t *dirp);
548
548
 
549
549
  // other helpers
 
550
  void _fragmap_remove_non_leaves(Inode *in);
 
551
 
550
552
  void _ll_get(Inode *in);
551
553
  int _ll_put(Inode *in, int num);
552
554
  void _ll_drop_pins();
554
556
  Fh *_create_fh(Inode *in, int flags, int cmode);
555
557
  int _release_fh(Fh *fh);
556
558
 
 
559
 
 
560
  struct C_Readahead : public Context {
 
561
    Client *client;
 
562
    Inode *inode;
 
563
    C_Readahead(Client *c, Inode *i)
 
564
      : client(c),
 
565
        inode(i) { }
 
566
    void finish(int r) {
 
567
      lsubdout(client->cct, client, 20) << "C_Readahead on " << inode << dendl;
 
568
      client->put_inode(inode, 1);
 
569
    }
 
570
  };
 
571
 
557
572
  int _read_sync(Fh *f, uint64_t off, uint64_t len, bufferlist *bl);
558
573
  int _read_async(Fh *f, uint64_t off, uint64_t len, bufferlist *bl);
559
574
 
680
695
  int open(const char *path, int flags, mode_t mode=0);
681
696
  int open(const char *path, int flags, mode_t mode, int stripe_unit, int stripe_count, int object_size, const char *data_pool);
682
697
  int lookup_hash(inodeno_t ino, inodeno_t dirino, const char *name);
683
 
  int lookup_ino(inodeno_t ino);
 
698
  int lookup_ino(inodeno_t ino, Inode **inode=NULL);
 
699
  int lookup_parent(Inode *in, Inode **parent=NULL);
 
700
  int lookup_name(Inode *in, Inode *parent);
684
701
  int close(int fd);
685
702
  loff_t lseek(int fd, loff_t offset, int whence);
686
703
  int read(int fd, char *buf, loff_t size, loff_t offset=-1);