公开(公告)号：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.

公开(公告)号：US09858187B2

公开(公告)日：2018-01-02

申请号：US14922686

申请日：2015-10-26

Applicant: salesforce.com, inc.

Inventor： Barathkumar Sundaravaradan ,  Christopher James Wall ,  Lawrence Thomas Lopez ,  Paul Sydell ,  Sreeram Duvur ,  Vijayanth Devadhar

IPC: G06F12/08 ,  G06F12/0815 ,  G06F13/16 ,  G06F12/0888 ,  G06F12/0811

CPC classification number: G06F12/0815 ,  G06F12/0811 ,  G06F12/0888 ,  G06F13/1642 ,  G06F13/1673 ,  G06F2212/621

Abstract: Techniques are disclosed relating to an in-memory cache for web application data. In some embodiments, received transactions include multiple operations, including one or more cache operations to access the in-memory cache. In some embodiments, transactions are performed atomically. In some embodiments, data for the one or more cache operations is stored locally in memory by an application server outside of the in-memory cache until the transaction is successfully completed. This may improve performance and facilitate atomicity, in some embodiments.

公开(公告)号：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到分区的映射。 确定了组织的资源消耗。 确定基于组织的资源消耗的分区的资源消耗以及组织到分区的映射。 生成基于资源消耗的分区得分。 分区根据分区分数在节点之间重新分配。

公开(公告)号：US09529626B2

公开(公告)日：2016-12-27

申请号：US13841417

申请日：2013-03-15

Applicant: salesforce.com,inc.

Inventor： Xiaodan Wang ,  Vijayanth Devadhar ,  Praveen Murugesan

IPC: H04L9/32 ,  G06F15/173 ,  G06F17/30 ,  G06F21/00 ,  G06F9/50 ,  G06Q30/08 ,  H04L12/26 ,  H04L12/911

CPC classification number: G06F9/50 ,  G06F9/5027 ,  G06F2209/508 ,  G06Q30/08 ,  H04L43/08 ,  H04L47/70

Abstract: In accordance with embodiments, there are provided mechanisms and methods for facilitating a fair allocation and usage of thread resources for user messages according to one embodiment in an on-demand services environment. In one embodiment and by way of example, a method includes tracking resource usage associated with a plurality of messages performed and completed in response to requests placed by a user via a user interface at a computing device, where the tracking includes recording an amount of resources consumed by each completed message. The method may further include classifying the plurality of messages into job types based on the tracked resource usage associated with the plurality of messages, and enforcing, based on the classification of the messages, a message selection process to ensure equitable distribution of resources to subsequently received messages.

Abstract translation: 根据实施例，提供了根据一个实施例在按需服务环境中促进用户消息的线程资源的公平分配和使用的机制和方法。 在一个实施例中，作为示例，一种方法包括跟踪与响应于用户经由计算设备处的用户界面发出的请求执行和完成的多个消息相关联的资源使用，其中跟踪包括记录资源量 每个完成的消息消耗。 该方法可以进一步包括基于与多个消息相关联的跟踪资源使用将多个消息分类为作业类型，并且基于消息的分类来执行消息选择过程以确保资源的公平分配以便随后接收 消息。

公开(公告)号：US09519547B2

公开(公告)日：2016-12-13

申请号：US14488159

申请日：2014-09-16

Applicant: salesforce.com, inc.

Inventor： Vijayanth Devadhar

IPC: G06F9/46 ,  G06F11/14 ,  G06F17/30

CPC classification number: G06F11/1446 ,  G06F9/466 ,  G06F17/30362

Abstract: In accordance with embodiments disclosed herein, there are provided methods, systems, and apparatuses including, for supporting transactional message handling in an on-demand service environment including, for example: enqueuing a message specifying a transaction to be processed via a host organization; inserting a row into a database of the host organization associating the message with a status of pending, wherein the row is autocommitted to the database upon insertion; updating the status for the row to ready if a commit operation for the transaction is initiated; requesting a lock on the row; and performing final processing for the transaction based on the status for the message and based further on whether the lock is obtained for the row. Final processing may include, for example, a transaction roll back, a transaction commit, a transaction requeue, a termination of transaction processing, or an orphaned transaction clean up.

Abstract translation: 根据本文公开的实施例，提供了包括用于在按需服务环境中支持事务性消息处理的方法，系统和装置，包括例如：排队指定要经由主机组织处理的事务的消息; 将一行插入主机组织的数据库中，将该消息与待处理状态相关联，其中该行在插入时自动提交到数据库; 如果事务的提交操作被启动，则将该行的状态更新为就绪; 请求在行上锁; 并且基于消息的状态对事务执行最终处理，并且还基于是否为该行获得锁定。 最终处理可以包括例如事务回滚，事务提交，事务重新排序，事务处理的终止或孤立的事务清理。

公开(公告)号：US09268605B2

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

申请号：US13841713

申请日：2013-03-15

Applicant: salesforce.com,inc.

Inventor： Xiaodan Wang ,  Vijayanth Devadhar ,  Praveen Murugesan

IPC: G06F9/46 ,  G06F15/173 ,  G06F9/50 ,  G06Q30/08 ,  H04L12/26 ,  H04L12/911

CPC classification number: G06F9/50 ,  G06F9/5027 ,  G06F2209/508 ,  G06Q30/08 ,  H04L43/08 ,  H04L47/70

Abstract: In accordance with embodiments, there are provided mechanisms and methods for facilitating sliding window resource tracking in message queues for fair management of resources for application servers in an on-demand services environment. In one embodiment and by way of example, a method includes monitoring, in real-time, in-flight jobs in message queues for incoming jobs from organizations in a distributed environment having application servers in communication over a network, applying local sliding windows to the message queues to estimate wait time associated with each incoming job in a message queue. A local sliding window may include segment of time being monitored in each message queue for estimating the wait time. The method may further include allocating, in real-time, based on the estimated wait time, thread resources to one or more of the incoming jobs associated with the one or more of the organizations.

Abstract translation: 根据实施例，提供了用于促进消息队列中的滑动窗口资源跟踪以用于按需服务环境中的应用服务器的资源的公平管理的机制和方法。 在一个实施例中，作为示例，一种方法包括实时地监视来自具有通过网络通信的应用服务器的分布式环境中的组织的来自作业的消息队列中的飞行中作业，将本地滑动窗口应用于 消息队列来估计与消息队列中的每个传入作业相关联的等待时间。 本地滑动窗口可以包括在每个消息队列中被监视的时间段，用于估计等待时间。 该方法可以进一步包括实时地基于估计的等待时间将线程资源分配给与一个或多个组织相关联的一个或多个进入作业。

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