{"push_id":759893381,"size":11,"distinct_size":11,"ref":"refs/heads/reduce_msg_dup","head":"c9c69817109ded5c65b94fb806fa4e69217c71e4","before":"2dcdab1a36bdd490fc10d6c7eafc911b266fbdae","commits":[{"sha":"d7d148c054c69d45814917038e877b0af1f264a6","author":{"email":"90eebc3ed9e472707552aa1f0850807e64b4e5e4@gmail.com","name":"Jim Garlick"},"message":"broker/snoop: inline docs, optional security\n\nAdd some explanatory docs in the header file.\n\nIf snoop_set_sec() is not called, don't try to initialize security\nand trigger an assertion in czmq (needed for testing).","distinct":true,"url":"https://api.github.com/repos/garlick/flux-core/commits/d7d148c054c69d45814917038e877b0af1f264a6"},{"sha":"25ec45a08a5335095fc6f4783c16b8dde87bb768","author":{"email":"90eebc3ed9e472707552aa1f0850807e64b4e5e4@gmail.com","name":"Jim Garlick"},"message":"test: add unit test for broker snoop class\n\nPerform basic setup/teardown of snoop socket.\nVerify that messages published with snoop_sendmsg() are\nreceived on the snoop socket after connect/subscription is processed.","distinct":true,"url":"https://api.github.com/repos/garlick/flux-core/commits/25ec45a08a5335095fc6f4783c16b8dde87bb768"},{"sha":"fd8e90c0e744169d1623c513ce36ea362c434db4","author":{"email":"90eebc3ed9e472707552aa1f0850807e64b4e5e4@gmail.com","name":"Jim Garlick"},"message":"broker/shutdown: cleanup, add shutdown callback\n\nAdd shutdown_set_callback() to register a shutdown_cb_f,\nrather than hardwiring an exit callback internally (needed for test).\n\nRename shutdown_complete() to shutdown_disarm().\n\nAdd some inline docs in the header.\n\nBreak out shutdown event decode/encode functions for standalone testing.\n\nHave shutdown_arm() and shutdown_recvmsg() return integer error code\ninstead of void.  On error, return -1; avoid calling err() or err_exit()\ninternally.","distinct":true,"url":"https://api.github.com/repos/garlick/flux-core/commits/fd8e90c0e744169d1623c513ce36ea362c434db4"},{"sha":"db9317b4cb278a51f300272a5db1349cd74c7787","author":{"email":"90eebc3ed9e472707552aa1f0850807e64b4e5e4@gmail.com","name":"Jim Garlick"},"message":"broker: add shutdown callback","distinct":true,"url":"https://api.github.com/repos/garlick/flux-core/commits/db9317b4cb278a51f300272a5db1349cd74c7787"},{"sha":"33fd1020b9228b28f1b19578086df47253d6aed9","author":{"email":"90eebc3ed9e472707552aa1f0850807e64b4e5e4@gmail.com","name":"Jim Garlick"},"message":"test: add unit test for broker shutdown class\n\nVerify shutdown message codec.\n\nUse the loop handle to verify that the grace timer operates\nproperly, shutdown_arm() sends the event message, and that\nthe shutdown callback runs and can access the exit code.\n\nVerify that shutdown_disarm() works.\n\nVerify rank 0 logs the shutdown message.","distinct":true,"url":"https://api.github.com/repos/garlick/flux-core/commits/33fd1020b9228b28f1b19578086df47253d6aed9"},{"sha":"459a6a7ca916671b4669f9ee7f7e67a1c07b730a","author":{"email":"90eebc3ed9e472707552aa1f0850807e64b4e5e4@gmail.com","name":"Jim Garlick"},"message":"libflux: add flux_heartbeat_encode() _decode()\n\nAlthough encode is only used within the broker, flux_heartbeat_decode()\nshould be avialable to API users that subscribe to the heartbeat event\nand need to extract the epoch.  It probably makes sense to keep these\ntogether, hence they both appear here.","distinct":true,"url":"https://api.github.com/repos/garlick/flux-core/commits/459a6a7ca916671b4669f9ee7f7e67a1c07b730a"},{"sha":"b6a1746a0b1208f58b6ec0a6a396a84285174238","author":{"email":"90eebc3ed9e472707552aa1f0850807e64b4e5e4@gmail.com","name":"Jim Garlick"},"message":"broker/heartbeat: cleanup, docs\n\nThe heartbeat timer generates the event messages, and the\nevent messages drive 1) internal epoch update, 2) heartbeat_cb_f.\n\nSince message watchers don't work with the broker's flux_t handle\nyet, events must be manually pushed to the class with heartbeat_recvmsg().\n\nNow all ranks simply register a callback to be received on each\nheartbeat.  Rank 0 doesn't have to do anything special apart from calling\nheartbeat_start(), setting the rate, etc..\n\nHeartbeat event message code was outsourced to libflux because other\nusers want to at least decode heartbeat messages, and shouldn't have\nto do that manually, even though there's not much to it.  This will\nallow us to change the protocol without necessarily update users.","distinct":true,"url":"https://api.github.com/repos/garlick/flux-core/commits/b6a1746a0b1208f58b6ec0a6a396a84285174238"},{"sha":"effd2e739e936d4f6c0b6570819399c5c18e2a9c","author":{"email":"90eebc3ed9e472707552aa1f0850807e64b4e5e4@gmail.com","name":"Jim Garlick"},"message":"test: add unit test for broker heartbeat class","distinct":true,"url":"https://api.github.com/repos/garlick/flux-core/commits/effd2e739e936d4f6c0b6570819399c5c18e2a9c"},{"sha":"7ccba36f5877f15c1cb0d5d9cc2a5d80597c3fba","author":{"email":"90eebc3ed9e472707552aa1f0850807e64b4e5e4@gmail.com","name":"Jim Garlick"},"message":"broker: update for heartbeat API change","distinct":true,"url":"https://api.github.com/repos/garlick/flux-core/commits/7ccba36f5877f15c1cb0d5d9cc2a5d80597c3fba"},{"sha":"6317af85a3617461b784653af1a0b166392e0475","author":{"email":"90eebc3ed9e472707552aa1f0850807e64b4e5e4@gmail.com","name":"Jim Garlick"},"message":"modules/live: use flux_heartbeat_decode()","distinct":true,"url":"https://api.github.com/repos/garlick/flux-core/commits/6317af85a3617461b784653af1a0b166392e0475"},{"sha":"c9c69817109ded5c65b94fb806fa4e69217c71e4","author":{"email":"90eebc3ed9e472707552aa1f0850807e64b4e5e4@gmail.com","name":"Jim Garlick"},"message":"modules/kvs: use flux_heartbeat_decode()","distinct":true,"url":"https://api.github.com/repos/garlick/flux-core/commits/c9c69817109ded5c65b94fb806fa4e69217c71e4"}]}