公开(公告)号：US11271995B2

公开(公告)日：2022-03-08

申请号：US16450920

申请日：2019-06-24

Applicant: salesforce.com, inc.

Inventor： Marco Helmich ,  Vijayanth Devadhar

IPC: H04L29/08 ,  G06F16/25 ,  G06F16/27 ,  H04L12/24 ,  H04L12/26 ,  H04L67/1008 ,  H04L41/5041 ,  H04L41/0896 ,  H04L43/04 ,  H04L43/0817

Abstract: Techniques for partition balancing. Organization identifiers (orgIDs) are acquired for one or more organizations within a multi-organization on-demand services environment having multiple nodes, each of which have one or more partitions. A mapping of the orgIDs to the partitions within the multi-organization on-demand services environment is determined. Resource consumption for the organizations is determined. Resource consumption for the partitions based on the resource consumption of the organization and the mapping of the organization to the partitions is determined. A score for the partitions based on the resource consumption is generated. The partitions are redistributed among the nodes based on the partition scores.

公开(公告)号：US09923960B2

公开(公告)日：2018-03-20

申请号：US14829428

申请日：2015-08-18

Applicant: salesforce.com, inc.

Inventor： Marco Helmich ,  Vijayanth Devadhar

IPC: H04L12/911 ,  H04L29/08 ,  H04L12/24 ,  G06F17/30 ,  H04L12/26

CPC classification number: H04L67/1008 ,  G06F17/30557 ,  G06F17/30584 ,  H04L41/0896 ,  H04L41/5041 ,  H04L43/04 ,  H04L43/0817

Abstract: Techniques for partition balancing. Organization identifiers (orgIDs) are acquired for one or more organizations within a multi-organization on-demand services environment having multiple nodes, each of which have one or more partitions. A mapping of the orgIDs to the partitions within the multi-organization on-demand services environment is determined. Resource consumption for the organizations is determined. Resource consumption for the partitions based on the resource consumption of the organization and the mapping of the organization to the partitions is determined. A score for the partitions based on the resource consumption is generated. The partitions are redistributed among the nodes based on the partition scores.

公开(公告)号：US20190312926A1

公开(公告)日：2019-10-10

申请号：US16450920

申请日：2019-06-24

Applicant: salesforce.com, inc.

Inventor： Marco Helmich ,  Vijayanth Devadhar

IPC: H04L29/08 ,  G06F16/27 ,  G06F16/25 ,  H04L12/24

Abstract: Techniques for partition balancing. Organization identifiers (orgIDs) are acquired for one or more organizations within a multi-organization on-demand services environment having multiple nodes, each of which have one or more partitions. A mapping of the orgIDs to the partitions within the multi-organization on-demand services environment is determined. Resource consumption for the organizations is determined. Resource consumption for the partitions based on the resource consumption of the organization and the mapping of the organization to the partitions is determined. A score for the partitions based on the resource consumption is generated. The partitions are redistributed among the nodes based on the partition scores.

公开(公告)号：US10019297B2

公开(公告)日：2018-07-10

申请号：US14306113

申请日：2014-06-16

Applicant: salesforce.com, inc.

Inventor： Marco Helmich ,  Ananya Yadav ,  Praveen Murugesan ,  Vijayanth Devadhar

IPC: G06F7/00 ,  G06F17/30 ,  G06F9/54 ,  H04L29/08

CPC classification number: G06F9/546 ,  G06F16/2455 ,  G06F2209/548 ,  H04L67/26

Abstract: Systems and methods for implementing bulk handling in asynchronous processing are described. For example, an exemplary system includes a processor and a memory to execute instructions at the system; a broker to enqueue received messages; a push connection from the broker to a thread, in which the broker is to push an initial message to the thread for processing; a pull connection from the thread to the broker, in which the thread is to request one or more additional messages for bulk processing with the initial message from the broker; a query interface to issue a database query from the thread to a data store, the database query specifying the initial message and the one or more additional messages as a set of messages to obtain a lock for the set of messages; and a message processing engine to handle the set of messages in bulk based on whether the lock for the set of messages is obtained.

公开(公告)号：US20180131757A1

公开(公告)日：2018-05-10

申请号：US15864783

申请日：2018-01-08

Applicant: Salesforce.com, inc.

Inventor： Marco Helmich ,  Vijayanth Devadhar

IPC: H04L29/08 ,  H04L12/24 ,  G06F17/30 ,  H04L12/26

CPC classification number: H04L67/1008 ,  G06F16/25 ,  G06F16/278 ,  H04L41/0896 ,  H04L41/5041 ,  H04L43/04 ,  H04L43/0817

