-
公开(公告)号：US11126467B2
公开(公告)日：2021-09-21
申请号：US15836670
申请日：2017-12-08
Applicant: salesforce.com, inc.
Inventor： William Victor Gray , Yogesh Patel , Shreedhar Sundaram , Shaahin Mehdinezhad Rushan , Mahalaxmi Sanathkumar , William Hackett , Rajkumar Pellakuru , Anjani Gupta , Chandra S. Chadalavada
Abstract: A method by a computing system implementing a node within a cluster of nodes to load balance among the cluster of nodes using retroactive refusal. Each of the nodes within the cluster of nodes is capable of processing work items. The method includes accepting a work item to be processed by the node, monitoring a resource utilization of the node, determining whether the resource utilization of the node exceeds a predetermined threshold, and retroactively refusing the work item in response to a determination that the resource utilization of the node exceeds the predetermined threshold, wherein the retroactive refusal causes the work item to be reassigned from the node to another node within the cluster of nodes.
-
公开(公告)号：US20210243246A1
公开(公告)日：2021-08-05
申请号：US16779418
申请日：2020-01-31
Applicant: salesforce.com, inc.
Inventor： Yogesh Patel , Percy Mehta , Shardul Vikram , Mattia Padovani
Abstract: A method and system that perform cluster node work assignments for tenants in a multi-tenant system. The method includes selecting a partition of a cluster tenant tracking structure having a hierarchical namespace and virtual nodes representing each tenant by a cluster node foreman controller, searching the selected partition for a tenant that is unlocked in the cluster tenant tracking structure, and initiating work for the tenant by the cluster node.
-
公开(公告)号：US10812544B2
公开(公告)日：2020-10-20
申请号：US15881665
申请日：2018-01-26
Applicant: salesforce.com, inc.
Inventor： Shreedhar Sundaram , Yogesh Patel , William Victor Gray , Shaahin Mehdinezhad Rushan , Mahalaxmi Sanathkumar , Anjani Gupta , Rajkumar Pellakuru , Bhaves Patel , William Edward Hackett
IPC: H04L29/06 , H04L12/911
Abstract: Embodiments regard transfer of data streaming services to provide continuous data flow. An embodiment of an apparatus includes a processor to process data for streaming to one or more organizations; and a memory to store data for streaming to the one or more organizations, wherein the apparatus is to provide a centralized work distribution service to track status of each of a plurality of data streams to the one or more organizations, and a plurality of nodes, each node being a virtual machine to stream one or more data streams to the one or more organizations, each node including a first daemon service to monitor connectivity of the node to dependency services for the node and, upon detecting a loss of connection to one or more of the dependency services, the node to discontinue ownership of the one or more data streams of the node and a second daemon service to poll the centralized work distribution service for data streams that are not assigned.
-
公开(公告)号：US10762109B2
公开(公告)日：2020-09-01
申请号：US16047738
申请日：2018-07-27
Applicant: salesforce.com, inc.
Inventor： Shaahin Mehdinezhad Rushan , Percy D. Mehta , Yogesh Patel , Shan-Cheng Ho , Shreedhar Sundaram
IPC: G06F16/27 , G06F16/22 , G06F16/21 , G06F16/245 , G06F16/23
Abstract: Methods, systems, and devices for asynchronous deletion at a non-relational database are described. The non-relational database may store a set of data object associations. The non-relational database may receive a read request indicating a first data object identifier. Based on the first data object identifier indicated in the read request, the non-relational database may identify a second data object identifier according to a first data object association of the stored set of data object associations that is indexed in the non-relational database with the first data object identifier. The non-relational database may determine that a last data entry that is indexed in the non-relational database with the identified second data object identifier and is associated with the first data object identifier has been deleted from the non-relational database. The non-relational database may delete the first data object association from the non-relational database.
-
公开(公告)号：US20200034473A1
公开(公告)日：2020-01-30
申请号：US16047738
申请日：2018-07-27
Applicant: salesforce.com, inc.
Inventor： Shaahin Mehdinezhad Rushan , Percy D. Mehta , Yogesh Patel , Shan-Cheng Ho , Shreedhar Sundaram
IPC: G06F17/30
Abstract: Methods, systems, and devices for asynchronous deletion at a non-relational database are described. The non-relational database may store a set of data object associations. The non-relational database may receive a read request indicating a first data object identifier. Based on the first data object identifier indicated in the read request, the non-relational database may identify a second data object identifier according to a first data object association of the stored set of data object associations that is indexed in the non-relational database with the first data object identifier. The non-relational database may determine that a last data entry that is indexed in the non-relational database with the identified second data object identifier and is associated with the first data object identifier has been deleted from the non-relational database. The non-relational database may delete the first data object association from the non-relational database.
-
Patent Agency Ranking
6.发明授权公开(公告)号：US11630844B2
公开(公告)日：2023-04-18
申请号：US17248574
申请日：2021-01-29
Applicant: salesforce.com, inc.
Inventor： Yogesh Patel , Birva Joshi , Shan-Cheng Ho , Mahalaxmi Sanathkumar , Priya Sethuraman
Abstract: A method of syncing data across multiple systems includes: receiving a plurality of calendar events from a plurality of independent calendar systems that use different calendar system specific schemas; aggregating the calendar events at a unifying communication system; converting the calendar events from a calendar system specific schema to a unifying communication system specific schema; storing the plurality of calendar events in the unifying communication system specific schema; converting a calendar event received from a non-master calendar system to the master calendar system specific schema; and sending the converted calendar event to the master calendar system; wherein copies of the received calendar events that are formatted according to the calendar system specific schema of the master calendar system are stored with the master calendar system, and copies of the calendar events that are formatted according to the unifying communication system specific schema are stored with the unifying communication system.
-
公开(公告)号：US11321139B2
公开(公告)日：2022-05-03
申请号：US15994162
申请日：2018-05-31
Applicant: salesforce.com, inc.
Inventor： Yogesh Patel , William Victor Gray , William Hackett , Shaahin Mehdinezhad Rushan , Johannes Kienzle , Shreedhar Sundaram , Mahalaxmi Sanathkumar , Rajkumar Pellakuru , Bhaves Patel , Bertha Ching Wai Lam
IPC: G06F9/50 , G06F9/455 , H04L12/26 , H04L43/067 , H04L43/0876 , H04L43/065
Abstract: A total number of messages in a set of messages that are processed by a computing node in a virtual computer cluster during a time interval is determined. The virtual computer cluster is deployed with a cloud computing service and includes the computing node and other computing nodes at an end time of the time interval. It is determined whether the total number of messages in the set of messages processed by the computing node is no less than a maximum per-interval message number threshold. In response to determining that the total number of messages is no less than a maximum per-interval message number threshold, the cloud computing service is caused to start an additional computing node in the virtual computer cluster after the time interval, wherein the additional computing node is used to process one or more subsequent messages to be processed after the time interval.
-
公开(公告)号：US20210037073A1
公开(公告)日：2021-02-04
申请号：US17074459
申请日：2020-10-19
Applicant: salesforce.com, inc.
Inventor： Shreedhar Sundaram , Yogesh Patel , William Victor Gray , Shaahin Mehdinezhad Rushan , Mahalaxmi Sanathkumar , Anjani Gupta , Rajkumar Pellakuru , Bhaves Patel , William Edward Hackett
IPC: H04L29/06 , H04L12/911
Abstract: Embodiments regard transfer of data streaming services to provide continuous data flow. An embodiment of an apparatus includes a processor to process data for streaming to one or more organizations; and a memory to store data for streaming to the one or more organizations, wherein the apparatus is to provide a centralized work distribution service to track status of each of a plurality of data streams to the one or more organizations, and a plurality of nodes, each node being a virtual machine to stream one or more data streams to the one or more organizations, each node including a first daemon service to monitor connectivity of the node to dependency services for the node and, upon detecting a loss of connection to one or more of the dependency services, the node to discontinue ownership of the one or more data streams of the node and a second daemon service to poll the centralized work distribution service for data streams that are not assigned.
-
公开(公告)号：US20190238604A1
公开(公告)日：2019-08-01
申请号：US15881665
申请日：2018-01-26
Applicant: salesforce.com, inc.
Inventor： Shreedhar Sundaram , Yogesh Patel , William Victor Gray , Shaahin Mehdinezhad Rushan , Mahalaxmi Sanathkumar , Anjani Gupta , Rajkumar Pellakuru , Bhaves Patel , William Edward Hackett
IPC: H04L29/06
Abstract: Embodiments regard transfer of data streaming services to provide continuous data flow. An embodiment of an apparatus includes a processor to process data for streaming to one or more organizations; and a memory to store data for streaming to the one or more organizations, wherein the apparatus is to provide a centralized work distribution service to track status of each of a plurality of data streams to the one or more organizations, and a plurality of nodes, each node being a virtual machine to stream one or more data streams to the one or more organizations, each node including a first daemon service to monitor connectivity of the node to dependency services for the node and, upon detecting a loss of connection to one or more of the dependency services, the node to discontinue ownership of the one or more data streams of the node and a second daemon service to poll the centralized work distribution service for data streams that are not assigned.
-
10.发明授权公开(公告)号：US11500878B2
公开(公告)日：2022-11-15
申请号：US16779398
申请日：2020-01-31
Applicant: salesforce.com, inc.
Inventor： Shan-Cheng Ho , Percy Mehta , Yogesh Patel , Lucas Ung , Birva Joshi , Wing Hing Ku , Mattia Padovani
IPC: G06F16/00 , G06F16/2455 , G06F16/27
Abstract: A method and system manage synchronization of data streams in a multi-tenant system. The method includes tracking by a flow control mechanism a recent flow rate of at least one data stream, determining by the flow control mechanism whether the flow rate of the at least one data stream varies from at least one related data stream, and adjusting by the flow control mechanism a throughput of the at least one data stream to correlate with the at least one related data stream, in response to determining that the at least one data stream has varied from the at least one related data stream.
-
-
-
-
-
-
-
-
-
Search Results
26
records
(took 0.016 seconds)
