]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
Merge branch 'nested' into unstable
authorSage Weil <sage@newdream.net>
Wed, 4 Jun 2008 20:59:16 +0000 (13:59 -0700)
committerSage Weil <sage@newdream.net>
Wed, 4 Jun 2008 20:59:16 +0000 (13:59 -0700)
1  2 
src/kernel/ktcp.c
src/kernel/ktcp.h
src/kernel/messenger.c

index 70ecc50245fd79f758fad824dcae66c7aa9c91f5,e7040ea7cf782d5f0293f75d12a46b180f59583f..5f7e4c036098a5e9d838e18e4526e9907ee5e285
@@@ -31,25 -31,27 +31,25 @@@ struct kobj_type ceph_socket_type = 
        .release = ceph_socket_destroy,
  };
  
- struct ceph_socket *ceph_socket_create()
+ static struct ceph_socket *ceph_socket_create(void)
  {
        struct ceph_socket *s;
 -      int err;
 -      
 +      int err = -ENOMEM;
 +
        s = kzalloc(sizeof(*s), GFP_NOFS);
 -      if (!s) {
 -              derr(10, "ENOMEM creating ceph_socket\n");
 -              return ERR_PTR(-ENOMEM);
 -      }
 +      if (!s)
 +              goto out;
  
        err = sock_create_kern(AF_INET, SOCK_STREAM, IPPROTO_TCP, &s->sock);
 -      if (err) {
 -              derr(10, "sock_create_kern error %d\n", err);
 -              return ERR_PTR(err);
 -      }
 +      if (err)
 +              goto out_free;
  
  #if LINUX_VERSION_CODE >= KERNEL_VERSION(2,6,25)
 -      kobject_init_and_add(&s->kobj, &ceph_socket_type,
 -                           ceph_sockets_kobj,
 -                           "socket %p", s);
 +      err = kobject_init_and_add(&s->kobj, &ceph_socket_type,
 +                                 ceph_sockets_kobj,
 +                                 "socket %p", s);
 +      if (err)
 +              goto out_release;
  #else
        kobject_init(&s->kobj);
        kobject_set_name(&s->kobj, "socket %p", s);
index 59314f37255e648ddf99d23018a8a01c2c539237,ef6650391d091cefd3e9c72ff3628797ed8f5e3f..bbe577cbfd854375569ad8c7ceef42a21c26ae0c
@@@ -22,9 -22,8 +22,8 @@@ void ceph_cancel_sock_callbacks(struct 
  int ceph_workqueue_init(void);
  void ceph_workqueue_shutdown(void);
  
- extern struct ceph_socket *ceph_socket_create(void);
  extern void ceph_socket_get(struct ceph_socket *s);
 -extern void ceph_socket_put(struct ceph_socket *s, int die);
 +extern void ceph_socket_put(struct ceph_socket *s);
  
  /* Max number of outstanding connections in listener queueu */
  #define NUM_BACKUP 10
Simple merge