Abstract: Techniques for partition balancing. Organization identifiers (orgIDs) are acquired for one or more organizations within a multi-organization on-demand services environment having multiple nodes, each of which have one or more partitions. A mapping of the orgIDs to the partitions within the multi-organization on-demand services environment is determined. Resource consumption for the organizations is determined. Resource consumption for the partitions based on the resource consumption of the organization and the mapping of the organization to the partitions is determined. A score for the partitions based on the resource consumption is generated. The partitions are redistributed among the nodes based on the partition scores.

公开(公告)号：US10334033B2

公开(公告)日：2019-06-25

申请号：US15864783

申请日：2018-01-08

Applicant: salesforce.com, inc.

Inventor： Marco Helmich ,  Vijayanth Devadhar

IPC: G06F16/25 ,  G06F16/27 ,  H04L12/24 ,  H04L12/26 ,  H04L29/08

Abstract: Techniques for partition balancing. Organization identifiers (orgIDs) are acquired for one or more organizations within a multi-organization on-demand services environment having multiple nodes, each of which have one or more partitions. A mapping of the orgIDs to the partitions within the multi-organization on-demand services environment is determined. Resource consumption for the organizations is determined. Resource consumption for the partitions based on the resource consumption of the organization and the mapping of the organization to the partitions is determined. A score for the partitions based on the resource consumption is generated. The partitions are redistributed among the nodes based on the partition scores.

公开(公告)号：US20170054797A1

公开(公告)日：2017-02-23

申请号：US14829428

申请日：2015-08-18

Applicant: salesforce.com, inc.

Inventor： Marco Helmich ,  Vijayanth Devadhar

IPC: H04L29/08 ,  H04L12/26 ,  G06F17/30 ,  H04L12/24

CPC classification number: H04L67/1008 ,  G06F17/30557 ,  G06F17/30584 ,  H04L41/0896 ,  H04L41/5041 ,  H04L43/04 ,  H04L43/0817

Abstract: Techniques for partition balancing. Organization identifiers (orgIDs) are acquired for one or more organizations within a multi-organization on-demand services environment having multiple nodes, each of which have one or more partitions. A mapping of the orgIDs to the partitions within the multi-organization on-demand services environment is determined. Resource consumption for the organizations is determined. Resource consumption for the partitions based on the resource consumption of the organization and the mapping of the organization to the partitions is determined. A score for the partitions based on the resource consumption is generated. The partitions are redistributed among the nodes based on the partition scores.

Abstract translation: 分区平衡技术 在具有多个节点的多组织按需服务环境中的一个或多个组织获取组织标识符（orgID），每个节点具有一个或多个分区。 确定在多组织按需服务环境中的orgID到分区的映射。 确定了组织的资源消耗。 确定基于组织的资源消耗的分区的资源消耗以及组织到分区的映射。 生成基于资源消耗的分区得分。 分区根据分区分数在节点之间重新分配。

公开(公告)号：US20140304246A1

公开(公告)日：2014-10-09

申请号：US14306113

申请日：2014-06-16

Applicant: salesforce.com, inc.

Inventor： Marco Helmich ,  Ananya Yadav ,  Praveen Murugesan ,  Vijayanth Devadhar

IPC: G06F17/30 ,  G06F9/52

CPC classification number: G06F9/546 ,  G06F17/30477 ,  G06F2209/548 ,  H04L67/26

Abstract: In accordance with disclosed embodiments, there are provided systems and methods for implementing bulk handling in asynchronous processing. According to a particular embodiment such a system includes a processor and a memory to execute instructions at the system; a broker to enqueue received messages; a push connection from the broker to a thread, in which the broker is to push an initial message to the thread for processing; a pull connection from the thread to the broker, in which the thread is to request one or more additional messages for bulk processing with the initial message from the broker; a query interface to issue a database query from the thread to a data store, the database query specifying the initial message and the one or more additional messages as a set of messages to obtain a lock for the set of messages; and a message processing engine to handle the set of messages in bulk based on whether the lock for the set of messages is obtained. Other related embodiments are disclosed.

Abstract translation: 根据所公开的实施例，提供了用于在异步处理中实现批量处理的系统和方法。 根据特定实施例，这样的系统包括处理器和存储器，用于在系统处执行指令; 一个经纪人排队收到的消息; 从代理到线程的推送连接，其中代理人将初始消息推送到线程进行处理; 从线程到代理的拉线连接，其中线程将使用来自代理器的初始消息来请求一个或多个附加消息进行批量处理; 查询接口，用于从线程发出数据库查询到数据存储，数据库查询指定初始消息，并将一个或多个附加消息作为一组消息获取消息集合的锁; 以及消息处理引擎，用于基于是否获得针对所述一组消息的锁来批量处理所述消息集合。 公开了其他相关实施例。